| /third_party/ffmpeg/libavutil/ |
| D | threadmessage.c | 40 int av_thread_message_queue_alloc(AVThreadMessageQueue **mq, in av_thread_message_queue_alloc() argument
75 *mq = rmq; in av_thread_message_queue_alloc()
78 *mq = NULL; in av_thread_message_queue_alloc()
83 void av_thread_message_queue_set_free_func(AVThreadMessageQueue *mq, in av_thread_message_queue_set_free_func() argument
87 mq->free_func = free_func; in av_thread_message_queue_set_free_func()
91 void av_thread_message_queue_free(AVThreadMessageQueue **mq) in av_thread_message_queue_free() argument
94 if (*mq) { in av_thread_message_queue_free()
95 av_thread_message_flush(*mq); in av_thread_message_queue_free()
96 av_fifo_freep(&(*mq)->fifo); in av_thread_message_queue_free()
97 pthread_cond_destroy(&(*mq)->cond_send); in av_thread_message_queue_free()
[all …]
|
| D | threadmessage.h | 44 int av_thread_message_queue_alloc(AVThreadMessageQueue **mq,
53 void av_thread_message_queue_free(AVThreadMessageQueue **mq);
58 int av_thread_message_queue_send(AVThreadMessageQueue *mq,
65 int av_thread_message_queue_recv(AVThreadMessageQueue *mq,
77 void av_thread_message_queue_set_err_send(AVThreadMessageQueue *mq,
88 void av_thread_message_queue_set_err_recv(AVThreadMessageQueue *mq,
95 void av_thread_message_queue_set_free_func(AVThreadMessageQueue *mq,
104 int av_thread_message_queue_nb_elems(AVThreadMessageQueue *mq);
113 void av_thread_message_flush(AVThreadMessageQueue *mq);
|
| /third_party/gstreamer/gstreamer/plugins/elements/ |
| D | gstmultiqueue.c | 198 static void wake_up_next_non_linked (GstMultiQueue * mq);
199 static void compute_high_id (GstMultiQueue * mq);
200 static void compute_high_time (GstMultiQueue * mq, guint groupid);
204 static void update_buffering (GstMultiQueue * mq, GstSingleQueue * sq);
205 static void gst_multi_queue_post_buffering (GstMultiQueue * mq);
206 static void recheck_buffering_status (GstMultiQueue * mq);
210 static void calculate_interleave (GstMultiQueue * mq, GstSingleQueue * sq);
344 #define SET_PERCENT(mq, perc) G_STMT_START { \ argument
345 if (perc != mq->buffering_percent) { \
346 mq->buffering_percent = perc; \
[all …]
|
| /third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/fork/ |
| D | 19-1.c | 58 mqd_t mq; in main() local
67 mq = mq_open(queue_name, O_RDWR | O_CREAT | O_NONBLOCK, in main()
70 if (mq == (mqd_t)-1) { in main()
76 ret = mq_send(mq, message, sizeof(message), 0); in main()
79 mq_close(mq); in main()
86 ret = mq_getattr(mq, &mqa); in main()
89 mq_close(mq); in main()
96 mq_close(mq); in main()
106 mq_close(mq); in main()
114 ret = mq_getattr(mq, &mqa); in main()
[all …]
|
| /third_party/gstreamer/gstreamer/tests/check/elements/ |
| D | multiqueue.c | 32 GstElement *mq; in setup_multiqueue() local
35 mq = gst_element_factory_make ("multiqueue", NULL); in setup_multiqueue()
36 fail_unless (mq != NULL, "failed to create 'multiqueue' element"); in setup_multiqueue()
38 gst_bin_add (GST_BIN (pipe), mq); in setup_multiqueue()
45 sinkpad = gst_element_request_pad_simple (mq, "sink_%u"); in setup_multiqueue()
70 srcpad = gst_element_request_pad_simple (mq, "src_%u"); in setup_multiqueue()
74 srcpad = gst_element_get_static_pad (mq, padname); in setup_multiqueue()
92 return mq; in setup_multiqueue()
182 GstElement *mq; in GST_START_TEST() local
184 mq = gst_element_factory_make ("multiqueue", NULL); in GST_START_TEST()
[all …]
|
| /third_party/curl/lib/ |
| D | mqtt.c | 101 struct MQTT *mq; in mqtt_setup_conn() local
105 mq = calloc(1, sizeof(struct MQTT)); in mqtt_setup_conn()
106 if(!mq) in mqtt_setup_conn()
108 data->req.p.mqtt = mq; in mqtt_setup_conn()
118 struct MQTT *mq = data->req.p.mqtt; in mqtt_send() local
128 mq->sendleftovers = sendleftovers; in mqtt_send()
129 mq->nsend = nsend; in mqtt_send()
132 mq->sendleftovers = NULL; in mqtt_send()
133 mq->nsend = 0; in mqtt_send()
590 struct MQTT *mq = data->req.p.mqtt; in mqtt_read_publish() local
[all …]
|
| /third_party/ltp/testcases/open_posix_testsuite/functional/mqueues/ |
| D | send_rev_1.c | 36 mqd_t mq = 0; in main() local
49 if (((mqd_t) - 1) == (mq = mq_open(MQ_NAME, oflag, 0777, &mqstat))) { in main()
60 mq_getattr(mq, &attr); in main()
65 if (-1 == mq_send(mq, s_msg_ptr[i], attr.mq_msgsize, 1)) { in main()
78 mq_getattr(mq, &attr); in main()
82 mq_receive(mq, r_msg_ptr[i], attr.mq_msgsize, in main()
98 (void)mq_close(mq); in main()
|
| D | send_rev_2.c | 39 static int *send_1(void *mq) in send_1() argument
42 mqd_t mq1 = *(mqd_t *) mq; in send_1()
57 static int *send_2(void *mq) in send_2() argument
60 mqd_t mq2 = *(mqd_t *) mq; in send_2()
74 static int *receive_1(void *mq) in receive_1() argument
77 mqd_t mq1 = *(mqd_t *) mq; in receive_1()
91 static int *receive_2(void *mq) in receive_2() argument
94 mqd_t mq2 = *(mqd_t *) mq; in receive_2()
|
| /third_party/ltp/testcases/open_posix_testsuite/stress/mqueues/ |
| D | multi_send_rev_2.c | 36 static mqd_t mq = 0; variable
45 if (-1 == mq_send(mq, s_msg_ptr[i], MSG_SIZE, i)) { in msend()
64 mq_receive(mq, r_msg_ptr[ThreadID][i], MSG_SIZE, NULL)) { in mreceive()
102 if ((mq = mq_open(MQ_NAME, oflag, 0777, &mqstat)) == (mqd_t)-1) { in main()
119 mq_close(mq); in main()
|
| D | multi_send_rev_1.c | 88 mqd_t mq[Max_Threads]; in main() local
114 if ((mq[i] = mq_open(MQ_NAME[i], oflag, 0777, &mqstat)) == (mqd_t)-1) { in main()
122 info[i].mqID = mq[i]; in main()
133 mq_close(mq[i]); in main()
134 mq_close(mq[i]); in main()
|
| /third_party/mesa3d/src/gallium/drivers/r600/sfn/ |
| D | sfn_nir_lower_tess_io.cpp | 151 auto mq = reinterpret_cast<MaskQuery *>(data); in update_alu_mask() local
153 if (mq->ssa_index == src->ssa->index) { in update_alu_mask()
154 mq->mask |= nir_alu_instr_src_read_mask(mq->alu, mq->index); in update_alu_mask()
156 ++mq->index; in update_alu_mask()
158 return mq->mask != mq->full_mask; in update_alu_mask()
165 MaskQuery mq = {0}; in get_dest_usee_mask() local
166 mq.full_mask = (1 << nir_dest_num_components(op->dest)) - 1; in get_dest_usee_mask()
170 mq.ssa_index = use_src->ssa->index; in get_dest_usee_mask()
174 mq.alu = nir_instr_as_alu(use_instr); in get_dest_usee_mask()
175 mq.index = 0; in get_dest_usee_mask()
[all …]
|
| /third_party/boost/libs/geometry/test/geometries/ |
| D | boost_polygon_overlay.cpp | 37 mp_type mp, mq; in test_overlay_using_boost_polygon() local
40 bg::read_wkt(wkt_q, mq); in test_overlay_using_boost_polygon()
43 q.insert(mq.begin(), mq.end()); in test_overlay_using_boost_polygon()
|
| /third_party/boost/libs/interprocess/example/ |
| D | comp_doc_message_queueA.cpp | 25 message_queue mq in main() local
34 mq.send(&i, sizeof(i), 0); in main()
|
| D | comp_doc_message_queueB.cpp | 22 message_queue mq in main() local
33 mq.receive(&number, sizeof(number), recvd_size, priority); in main()
|
| /third_party/boost/libs/geometry/test/robustness/overlay/areal_areal/ |
| D | intersection_pies.cpp | 203 multi_polygon mq; in test_pie() local
204 mq.push_back(q); in test_pie()
205 mq.push_back(q2); in test_pie()
207 good = test_overlay_p_q<polygon, T>(out.str(), p, mq, settings); in test_pie()
|
| /third_party/gstreamer/gstplugins_bad/tests/examples/ipcpipeline/ |
| D | ipc-play.c | 828 GstElement *ipcpipelinesrc, *mq, *decodebin; in pipe_reader() local
854 mq = gst_bin_get_by_name (GST_BIN (pipeline), "mq"); in pipe_reader()
855 if (!mq) { in pipe_reader()
859 if (!gst_element_link (ipcpipelinesrc, mq)) { in pipe_reader()
865 rpad = gst_element_get_static_pad (mq, name); in pipe_reader()
887 gst_object_unref (mq); in pipe_reader()
|
| /third_party/musl/arch/powerpc/bits/ |
| D | user.h | 3 unsigned long gpr[32], nip, msr, orig_gpr3, ctr, link, xer, ccr, mq; member
|
| /third_party/boost/libs/interprocess/test/ |
| D | message_queue_test.cpp | 324 boost::interprocess::message_queue mq in test_multi_sender_receiver() local
326 global_queue = &mq; in test_multi_sender_receiver()
|
| /third_party/flutter/skia/third_party/externals/angle2/src/compiler/translator/ |
| D | Types.h | 161 void setMemoryQualifier(const TMemoryQualifier &mq) { memoryQualifier = mq; } in setMemoryQualifier() argument
|
| /third_party/skia/third_party/externals/angle2/src/compiler/translator/ |
| D | Types.h | 172 void setMemoryQualifier(const TMemoryQualifier &mq) { memoryQualifier = mq; } in setMemoryQualifier() argument
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | meson.build | 57 'thread-mq.c',
110 'thread-mq.h',
|
| /third_party/flutter/skia/third_party/externals/icu/source/data/unit/ |
| D | az.txt | 1118 dnam{"mq/dl"}
1119 one{"{0} mq/dl"}
1120 other{"{0} mq/dl"}
1502 dnam{"mq"}
1503 one{"{0} mq"}
1504 other{"{0} mq"}
|
| /third_party/re2/re2/ |
| D | dfa.cc | 208 State* WorkqToCachedState(Workq* q, Workq* mq, uint32_t flag);
609 DFA::State* DFA::WorkqToCachedState(Workq* q, Workq* mq, uint32_t flag) { in WorkqToCachedState() argument
726 if (mq != NULL) { in WorkqToCachedState()
728 for (Workq::iterator i = mq->begin(); i != mq->end(); ++i) { in WorkqToCachedState()
|
| /third_party/skia/third_party/externals/icu/source/data/unit/ |
| D | az.txt | 1403 dnam{"mq/dl"}
1404 one{"{0} mq/dl"}
1405 other{"{0} mq/dl"}
1895 dnam{"mq"}
1896 one{"{0} mq"}
1897 other{"{0} mq"}
|
| /third_party/icu/icu4c/source/data/unit/ |
| D | az.txt | 1403 dnam{"mq/dl"}
1404 one{"{0} mq/dl"}
1405 other{"{0} mq/dl"}
1895 dnam{"mq"}
1896 one{"{0} mq"}
1897 other{"{0} mq"}
|