Home
last modified time | relevance | path

Searched refs:mq_curmsgs (Results 1 - 25 of 26) sorted by relevance

12

/kernel/liteos_m/testsuites/sample/posix/mqueue/
H A DIt_posix_queue_049.c57 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()
H A DIt_posix_queue_008.c48 ICUNIT_GOTO_EQUAL(attr.mq_curmsgs, 0, attr.mq_curmsgs, EXIT1); in Testcase()
H A DIt_posix_queue_009.c51 ICUNIT_GOTO_EQUAL(attrget.mq_curmsgs, 0, attrget.mq_curmsgs, EXIT1); in Testcase()
H A DIt_posix_queue_046.c60 ICUNIT_GOTO_EQUAL(mqstat.mq_curmsgs, 5, mqstat.mq_curmsgs, EXIT1); // 5, assert the curmsgs. in Testcase()
H A DIt_posix_queue_044.c61 ICUNIT_GOTO_EQUAL(mqstat2.mq_curmsgs, 0, mqstat2.mq_curmsgs, EXIT1); in Testcase()
/kernel/liteos_a/testsuites/unittest/libc/posix/mqueue/full/
H A DIt_posix_queue_067.cpp58 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()
H A DIt_posix_queue_014.cpp49 ICUNIT_GOTO_EQUAL(attr.mq_curmsgs, 0, attr.mq_curmsgs, EXIT1); in Testcase()
H A DIt_posix_queue_015.cpp52 ICUNIT_GOTO_EQUAL(attrget.mq_curmsgs, 0, attrget.mq_curmsgs, EXIT1); in Testcase()
H A DIt_posix_queue_064.cpp60 ICUNIT_GOTO_EQUAL(mqstat.mq_curmsgs, 5, mqstat.mq_curmsgs, EXIT1); // 5, assert the curmsgs. in Testcase()
/kernel/liteos_m/testsuites/unittest/xts/ipc/msg_queue/
H A Dmq_test.c170 ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no special meaning */
216 ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no special meaning */
286 ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no special meaning */
365 ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /* 1, common data for test, no special meaning */
442 ICUNIT_ASSERT_EQUAL(getAttr.mq_curmsgs, 1, getAttr.mq_curmsgs); /*
[all...]
/kernel/liteos_a/testsuites/unittest/libc/posix/mqueue/smoke/
H A DIt_posix_queue_062.cpp62 ICUNIT_GOTO_EQUAL(mqstat2.mq_curmsgs, 0, mqstat2.mq_curmsgs, EXIT1); in Testcase()
/kernel/linux/linux-5.10/include/uapi/linux/
H A Dmqueue.h32 __kernel_long_t mq_curmsgs; /* number of messages currently queued */ member
/kernel/linux/linux-6.6/include/uapi/linux/
H A Dmqueue.h32 __kernel_long_t mq_curmsgs; /* number of messages currently queued */ member
/kernel/linux/patches/linux-6.6/prebuilts/usr/include/linux/
H A Dmqueue.h28 __kernel_long_t mq_curmsgs; member
/kernel/linux/patches/linux-5.10/prebuilts/usr/include/linux/
H A Dmqueue.h28 __kernel_long_t mq_curmsgs; member
/kernel/linux/patches/linux-4.19/prebuilts/usr/include/linux/
H A Dmqueue.h15 __kernel_long_t mq_curmsgs; member
/kernel/linux/linux-5.10/ipc/
H A Dmqueue.c229 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; /* numbe member
[all...]
/kernel/linux/linux-6.6/ipc/
H A Dmqueue.c227 info->attr.mq_curmsgs++; in msg_insert()
262 if (info->attr.mq_curmsgs) { in msg_get()
266 info->attr.mq_curmsgs = 0; in msg_get()
285 info->attr.mq_curmsgs--; in msg_get()
684 if (info->attr.mq_curmsgs) in mqueue_poll_file()
687 if (info->attr.mq_curmsgs < info->attr.mq_maxmsg) in mqueue_poll_file()
791 info->attr.mq_curmsgs == 1) { in __do_notify()
1139 if (info->attr.mq_curmsgs == info->attr.mq_maxmsg) { in do_mq_timedsend()
1243 if (info->attr.mq_curmsgs == 0) { in do_mq_timedreceive()
1526 compat_long_t mq_curmsgs; /* numbe member
[all...]
/kernel/liteos_m/kal/libc/newlib/porting/include/
H A Dmqueue.h44 long mq_flags, mq_maxmsg, mq_msgsize, mq_curmsgs, _unused[4]; member
/kernel/liteos_a/compat/posix/include/
H A Dmqueue.h124 long mq_curmsgs; /**< Number of messages in the current message queue */ member
144 * <li>The "mq_curmsgs" member of the mq_attr structure is not supported.</li>
320 * <li> The mq_maxmsg, mq_msgsize, and mq_curmsgs attributes are not modified
/kernel/linux/linux-5.10/tools/testing/selftests/mqueue/
H A Dmq_perf_tests.c307 printf("\t\tmq_curmsgs:\t\t\t%lu\n", result.mq_curmsgs); in open_queue()
/kernel/linux/linux-6.6/tools/testing/selftests/mqueue/
H A Dmq_perf_tests.c307 printf("\t\tmq_curmsgs:\t\t\t%lu\n", result.mq_curmsgs); in open_queue()
/kernel/liteos_m/kal/posix/src/
H A Dmqueue.c393 mqAttr->mq_curmsgs = mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ]; in OsMqGetAttr()
/kernel/liteos_a/compat/posix/src/
H A Dmqueue.c633 mqAttr->mq_curmsgs = mqueueCB->mqcb->readWriteableCnt[OS_QUEUE_READ]; in OsMqGetAttr()
/kernel/linux/linux-5.10/kernel/
H A Dauditsc.c1316 "mq_msgsize=%ld mq_curmsgs=%ld", in show_special()
1321 context->mq_open.attr.mq_curmsgs); in show_special()
1342 "mq_curmsgs=%ld ", in show_special()
1345 attr->mq_msgsize, attr->mq_curmsgs); in show_special()

Completed in 18 milliseconds

12