Searched refs:reader_thread (Results 1 – 8 of 8) sorted by relevance
| /third_party/boost/libs/log/test/run/ |
| D | util_ipc_reliable_mq.cpp | 410 …boost::thread reader_thread(&stop_reset_reading_thread, boost::ref(reader_queue), reader_results, … in BOOST_AUTO_TEST_CASE() local
414 reader_thread.join(); in BOOST_AUTO_TEST_CASE()
443 …hread(&stop_reset_reading_thread, boost::ref(reader_queue), reader_results, 2).swap(reader_thread); in BOOST_AUTO_TEST_CASE()
455 reader_thread.join(); in BOOST_AUTO_TEST_CASE()
|
| /third_party/gstreamer/gstplugins_bad/sys/ipcpipeline/ |
| D | gstipcpipelinecomm.h | 65 GThread *reader_thread; member
|
| D | gstipcpipelinecomm.c | 2171 reader_thread (gpointer data) in reader_thread() function
2208 if (comm->reader_thread) in gst_ipc_pipeline_comm_start_reader_thread()
2220 comm->reader_thread = in gst_ipc_pipeline_comm_start_reader_thread()
2221 g_thread_new ("reader", (GThreadFunc) reader_thread, comm); in gst_ipc_pipeline_comm_start_reader_thread()
2228 if (!comm->reader_thread) in gst_ipc_pipeline_comm_stop_reader_thread()
2232 g_thread_join (comm->reader_thread); in gst_ipc_pipeline_comm_stop_reader_thread()
2233 comm->reader_thread = NULL; in gst_ipc_pipeline_comm_stop_reader_thread()
|
| D | gstipcpipelinesink.c | 611 if (!sink->comm.reader_thread) { in gst_ipc_pipeline_sink_change_state()
|
| D | gstipcpipelinesrc.c | 945 if (!src->comm.reader_thread) { in gst_ipc_pipeline_src_change_state()
|
| /third_party/glib/gio/tests/ |
| D | win32-streams.c | 87 reader_thread (gpointer user_data) in reader_thread() function
240 reader = g_thread_new ("reader", reader_thread, NULL); in test_pipe_io()
|
| D | unix-streams.c | 82 reader_thread (gpointer user_data) in reader_thread() function
291 reader = g_thread_new ("reader", reader_thread, NULL); in test_pipe_io()
|
| /third_party/grpc/test/cpp/end2end/ |
| D | end2end_test.cc | 1324 std::thread reader_thread(ReaderThreadFunc, stream.get(), &ev); in TEST_P() local
1327 reader_thread.join(); in TEST_P()
|