lib/librt/mq.c

105 __mq_close(mqd_t mqd)
109 	if (mqd->node != NULL) {
111 		__sigev_delete_node(mqd->node);
114 	h = mqd->oshandle;
115 	free(mqd);
135 __mq_notify(mqd_t mqd, const struct sigevent *evp)
142 		if (mqd->node != NULL) {
144 			__sigev_delete_node(mqd->node);
145 			mqd->node = NULL;
148 		return __sys_kmq_notify(mqd->oshandle, evp);
159 	sn = __sigev_alloc(SI_MESGQ, evp, mqd->node, 1);
165 	sn->sn_id = mqd->oshandle;
169 	if (mqd->node != NULL)
170 		__sigev_delete_node(mqd->node);
171 	mqd->node = sn;
173 	ret = __sys_kmq_notify(mqd->oshandle, &ev);
179 __mq_getattr(mqd_t mqd, struct mq_attr *attr)
182 	return __sys_kmq_setattr(mqd->oshandle, NULL, attr);
186 __mq_setattr(mqd_t mqd, const struct mq_attr *newattr, struct mq_attr *oldattr)
189 	return __sys_kmq_setattr(mqd->oshandle, newattr, oldattr);
193 __mq_timedreceive(mqd_t mqd, char *buf, size_t len,
197 	return __sys_kmq_timedreceive(mqd->oshandle, buf, len, prio, timeout);
201 __mq_timedreceive_cancel(mqd_t mqd, char *buf, size_t len,
207 	ret = __sys_kmq_timedreceive(mqd->oshandle, buf, len, prio, timeout);
213 __mq_receive(mqd_t mqd, char *buf, size_t len, unsigned *prio)
216 	return __sys_kmq_timedreceive(mqd->oshandle, buf, len, prio, NULL);
220 __mq_receive_cancel(mqd_t mqd, char *buf, size_t len, unsigned *prio)
225 	ret = __sys_kmq_timedreceive(mqd->oshandle, buf, len, prio, NULL);
230 __mq_timedsend(mqd_t mqd, char *buf, size_t len,
234 	return __sys_kmq_timedsend(mqd->oshandle, buf, len, prio, timeout);
238 __mq_timedsend_cancel(mqd_t mqd, char *buf, size_t len,
244 	ret = __sys_kmq_timedsend(mqd->oshandle, buf, len, prio, timeout);
250 __mq_send(mqd_t mqd, char *buf, size_t len, unsigned prio)
253 	return __sys_kmq_timedsend(mqd->oshandle, buf, len, prio, NULL);
258 __mq_send_cancel(mqd_t mqd, char *buf, size_t len, unsigned prio)
263 	ret = __sys_kmq_timedsend(mqd->oshandle, buf, len, prio, NULL);
276 __mq_oshandle(mqd_t mqd)
279 	return (mqd->oshandle);