Versions in this module Expand all Collapse all v1 v1.0.1 Apr 30, 2024 Changes in this version + func NewFileDescription(ep transport.Endpoint, stype linux.SockType, flags uint32, ns *inet.Namespace, ...) (*vfs.FileDescription, error) + func NewSockfsFile(t *kernel.Task, ep transport.Endpoint, stype linux.SockType) (*vfs.FileDescription, *syserr.Error) + type EndpointReader struct + Control transport.ControlMessages + ControlTrunc bool + Creds bool + Ctx context.Context + Endpoint transport.Endpoint + From transport.Address + MsgSize int64 + Notify func() + NumRights int + Peek bool + UnusedRights []transport.RightsControlMessage + func (r *EndpointReader) ReadToBlocks(dsts safemem.BlockSeq) (uint64, error) + func (r *EndpointReader) Truncate() error + type EndpointWriter struct + Control transport.ControlMessages + Ctx context.Context + Endpoint transport.Endpoint + Notify func() + To transport.BoundEndpoint + func (w *EndpointWriter) WriteFromBlocks(srcs safemem.BlockSeq) (uint64, error) + type Socket struct + func (s *Socket) Accept(t *kernel.Task, peerRequested bool, flags int, blocking bool) (int32, linux.SockAddr, uint32, *syserr.Error) + func (s *Socket) Bind(t *kernel.Task, sockaddr []byte) *syserr.Error + func (s *Socket) Connect(t *kernel.Task, sockaddr []byte, blocking bool) *syserr.Error + func (s *Socket) ConnectedPasscred() bool + func (s *Socket) DecRef(ctx context.Context) + func (s *Socket) Endpoint() transport.Endpoint + func (s *Socket) Epollable() bool + func (s *Socket) EventRegister(e *waiter.Entry) error + func (s *Socket) EventUnregister(e *waiter.Entry) + func (s *Socket) GetPeerName(t *kernel.Task) (linux.SockAddr, uint32, *syserr.Error) + func (s *Socket) GetSockName(t *kernel.Task) (linux.SockAddr, uint32, *syserr.Error) + func (s *Socket) GetSockOpt(t *kernel.Task, level, name int, outPtr hostarch.Addr, outLen int) (marshal.Marshallable, *syserr.Error) + func (s *Socket) Ioctl(ctx context.Context, uio usermem.IO, sysno uintptr, args arch.SyscallArguments) (uintptr, error) + func (s *Socket) Listen(t *kernel.Task, backlog int) *syserr.Error + func (s *Socket) PRead(ctx context.Context, dst usermem.IOSequence, offset int64, ...) (int64, error) + func (s *Socket) PWrite(ctx context.Context, src usermem.IOSequence, offset int64, ...) (int64, error) + func (s *Socket) Passcred() bool + func (s *Socket) Read(ctx context.Context, dst usermem.IOSequence, opts vfs.ReadOptions) (int64, error) + func (s *Socket) Readiness(mask waiter.EventMask) waiter.EventMask + func (s *Socket) RecvMsg(t *kernel.Task, dst usermem.IOSequence, flags int, haveDeadline bool, ...) (n int, msgFlags int, senderAddr linux.SockAddr, senderAddrLen uint32, ...) + func (s *Socket) Release(ctx context.Context) + func (s *Socket) SendMsg(t *kernel.Task, src usermem.IOSequence, to []byte, flags int, ...) (int, *syserr.Error) + func (s *Socket) SetSockOpt(t *kernel.Task, level int, name int, optVal []byte) *syserr.Error + func (s *Socket) Shutdown(t *kernel.Task, how int) *syserr.Error + func (s *Socket) State() uint32 + func (s *Socket) Type() (family int, skType linux.SockType, protocol int) + func (s *Socket) Write(ctx context.Context, src usermem.IOSequence, opts vfs.WriteOptions) (int64, error)
Go to main page