| /dports/net/sems/sems-f89581a/core/ |
| H A D | AmEventQueue.cpp | 44 while(!ev_queue.empty()){ in ~AmEventQueue()
45 delete ev_queue.front(); in ~AmEventQueue()
46 ev_queue.pop(); in ~AmEventQueue()
59 ev_queue.push(event); in postEvent()
77 while(!ev_queue.empty()) { in processEvents()
79 AmEvent* event = ev_queue.front(); in processEvents()
80 ev_queue.pop(); in processEvents()
107 if (!ev_queue.empty()) { in processSingleEvent()
110 ev_queue.pop(); in processSingleEvent()
121 if (ev_queue.empty()) in processSingleEvent()
[all …]
|
| /dports/net/pjsip/pjproject-2.11.1/pjmedia/src/pjmedia/ |
| H A D | event.c | 58 event_queue ev_queue; member
71 if (ev_queue->is_full) { in event_queue_add_event()
83 pj_memcpy(&ev_queue->events[ev_queue->tail], event, sizeof(*event)); in event_queue_add_event()
84 ev_queue->tail = (ev_queue->tail + 1) % MAX_EVENTS; in event_queue_add_event()
85 if (ev_queue->tail == ev_queue->head) in event_queue_add_event()
86 ev_queue->is_full = PJ_TRUE; in event_queue_add_event()
98 pjmedia_event *ev = &ev_queue->events[ev_queue->head]; in event_mgr_distribute_events()
132 ev_queue->head = (ev_queue->head + 1) % MAX_EVENTS; in event_mgr_distribute_events()
133 ev_queue->is_full = PJ_FALSE; in event_mgr_distribute_events()
389 ev_queue.head = ev_queue.tail = 0; in pjmedia_event_publish()
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/core/ |
| H A D | uverbs_main.c | 222 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_read()
232 ev_queue->is_closed))) in ib_uverbs_event_read()
235 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_read()
238 if (list_empty(&ev_queue->event_list) && ev_queue->is_closed) { in ib_uverbs_event_read()
257 spin_unlock_irq(&ev_queue->lock); in ib_uverbs_event_read()
299 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_poll()
302 else if (ev_queue->is_closed) in ib_uverbs_event_poll()
366 if (!ev_queue) in ib_uverbs_comp_handler()
370 if (ev_queue->is_closed) { in ib_uverbs_comp_handler()
476 ev_queue->is_closed = 0; in ib_uverbs_init_event_queue()
[all …]
|
| H A D | uverbs_std_types_cq.c | 43 struct ib_uverbs_event_queue *ev_queue = cq->cq_context; in uverbs_free_cq() local
53 ev_queue ? container_of(ev_queue, in uverbs_free_cq()
55 ev_queue) : in uverbs_free_cq()
125 cq->cq_context = ev_file ? &ev_file->ev_queue : NULL; in UVERBS_HANDLER()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/core/ |
| H A D | uverbs_main.c | 222 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_read()
232 ev_queue->is_closed))) in ib_uverbs_event_read()
235 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_read()
238 if (list_empty(&ev_queue->event_list) && ev_queue->is_closed) { in ib_uverbs_event_read()
257 spin_unlock_irq(&ev_queue->lock); in ib_uverbs_event_read()
299 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_poll()
302 else if (ev_queue->is_closed) in ib_uverbs_event_poll()
366 if (!ev_queue) in ib_uverbs_comp_handler()
370 if (ev_queue->is_closed) { in ib_uverbs_comp_handler()
476 ev_queue->is_closed = 0; in ib_uverbs_init_event_queue()
[all …]
|
| H A D | uverbs_std_types_cq.c | 43 struct ib_uverbs_event_queue *ev_queue = cq->cq_context; in uverbs_free_cq() local
53 ev_queue ? container_of(ev_queue, in uverbs_free_cq()
55 ev_queue) : in uverbs_free_cq()
125 cq->cq_context = ev_file ? &ev_file->ev_queue : NULL; in UVERBS_HANDLER()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/core/ |
| H A D | uverbs_main.c | 222 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_read()
232 ev_queue->is_closed))) in ib_uverbs_event_read()
235 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_read()
238 if (list_empty(&ev_queue->event_list) && ev_queue->is_closed) { in ib_uverbs_event_read()
257 spin_unlock_irq(&ev_queue->lock); in ib_uverbs_event_read()
299 spin_lock_irq(&ev_queue->lock); in ib_uverbs_event_poll()
302 else if (ev_queue->is_closed) in ib_uverbs_event_poll()
366 if (!ev_queue) in ib_uverbs_comp_handler()
370 if (ev_queue->is_closed) { in ib_uverbs_comp_handler()
476 ev_queue->is_closed = 0; in ib_uverbs_init_event_queue()
[all …]
|
| H A D | uverbs_std_types_cq.c | 43 struct ib_uverbs_event_queue *ev_queue = cq->cq_context; in uverbs_free_cq() local
53 ev_queue ? container_of(ev_queue, in uverbs_free_cq()
55 ev_queue) : in uverbs_free_cq()
125 cq->cq_context = ev_file ? &ev_file->ev_queue : NULL; in UVERBS_HANDLER()
|
| /dports/databases/mdcached/mdcached-1.0.9/mdcached/ |
| H A D | minilibevent.h | 55 typedef int ev_queue; typedef
124 static inline ev_queue ev_create_queue() in ev_create_queue()
133 static inline int ev_valid_queue(ev_queue q) in ev_valid_queue()
142 static inline void ev_destroy_queue(ev_queue q) in ev_destroy_queue()
213 typedef struct ev_queue_* ev_queue;
280 static inline ev_queue ev_create_queue()
282 ev_queue q;
283 q = (ev_queue) malloc(sizeof(struct ev_queue_));
293 static inline int ev_valid_queue(ev_queue q)
299 static inline void ev_destroy_queue(ev_queue q)
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/fddi/skfp/ |
| H A D | queue.c | 28 smc->q.ev_put = smc->q.ev_get = smc->q.ev_queue ; in ev_init()
39 if (++smc->q.ev_put == &smc->q.ev_queue[MAX_EVENT]) in queue_event()
40 smc->q.ev_put = smc->q.ev_queue ; in queue_event()
104 if (++ev == &smc->q.ev_queue[MAX_EVENT]) in ev_dispatcher()
105 ev = smc->q.ev_queue ; in ev_dispatcher()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/fddi/skfp/ |
| H A D | queue.c | 28 smc->q.ev_put = smc->q.ev_get = smc->q.ev_queue ; in ev_init()
39 if (++smc->q.ev_put == &smc->q.ev_queue[MAX_EVENT]) in queue_event()
40 smc->q.ev_put = smc->q.ev_queue ; in queue_event()
104 if (++ev == &smc->q.ev_queue[MAX_EVENT]) in ev_dispatcher()
105 ev = smc->q.ev_queue ; in ev_dispatcher()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/fddi/skfp/ |
| H A D | queue.c | 28 smc->q.ev_put = smc->q.ev_get = smc->q.ev_queue ; in ev_init()
39 if (++smc->q.ev_put == &smc->q.ev_queue[MAX_EVENT]) in queue_event()
40 smc->q.ev_put = smc->q.ev_queue ; in queue_event()
104 if (++ev == &smc->q.ev_queue[MAX_EVENT]) in ev_dispatcher()
105 ev = smc->q.ev_queue ; in ev_dispatcher()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/hw/mlx5/ |
| H A D | devx.c | 1671 ev_queue->is_destroyed = 0; in devx_init_event_queue()
1727 struct devx_async_event_queue *ev_queue = &ev_file->ev_queue; in devx_query_callback() local
2558 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_read() local
2563 spin_lock_irq(&ev_queue->lock); in devx_async_cmd_event_read()
2572 ev_queue->poll_wait, in devx_async_cmd_event_read()
2579 if (ev_queue->is_destroyed) { in devx_async_cmd_event_read()
2612 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_poll() local
2617 spin_lock_irq(&ev_queue->lock); in devx_async_cmd_event_poll()
2618 if (ev_queue->is_destroyed) in devx_async_cmd_event_poll()
2756 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_destroy_uobj() local
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/hw/mlx5/ |
| H A D | devx.c | 1671 ev_queue->is_destroyed = 0; in devx_init_event_queue()
1727 struct devx_async_event_queue *ev_queue = &ev_file->ev_queue; in devx_query_callback() local
2558 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_read() local
2563 spin_lock_irq(&ev_queue->lock); in devx_async_cmd_event_read()
2572 ev_queue->poll_wait, in devx_async_cmd_event_read()
2579 if (ev_queue->is_destroyed) { in devx_async_cmd_event_read()
2612 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_poll() local
2617 spin_lock_irq(&ev_queue->lock); in devx_async_cmd_event_poll()
2618 if (ev_queue->is_destroyed) in devx_async_cmd_event_poll()
2756 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_destroy_uobj() local
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/hw/mlx5/ |
| H A D | devx.c | 1671 ev_queue->is_destroyed = 0; in devx_init_event_queue()
1727 struct devx_async_event_queue *ev_queue = &ev_file->ev_queue; in devx_query_callback() local
2558 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_read() local
2563 spin_lock_irq(&ev_queue->lock); in devx_async_cmd_event_read()
2572 ev_queue->poll_wait, in devx_async_cmd_event_read()
2579 if (ev_queue->is_destroyed) { in devx_async_cmd_event_read()
2612 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_poll() local
2617 spin_lock_irq(&ev_queue->lock); in devx_async_cmd_event_poll()
2618 if (ev_queue->is_destroyed) in devx_async_cmd_event_poll()
2756 struct devx_async_event_queue *ev_queue = &comp_ev_file->ev_queue; in devx_async_cmd_event_destroy_uobj() local
[all …]
|
| /dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/may-0.3.17/src/ |
| H A D | cqueue.rs | 114 self.cqueue.ev_queue.push(Event { in subscribe()
134 self.cqueue.ev_queue.push(Event { in drop()
151 ev_queue: Queue<Event>, field
243 match self.ev_queue.pop() { in poll()
256 match self.ev_queue.pop() { in poll()
318 ev_queue: Queue::new(), in scope()
|
| /dports/emulators/qemu42/qemu-4.2.1/roms/ipxe/src/drivers/net/ |
| H A D | etherfabric.c | 3493 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3848 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3854 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3868 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3870 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3887 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3914 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3935 if ( ev_queue->ring ) in efab_free_resources()
3940 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3949 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|
| /dports/emulators/qemu-powernv/qemu-powernv-3.0.50/roms/ipxe/src/drivers/net/ |
| H A D | etherfabric.c | 3493 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3848 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3854 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3868 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3870 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3887 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3914 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3935 if ( ev_queue->ring ) in efab_free_resources()
3940 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3949 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|
| /dports/emulators/qemu-utils/qemu-4.2.1/roms/ipxe/src/drivers/net/ |
| H A D | etherfabric.c | 3493 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3848 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3854 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3868 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3870 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3887 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3914 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3935 if ( ev_queue->ring ) in efab_free_resources()
3940 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3949 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|
| /dports/emulators/qemu5/qemu-5.2.0/roms/ipxe/src/drivers/net/ |
| H A D | etherfabric.c | 3493 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3848 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3854 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3868 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3870 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3887 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3914 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3935 if ( ev_queue->ring ) in efab_free_resources()
3940 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3949 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|
| /dports/net/ipxe/ipxe-2265a65/src/drivers/net/ |
| H A D | etherfabric.c | 3493 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3848 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3854 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3868 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3870 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3887 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3914 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3935 if ( ev_queue->ring ) in efab_free_resources()
3940 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3949 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|
| /dports/emulators/qemu-guest-agent/qemu-5.0.1/roms/ipxe/src/drivers/net/ |
| H A D | etherfabric.c | 3493 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3848 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3854 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3868 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3870 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3887 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3914 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3935 if ( ev_queue->ring ) in efab_free_resources()
3940 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3949 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|
| /dports/emulators/qemu/qemu-6.2.0/roms/ipxe/src/drivers/net/ |
| H A D | etherfabric.c | 3493 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3848 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3854 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3868 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3870 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3887 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3914 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3935 if ( ev_queue->ring ) in efab_free_resources()
3940 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3949 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|
| /dports/emulators/qemu60/qemu-6.0.0/roms/ipxe/src/drivers/net/ |
| H A D | etherfabric.c | 3493 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3848 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3854 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3868 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3870 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3887 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3914 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3935 if ( ev_queue->ring ) in efab_free_resources()
3940 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3949 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|
| /dports/sysutils/syslinux/syslinux-6.03/gpxe/src/drivers/net/ |
| H A D | etherfabric.c | 3504 struct efab_ev_queue *ev_queue = &efab->ev_queue; in falcon_init_resources() local
3858 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_poll() local
3864 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3878 ev_queue->read_ptr = ( ( ev_queue->read_ptr + 1 ) % in efab_poll()
3880 evt = ev_queue->ring + ev_queue->read_ptr; in efab_poll()
3897 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_irq() local
3924 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_free_resources() local
3945 if ( ev_queue->ring ) in efab_free_resources()
3950 memset ( ev_queue, 0, sizeof ( *ev_queue ) ); in efab_free_resources()
3959 struct efab_ev_queue *ev_queue = &efab->ev_queue; in efab_alloc_resources() local
[all …]
|