package sniffer

import "gvisor.dev/gvisor/tools/ioctl_sniffer/sniffer"

Package sniffer parses the output of the ioctl hook.

Index ¶

• func Init() error
• type Connection
• func (c Connection) ReadHookOutput(ctx context.Context) *Results
• func (c *Connection) ReadIoctlProto(ctx context.Context) (*pb.Ioctl, error)
• type Ioctl
• func ParseIoctlOutput(ioctl *pb.Ioctl) (Ioctl, error)
• func (i Ioctl) IsSupported() bool
• func (i Ioctl) String() string
• type Results
• func NewResults() *Results
• func (r *Results) AddUnsupportedIoctl(ioctl Ioctl)
• func (r *Results) HasUnsupportedIoctl() bool
• func (r *Results) Merge(other *Results)
• func (r *Results) String() string
• type Server
• func NewServer() *Server
• func (s *Server) Addr() string
• func (s *Server) AllResults() *Results
• func (s *Server) Listen() error
• func (s *Server) Serve(ctx context.Context) error

Functions ¶

func Init ¶

func Init() error

Init reads from nvproxy and sets up the supported ioctl maps.

Types ¶

type Connection ¶

type Connection struct {
	// contains filtered or unexported fields
}

Connection is a connection to the sniffer hook.

func (Connection) ReadHookOutput ¶

func (c Connection) ReadHookOutput(ctx context.Context) *Results

ReadHookOutput reads the output of the ioctl hook until an EOF is reached.

func (*Connection) ReadIoctlProto ¶

func (c *Connection) ReadIoctlProto(ctx context.Context) (*pb.Ioctl, error)

ReadIoctlProto reads a single ioctl proto from this connection. Our format is:

• 8 byte little endian uint64 containing the size of the proto.
• The proto bytes.

This should match the format in sniffer_bridge.h.

type Ioctl ¶

type Ioctl struct {
	// contains filtered or unexported fields
}

Ioctl contains the parsed ioctl protobuf information.

func ParseIoctlOutput ¶

func ParseIoctlOutput(ioctl *pb.Ioctl) (Ioctl, error)

ParseIoctlOutput parses an ioctl protobuf from the ioctl hook.

func (Ioctl) IsSupported ¶

func (i Ioctl) IsSupported() bool

IsSupported returns true if the ioctl is supported by nvproxy.

func (Ioctl) String ¶

func (i Ioctl) String() string

type Results ¶

type Results struct {
	// contains filtered or unexported fields
}

Results contains the list of unsupported ioctls.

func NewResults ¶

func NewResults() *Results

NewResults creates a new Results object.

func (*Results) AddUnsupportedIoctl ¶

func (r *Results) AddUnsupportedIoctl(ioctl Ioctl)

AddUnsupportedIoctl adds an unsupported ioctl to the results.

func (*Results) HasUnsupportedIoctl ¶

func (r *Results) HasUnsupportedIoctl() bool

HasUnsupportedIoctl returns true if there are any unsupported ioctls.

func (*Results) Merge ¶

func (r *Results) Merge(other *Results)

Merge merges the results from another Results object into this one.

func (*Results) String ¶

func (r *Results) String() string

type Server ¶

type Server struct {
	// contains filtered or unexported fields
}

Server is a server that accepts connections from the sniffer hook. It reads ioctl protos from each connection and sends them to the results channel.

func NewServer ¶

func NewServer() *Server

NewServer creates a new Server.

func (*Server) Addr ¶

func (s *Server) Addr() string

Addr returns the address of the socket.

func (*Server) AllResults ¶

func (s *Server) AllResults() *Results

AllResults blocks until all connections have closed and returns an aggregate of all the results.

func (*Server) Listen ¶

func (s *Server) Listen() error

Listen opens a new socket server.

func (*Server) Serve ¶

func (s *Server) Serve(ctx context.Context) error

Serve opens a new socket server, continually accepts connections from the socket and reads ioctl protos from each connection. It blocks until the context is cancelled.

Source Files ¶

sniffer.go sniffer_bridge.go