Searched refs:mq1 (Results 1 – 3 of 3) sorted by relevance
| /third_party/ltp/testcases/open_posix_testsuite/functional/mqueues/ |
| D | send_rev_2.c | 42 mqd_t mq1 = *(mqd_t *) mq; in send_1() local
46 if (-1 == mq_send(mq1, s_msg_ptr[i], MSG_SIZE, i)) { in send_1()
77 mqd_t mq1 = *(mqd_t *) mq; in receive_1() local
81 if (-1 == mq_receive(mq1, r_msg_ptr_1[i], MSG_SIZE, NULL)) { in receive_1()
111 mqd_t mq1 = 0, mq2 = 0; in main() local
120 if ((mq1 = mq_open(MQ_NAME_1, oflag, 0777, &mqstat)) == (mqd_t)-1) { in main()
128 pthread_create(&send1, NULL, (void *)send_1, (void *)&mq1); in main()
130 pthread_create(&rev1, NULL, (void *)receive_1, (void *)&mq1); in main()
137 mq_close(mq1); in main()
|
| /third_party/boost/libs/interprocess/test/ |
| D | message_queue_test.cpp | 48 message_queue mq1 in test_priority_order() local
65 mq1.send(&tstamp, sizeof(tstamp), (unsigned int)(i%10)); in test_priority_order()
74 mq1.receive(&tstamp, sizeof(tstamp), recvd, priority); in test_priority_order()
88 mq1.send(&tstamp, sizeof(tstamp), (unsigned int)(9 - i%10)); in test_priority_order()
97 mq1.receive(&tstamp, sizeof(tstamp), recvd, priority); in test_priority_order()
139 message_queue mq1(create_only, test::get_process_id_name(), 1, MaxMsgSize); in test_serialize_db() local
176 mq1.send( &static_cast<char*>(db_origin.get_address())[sent] in test_serialize_db()
|
| /third_party/gstreamer/gstplugins_base/tests/check/elements/ |
| D | decodebin.c | 622 GstElement *mq0, *mq1, *mq2; in GST_START_TEST() local
637 mq1 = gst_element_factory_make ("multiqueue", NULL); in GST_START_TEST()
641 fail_unless (gst_bin_add (GST_BIN (decodebin), mq1)); in GST_START_TEST()
666 gst_element_post_message (mq1, gst_message_new_buffering (GST_OBJECT (mq1), in GST_START_TEST()
670 fail_unless (GST_MESSAGE_SRC (msg) == (GstObject *) mq1); in GST_START_TEST()
680 fail_unless (GST_MESSAGE_SRC (msg) == (GstObject *) mq1); in GST_START_TEST()
690 fail_unless (GST_MESSAGE_SRC (msg) == (GstObject *) mq1); in GST_START_TEST()
696 gst_element_post_message (mq1, gst_message_new_buffering (GST_OBJECT (mq1), in GST_START_TEST()
|