Home
last modified time | relevance | path

Searched refs:mqd (Results 1 - 25 of 28) sorted by relevance

12

/third_party/rust/crates/nix/test/
H A Dtest_mq.rs71 let mqd = r.unwrap(); in test_mq_getattr()
73 let read_attr = mq_getattr(&mqd).unwrap(); in test_mq_getattr()
75 mq_close(mqd).unwrap(); in test_mq_getattr()
96 let mqd = r.unwrap(); in test_mq_setattr()
99 let old_attr = mq_setattr(&mqd, &new_attr).unwrap(); in test_mq_setattr()
106 let new_attr_get = mq_getattr(&mqd).unwrap(); in test_mq_setattr()
116 mq_setattr(&mqd, &new_attr_non_blocking).unwrap(); in test_mq_setattr()
117 let new_attr_get = mq_getattr(&mqd).unwrap(); in test_mq_setattr()
125 mq_close(mqd).unwrap(); in test_mq_setattr()
146 let mqd in test_mq_set_nonblocking()
[all...]
/third_party/ltp/testcases/kernel/containers/pidns/
H A Dpidns30.c25 static mqd_t mqd = -1; variable
29 static void remove_mqueue(mqd_t mqd) in remove_mqueue() argument
31 if (mqd != -1) in remove_mqueue()
32 SAFE_MQ_CLOSE(mqd); in remove_mqueue()
86 remove_mqueue(mqd); in cleanup()
96 remove_mqueue(mqd); in run()
104 mqd = SAFE_MQ_OPEN(MQNAME, O_RDWR | O_CREAT | O_EXCL, 0777, 0); in run()
110 SAFE_MQ_SEND(mqd, "pippo", 5, 1); in run()
H A Dpidns31.c25 static mqd_t mqd = -1; variable
29 static void remove_mqueue(mqd_t mqd) in remove_mqueue() argument
31 if (mqd != -1) in remove_mqueue()
32 SAFE_MQ_CLOSE(mqd); in remove_mqueue()
66 remove_mqueue(mqd); in cleanup()
79 remove_mqueue(mqd); in run()
90 mqd = SAFE_MQ_OPEN(MQNAME, O_RDWR | O_CREAT | O_EXCL, 0777, NULL); in run()
95 SAFE_MQ_NOTIFY(mqd, &notif); in run()
/third_party/rust/crates/nix/src/
H A Dmqueue.rs218 pub fn mq_getattr(mqd: &MqdT) -> Result<MqAttr> { in mq_getattr()
220 let res = unsafe { libc::mq_getattr(mqd.0, attr.as_mut_ptr()) }; in mq_getattr()
233 pub fn mq_setattr(mqd: &MqdT, newattr: &MqAttr) -> Result<MqAttr> { in mq_setattr()
237 mqd.0, in mq_setattr()
253 pub fn mq_set_nonblock(mqd: &MqdT) -> Result<MqAttr> { in mq_set_nonblock()
254 let oldattr = mq_getattr(mqd)?; in mq_set_nonblock()
261 mq_setattr(mqd, &newattr) in mq_set_nonblock()
267 pub fn mq_remove_nonblock(mqd: &MqdT) -> Result<MqAttr> { in mq_remove_nonblock()
268 let oldattr = mq_getattr(mqd)?; in mq_remove_nonblock()
275 mq_setattr(mqd, in mq_remove_nonblock()
[all...]
/third_party/musl/src/mq/
H A Dmq_notify.c17 mqd_t mqd; member
38 args->err = err = -__syscall(SYS_mq_notify, args->mqd, &sev2); in start()
51 int mq_notify(mqd_t mqd, const struct sigevent *sev) in mq_notify() argument
55 return syscall(SYS_mq_notify, mqd, sev); in mq_notify()
69 return syscall(SYS_mq_notify, mqd, sev); in mq_notify()
74 args.mqd = mqd; in mq_notify()
H A Dmq_timedreceive.c8 ssize_t mq_timedreceive(mqd_t mqd, char *restrict msg, size_t len, unsigned *restrict prio, const struct timespec *restrict at) 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()
H A Dmq_timedsend.c8 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()
H A Dmq_close.c4 int mq_close(mqd_t mqd) in mq_close() argument
7 return syscall(SYS_mqclose, mqd); in mq_close()
9 return syscall(SYS_close, mqd); in mq_close()
H A Dmq_getattr.c4 int mq_getattr(mqd_t mqd, struct mq_attr *attr) in mq_getattr() argument
6 return mq_setattr(mqd, 0, attr); in mq_getattr()
H A Dmq_receive.c3 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()
H A Dmq_setattr.c4 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()
H A Dmq_send.c3 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()
/third_party/ltp/testcases/kernel/containers/mqns/
H A Dmqns_helper.h37 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()
H A Dmqns_01.c22 static mqd_t mqd; variable
61 mqd = SAFE_MQ_OPEN(MQNAME, O_RDWR | O_CREAT | O_EXCL, 0777, NULL); in setup()
66 if (mqd != -1) { in cleanup()
67 SAFE_MQ_CLOSE(mqd); in cleanup()
H A Dmqns_02.c21 static mqd_t mqd; variable
89 mqd = SAFE_MQ_OPEN(MQNAME, O_RDWR | O_CREAT | O_EXCL, 0777, NULL); in setup()
94 if (mqd != -1) { in cleanup()
95 SAFE_MQ_CLOSE(mqd); in cleanup()
H A Dmqns_03.c47 mqd_t mqd; in check_mqueue() local
51 mqd = TST_RETRY_FUNC( in check_mqueue()
54 if (mqd == -1) in check_mqueue()
57 SAFE_MQ_CLOSE(mqd); in check_mqueue()
H A Dmqns_04.c44 mqd_t mqd; in check_mqueue() local
48 mqd = TST_RETRY_FUNC( in check_mqueue()
51 if (mqd == -1) in check_mqueue()
54 SAFE_MQ_CLOSE(mqd); in check_mqueue()
/third_party/musl/porting/linux/user/src/mq/
H A Dmq_notify.c33 int mq_notify(mqd_t mqd, const struct sigevent *sev) in mq_notify() argument
43 return syscall(SYS_mq_notify, mqd, sev); in mq_notify()
67 if (syscall(SYS_mq_notify, mqd, &sev2) < 0) { in mq_notify()
/third_party/musl/porting/liteos_a/user/src/mq/
H A Dmq_close.c4 int mq_close(mqd_t mqd) in mq_close() argument
6 return syscall(SYS_mqclose, mqd); in mq_close()
H A Dmq_notify.c9 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/
H A Dmq_timedreceive_time32.c5 ssize_t __mq_timedreceive_time32(mqd_t mqd, char *restrict msg, size_t len, unsigned *restrict prio, const struct timespec32 *restrict ts32) in __mq_timedreceive_time32() argument
7 return mq_timedreceive(mqd, msg, len, prio, ts32 ? (&(struct timespec){ in __mq_timedreceive_time32()
H A Dmq_timedsend_time32.c5 int __mq_timedsend_time32(mqd_t mqd, const char *msg, size_t len, unsigned prio, const struct timespec32 *ts32) in __mq_timedsend_time32() argument
7 return mq_timedsend(mqd, msg, len, prio, ts32 ? (&(struct timespec){ in __mq_timedsend_time32()
/third_party/rust/crates/libc/src/unix/bsd/freebsdlike/
H A Dmod.rs1741 pub fn mq_close(mqd: ::mqd_t) -> ::c_int; in mq_close()
1742 pub fn mq_getattr(mqd: ::mqd_t, attr: *mut ::mq_attr) -> ::c_int; in mq_getattr()
1743 pub fn mq_notify(mqd: ::mqd_t, notification: *const ::sigevent) -> ::c_int; in mq_notify()
1746 mqd: ::mqd_t, in mq_receive()
1752 mqd: ::mqd_t, in mq_send()
1757 pub fn mq_setattr(mqd: ::mqd_t, newattr: *const ::mq_attr, oldattr: *mut ::mq_attr) -> ::c_int; in mq_setattr()
1759 mqd: ::mqd_t, in mq_timedreceive()
1766 mqd: ::mqd_t, in mq_timedsend()
/third_party/rust/crates/libc/src/vxworks/
H A Dmod.rs1797 pub fn mq_close(mqd: ::mqd_t) -> ::c_int; in mq_close()
1800 mqd: ::mqd_t, in mq_receive()
1806 mqd: ::mqd_t, in mq_timedreceive()
1813 mqd: ::mqd_t, in mq_send()
1819 mqd: ::mqd_t, in mq_timedsend()
1825 pub fn mq_getattr(mqd: ::mqd_t, attr: *mut ::mq_attr) -> ::c_int; in mq_getattr()
1826 pub fn mq_setattr(mqd: ::mqd_t, newattr: *const ::mq_attr, oldattr: *mut ::mq_attr) -> ::c_int; in mq_setattr()
/third_party/rust/crates/libc/src/unix/bsd/netbsdlike/netbsd/
H A Dmod.rs2607 pub fn mq_close(mqd: ::mqd_t) -> ::c_int; in mq_close()
2608 pub fn mq_getattr(mqd: ::mqd_t, attr: *mut ::mq_attr) -> ::c_int; in mq_getattr()
2609 pub fn mq_notify(mqd: ::mqd_t, notification: *const ::sigevent) -> ::c_int; in mq_notify()
2611 mqd: ::mqd_t, in mq_receive()
2617 mqd: ::mqd_t, in mq_send()
2622 pub fn mq_setattr(mqd: ::mqd_t, newattr: *const ::mq_attr, oldattr: *mut ::mq_attr) -> ::c_int; in mq_setattr()
2625 mqd: ::mqd_t, in mq_timedreceive()
2633 mqd: ::mqd_t, in mq_timedsend()

Completed in 25 milliseconds

12