| /external/jemalloc_new/test/include/test/ |
| D | mq.h | 38 a_prefix##init(a_mq_type *mq) { \
40 if (mtx_init(&mq->lock)) { \
43 ql_new(&mq->msgs); \
44 mq->count = 0; \
48 a_prefix##fini(a_mq_type *mq) { \
49 mtx_fini(&mq->lock); \
52 a_prefix##count(a_mq_type *mq) { \
55 mtx_lock(&mq->lock); \
56 count = mq->count; \
57 mtx_unlock(&mq->lock); \
[all …]
|
| /external/jemalloc_new/test/unit/ |
| D | mq.c | 13 mq_t mq; in mq_gen() local
16 assert_false(mq_init(&mq), "Unexpected mq_init() failure"); in mq_gen()
17 assert_u_eq(mq_count(&mq), 0, "mq should be empty"); in mq_gen()
18 assert_ptr_null(mq_tryget(&mq), in mq_gen()
21 mq_put(&mq, &msg); in mq_gen()
22 assert_u_eq(mq_count(&mq), 1, "mq should contain one message"); in mq_gen()
23 assert_ptr_eq(mq_tryget(&mq), &msg, "mq_tryget() should return msg"); in mq_gen()
25 mq_put(&mq, &msg); in mq_gen()
26 assert_ptr_eq(mq_get(&mq), &msg, "mq_get() should return msg"); in mq_gen()
28 mq_fini(&mq); in mq_gen()
[all …]
|
| /external/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 …]
|
| /external/llvm-project/polly/lib/External/isl/test_inputs/codegen/omega/ |
| D | olda-1.in | 1 …0[mp, mq, mi] -> [mi, mq, mp, 0] : mq >= 1 and mq <= mp and mp <= np and mi >= 1 and mi <= morb; s…
|
| D | olda-0.in | 1 …0[mp, mq, mi] -> [mi, mq, mp, 0] : mq >= 1 and mq <= mp and mp <= np and mi >= 1 and mi <= morb; s…
|
| /external/curl/lib/ |
| D | mqtt.c | 97 struct MQTT *mq; in mqtt_setup_conn() local
101 mq = calloc(1, sizeof(struct MQTT)); in mqtt_setup_conn()
102 if(!mq) in mqtt_setup_conn()
104 data->req.protop = mq; in mqtt_setup_conn()
114 struct MQTT *mq = data->req.protop; in mqtt_send() local
124 mq->sendleftovers = sendleftovers; in mqtt_send()
125 mq->nsend = nsend; in mqtt_send()
430 struct MQTT *mq = data->req.protop; in mqtt_read_publish() local
446 packet = mq->firstbyte & 0xf0; in mqtt_read_publish()
464 remlen = mq->remaining_length; in mqtt_read_publish()
[all …]
|
| /external/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 int *send_1(void *mq) in send_1() argument
42 mqd_t mq1 = *(mqd_t *) mq; in send_1()
57 int *send_2(void *mq) in send_2() argument
60 mqd_t mq2 = *(mqd_t *) mq; in send_2()
74 int *receive_1(void *mq) in receive_1() argument
77 mqd_t mq1 = *(mqd_t *) mq; in receive_1()
91 int *receive_2(void *mq) in receive_2() argument
94 mqd_t mq2 = *(mqd_t *) mq; in receive_2()
|
| /external/ltp/testcases/open_posix_testsuite/stress/mqueues/ |
| D | multi_send_rev_2.c | 36 mqd_t mq = 0; variable
45 if (-1 == mq_send(mq, s_msg_ptr[i], MSG_SIZE, i)) { in send()
64 mq_receive(mq, r_msg_ptr[ThreadID][i], MSG_SIZE, NULL)) { in receive()
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()
|
| /external/testng/src/main/java/org/testng/reporters/ |
| D | EmailableReporter.java | 137 int mq = 0; in resultSummary() local
144 if (mq == 0) { in resultSummary()
150 if (mq > 0) { in resultSummary()
154 if (mq > 1) { in resultSummary()
155 m_out.print(" rowspan=\"" + mq + "\""); in resultSummary()
159 mq = 0; in resultSummary()
174 mq += 1; in resultSummary()
175 if (mq > 1) { in resultSummary()
193 if (mq > 0) { in resultSummary()
197 if (mq > 1) { in resultSummary()
[all …]
|
| /external/iproute2/tc/ |
| D | q_prio.c | 37 unsigned char mq = 0; in prio_parse_opt() local
55 mq = 1; in prio_parse_opt()
91 if (mq) in prio_parse_opt()
|
| D | q_rr.c | 38 unsigned char mq = 0; in rr_parse_opt() local
59 mq = 1; in rr_parse_opt()
86 if (mq) in rr_parse_opt()
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowMessage.java | 140 private static ShadowMessageQueue shadowOf(MessageQueue mq) { in shadowOf() argument
141 return Shadow.extract(mq); in shadowOf()
|
| D | ShadowLooper.java | 406 private static ShadowMessageQueue shadowOf(MessageQueue mq) { in shadowOf() argument
407 return Shadow.extract(mq); in shadowOf()
|
| /external/openssh/regress/unittests/sshkey/testdata/ |
| D | dsa_1.pub | 1 …z4Dp3S8kLs+X5/1DMn/Tg1Y4D4yLB+6vCtHcJF7rVBFhvw/KZwc7G54ez3khyOtsg82fzpyOc8/mq+/+C5TMKO7DDjMF0k5emW…
|
| D | dsa_1-cert.pub | 1 …z4Dp3S8kLs+X5/1DMn/Tg1Y4D4yLB+6vCtHcJF7rVBFhvw/KZwc7G54ez3khyOtsg82fzpyOc8/mq+/+C5TMKO7DDjMF0k5emW…
|
| D | dsa_n_pw | 5 4D4yLB+6vCtHcJF7rVBFhvw/KZwc7G54ez3khyOtsg82fzpyOc8/mq+/+C5TMKO7DDjMF0
|
| /external/google-breakpad/src/google_breakpad/common/ |
| D | minidump_cpu_ppc.h | 133 uint32_t mq; /* Multiply/Quotient (PPC 601, POWER only) */ member
|
| /external/dtc/tests/ |
| D | multilabel.dts | 3 m1: mq: /memreserve/ 0 0x1000;
|
| D | multilabel_merge.dts | 3 m1: mq: /memreserve/ 0 0x1000;
|
| /external/angle/src/compiler/translator/ |
| D | Types.h | 172 void setMemoryQualifier(const TMemoryQualifier &mq) { memoryQualifier = mq; } in setMemoryQualifier() argument
|
| /external/hyphenation-patterns/la/ |
| D | hyph-la.pat.txt | 114 2mq
|
| /external/rust/crates/grpcio-sys/grpc/third_party/re2/re2/ |
| D | dfa.cc | 192 State* WorkqToCachedState(Workq* q, Workq* mq, uint32_t flag);
595 DFA::State* DFA::WorkqToCachedState(Workq* q, Workq* mq, uint32_t flag) { in WorkqToCachedState() argument
710 if (mq != NULL) { in WorkqToCachedState()
712 for (Workq::iterator i = mq->begin(); i != mq->end(); ++i) { in WorkqToCachedState()
|
| /external/ImageMagick/PerlMagick/t/reference/filter/ |
| D | Minify.miff | 15 …Z`a\mOIP@<;A<3H@3H?7N=6�>4�</�;,�;/�=0�9/�4.�4*�<.�I@�D>�?9�AF�BV�Ei�Lt�Tn�mq̸���������կ��=:2;80C>…
|