| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_event_thread.c | 53 static grpc_rb_event_queue event_queue; variable
60 gpr_mu_lock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
61 if (event_queue.tail == NULL) { in grpc_rb_event_queue_enqueue()
62 event_queue.head = event_queue.tail = event; in grpc_rb_event_queue_enqueue()
64 event_queue.tail->next = event; in grpc_rb_event_queue_enqueue()
65 event_queue.tail = event; in grpc_rb_event_queue_enqueue()
67 gpr_cv_signal(&event_queue.cv); in grpc_rb_event_queue_enqueue()
68 gpr_mu_unlock(&event_queue.mu); in grpc_rb_event_queue_enqueue()
73 if (event_queue.head == NULL) { in grpc_rb_event_queue_dequeue()
76 event = event_queue.head; in grpc_rb_event_queue_dequeue()
[all …]
|
| /third_party/gstreamer/gstreamer/tests/check/gst/ |
| D | gstpromise.c | 28 struct event_queue struct
46 _promise_thread (struct event_queue *q) in _promise_thread() argument
70 event_queue_start (struct event_queue *q) in event_queue_start()
81 event_queue_stop (struct event_queue *q) in event_queue_stop()
90 event_queue_stop_wait (struct event_queue *q) in event_queue_stop_wait()
102 static struct event_queue *
105 struct event_queue *q = g_new0 (struct event_queue, 1); in event_queue_new()
117 event_queue_free (struct event_queue *q) in event_queue_free()
130 _enqueue_task (struct event_queue *q, GSourceFunc func, gpointer data, in _enqueue_task()
440 struct event_queue *q;
[all …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/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()
231 if (!dl_list_empty(&s->event_queue)) in event_http_cb()
282 dl_list_empty(&s->event_queue)) in event_send_start()
324 !dl_list_empty(&s->event_queue) /* more to do */) { in event_send_all_later_handler()
380 len = dl_list_len(&s->event_queue); in wps_upnp_event_add()
420 dl_list_add_tail(&s->event_queue, &e->list); in wps_upnp_event_add()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/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()
378 len = dl_list_len(&s->event_queue); in event_add()
418 dl_list_add_tail(&s->event_queue, &e->list); in event_add()
|
| /third_party/gstreamer/gstplugins_good/gst/dtmf/ |
| D | gstdtmfsrc.c | 262 dtmfsrc->event_queue = g_async_queue_new_full ((GDestroyNotify) event_free); in gst_dtmf_src_init()
277 if (dtmfsrc->event_queue) { in gst_dtmf_src_finalize()
278 g_async_queue_unref (dtmfsrc->event_queue); in gst_dtmf_src_finalize()
279 dtmfsrc->event_queue = NULL; in gst_dtmf_src_finalize()
490 g_async_queue_push (dtmfsrc->event_queue, event); in gst_dtmf_src_add_start_event()
503 g_async_queue_push (dtmfsrc->event_queue, event); in gst_dtmf_src_add_stop_event()
658 event = g_async_queue_pop (dtmfsrc->event_queue); in gst_dtmf_src_create()
685 g_async_queue_push (dtmfsrc->event_queue, event); in gst_dtmf_src_create()
695 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_dtmf_src_create()
719 g_async_queue_push (dtmfsrc->event_queue, event); in gst_dtmf_src_create()
[all …]
|
| D | gstrtpdtmfsrc.c | 267 object->event_queue = in gst_rtp_dtmf_src_init()
281 if (dtmfsrc->event_queue) { in gst_rtp_dtmf_src_finalize()
282 g_async_queue_unref (dtmfsrc->event_queue); in gst_rtp_dtmf_src_finalize()
283 dtmfsrc->event_queue = NULL; in gst_rtp_dtmf_src_finalize()
518 g_async_queue_push (dtmfsrc->event_queue, event); in gst_rtp_dtmf_src_add_start_event()
528 g_async_queue_push (dtmfsrc->event_queue, event); in gst_rtp_dtmf_src_add_stop_event()
670 event = g_async_queue_pop (dtmfsrc->event_queue); in gst_rtp_dtmf_src_create()
705 g_async_queue_push (dtmfsrc->event_queue, event); in gst_rtp_dtmf_src_create()
717 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_rtp_dtmf_src_create()
748 g_async_queue_push (dtmfsrc->event_queue, event); in gst_rtp_dtmf_src_create()
[all …]
|
| D | gstdtmfsrc.h | 75 GAsyncQueue *event_queue; member
|
| D | gstrtpdtmfsrc.h | 75 GAsyncQueue *event_queue; member
|
| /third_party/gstreamer/gstplugins_bad/ext/kate/ |
| D | gstkateutil.c | 119 decoder->event_queue = NULL; in gst_kate_util_decode_base_init()
136 if (decoder->event_queue) { in gst_kate_util_decode_base_reset()
176 g_queue_push_tail (decoder->event_queue, item); in gst_kate_util_decoder_base_queue_event()
189 while (decoder->event_queue->length) { in gst_kate_util_decoder_base_free_event_queue()
191 g_queue_pop_head (decoder->event_queue); in gst_kate_util_decoder_base_free_event_queue()
195 g_queue_free (decoder->event_queue); in gst_kate_util_decoder_base_free_event_queue()
196 decoder->event_queue = NULL; in gst_kate_util_decoder_base_free_event_queue()
204 if (decoder->event_queue->length == 0) in gst_kate_util_decoder_base_drain_event_queue()
208 while (decoder->event_queue->length) { in gst_kate_util_decoder_base_drain_event_queue()
210 g_queue_pop_head (decoder->event_queue); in gst_kate_util_decoder_base_drain_event_queue()
[all …]
|
| D | gstkateparse.c | 148 while (parse->event_queue->length) { in gst_kate_parse_drain_event_queue()
151 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in gst_kate_parse_drain_event_queue()
240 while (parse->event_queue->length) { in gst_kate_parse_clear_queue()
243 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in gst_kate_parse_clear_queue()
412 g_queue_push_tail (parse->event_queue, event); in gst_kate_parse_queue_event()
608 parse->event_queue = g_queue_new (); in gst_kate_parse_change_state()
624 g_queue_free (parse->event_queue); in gst_kate_parse_change_state()
625 parse->event_queue = NULL; in gst_kate_parse_change_state()
|
| D | gstkateparse.h | 60 GQueue *event_queue; member
|
| /third_party/glib/gio/ |
| D | glocalfilemonitor.c | 56 GQueue event_queue; member
140 if (fms->event_queue.length) in g_file_monitor_source_get_ready_time()
248 g_queue_push_tail (&fms->event_queue, event); in g_file_monitor_source_queue_event()
504 GQueue event_queue; in g_file_monitor_source_dispatch() local
553 memcpy (&event_queue, &fms->event_queue, sizeof event_queue); in g_file_monitor_source_dispatch()
554 memset (&fms->event_queue, 0, sizeof fms->event_queue); in g_file_monitor_source_dispatch()
562 while ((event = g_queue_pop_head (&event_queue))) in g_file_monitor_source_dispatch()
592 while ((event = g_queue_pop_head (&fms->event_queue))) in g_file_monitor_source_dispose()
597 g_assert (fms->event_queue.length == 0); in g_file_monitor_source_dispose()
618 g_assert (fms->event_queue.length == 0); in g_file_monitor_source_finalize()
|
| /third_party/gstreamer/gstplugins_base/ext/vorbis/ |
| D | gstvorbisparse.c | 179 while (parse->event_queue->length) { in vorbis_parse_drain_event_queue()
182 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in vorbis_parse_drain_event_queue()
301 while (parse->event_queue->length) { in vorbis_parse_clear_queue()
304 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in vorbis_parse_clear_queue()
492 g_queue_push_tail (parse->event_queue, event); in vorbis_parse_queue_event()
692 parse->event_queue = g_queue_new (); in vorbis_parse_change_state()
707 g_queue_free (parse->event_queue); in vorbis_parse_change_state()
708 parse->event_queue = NULL; in vorbis_parse_change_state()
|
| D | gstvorbisparse.h | 60 GQueue * event_queue; member
|
| /third_party/gstreamer/gstplugins_bad/gst/onvif/ |
| D | gstrtponviftimestamp.c | 162 while (!g_queue_is_empty (self->event_queue)) { in send_cached_buffer_and_events()
165 event = GST_EVENT_CAST (g_queue_pop_head (self->event_queue)); in send_cached_buffer_and_events()
190 while (!g_queue_is_empty (self->event_queue)) { in purge_cached_buffer_and_events()
193 event = GST_EVENT_CAST (g_queue_pop_head (self->event_queue)); in purge_cached_buffer_and_events()
241 g_queue_free (self->event_queue); in gst_rtp_onvif_timestamp_finalize()
395 g_queue_push_tail (self->event_queue, event); in gst_rtp_onvif_timestamp_sink_event()
462 self->event_queue = g_queue_new (); in gst_rtp_onvif_timestamp_init()
|
| D | gstrtponviftimestamp.h | 68 GQueue *event_queue; member
|
| /third_party/gstreamer/gstplugins_base/ext/theora/ |
| D | gsttheoraparse.c | 357 while (parse->event_queue->length) { in theora_parse_drain_event_queue()
360 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in theora_parse_drain_event_queue()
396 while (parse->event_queue->length) { in theora_parse_clear_queue()
399 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in theora_parse_clear_queue()
700 g_queue_push_tail (parse->event_queue, event); in theora_parse_queue_event()
913 parse->event_queue = g_queue_new (); in theora_parse_change_state()
930 g_queue_free (parse->event_queue); in theora_parse_change_state()
|
| D | gsttheoraparse.h | 62 GQueue * event_queue; member
|
| /third_party/flutter/glfw/src/ |
| D | mir_window.c | 69 TAILQ_INSERT_TAIL(&_glfw.mir.event_queue->head, new_node, entries); in enqueueEvent()
560 while ((node = dequeueEvent(_glfw.mir.event_queue))) in _glfwPlatformPollEvents()
563 deleteNode(_glfw.mir.event_queue, node); in _glfwPlatformPollEvents()
571 if (emptyEventQueue(_glfw.mir.event_queue)) in _glfwPlatformWaitEvents()
583 if (emptyEventQueue(_glfw.mir.event_queue)) in _glfwPlatformWaitEventsTimeout()
|
| D | mir_init.c | 194 _glfw.mir.event_queue = calloc(1, sizeof(EventQueue)); in _glfwPlatformInit()
195 _glfwInitEventQueueMir(_glfw.mir.event_queue); in _glfwPlatformInit()
215 _glfwDeleteEventQueueMir(_glfw.mir.event_queue); in _glfwPlatformTerminate()
|
| D | mir_platform.h | 108 EventQueue* event_queue; member
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/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 …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/drivers/ |
| D | driver_ndis.h | 31 HANDLE event_queue; /* NDISUIO notifier MsgQueue */ member
|
| D | driver_ndis.c | 1868 if (!ReadMsgQueue(drv->event_queue, buf, NDISUIO_MSG_SIZE, &len, 0, in ndisuio_notification_receive()
1932 req.hMsgQueue = drv->event_queue; in ndisuio_notification_deinit()
1949 if (drv->event_queue) { in ndisuio_notification_deinit()
1950 eloop_unregister_event(drv->event_queue, in ndisuio_notification_deinit()
1951 sizeof(drv->event_queue)); in ndisuio_notification_deinit()
1952 CloseHandle(drv->event_queue); in ndisuio_notification_deinit()
1953 drv->event_queue = NULL; in ndisuio_notification_deinit()
1983 drv->event_queue = CreateMsgQueue(NULL, &opt); in ndisuio_notification_init()
1984 if (drv->event_queue == NULL) { in ndisuio_notification_init()
1993 req.hMsgQueue = drv->event_queue; in ndisuio_notification_init()
[all …]
|