1 use std::ffi::CString;
2 use std::str;
3
4 use nix::errno::Errno;
5 use nix::mqueue::{mq_open, mq_close, mq_send, mq_receive, mq_attr_member_t};
6 use nix::mqueue::{MqAttr, MQ_OFlag};
7 use nix::sys::stat::Mode;
8
9 #[test]
test_mq_send_and_receive()10 fn test_mq_send_and_receive() {
11 const MSG_SIZE: mq_attr_member_t = 32;
12 let attr = MqAttr::new(0, 10, MSG_SIZE, 0);
13 let mq_name= &CString::new(b"/a_nix_test_queue".as_ref()).unwrap();
14
15 let oflag0 = MQ_OFlag::O_CREAT | MQ_OFlag::O_WRONLY;
16 let mode = Mode::S_IWUSR | Mode::S_IRUSR | Mode::S_IRGRP | Mode::S_IROTH;
17 let r0 = mq_open(mq_name, oflag0, mode, Some(&attr));
18 if let Err(Errno::ENOSYS) = r0 {
19 println!("message queues not supported or module not loaded?");
20 return;
21 };
22 let mqd0 = r0.unwrap();
23 let msg_to_send = "msg_1";
24 mq_send(mqd0, msg_to_send.as_bytes(), 1).unwrap();
25
26 let oflag1 = MQ_OFlag::O_CREAT | MQ_OFlag::O_RDONLY;
27 let mqd1 = mq_open(mq_name, oflag1, mode, Some(&attr)).unwrap();
28 let mut buf = [0u8; 32];
29 let mut prio = 0u32;
30 let len = mq_receive(mqd1, &mut buf, &mut prio).unwrap();
31 assert_eq!(prio, 1);
32
33 mq_close(mqd1).unwrap();
34 mq_close(mqd0).unwrap();
35 assert_eq!(msg_to_send, str::from_utf8(&buf[0..len]).unwrap());
36 }
37
38
39 #[test]
40 #[cfg(not(any(target_os = "netbsd")))]
test_mq_getattr()41 fn test_mq_getattr() {
42 use nix::mqueue::mq_getattr;
43 const MSG_SIZE: mq_attr_member_t = 32;
44 let initial_attr = MqAttr::new(0, 10, MSG_SIZE, 0);
45 let mq_name = &CString::new(b"/attr_test_get_attr".as_ref()).unwrap();
46 let oflag = MQ_OFlag::O_CREAT | MQ_OFlag::O_WRONLY;
47 let mode = Mode::S_IWUSR | Mode::S_IRUSR | Mode::S_IRGRP | Mode::S_IROTH;
48 let r = mq_open(mq_name, oflag, mode, Some(&initial_attr));
49 if let Err(Errno::ENOSYS) = r {
50 println!("message queues not supported or module not loaded?");
51 return;
52 };
53 let mqd = r.unwrap();
54
55 let read_attr = mq_getattr(mqd).unwrap();
56 assert_eq!(read_attr, initial_attr);
57 mq_close(mqd).unwrap();
58 }
59
60 // FIXME: Fix failures for mips in QEMU
61 #[test]
62 #[cfg(not(any(target_os = "netbsd")))]
63 #[cfg_attr(any(target_arch = "mips", target_arch = "mips64"), ignore)]
test_mq_setattr()64 fn test_mq_setattr() {
65 use nix::mqueue::{mq_getattr, mq_setattr};
66 const MSG_SIZE: mq_attr_member_t = 32;
67 let initial_attr = MqAttr::new(0, 10, MSG_SIZE, 0);
68 let mq_name = &CString::new(b"/attr_test_get_attr".as_ref()).unwrap();
69 let oflag = MQ_OFlag::O_CREAT | MQ_OFlag::O_WRONLY;
70 let mode = Mode::S_IWUSR | Mode::S_IRUSR | Mode::S_IRGRP | Mode::S_IROTH;
71 let r = mq_open(mq_name, oflag, mode, Some(&initial_attr));
72 if let Err(Errno::ENOSYS) = r {
73 println!("message queues not supported or module not loaded?");
74 return;
75 };
76 let mqd = r.unwrap();
77
78 let new_attr = MqAttr::new(0, 20, MSG_SIZE * 2, 100);
79 let old_attr = mq_setattr(mqd, &new_attr).unwrap();
80 assert_eq!(old_attr, initial_attr);
81
82 let new_attr_get = mq_getattr(mqd).unwrap();
83 // The following tests make sense. No changes here because according to the Linux man page only
84 // O_NONBLOCK can be set (see tests below)
85 assert_ne!(new_attr_get, new_attr);
86
87 let new_attr_non_blocking = MqAttr::new(MQ_OFlag::O_NONBLOCK.bits() as mq_attr_member_t, 10, MSG_SIZE, 0);
88 mq_setattr(mqd, &new_attr_non_blocking).unwrap();
89 let new_attr_get = mq_getattr(mqd).unwrap();
90
91 // now the O_NONBLOCK flag has been set
92 assert_ne!(new_attr_get, initial_attr);
93 assert_eq!(new_attr_get, new_attr_non_blocking);
94 mq_close(mqd).unwrap();
95 }
96
97 // FIXME: Fix failures for mips in QEMU
98 #[test]
99 #[cfg(not(any(target_os = "netbsd")))]
100 #[cfg_attr(any(target_arch = "mips", target_arch = "mips64"), ignore)]
test_mq_set_nonblocking()101 fn test_mq_set_nonblocking() {
102 use nix::mqueue::{mq_getattr, mq_set_nonblock, mq_remove_nonblock};
103 const MSG_SIZE: mq_attr_member_t = 32;
104 let initial_attr = MqAttr::new(0, 10, MSG_SIZE, 0);
105 let mq_name = &CString::new(b"/attr_test_get_attr".as_ref()).unwrap();
106 let oflag = MQ_OFlag::O_CREAT | MQ_OFlag::O_WRONLY;
107 let mode = Mode::S_IWUSR | Mode::S_IRUSR | Mode::S_IRGRP | Mode::S_IROTH;
108 let r = mq_open(mq_name, oflag, mode, Some(&initial_attr));
109 if let Err(Errno::ENOSYS) = r {
110 println!("message queues not supported or module not loaded?");
111 return;
112 };
113 let mqd = r.unwrap();
114 mq_set_nonblock(mqd).unwrap();
115 let new_attr = mq_getattr(mqd);
116 assert_eq!(new_attr.unwrap().flags(), MQ_OFlag::O_NONBLOCK.bits() as mq_attr_member_t);
117 mq_remove_nonblock(mqd).unwrap();
118 let new_attr = mq_getattr(mqd);
119 assert_eq!(new_attr.unwrap().flags(), 0);
120 mq_close(mqd).unwrap();
121 }
122
123 #[test]
124 #[cfg(not(any(target_os = "netbsd")))]
test_mq_unlink()125 fn test_mq_unlink() {
126 use nix::mqueue::mq_unlink;
127 const MSG_SIZE: mq_attr_member_t = 32;
128 let initial_attr = MqAttr::new(0, 10, MSG_SIZE, 0);
129 let mq_name_opened = &CString::new(b"/mq_unlink_test".as_ref()).unwrap();
130 let mq_name_not_opened = &CString::new(b"/mq_unlink_test".as_ref()).unwrap();
131 let oflag = MQ_OFlag::O_CREAT | MQ_OFlag::O_WRONLY;
132 let mode = Mode::S_IWUSR | Mode::S_IRUSR | Mode::S_IRGRP | Mode::S_IROTH;
133 let r = mq_open(mq_name_opened, oflag, mode, Some(&initial_attr));
134 if let Err(Errno::ENOSYS) = r {
135 println!("message queues not supported or module not loaded?");
136 return;
137 };
138 let mqd = r.unwrap();
139
140 let res_unlink = mq_unlink(mq_name_opened);
141 assert_eq!(res_unlink, Ok(()) );
142
143 let res_unlink_not_opened = mq_unlink(mq_name_not_opened);
144 assert_eq!(res_unlink_not_opened, Err(Errno::ENOENT) );
145
146 mq_close(mqd).unwrap();
147 let res_unlink_after_close = mq_unlink(mq_name_opened);
148 assert_eq!(res_unlink_after_close, Err(Errno::ENOENT) );
149 }
150