Searched refs:g_async_queue_pop (Results 1 – 15 of 15) sorted by relevance
| /third_party/glib/glib/tests/ |
| D | asyncqueue.c | 57 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 1); in test_async_queue_sort()
58 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 2); in test_async_queue_sort()
59 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 7); in test_async_queue_sort()
60 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 8); in test_async_queue_sort()
61 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 10); in test_async_queue_sort()
112 value = GPOINTER_TO_INT (g_async_queue_pop (q)); in thread_func()
239 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 10); in test_async_queue_remove()
240 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 2); in test_async_queue_remove()
241 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 1); in test_async_queue_remove()
261 g_assert_cmpint (GPOINTER_TO_INT (g_async_queue_pop (q)), ==, 1); in test_async_queue_push_front()
[all …]
|
| /third_party/gstreamer/gstplugins_base/tests/examples/gl/sdl/ |
| D | sdlshare.c | 368 vframe = (GstVideoFrame *) g_async_queue_pop (queue_output_buf); in on_new_sample()
494 vframe = (GstVideoFrame *) g_async_queue_pop (queue_input_buf); in sdl_event_loop()
641 (GstVideoFrame *) g_async_queue_pop (queue_input_buf); in main()
648 (GstVideoFrame *) g_async_queue_pop (queue_output_buf); in main()
|
| /third_party/glib/tests/ |
| D | asyncqueue-test.c | 86 p = g_async_queue_pop (async_queue); in sort_queue()
169 item = g_async_queue_pop (q); in basic_tests()
|
| /third_party/glib/glib/ |
| D | gasyncqueue.h | 74 gpointer g_async_queue_pop (GAsyncQueue *queue);
|
| D | gasyncqueue.c | 446 g_async_queue_pop (GAsyncQueue *queue) in g_async_queue_pop() function
|
| D | gthreadpool.c | 190 pool = g_async_queue_pop (unused_thread_queue); in g_thread_pool_wait_for_new_pool()
|
| /third_party/gstreamer/gstreamer/tests/check/gst/ |
| D | gstpromise.c | 505 item = g_async_queue_pop (s_q->push_queue); in _pop_promise()
521 item = g_async_queue_pop (s_q->wait_queue); in _wait_promise()
|
| /third_party/glib/gio/tests/ |
| D | cancellable.c | 250 while ((cancellable_source = g_async_queue_pop (data->cancellable_source_queue)) != (gpointer) 1) in threaded_dispose_thread_cb()
|
| D | gdbus-connection.c | 847 while ((popped_message = g_async_queue_pop (incoming_queue)) != NULL) in wait_for_filtered_reply()
|
| /third_party/gstreamer/gstplugins_base/tests/check/elements/ |
| D | vorbistag.c | 153 return GST_BUFFER (g_async_queue_pop (pending_buffers)); in get_buffer()
|
| /third_party/gstreamer/gstplugins_good/gst/dtmf/ |
| D | gstdtmfsrc.c | 658 event = g_async_queue_pop (dtmfsrc->event_queue); in gst_dtmf_src_create()
|
| D | gstrtpdtmfsrc.c | 670 event = g_async_queue_pop (dtmfsrc->event_queue); in gst_rtp_dtmf_src_create()
|
| /third_party/gstreamer/gstplugins_bad/sys/nvcodec/ |
| D | gstnvbaseenc.c | 1144 state_in_queue = g_async_queue_pop (nvenc->bitstream_queue); in gst_nv_base_enc_bitstream_thread()
2288 *input = g_async_queue_pop (nvenc->available_queue); in _acquire_input_buffer()
|
| /third_party/glib/docs/reference/glib/ |
| D | glib-sections.txt | 1169 g_async_queue_pop
|
| /third_party/gstreamer/gstplugins_bad/ |
| D | ChangeLog | 27133 We need to do this without holding the lock as the `g_async_queue_pop`
|