msqptr 155 kern/sysv_msg.c struct msqid_ds msqbuf, *msqptr;
msqptr 169 kern/sysv_msg.c msqptr = &msqids[ix];
msqptr 171 kern/sysv_msg.c if (msqptr->msg_qbytes == 0) {
msqptr 175 kern/sysv_msg.c if (msqptr->msg_perm.seq != IPCID_TO_SEQ(msqid)) {
msqptr 182 kern/sysv_msg.c if ((error = ipcperm(cred, &msqptr->msg_perm, IPC_M)) != 0)
msqptr 185 kern/sysv_msg.c msghdr = msqptr->msg_first;
msqptr 190 kern/sysv_msg.c msqptr->msg_cbytes -= msghdr->msg_ts;
msqptr 191 kern/sysv_msg.c msqptr->msg_qnum--;
msqptr 198 kern/sysv_msg.c if (msqptr->msg_cbytes != 0)
msqptr 200 kern/sysv_msg.c if (msqptr->msg_qnum != 0)
msqptr 203 kern/sysv_msg.c msqptr->msg_qbytes = 0; /* Mark it as free */
msqptr 204 kern/sysv_msg.c wakeup(msqptr);
msqptr 208 kern/sysv_msg.c if ((error = ipcperm(cred, &msqptr->msg_perm, IPC_M)))
msqptr 212 kern/sysv_msg.c if (msqbuf.msg_qbytes > msqptr->msg_qbytes &&
msqptr 225 kern/sysv_msg.c msqptr->msg_perm.uid = msqbuf.msg_perm.uid;
msqptr 226 kern/sysv_msg.c msqptr->msg_perm.gid = msqbuf.msg_perm.gid;
msqptr 227 kern/sysv_msg.c msqptr->msg_perm.mode = (msqptr->msg_perm.mode & ~0777) |
msqptr 229 kern/sysv_msg.c msqptr->msg_qbytes = msqbuf.msg_qbytes;
msqptr 230 kern/sysv_msg.c msqptr->msg_ctime = time_second;
msqptr 234 kern/sysv_msg.c if ((error = ipcperm(cred, &msqptr->msg_perm, IPC_R))) {
msqptr 238 kern/sysv_msg.c error = ds_copyout(msqptr, buf, sizeof(struct msqid_ds));
msqptr 259 kern/sysv_msg.c struct msqid_ds *msqptr = NULL;
msqptr 265 kern/sysv_msg.c msqptr = &msqids[msqid];
msqptr 266 kern/sysv_msg.c if (msqptr->msg_qbytes != 0 &&
msqptr 267 kern/sysv_msg.c msqptr->msg_perm.key == key)
msqptr 276 kern/sysv_msg.c if ((eval = ipcperm(cred, &msqptr->msg_perm, msgflg & 0700 ))) {
msqptr 294 kern/sysv_msg.c msqptr = &msqids[msqid];
msqptr 295 kern/sysv_msg.c if (msqptr->msg_qbytes == 0 &&
msqptr 296 kern/sysv_msg.c (msqptr->msg_perm.mode & MSG_LOCKED) == 0)
msqptr 304 kern/sysv_msg.c msqptr->msg_perm.key = key;
msqptr 305 kern/sysv_msg.c msqptr->msg_perm.cuid = cred->cr_uid;
msqptr 306 kern/sysv_msg.c msqptr->msg_perm.uid = cred->cr_uid;
msqptr 307 kern/sysv_msg.c msqptr->msg_perm.cgid = cred->cr_gid;
msqptr 308 kern/sysv_msg.c msqptr->msg_perm.gid = cred->cr_gid;
msqptr 309 kern/sysv_msg.c msqptr->msg_perm.mode = (msgflg & 0777);
msqptr 311 kern/sysv_msg.c msqptr->msg_perm.seq = (msqptr->msg_perm.seq + 1) & 0x7fff;
msqptr 312 kern/sysv_msg.c msqptr->msg_first = NULL;
msqptr 313 kern/sysv_msg.c msqptr->msg_last = NULL;
msqptr 314 kern/sysv_msg.c msqptr->msg_cbytes = 0;
msqptr 315 kern/sysv_msg.c msqptr->msg_qnum = 0;
msqptr 316 kern/sysv_msg.c msqptr->msg_qbytes = msginfo.msgmnb;
msqptr 317 kern/sysv_msg.c msqptr->msg_lspid = 0;
msqptr 318 kern/sysv_msg.c msqptr->msg_lrpid = 0;
msqptr 319 kern/sysv_msg.c msqptr->msg_stime = 0;
msqptr 320 kern/sysv_msg.c msqptr->msg_rtime = 0;
msqptr 321 kern/sysv_msg.c msqptr->msg_ctime = time_second;
msqptr 329 kern/sysv_msg.c *retval = IXSEQ_TO_IPCID(msqid, msqptr->msg_perm);
msqptr 348 kern/sysv_msg.c struct msqid_ds *msqptr;
msqptr 363 kern/sysv_msg.c msqptr = &msqids[msqid];
msqptr 364 kern/sysv_msg.c if (msqptr->msg_qbytes == 0) {
msqptr 368 kern/sysv_msg.c if (msqptr->msg_perm.seq != IPCID_TO_SEQ(SCARG(uap, msqid))) {
msqptr 373 kern/sysv_msg.c if ((eval = ipcperm(cred, &msqptr->msg_perm, IPC_W))) {
msqptr 389 kern/sysv_msg.c if (msgsz > msqptr->msg_qbytes) {
msqptr 394 kern/sysv_msg.c if (msqptr->msg_perm.mode & MSG_LOCKED) {
msqptr 398 kern/sysv_msg.c if (msgsz + msqptr->msg_cbytes > msqptr->msg_qbytes) {
msqptr 420 kern/sysv_msg.c if ((msqptr->msg_perm.mode & MSG_LOCKED) != 0) {
msqptr 427 kern/sysv_msg.c msqptr->msg_perm.mode |= MSG_LOCKED;
msqptr 431 kern/sysv_msg.c eval = tsleep(msqptr, (PZERO - 4) | PCATCH,
msqptr 435 kern/sysv_msg.c msqptr->msg_perm.mode &= ~MSG_LOCKED;
msqptr 445 kern/sysv_msg.c if (msqptr->msg_qbytes == 0) {
msqptr 462 kern/sysv_msg.c if (msqptr->msg_perm.mode & MSG_LOCKED)
msqptr 466 kern/sysv_msg.c if (msgsz + msqptr->msg_cbytes > msqptr->msg_qbytes)
msqptr 478 kern/sysv_msg.c if ((msqptr->msg_perm.mode & MSG_LOCKED) != 0)
msqptr 481 kern/sysv_msg.c msqptr->msg_perm.mode |= MSG_LOCKED;
msqptr 526 kern/sysv_msg.c msqptr->msg_perm.mode &= ~MSG_LOCKED;
msqptr 527 kern/sysv_msg.c wakeup(msqptr);
msqptr 538 kern/sysv_msg.c msqptr->msg_perm.mode &= ~MSG_LOCKED;
msqptr 539 kern/sysv_msg.c wakeup(msqptr);
msqptr 566 kern/sysv_msg.c msqptr->msg_perm.mode &= ~MSG_LOCKED;
msqptr 567 kern/sysv_msg.c wakeup(msqptr);
msqptr 582 kern/sysv_msg.c msqptr->msg_perm.mode &= ~MSG_LOCKED;
msqptr 588 kern/sysv_msg.c if (msqptr->msg_qbytes == 0) {
msqptr 590 kern/sysv_msg.c wakeup(msqptr);
msqptr 598 kern/sysv_msg.c if (msqptr->msg_first == NULL) {
msqptr 599 kern/sysv_msg.c msqptr->msg_first = msghdr;
msqptr 600 kern/sysv_msg.c msqptr->msg_last = msghdr;
msqptr 602 kern/sysv_msg.c msqptr->msg_last->msg_next = msghdr;
msqptr 603 kern/sysv_msg.c msqptr->msg_last = msghdr;
msqptr 605 kern/sysv_msg.c msqptr->msg_last->msg_next = NULL;
msqptr 607 kern/sysv_msg.c msqptr->msg_cbytes += msghdr->msg_ts;
msqptr 608 kern/sysv_msg.c msqptr->msg_qnum++;
msqptr 609 kern/sysv_msg.c msqptr->msg_lspid = p->p_pid;
msqptr 610 kern/sysv_msg.c msqptr->msg_stime = time_second;
msqptr 612 kern/sysv_msg.c wakeup(msqptr);
msqptr 634 kern/sysv_msg.c struct msqid_ds *msqptr;
msqptr 650 kern/sysv_msg.c msqptr = &msqids[msqid];
msqptr 651 kern/sysv_msg.c if (msqptr->msg_qbytes == 0) {
msqptr 655 kern/sysv_msg.c if (msqptr->msg_perm.seq != IPCID_TO_SEQ(SCARG(uap, msqid))) {
msqptr 660 kern/sysv_msg.c if ((eval = ipcperm(cred, &msqptr->msg_perm, IPC_R))) {
msqptr 676 kern/sysv_msg.c msghdr = msqptr->msg_first;
msqptr 685 kern/sysv_msg.c if (msqptr->msg_first == msqptr->msg_last) {
msqptr 686 kern/sysv_msg.c msqptr->msg_first = NULL;
msqptr 687 kern/sysv_msg.c msqptr->msg_last = NULL;
msqptr 689 kern/sysv_msg.c msqptr->msg_first = msghdr->msg_next;
msqptr 691 kern/sysv_msg.c if (msqptr->msg_first == NULL)
msqptr 700 kern/sysv_msg.c for (previous = NULL, prev = &msqptr->msg_first;
msqptr 726 kern/sysv_msg.c if (msghdr == msqptr->msg_last) {
msqptr 730 kern/sysv_msg.c &msqptr->msg_first)
msqptr 733 kern/sysv_msg.c msqptr->msg_first =
msqptr 735 kern/sysv_msg.c msqptr->msg_last =
msqptr 740 kern/sysv_msg.c &msqptr->msg_first)
msqptr 743 kern/sysv_msg.c msqptr->msg_last =
msqptr 776 kern/sysv_msg.c eval = tsleep(msqptr, (PZERO - 4) | PCATCH, "msgwait",
msqptr 789 kern/sysv_msg.c if (msqptr->msg_qbytes == 0 ||
msqptr 790 kern/sysv_msg.c msqptr->msg_perm.seq != IPCID_TO_SEQ(SCARG(uap, msqid))) {
msqptr 802 kern/sysv_msg.c msqptr->msg_cbytes -= msghdr->msg_ts;
msqptr 803 kern/sysv_msg.c msqptr->msg_qnum--;
msqptr 804 kern/sysv_msg.c msqptr->msg_lrpid = p->p_pid;
msqptr 805 kern/sysv_msg.c msqptr->msg_rtime = time_second;
msqptr 827 kern/sysv_msg.c wakeup(msqptr);
msqptr 856 kern/sysv_msg.c wakeup(msqptr);
msqptr 868 kern/sysv_msg.c wakeup(msqptr);