| /kernel/liteos_m/kal/libc/newlib/porting/include/ |
| D | mqueue.h | 41 typedef int mqd_t; typedef
49 int mq_close(mqd_t personal);
50 int mq_getattr(mqd_t personal, struct mq_attr *attr);
51 mqd_t mq_open(const char *mqName, int openFlag, ...);
52 ssize_t mq_receive(mqd_t personal, char *msg_ptr, size_t msg_len, unsigned *msg_prio);
53 int mq_send(mqd_t personal, const char *msg_ptr, size_t msg_len, unsigned msg_prio);
54 int mq_setattr(mqd_t personal, const struct mq_attr *__restrict new, struct mq_attr *__restrict old…
55 ssize_t mq_timedreceive(mqd_t personal, char *__restrict msg, size_t msg_len, \
57 int mq_timedsend(mqd_t personal, const char *msg, size_t msg_len, unsigned msg_prio, const struct t…
|
| /kernel/liteos_m/testsuites/unittest/posix/src/mqueue/ |
| D | mqueue_func_test.c | 105 mqd_t mqueue;
113 ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1);
145 mqd_t queue, queueOther;
150 ICUNIT_GOTO_NOT_EQUAL(queue, (mqd_t)-1, queue, EXIT1);
153 ICUNIT_GOTO_EQUAL(queueOther, (mqd_t)-1, queueOther, EXIT1);
173 mqd_t queue;
212 ICUNIT_TRACK_EQUAL(queue, (mqd_t)-1, queue);
214 if (queue != (mqd_t)-1) {
242 mqd_t queue;
251 ICUNIT_TRACK_EQUAL(queue, (mqd_t)-1, queue);
[all …]
|
| /kernel/liteos_a/compat/posix/include/ |
| D | mqueue.h | 131 typedef UINTPTR mqd_t; typedef
174 extern mqd_t mq_open(const char *mqName, int openFlag, ...);
203 extern int mq_close(mqd_t personal);
274 extern int mq_send(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio);
311 extern ssize_t mq_receive(mqd_t personal, char *msg, size_t msgLen, unsigned int *msgPrio);
342 extern int mq_getsetattr(mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *MqOldAttr…
384 extern int mq_timedsend(mqd_t personal, const char *msg, size_t msgLen,
426 extern ssize_t mq_timedreceive(mqd_t personal, char *msg, size_t msgLen,
430 extern int OsMqNotify(mqd_t personal, const struct sigevent *sigev);
|
| /kernel/liteos_a/testsuites/unittest/libc/posix/mqueue/full/ |
| D | It_posix_queue_145.cpp | 36 mqd_t mqueue1 = *(mqd_t *)mq; in PthreadF01()
58 mqd_t mqueue2 = *(mqd_t *)mq; in PthreadF02()
79 mqd_t mqueue1 = *(mqd_t *)mq; in PthreadF03()
100 mqd_t mqueue2 = *(mqd_t *)mq; in PthreadF04()
124 mqd_t mqueue1 = 0, mqueue2 = 0; in Testcase()
143 ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT); in Testcase()
146 ICUNIT_GOTO_NOT_EQUAL(mqueue2, (mqd_t)-1, mqueue2, EXIT1); in Testcase()
|
| D | It_posix_queue_127.cpp | 39 mqd_t msgQId1; in Testcase()
40 mqd_t msgQId2; in Testcase()
47 ICUNIT_GOTO_NOT_EQUAL(msgQId1, (mqd_t)-1, msgQId1, EXIT1); in Testcase()
50 ICUNIT_GOTO_NOT_EQUAL(msgQId2, (mqd_t)-1, msgQId2, EXIT2); in Testcase()
|
| D | It_posix_queue_057.cpp | 37 mqd_t mqueue; in Testcase()
48 ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1); in Testcase()
50 mqueue = (mqd_t)((UINTPTR)mqueue + PER_ADDED_VALUE); in Testcase()
55 ret = mq_close((mqd_t)((UINTPTR)mqueue - PER_ADDED_VALUE)); in Testcase()
|
| D | It_posix_queue_106.cpp | 38 mqd_t mqueue; in Testcase()
49 ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT1); in Testcase()
51 mqueue = (mqd_t)((UINTPTR)mqueue + PER_ADDED_VALUE); in Testcase()
58 ret = mq_close((mqd_t)((UINTPTR)mqueue - PER_ADDED_VALUE)); in Testcase()
|
| D | It_posix_queue_156.cpp | 37 mqd_t msgQIdA; // Define queue ID for queue A in Testcase()
38 mqd_t msgQIdB; // Define queue ID for queue B in Testcase()
51 ICUNIT_ASSERT_NOT_EQUAL(msgQIdA, (mqd_t)-1, msgQIdA); in Testcase()
57 ICUNIT_ASSERT_NOT_EQUAL(msgQIdB, (mqd_t)-1, msgQIdB); in Testcase()
|
| D | It_posix_queue_073.cpp | 39 mqd_t mqueue1; in Testcase()
40 mqd_t mqueue2; in Testcase()
54 ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT); in Testcase()
57 ICUNIT_GOTO_NOT_EQUAL(mqueue2, (mqd_t)-1, mqueue2, EXIT1); in Testcase()
|
| D | It_posix_queue_159.cpp | 40 mqd_t mqueue[LOSCFG_BASE_IPC_QUEUE_CONFIG + 1]; in Testcase()
51 ICUNIT_GOTO_NOT_EQUAL(mqueue[i], (mqd_t)-1, mqueue[i], EXIT); in Testcase()
58 ICUNIT_GOTO_EQUAL(mqueue[i], (mqd_t)(-1), mqueue[i], EXIT); in Testcase()
60 mqueue[i] = (mqd_t)(-1); in Testcase()
|
| /kernel/liteos_m/kal/posix/src/ |
| D | mqueue.c | 262 mqd_t mq_open(const char *mqName, int openFlag, ...) in mq_open()
272 return (mqd_t)-1; in mq_open()
310 return (mqd_t)privateMqPersonal; in mq_open()
313 int mq_close(mqd_t personal) in mq_close()
320 if ((personal == (mqd_t)NULL) || (personal == (mqd_t)-1)) { in mq_close()
372 int OsMqGetAttr(mqd_t personal, struct mq_attr *mqAttr) in OsMqGetAttr()
399 int OsMqSetAttr(mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *mqOldAttr) in OsMqSetAttr()
417 (VOID)OsMqGetAttr((mqd_t)privateMqPersonal, mqOldAttr); in OsMqSetAttr()
428 static int MqGetSetAttr(mqd_t mqd, const struct mq_attr *new, struct mq_attr *old) in MqGetSetAttr()
436 int mq_getattr(mqd_t mqd, struct mq_attr *attr) in mq_getattr()
[all …]
|
| /kernel/liteos_a/syscall/ |
| D | ipc_syscall.c | 47 (id) = (mqd_t)sysFd; \
55 (id) = (mqd_t)(-EMFILE); \
57 (id) = (mqd_t)procFd; \
61 mqd_t SysMqOpen(const char *mqName, int openFlag, mode_t mode, struct mq_attr *attr) in SysMqOpen()
63 mqd_t ret; in SysMqOpen()
73 return (mqd_t)-get_errno(); in SysMqOpen()
80 int SysMqClose(mqd_t personal) in SysMqClose()
94 int SysMqNotify(mqd_t personal, const struct sigevent *sigev) in SysMqNotify()
106 int SysMqGetSetAttr(mqd_t mqd, const struct mq_attr *new, struct mq_attr *old) in SysMqGetSetAttr()
150 int SysMqTimedSend(mqd_t personal, const char *msg, size_t msgLen, unsigned int msgPrio, in SysMqTimedSend()
[all …]
|
| /kernel/liteos_m/testsuites/unittest/xts/ipc/msg_queue/ |
| D | mq_exp_test.c | 53 mqd_t queue;
64 …ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); /* -1, common data for test, no special meaning …
96 mqd_t queue;
107 …ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); /* -1, common data for test, no special meaning …
133 mqd_t queue;
143 …ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); /* -1, common data for test, no special meaning …
164 mqd_t queue;
174 …ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); /* -1, common data for test, no special meaning …
198 …ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); /* -1, common data for test, no special meaning …
226 mqd_t queue;
[all …]
|
| D | mq_test.c | 53 mqd_t queue;
65 …ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); /* -1, common data for test, no special meaning …
95 mqd_t queue;
109 …ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); /* -1, common data for test, no special meaning …
143 mqd_t queue;
157 …ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); /* -1, common data for test, no special meaning …
191 mqd_t queue;
235 mqd_t queue; in PthreadCom()
240 queue = (mqd_t)arg; in PthreadCom()
261 mqd_t queue;
[all …]
|
| /kernel/liteos_m/testsuites/sample/posix/mqueue/ |
| D | It_posix_queue_010.c | 36 mqd_t mqueue1; in Testcase()
37 mqd_t mqueue2; in Testcase()
44 ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT1); in Testcase()
47 ICUNIT_GOTO_EQUAL(mqueue2, (mqd_t)-1, mqueue2, EXIT2); in Testcase()
|
| D | It_posix_queue_005.c | 36 mqd_t roqueue; in Testcase()
37 mqd_t roqueue2; in Testcase()
44 ICUNIT_GOTO_NOT_EQUAL(roqueue, (mqd_t)-1, roqueue, EXIT); in Testcase()
47 ICUNIT_GOTO_NOT_EQUAL(roqueue2, (mqd_t)-1, roqueue2, EXIT1); in Testcase()
|
| D | It_posix_queue_003.c | 38 mqd_t mqueue1; in Testcase()
39 mqd_t mqueue2; in Testcase()
49 ICUNIT_ASSERT_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1); in Testcase()
52 ICUNIT_ASSERT_NOT_EQUAL(mqueue2, (mqd_t)-1, mqueue2); in Testcase()
|
| D | It_posix_queue_040.c | 36 mqd_t mqueue; in Testcase()
47 ICUNIT_GOTO_NOT_EQUAL(mqueue, (mqd_t)-1, mqueue, EXIT2); in Testcase()
49 mqueue = (mqd_t)((UINTPTR)mqueue + PER_ADDED_VALUE); in Testcase()
54 ret = mq_close((mqd_t)((UINTPTR)mqueue - PER_ADDED_VALUE)); in Testcase()
|
| D | It_posix_queue_007.c | 37 mqd_t mqueue1; in Testcase()
38 mqd_t mqueue2; in Testcase()
45 ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT1); in Testcase()
51 ICUNIT_GOTO_NOT_EQUAL(mqueue2, (mqd_t)-1, mqueue2, EXIT2); in Testcase()
|
| D | It_posix_queue_012.c | 38 mqd_t mqueue1; in Testcase()
39 mqd_t mqueue2; in Testcase()
50 ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT1); in Testcase()
59 ICUNIT_GOTO_NOT_EQUAL(mqueue1, (mqd_t)-1, mqueue1, EXIT2); in Testcase()
|
| D | It_posix_queue_006.c | 39 mqd_t rdwrqueue; in Testcase()
40 mqd_t rdwrqueue2; in Testcase()
50 ICUNIT_GOTO_NOT_EQUAL(rdwrqueue, (mqd_t)-1, rdwrqueue, EXIT); in Testcase()
59 ICUNIT_GOTO_NOT_EQUAL(rdwrqueue2, (mqd_t)-1, rdwrqueue2, EXIT1); in Testcase()
|
| D | It_posix_queue_017.c | 36 mqd_t queue; in Testcase()
43 if (queue == (mqd_t)-1) { in Testcase()
44 ICUNIT_ASSERT_NOT_EQUAL(queue, (mqd_t)-1, queue); in Testcase()
|
| /kernel/liteos_a/testsuites/unittest/process/plimits/smoke/ |
| D | It_process_plimits_ipc_013.cpp | 46 static int FreeResource(mqd_t *mqueue, int index, char *mqname) in FreeResource()
73 mqd_t mqueue[g_buff]; in ItProcessPlimitsIpc013()
96 ASSERT_NE(mqueue[index], (mqd_t)-1); in ItProcessPlimitsIpc013()
103 ASSERT_EQ(mqueue[index], (mqd_t)-1); in ItProcessPlimitsIpc013()
|
| D | It_process_plimits_ipc_006.cpp | 47 static int FreeResource(mqd_t *mqueue, int index, char *mqname) in FreeResource()
77 mqd_t mqueue[g_readLen]; in ItProcessPlimitsIpc006()
97 ASSERT_NE(mqueue[index], (mqd_t)-1); in ItProcessPlimitsIpc006()
103 ASSERT_EQ(mqueue[index], (mqd_t)-1); in ItProcessPlimitsIpc006()
|
| /kernel/liteos_a/compat/posix/src/ |
| D | mqueue.c | 308 STATIC struct mqpersonal *MqGetPrivDataBuff(mqd_t personal) in MqGetPrivDataBuff()
346 STATIC VOID MqFreeSysFd(mqd_t personal) in MqFreeSysFd()
364 privateMqPersonal = MqGetPrivDataBuff((mqd_t)sysFd); in MqueueRefer()
504 mqd_t mq_open(const char *mqName, int openFlag, ...) in mq_open()
512 mqd_t mqFd = -1; in mq_open()
516 return (mqd_t)-1; in mq_open()
561 mqFd = (mqd_t)sysFd; in mq_open()
568 int mq_close(mqd_t personal) in mq_close()
602 int OsMqGetAttr(mqd_t personal, struct mq_attr *mqAttr) in OsMqGetAttr()
633 int OsMqSetAttr(mqd_t personal, const struct mq_attr *mqSetAttr, struct mq_attr *mqOldAttr) in OsMqSetAttr()
[all …]
|