Lines Matching refs:mqd

92 __mq_close(mqd_t mqd)
96 if (mqd->node != NULL) {
98 __sigev_delete_node(mqd->node);
101 h = mqd->oshandle;
102 free(mqd);
122 __mq_notify(mqd_t mqd, const struct sigevent *evp)
129 if (mqd->node != NULL) {
131 __sigev_delete_node(mqd->node);
132 mqd->node = NULL;
135 return __sys_kmq_notify(mqd->oshandle, evp);
146 sn = __sigev_alloc(SI_MESGQ, evp, mqd->node, 1);
152 sn->sn_id = mqd->oshandle;
156 if (mqd->node != NULL)
157 __sigev_delete_node(mqd->node);
158 mqd->node = sn;
160 ret = __sys_kmq_notify(mqd->oshandle, &ev);
166 __mq_getattr(mqd_t mqd, struct mq_attr *attr)
169 return __sys_kmq_setattr(mqd->oshandle, NULL, attr);
173 __mq_setattr(mqd_t mqd, const struct mq_attr *newattr, struct mq_attr *oldattr)
176 return __sys_kmq_setattr(mqd->oshandle, newattr, oldattr);
180 __mq_timedreceive(mqd_t mqd, char *buf, size_t len,
184 return __sys_kmq_timedreceive(mqd->oshandle, buf, len, prio, timeout);
188 __mq_timedreceive_cancel(mqd_t mqd, char *buf, size_t len,
194 ret = __sys_kmq_timedreceive(mqd->oshandle, buf, len, prio, timeout);
200 __mq_receive(mqd_t mqd, char *buf, size_t len, unsigned *prio)
203 return __sys_kmq_timedreceive(mqd->oshandle, buf, len, prio, NULL);
207 __mq_receive_cancel(mqd_t mqd, char *buf, size_t len, unsigned *prio)
212 ret = __sys_kmq_timedreceive(mqd->oshandle, buf, len, prio, NULL);
217 __mq_timedsend(mqd_t mqd, char *buf, size_t len,
221 return __sys_kmq_timedsend(mqd->oshandle, buf, len, prio, timeout);
225 __mq_timedsend_cancel(mqd_t mqd, char *buf, size_t len,
231 ret = __sys_kmq_timedsend(mqd->oshandle, buf, len, prio, timeout);
237 __mq_send(mqd_t mqd, char *buf, size_t len, unsigned prio)
240 return __sys_kmq_timedsend(mqd->oshandle, buf, len, prio, NULL);
245 __mq_send_cancel(mqd_t mqd, char *buf, size_t len, unsigned prio)
250 ret = __sys_kmq_timedsend(mqd->oshandle, buf, len, prio, NULL);
264 mq_getfd_np(mqd_t mqd)
267 return (mqd->oshandle);