| /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()
439 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()
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/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 | 301 dtmfsrc->event_queue = g_async_queue_new_full ((GDestroyNotify) event_free); in gst_dtmf_src_init()
316 if (dtmfsrc->event_queue) { in gst_dtmf_src_finalize()
317 g_async_queue_unref (dtmfsrc->event_queue); in gst_dtmf_src_finalize()
318 dtmfsrc->event_queue = NULL; in gst_dtmf_src_finalize()
529 g_async_queue_push (dtmfsrc->event_queue, event); in gst_dtmf_src_add_start_event()
542 g_async_queue_push (dtmfsrc->event_queue, event); in gst_dtmf_src_add_stop_event()
697 event = g_async_queue_pop (dtmfsrc->event_queue); in gst_dtmf_src_create()
724 g_async_queue_push (dtmfsrc->event_queue, event); in gst_dtmf_src_create()
734 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_dtmf_src_create()
758 g_async_queue_push (dtmfsrc->event_queue, event); in gst_dtmf_src_create()
[all …]
|
| D | gstrtpdtmfsrc.c | 305 object->event_queue = in gst_rtp_dtmf_src_init()
319 if (dtmfsrc->event_queue) { in gst_rtp_dtmf_src_finalize()
320 g_async_queue_unref (dtmfsrc->event_queue); in gst_rtp_dtmf_src_finalize()
321 dtmfsrc->event_queue = NULL; in gst_rtp_dtmf_src_finalize()
556 g_async_queue_push (dtmfsrc->event_queue, event); in gst_rtp_dtmf_src_add_start_event()
566 g_async_queue_push (dtmfsrc->event_queue, event); in gst_rtp_dtmf_src_add_stop_event()
706 event = g_async_queue_pop (dtmfsrc->event_queue); in gst_rtp_dtmf_src_create()
741 g_async_queue_push (dtmfsrc->event_queue, event); in gst_rtp_dtmf_src_create()
753 event = g_async_queue_try_pop (dtmfsrc->event_queue); in gst_rtp_dtmf_src_create()
784 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 | 120 decoder->event_queue = NULL; in gst_kate_util_decode_base_init()
137 if (decoder->event_queue) { in gst_kate_util_decode_base_reset()
177 g_queue_push_tail (decoder->event_queue, item); in gst_kate_util_decoder_base_queue_event()
190 while (decoder->event_queue->length) { in gst_kate_util_decoder_base_free_event_queue()
192 g_queue_pop_head (decoder->event_queue); in gst_kate_util_decoder_base_free_event_queue()
196 g_queue_free (decoder->event_queue); in gst_kate_util_decoder_base_free_event_queue()
197 decoder->event_queue = NULL; in gst_kate_util_decoder_base_free_event_queue()
205 if (decoder->event_queue->length == 0) in gst_kate_util_decoder_base_drain_event_queue()
209 while (decoder->event_queue->length) { in gst_kate_util_decoder_base_drain_event_queue()
211 g_queue_pop_head (decoder->event_queue); in gst_kate_util_decoder_base_drain_event_queue()
[all …]
|
| D | gstkateparse.c | 141 while (parse->event_queue->length) { in gst_kate_parse_drain_event_queue()
144 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in gst_kate_parse_drain_event_queue()
233 while (parse->event_queue->length) { in gst_kate_parse_clear_queue()
236 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in gst_kate_parse_clear_queue()
405 g_queue_push_tail (parse->event_queue, event); in gst_kate_parse_queue_event()
601 parse->event_queue = g_queue_new (); in gst_kate_parse_change_state()
617 g_queue_free (parse->event_queue); in gst_kate_parse_change_state()
618 parse->event_queue = NULL; in gst_kate_parse_change_state()
|
| D | gstkateparse.h | 60 GQueue *event_queue; member
|
| D | gstkateutil.h | 76 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 | 173 while (parse->event_queue->length) { in vorbis_parse_drain_event_queue()
176 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in vorbis_parse_drain_event_queue()
295 while (parse->event_queue->length) { in vorbis_parse_clear_queue()
298 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in vorbis_parse_clear_queue()
486 g_queue_push_tail (parse->event_queue, event); in vorbis_parse_queue_event()
686 parse->event_queue = g_queue_new (); in vorbis_parse_change_state()
701 g_queue_free (parse->event_queue); in vorbis_parse_change_state()
702 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 | 152 while (!g_queue_is_empty (self->event_queue)) { in send_cached_buffer_and_events()
155 event = GST_EVENT_CAST (g_queue_pop_head (self->event_queue)); in send_cached_buffer_and_events()
180 while (!g_queue_is_empty (self->event_queue)) { in purge_cached_buffer_and_events()
183 event = GST_EVENT_CAST (g_queue_pop_head (self->event_queue)); in purge_cached_buffer_and_events()
231 g_queue_free (self->event_queue); in gst_rtp_onvif_timestamp_finalize()
378 g_queue_push_tail (self->event_queue, event); in gst_rtp_onvif_timestamp_sink_event()
444 self->event_queue = g_queue_new (); in gst_rtp_onvif_timestamp_init()
|
| D | gstrtponviftimestamp.h | 67 GQueue *event_queue; member
|
| /third_party/gstreamer/gstplugins_base/ext/theora/ |
| D | gsttheoraparse.c | 355 while (parse->event_queue->length) { in theora_parse_drain_event_queue()
358 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in theora_parse_drain_event_queue()
394 while (parse->event_queue->length) { in theora_parse_clear_queue()
397 event = GST_EVENT_CAST (g_queue_pop_head (parse->event_queue)); in theora_parse_clear_queue()
698 g_queue_push_tail (parse->event_queue, event); in theora_parse_queue_event()
911 parse->event_queue = g_queue_new (); in theora_parse_change_state()
928 g_queue_free (parse->event_queue); in theora_parse_change_state()
|
| D | gsttheoraparse.h | 62 GQueue * event_queue; member
|
| /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 …]
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/drivers/ |
| D | driver_ndis.h | 31 HANDLE event_queue; /* NDISUIO notifier MsgQueue */ 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
|