Function newSocket

pkg/sentry/socket/plugin/stack/socket.go:73–108

(t *kernel.Task, family int, skType linux.SockType, protocol int, notifier *Notifier, fd int, flags uint32)

)

func newSocket(t *kernel.Task, family int, skType linux.SockType, protocol int, notifier *Notifier, fd int, flags uint32) (*vfs.FileDescription, *syserr.Error) {
	mnt := t.Kernel().SocketMount()
	d := sockfs.NewDentry(t, mnt)
	defer d.DecRef(t)

	switch skType {
	case syscall.SOCK_STREAM:
	case syscall.SOCK_DGRAM:
	default:
		return nil, syserr.ErrSocketNotSupported
	}

	wq := &waiter.Queue{}
	sop := &socketOperations{
		family:    family,
		fd:        uint32(fd),
		protocol:  protocol,
		skType:    skType,
		eventInfo: plugin.EventInfo{Wq: wq},
	}

	sop.LockFD.Init(&vfs.FileLocks{})

	vfsfd := &sop.vfsfd
	if err := vfsfd.Init(sop, linux.O_RDWR|(flags&linux.O_NONBLOCK), t.Credentials(), mnt, d, &vfs.FileDescriptionOptions{
		DenyPRead:         true,
		DenyPWrite:        true,
		UseDentryMetadata: true,
	}); err != nil {
		return nil, syserr.FromError(err)
	}

	notifier.AddFD(uint32(fd), &sop.eventInfo)

	return vfsfd, nil
}

// Bind implements socket.Socket.Bind.
func (s *socketOperations) Bind(t *kernel.Task, sockaddr []byte) *syserr.Error {