Method SendMsg

pkg/sentry/socket/plugin/stack/socket.go:756–795

SendMsg implements socket.Socket.SendMsg.

(t *kernel.Task, src usermem.IOSequence, to []byte, flags int, haveDeadline bool, deadline ktime.Time, controlMessages socket.ControlMessages)

// SendMsg implements socket.Socket.SendMsg.
func (s *socketOperations) SendMsg(t *kernel.Task, src usermem.IOSequence, to []byte, flags int, haveDeadline bool, deadline ktime.Time, controlMessages socket.ControlMessages) (int, *syserr.Error) {
	total := src.NumBytes()
	nonblock := flags & syscall.MSG_DONTWAIT
	sysflags := flags | syscall.MSG_DONTWAIT

	n, err := s.send(t, src, to, sysflags)

	if nonblock != 0 {
		return int(n), syserr.FromError(err)
	}

	var sent int64
	for err == nil || err == linuxerr.ErrWouldBlock {
		if n > 0 {
			src = src.DropFirst64(n)
			sent += n
		}

		if sent == total {
			return int(total), nil
		}

		if haveDeadline {
			err = s.waitEventT(t, waiter.EventOut, deadline)
		} else {
			err = s.waitEvent(t, waiter.EventOut)
		}

		if err != nil {
			if err == linuxerr.ETIMEDOUT {
				err = linuxerr.ErrWouldBlock
			}
			return int(sent), syserr.FromError(err)
		}

		n, err = s.send(t, src, to, sysflags)
	}

	return int(sent), syserr.FromError(err)
}

// Write implements socket.Socket.Write.
func (s *socketOperations) Write(ctx context.Context, src usermem.IOSequence, opts vfs.WriteOptions) (int64, error) {