| /third_party/ltp/testcases/kernel/containers/pidns/ |
| D | pidns31.c | 83 mqd_t mqd; member
93 static void remove_mqueue(mqd_t mqd) in remove_mqueue() argument
95 mq_close(mqd); in remove_mqueue()
103 static void cleanup_resources(int step, mqd_t mqd) in cleanup_resources() argument
110 mq_close(mqd); in cleanup_resources()
114 remove_mqueue(mqd); in cleanup_resources()
119 ltp_syscall(__NR_mq_notify, mqd, NULL); in cleanup_resources()
122 remove_mqueue(mqd); in cleanup_resources()
138 void cleanup_mqueue(int result, int step, mqd_t mqd) in cleanup_mqueue() argument
141 cleanup_resources(step, mqd); in cleanup_mqueue()
[all …]
|
| D | pidns30.c | 83 mqd_t mqd = -1; variable
91 static void remove_mqueue(mqd_t mqd) in remove_mqueue() argument
93 mq_close(mqd); in remove_mqueue()
99 if (mqd != -1) { in cleanup()
100 remove_mqueue(mqd); in cleanup()
111 if (mqd != -1) { in cleanup_child()
112 ltp_syscall(__NR_mq_notify, mqd, NULL); in cleanup_child()
185 mqd = ltp_syscall(__NR_mq_open, mqname, O_RDONLY, 0, NULL); in child_fn()
186 if (mqd == -1) { in child_fn()
195 notif.sigev_value.sival_int = mqd; in child_fn()
[all …]
|
| /third_party/ltp/testcases/kernel/containers/mqns/ |
| D | mqns_01.c | 51 mqd_t mqd; in check_mqueue() local
62 mqd = ltp_syscall(__NR_mq_open, NOSLASH_MQ1, O_RDONLY); in check_mqueue()
63 if (mqd == -1) { in check_mqueue()
72 } else if (mq_close(mqd) < 0) { in check_mqueue()
90 mqd_t mqd; in main() local
108 mqd = ltp_syscall(__NR_mq_open, NOSLASH_MQ1, O_RDWR | O_CREAT | O_EXCL, in main()
110 if (mqd == -1) { in main()
120 mq_close(mqd); in main()
142 if (mq_close(mqd) == -1) { in main()
|
| D | mqns_02.c | 54 mqd_t mqd; in check_mqueue() local
66 mqd = in check_mqueue()
69 if (mqd == -1) { in check_mqueue()
87 if (mq_close(mqd) < 0) { in check_mqueue()
123 mqd_t mqd; in main() local
164 mqd = ltp_syscall(__NR_mq_open, NOSLASH_MQ1, O_RDONLY); in main()
165 if (mqd == -1) { in main()
171 mq_close(mqd); in main()
|
| D | mqns_helper.h | 37 mqd_t mqd; in check_mqns() local
43 mqd = in check_mqns()
45 if (mqd == -1) in check_mqns()
48 mq_close(mqd); in check_mqns()
|
| D | mqns_04.c | 57 mqd_t mqd; in check_mqueue() local
67 mqd = ltp_syscall(__NR_mq_open, NOSLASH_MQ1, O_RDWR | O_CREAT | O_EXCL, in check_mqueue()
69 if (mqd == -1) { in check_mqueue()
74 mq_close(mqd); in check_mqueue()
|
| D | mqns_03.c | 60 mqd_t mqd; in check_mqueue() local
74 mqd = ltp_syscall(__NR_mq_open, NOSLASH_MQ1, O_RDWR | O_CREAT | O_EXCL, in check_mqueue()
76 if (mqd == -1) { in check_mqueue()
81 mq_close(mqd); in check_mqueue()
|
| /third_party/musl/src/mq/ |
| D | mq_timedreceive.c | 8 ssize_t mq_timedreceive(mqd_t mqd, char *restrict msg, size_t len, unsigned *restrict prio, const s… in mq_timedreceive() argument
15 r = __syscall_cp(SYS_mq_timedreceive_time64, mqd, msg, len, prio, in mq_timedreceive()
19 return syscall_cp(SYS_mq_timedreceive, mqd, msg, len, prio, in mq_timedreceive()
22 return syscall_cp(SYS_mq_timedreceive, mqd, msg, len, prio, at); in mq_timedreceive()
|
| D | mq_timedsend.c | 8 int mq_timedsend(mqd_t mqd, const char *msg, size_t len, unsigned prio, const struct timespec *at) in mq_timedsend() argument
15 r = __syscall_cp(SYS_mq_timedsend_time64, mqd, msg, len, prio, in mq_timedsend()
19 return syscall_cp(SYS_mq_timedsend, mqd, msg, len, prio, in mq_timedsend()
22 return syscall_cp(SYS_mq_timedsend, mqd, msg, len, prio, at); in mq_timedsend()
|
| D | mq_notify.c | 32 int mq_notify(mqd_t mqd, const struct sigevent *sev) in mq_notify() argument
42 return syscall(SYS_mq_notify, mqd, sev); in mq_notify()
66 if (syscall(SYS_mq_notify, mqd, &sev2) < 0) { in mq_notify()
|
| D | mq_close.c | 4 int mq_close(mqd_t mqd) in mq_close() argument
6 return syscall(SYS_close, mqd); in mq_close()
|
| D | mq_getattr.c | 4 int mq_getattr(mqd_t mqd, struct mq_attr *attr) in mq_getattr() argument
6 return mq_setattr(mqd, 0, attr); in mq_getattr()
|
| D | mq_setattr.c | 4 int mq_setattr(mqd_t mqd, const struct mq_attr *restrict new, struct mq_attr *restrict old) in mq_setattr() argument
6 return syscall(SYS_mq_getsetattr, mqd, new, old); in mq_setattr()
|
| D | mq_send.c | 3 int mq_send(mqd_t mqd, const char *msg, size_t len, unsigned prio) in mq_send() argument
5 return mq_timedsend(mqd, msg, len, prio, 0); in mq_send()
|
| D | mq_receive.c | 3 ssize_t mq_receive(mqd_t mqd, char *msg, size_t len, unsigned *prio) in mq_receive() argument
5 return mq_timedreceive(mqd, msg, len, prio, 0); in mq_receive()
|
| /third_party/musl/porting/liteos_a/user/src/mq/ |
| D | mq_close.c | 4 int mq_close(mqd_t mqd) in mq_close() argument
6 return syscall(SYS_mqclose, mqd); in mq_close()
|
| D | mq_notify.c | 9 int mq_notify(mqd_t mqd, const struct sigevent *sev) in mq_notify() argument
12 return syscall(SYS_mq_notify, mqd, sev); in mq_notify()
|
| /third_party/musl/compat/time32/ |
| D | mq_timedsend_time32.c | 5 int __mq_timedsend_time32(mqd_t mqd, const char *msg, size_t len, unsigned prio, const struct times… in __mq_timedsend_time32() argument
7 return mq_timedsend(mqd, msg, len, prio, ts32 ? (&(struct timespec){ in __mq_timedsend_time32()
|
| D | mq_timedreceive_time32.c | 5 ssize_t __mq_timedreceive_time32(mqd_t mqd, char *restrict msg, size_t len, unsigned *restrict prio… in __mq_timedreceive_time32() argument
7 return mq_timedreceive(mqd, msg, len, prio, ts32 ? (&(struct timespec){ in __mq_timedreceive_time32()
|