diff options
Diffstat (limited to 'ot_mutex.c')
| -rw-r--r-- | ot_mutex.c | 10 |
1 files changed, 5 insertions, 5 deletions
| @@ -1,6 +1,6 @@ | |||
| 1 | /* This software was written by Dirk Engling <erdgeist@erdgeist.org> | 1 | /* This software was written by Dirk Engling <erdgeist@erdgeist.org> |
| 2 | It is considered beerware. Prost. Skol. Cheers or whatever. | 2 | It is considered beerware. Prost. Skol. Cheers or whatever. |
| 3 | 3 | ||
| 4 | $id$ */ | 4 | $id$ */ |
| 5 | 5 | ||
| 6 | /* System */ | 6 | /* System */ |
| @@ -93,7 +93,7 @@ void mutex_bucket_unlock( int bucket ) { | |||
| 93 | bucket_remove( bucket ); | 93 | bucket_remove( bucket ); |
| 94 | pthread_cond_broadcast( &bucket_being_unlocked ); | 94 | pthread_cond_broadcast( &bucket_being_unlocked ); |
| 95 | pthread_mutex_unlock( &bucket_mutex ); | 95 | pthread_mutex_unlock( &bucket_mutex ); |
| 96 | } | 96 | } |
| 97 | 97 | ||
| 98 | void mutex_bucket_unlock_by_hash( ot_hash *hash ) { | 98 | void mutex_bucket_unlock_by_hash( ot_hash *hash ) { |
| 99 | unsigned char *local_hash = hash[0]; | 99 | unsigned char *local_hash = hash[0]; |
| @@ -134,7 +134,7 @@ int mutex_workqueue_pushtask( int64 socket, ot_tasktype tasktype ) { | |||
| 134 | } | 134 | } |
| 135 | 135 | ||
| 136 | /* Skip to end of list */ | 136 | /* Skip to end of list */ |
| 137 | tmptask = &tasklist; | 137 | tmptask = &tasklist; |
| 138 | while( *tmptask ) | 138 | while( *tmptask ) |
| 139 | tmptask = &(*tmptask)->next; | 139 | tmptask = &(*tmptask)->next; |
| 140 | *tmptask = task; | 140 | *tmptask = task; |
| @@ -267,7 +267,7 @@ int mutex_workqueue_pushresult( ot_taskid taskid, int iovec_entries, struct iove | |||
| 267 | MTX_DBG( "pushresult unlocks.\n" ); | 267 | MTX_DBG( "pushresult unlocks.\n" ); |
| 268 | pthread_mutex_unlock( &tasklist_mutex ); | 268 | pthread_mutex_unlock( &tasklist_mutex ); |
| 269 | MTX_DBG( "pushresult unlocked.\n" ); | 269 | MTX_DBG( "pushresult unlocked.\n" ); |
| 270 | 270 | ||
| 271 | /* Indicate whether the worker has to throw away results */ | 271 | /* Indicate whether the worker has to throw away results */ |
| 272 | return task ? 0 : -1; | 272 | return task ? 0 : -1; |
| 273 | } | 273 | } |
| @@ -291,7 +291,7 @@ int64 mutex_workqueue_popresult( int *iovec_entries, struct iovec ** iovec ) { | |||
| 291 | *iovec_entries = (*task)->iovec_entries; | 291 | *iovec_entries = (*task)->iovec_entries; |
| 292 | *iovec = (*task)->iovec; | 292 | *iovec = (*task)->iovec; |
| 293 | socket = (*task)->socket; | 293 | socket = (*task)->socket; |
| 294 | 294 | ||
| 295 | *task = (*task)->next; | 295 | *task = (*task)->next; |
| 296 | free( ptask ); | 296 | free( ptask ); |
| 297 | } | 297 | } |
