Searched refs:pbuf_incoming_mutex (Results 1 – 4 of 4) sorted by relevance
623 if ((me = pthread_mutex_lock(&w->pbuf_incoming_mutex))) { in dupecheck_drain_worker()632 if ((me = pthread_mutex_unlock(&w->pbuf_incoming_mutex))) { in dupecheck_drain_worker()
412 if (pthread_mutex_trylock(&self->pbuf_incoming_mutex) != 0) in incoming_flush()418 if ((me = pthread_mutex_unlock(&self->pbuf_incoming_mutex))) { in incoming_flush()
465 pthread_mutex_t pbuf_incoming_mutex; member
1933 pthread_mutex_init(&w->pbuf_incoming_mutex, NULL); in worker_alloc()