| /kernel/liteos_m/testsuites/sample/posix/mqueue/ |
| D | It_posix_queue_049.c | 57 mqstat1.mq_curmsgs = mqstat1.mq_curmsgs + 1; in Testcase()
66 ICUNIT_GOTO_NOT_EQUAL(mqstat2.mq_curmsgs, mqstat1.mq_curmsgs, mqstat2.mq_curmsgs, EXIT1); in Testcase()
|
| D | It_posix_queue_008.c | 48 ICUNIT_GOTO_EQUAL(attr.mq_curmsgs, 0, attr.mq_curmsgs, EXIT1); in Testcase()
|
| D | It_posix_queue_009.c | 51 ICUNIT_GOTO_EQUAL(attrget.mq_curmsgs, 0, attrget.mq_curmsgs, EXIT1); in Testcase()
|
| D | It_posix_queue_046.c | 60 ICUNIT_GOTO_EQUAL(mqstat.mq_curmsgs, 5, mqstat.mq_curmsgs, EXIT1); // 5, assert the curmsgs. in Testcase()
|
| D | It_posix_queue_044.c | 61 ICUNIT_GOTO_EQUAL(mqstat2.mq_curmsgs, 0, mqstat2.mq_curmsgs, EXIT1); in Testcase()
|
| /kernel/liteos_a/testsuites/unittest/libc/posix/mqueue/full/ |
| D | It_posix_queue_067.cpp | 58 mqstat1.mq_curmsgs = mqstat1.mq_curmsgs + 1; in Testcase()
67 ICUNIT_GOTO_NOT_EQUAL(mqstat2.mq_curmsgs, mqstat1.mq_curmsgs, mqstat2.mq_curmsgs, EXIT1); in Testcase()
|
| D | It_posix_queue_014.cpp | 49 ICUNIT_GOTO_EQUAL(attr.mq_curmsgs, 0, attr.mq_curmsgs, EXIT1); in Testcase()
|
| D | It_posix_queue_064.cpp | 60 ICUNIT_GOTO_EQUAL(mqstat.mq_curmsgs, 5, mqstat.mq_curmsgs, EXIT1); // 5, assert the curmsgs. in Testcase()
|
| D | It_posix_queue_015.cpp | 52 ICUNIT_GOTO_EQUAL(attrget.mq_curmsgs, 0, attrget.mq_curmsgs, EXIT1); in Testcase()
|
| /kernel/liteos_m/testsuites/unittest/xts/ipc/msg_queue/ |
| D | mq_test.c | 170 …ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no spe…
216 …ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no spe…
286 …ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no spe…
365 …ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no spe…
442 …ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no spe…
|
| /kernel/liteos_a/testsuites/unittest/libc/posix/mqueue/smoke/ |
| D | It_posix_queue_062.cpp | 62 ICUNIT_GOTO_EQUAL(mqstat2.mq_curmsgs, 0, mqstat2.mq_curmsgs, EXIT1); in Testcase()
|
| /kernel/linux/linux-5.10/ipc/ |
| D | mqueue.c | 229 info->attr.mq_curmsgs++; in msg_insert()
264 if (info->attr.mq_curmsgs) { in msg_get()
268 info->attr.mq_curmsgs = 0; in msg_get()
287 info->attr.mq_curmsgs--; in msg_get()
683 if (info->attr.mq_curmsgs) in mqueue_poll_file()
686 if (info->attr.mq_curmsgs < info->attr.mq_maxmsg) in mqueue_poll_file()
790 info->attr.mq_curmsgs == 1) { in __do_notify()
1138 if (info->attr.mq_curmsgs == info->attr.mq_maxmsg) { in do_mq_timedsend()
1243 if (info->attr.mq_curmsgs == 0) { in do_mq_timedreceive()
1527 compat_long_t mq_curmsgs; /* number of messages currently queued */ member
[all …]
|
| /kernel/linux/patches/linux-4.19/prebuilts/usr/include/linux/ |
| D | mqueue.h | 15 __kernel_long_t mq_curmsgs; member
|
| /kernel/linux/patches/linux-5.10/prebuilts/usr/include/linux/ |
| D | mqueue.h | 28 __kernel_long_t mq_curmsgs; member
|
| /kernel/linux/linux-5.10/include/uapi/linux/ |
| D | mqueue.h | 32 __kernel_long_t mq_curmsgs; /* number of messages currently queued */ member
|
| /kernel/liteos_m/kal/libc/newlib/porting/include/ |
| D | mqueue.h | 44 long mq_flags, mq_maxmsg, mq_msgsize, mq_curmsgs, _unused[4]; member
|
| /kernel/liteos_a/compat/posix/include/ |
| D | mqueue.h | 124 long mq_curmsgs; /**< Number of messages in the current message queue */ member
|
| /kernel/linux/linux-5.10/tools/testing/selftests/mqueue/ |
| D | mq_perf_tests.c | 307 printf("\t\tmq_curmsgs:\t\t\t%lu\n", result.mq_curmsgs); in open_queue()
|
| /kernel/liteos_m/kal/posix/src/ |
| D | mqueue.c | 393 mqAttr->mq_curmsgs = mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ]; in OsMqGetAttr()
|
| /kernel/liteos_a/compat/posix/src/ |
| D | mqueue.c | 627 mqAttr->mq_curmsgs = mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ]; in OsMqGetAttr()
|
| /kernel/linux/linux-5.10/kernel/ |
| D | auditsc.c | 1321 context->mq_open.attr.mq_curmsgs); in show_special()
1345 attr->mq_msgsize, attr->mq_curmsgs); in show_special()
|