- Timestamp:
- 03/15/10 15:44:12 (12 years ago)
- Branches:
- 4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, getfragoff, help, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes
- Children:
- 7fc0eaa2
- Parents:
- 9d6452b
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
lib/iow-lzo.c
r9d6452b r91c38f8 260 260 &tdata->outbuf); 261 261 262 pthread_mutex_lock(&tdata->mutex); 262 263 tdata->state = FULL; 263 264 pthread_cond_signal(&tdata->out_ready); 264 pthread_mutex_lock(&tdata->mutex);265 265 } 266 266 pthread_mutex_unlock(&tdata->mutex); … … 433 433 ||get_next_thread(iow)->inbuf.offset >= MAX_BLOCK_SIZE) { 434 434 get_next_thread(iow)->state = WAITING; 435 pthread_cond_signal(&get_next_thread(iow)->in_ready); 435 436 pthread_mutex_unlock(&get_next_thread(iow)->mutex); 436 pthread_cond_signal(&get_next_thread(iow)->in_ready);437 437 438 438 DATA(iow)->next_thread = … … 475 475 /* Now the thread should be empty, so ask it to shut down */ 476 476 thread->closing = true; 477 pthread_cond_signal(&thread->in_ready); 477 478 pthread_mutex_unlock(&thread->mutex); 478 pthread_cond_signal(&thread->in_ready);479 479 /* And wait for it to die */ 480 480 pthread_join(thread->thread,NULL);
Note: See TracChangeset
for help on using the changeset viewer.