Function receive

pkg/sentry/syscalls/linux/sys_msgqueue.go:108–121

receive returns a message from the queue with the given ID. If msgCopy is true, a message is copied from the queue without being removed. Otherwise, a message is removed from the queue and returned.

(t *kernel.Task, id ipc.ID, mType int64, maxSize uint64, flags int32)

// true, a message is copied from the queue without being removed. Otherwise,
// a message is removed from the queue and returned.
func receive(t *kernel.Task, id ipc.ID, mType int64, maxSize uint64, flags int32) (*msgqueue.Message, error) {
	if flags&linux.MSG_COPY != 0 {
		if flags&(linux.IPC_NOWAIT|linux.MSG_EXCEPT) != linux.IPC_NOWAIT {
			return nil, linuxerr.EINVAL
		}
	}

	queue, err := t.IPCNamespace().MsgqueueRegistry().FindByID(id)
	if err != nil {
		return nil, err
	}
	pid := int32(t.ThreadGroup().ID())
	return queue.Receive(t, mType, maxSize, flags, pid)
}

// Msgctl implements msgctl(2).
func Msgctl(t *kernel.Task, sysno uintptr, args arch.SyscallArguments) (uintptr, *kernel.SyscallControl, error) {