Searched refs:event_queue (Results 1 – 9 of 9) sorted by relevance
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_event_thread.c | 51 static grpc_rb_event_queue event_queue; variable
58 gpr_mu_lock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
59 if (event_queue.tail == NULL) { in grpc_rb_event_queue_enqueue()
60 event_queue.head = event_queue.tail = event; in grpc_rb_event_queue_enqueue()
62 event_queue.tail->next = event; in grpc_rb_event_queue_enqueue()
63 event_queue.tail = event; in grpc_rb_event_queue_enqueue()
65 gpr_cv_signal(&event_queue.cv); in grpc_rb_event_queue_enqueue()
66 gpr_mu_unlock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
71 if (event_queue.head == NULL) { in grpc_rb_event_queue_dequeue()
74 event = event_queue.head; in grpc_rb_event_queue_dequeue()
[all …]
|
| /external/wpa_supplicant_8/src/wps/ |
| D | wps_upnp_event.c | 89 e = dl_list_first(&s->event_queue, struct wps_event_, list); in event_dequeue()
136 if (!dl_list_empty(&s->event_queue)) in event_retry()
140 dl_list_add(&s->event_queue, &e->list); in event_retry()
230 if (!dl_list_empty(&s->event_queue)) in event_http_cb()
281 dl_list_empty(&s->event_queue)) in event_send_start()
323 !dl_list_empty(&s->event_queue) /* more to do */) { in event_send_all_later_handler()
379 len = dl_list_len(&s->event_queue); in wps_upnp_event_add()
419 dl_list_add_tail(&s->event_queue, &e->list); in wps_upnp_event_add()
|
| D | wps_upnp_i.h | 92 struct dl_list event_queue; /* Queued event messages. */ member
|
| D | wps_upnp.c | 720 dl_list_init(&s->event_queue); in subscription_start()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | scheduler.cc | 218 std::priority_queue<Event> event_queue; in ComputeSchedule() local
223 event_queue.push(src_event); in ComputeSchedule()
226 while (!event_queue.empty()) { in ComputeSchedule()
227 Event event = event_queue.top(); in ComputeSchedule()
228 event_queue.pop(); in ComputeSchedule()
255 event_queue.push(e); in ComputeSchedule()
271 event_queue.push(e); in ComputeSchedule()
|
| /external/wpa_supplicant_8/src/drivers/ |
| D | driver_ndis.h | 31 HANDLE event_queue; /* NDISUIO notifier MsgQueue */ member
|
| D | driver_ndis.c | 1880 if (!ReadMsgQueue(drv->event_queue, buf, NDISUIO_MSG_SIZE, &len, 0, in ndisuio_notification_receive()
1944 req.hMsgQueue = drv->event_queue; in ndisuio_notification_deinit()
1961 if (drv->event_queue) { in ndisuio_notification_deinit()
1962 eloop_unregister_event(drv->event_queue, in ndisuio_notification_deinit()
1963 sizeof(drv->event_queue)); in ndisuio_notification_deinit()
1964 CloseHandle(drv->event_queue); in ndisuio_notification_deinit()
1965 drv->event_queue = NULL; in ndisuio_notification_deinit()
1995 drv->event_queue = CreateMsgQueue(NULL, &opt); in ndisuio_notification_init()
1996 if (drv->event_queue == NULL) { in ndisuio_notification_init()
2005 req.hMsgQueue = drv->event_queue; in ndisuio_notification_init()
[all …]
|
| /external/crosvm/devices/src/virtio/input/ |
| D | mod.rs | 387 event_queue: Queue, field
404 let queue = &mut self.event_queue; in send_events()
638 let event_queue = queues.remove(0); in activate() localVariable
647 event_queue, in activate()
|
| /external/googletest/googlemock/docs/ |
| D | cook_book.md | 2684 EventQueue event_queue(&mock_event_dispatcher);
2691 event_queue.EnqueueEvent(kEventId);
|