Searched refs:pending_event_queue (Results 1 – 6 of 6) sorted by relevance
82 DAPL_RING_BUFFER pending_event_queue; in dapl_evd_resize() local128 dat_status = dapls_rbuf_alloc(&pending_event_queue, evd_qlen); in dapl_evd_resize()150 dapls_rbuf_remove(&evd_ptr->pending_event_queue)) { in dapl_evd_resize()154 dat_status = dapls_rbuf_add(&pending_event_queue, new_event); in dapl_evd_resize()161 dapls_rbuf_destroy(&evd_ptr->pending_event_queue); in dapl_evd_resize()168 evd_ptr->pending_event_queue = pending_event_queue; in dapl_evd_resize()179 dapls_rbuf_destroy(&pending_event_queue); in dapl_evd_resize()
117 if (evd_ptr->pending_event_queue.head != in dapl_evd_dequeue()118 evd_ptr->pending_event_queue.tail) { in dapl_evd_dequeue()120 dapls_rbuf_remove(&evd_ptr->pending_event_queue); in dapl_evd_dequeue()150 &evd_ptr->pending_event_queue); in dapl_evd_dequeue()
151 if (dapls_rbuf_count(&evd_ptr->pending_event_queue) > 0) { in dapl_evd_wait()165 if (dapls_rbuf_count(&evd_ptr->pending_event_queue) == 0) { in dapl_evd_wait()171 local_event = dapls_rbuf_remove(&evd_ptr->pending_event_queue); in dapl_evd_wait()182 *nmore = dapls_rbuf_count(&evd_ptr->pending_event_queue); in dapl_evd_wait()
300 dat_status = dapls_rbuf_alloc(&evd_ptr->pending_event_queue, qlen); in dapli_evd_event_alloc()394 dapls_rbuf_destroy(&evd_ptr->pending_event_queue); in dapls_evd_dealloc()548 dat_status = dapls_rbuf_add(&evd_ptr->pending_event_queue, in dapli_evd_post_event()635 dat_status = dapls_rbuf_add(&evd_ptr->pending_event_queue, in dapli_evd_post_event_nosignal()1411 dapls_rbuf_count(&evd_ptr->pending_event_queue); in dapls_evd_copy_events()1535 } while (dapls_rbuf_count(&evd_ptr->pending_event_queue) + num_ke < in dapls_evd_copy_events()
107 if (dapls_rbuf_count(&evd_ptr->pending_event_queue) > 0) { in dapl_cno_wait()
451 DAPL_RING_BUFFER pending_event_queue; member