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 if ((mq = (sysvmsg_queue_t *)zend_fetch_resource(Z_RES_P(queue), "sysvmsg queue", le_sysvmsg)) == NULL) { mq 171 ext/sysvmsg/sysvmsg.c if (msgctl(mq->id, IPC_STAT, &stat) == 0) { mq 191 ext/sysvmsg/sysvmsg.c if (msgctl(mq->id, IPC_SET, &stat) == 0) { mq 203 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq = NULL; mq 212 ext/sysvmsg/sysvmsg.c if ((mq = (sysvmsg_queue_t *)zend_fetch_resource(Z_RES_P(queue), "sysvmsg queue", le_sysvmsg)) == NULL) { mq 216 ext/sysvmsg/sysvmsg.c if (msgctl(mq->id, IPC_STAT, &stat) == 0) { mq 257 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq; mq 263 ext/sysvmsg/sysvmsg.c mq = (sysvmsg_queue_t *) emalloc(sizeof(sysvmsg_queue_t)); mq 265 ext/sysvmsg/sysvmsg.c mq->key = key; mq 266 ext/sysvmsg/sysvmsg.c mq->id = msgget(key, 0); mq 267 ext/sysvmsg/sysvmsg.c if (mq->id < 0) { mq 269 ext/sysvmsg/sysvmsg.c mq->id = msgget(key, IPC_CREAT | IPC_EXCL | perms); mq 270 ext/sysvmsg/sysvmsg.c if (mq->id < 0) { mq 272 ext/sysvmsg/sysvmsg.c efree(mq); mq 276 ext/sysvmsg/sysvmsg.c ZVAL_COPY_VALUE(return_value, zend_list_insert(mq, le_sysvmsg)); mq 285 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq = NULL; mq 291 ext/sysvmsg/sysvmsg.c if ((mq = (sysvmsg_queue_t *)zend_fetch_resource(Z_RES_P(queue), "sysvmsg queue", le_sysvmsg)) == NULL) { mq 295 ext/sysvmsg/sysvmsg.c if (msgctl(mq->id, IPC_RMID, NULL) == 0) { mq 311 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t *mq = NULL; mq 345 ext/sysvmsg/sysvmsg.c if ((mq = (sysvmsg_queue_t *)zend_fetch_resource(Z_RES_P(queue), "sysvmsg queue", le_sysvmsg)) == NULL) { mq 351 ext/sysvmsg/sysvmsg.c result = msgrcv(mq->id, messagebuffer, maxsize, desiredmsgtype, realflags); mq 399 ext/sysvmsg/sysvmsg.c sysvmsg_queue_t * mq = NULL; mq 411 ext/sysvmsg/sysvmsg.c if ((mq = (sysvmsg_queue_t *)zend_fetch_resource(Z_RES_P(queue), "sysvmsg queue", le_sysvmsg)) == NULL) { mq 465 ext/sysvmsg/sysvmsg.c result = msgsnd(mq->id, messagebuffer, message_len, blocking ? 0 : IPC_NOWAIT);