mq 124 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t * mq = (sysvmsg_queue_t *) rsrc->ptr; mq 125 ext/sysvmsg/sysvmsg.c efree(mq); mq 158 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq = NULL; mq 167 ext/sysvmsg/sysvmsg.c ZEND_FETCH_RESOURCE(mq, sysvmsg_queue_t *, &queue, -1, "sysvmsg queue", le_sysvmsg); mq 169 ext/sysvmsg/sysvmsg.c if (msgctl(mq->id, IPC_STAT, &stat) == 0) { mq 189 ext/sysvmsg/sysvmsg.c if (msgctl(mq->id, IPC_SET, &stat) == 0) { mq 201 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq = NULL; mq 210 ext/sysvmsg/sysvmsg.c ZEND_FETCH_RESOURCE(mq, sysvmsg_queue_t *, &queue, -1, "sysvmsg queue", le_sysvmsg); mq 212 ext/sysvmsg/sysvmsg.c if (msgctl(mq->id, IPC_STAT, &stat) == 0) { mq 255 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq; mq 261 ext/sysvmsg/sysvmsg.c mq = (sysvmsg_queue_t *) emalloc(sizeof(sysvmsg_queue_t)); mq 263 ext/sysvmsg/sysvmsg.c mq->key = key; mq 264 ext/sysvmsg/sysvmsg.c mq->id = msgget(key, 0); mq 265 ext/sysvmsg/sysvmsg.c if (mq->id < 0) { mq 267 ext/sysvmsg/sysvmsg.c mq->id = msgget(key, IPC_CREAT | IPC_EXCL | perms); mq 268 ext/sysvmsg/sysvmsg.c if (mq->id < 0) { mq 270 ext/sysvmsg/sysvmsg.c efree(mq); mq 274 ext/sysvmsg/sysvmsg.c RETVAL_RESOURCE(zend_list_insert(mq, le_sysvmsg TSRMLS_CC)); mq 283 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq = NULL; mq 289 ext/sysvmsg/sysvmsg.c ZEND_FETCH_RESOURCE(mq, sysvmsg_queue_t *, &queue, -1, "sysvmsg queue", le_sysvmsg); mq 291 ext/sysvmsg/sysvmsg.c if (msgctl(mq->id, IPC_RMID, NULL) == 0) { mq 307 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq = NULL; mq 341 ext/sysvmsg/sysvmsg.c ZEND_FETCH_RESOURCE(mq, sysvmsg_queue_t *, &queue, -1, "sysvmsg queue", le_sysvmsg); mq 345 ext/sysvmsg/sysvmsg.c result = msgrcv(mq->id, messagebuffer, maxsize, desiredmsgtype, realflags); mq 394 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t * mq = NULL; mq 406 ext/sysvmsg/sysvmsg.c ZEND_FETCH_RESOURCE(mq, sysvmsg_queue_t*, &queue, -1, "sysvmsg queue", le_sysvmsg); mq 455 ext/sysvmsg/sysvmsg.c result = msgsnd(mq->id, messagebuffer, message_len, blocking ? 0 : IPC_NOWAIT);