ingress

Nov 14, 2019

Changes in this version

+ func NewFrameBufs(frames ringbuf.EntryList) int

type Dispatcher

+ func NewDispatcher(tio io.ReadWriteCloser) *Dispatcher

Jul 19, 2018

Changes in this version

+ func Init(tio io.ReadWriteCloser) error

+ type Dispatcher struct

+ func (d *Dispatcher) Run() error

+ type FrameBuf struct

+ func NewFrameBuf() *FrameBuf

+ func (fb *FrameBuf) ProcessCompletePkts()

+ func (fb *FrameBuf) Processed() bool

+ func (fb *FrameBuf) Release()

+ func (fb *FrameBuf) Reset()

+ func (fb *FrameBuf) SetProcessed()

+ func (fb *FrameBuf) String() string

+ type ReassemblyList struct

+ func NewReassemblyList(epoch int, capacity int, s sender) *ReassemblyList

+ func (l *ReassemblyList) Insert(frame *FrameBuf)

+ type Worker struct

+ Remote *snet.Addr

+ Ring *ringbuf.Ring

+ SessId mgmt.SessionType

+ func NewWorker(remote *snet.Addr, sessId mgmt.SessionType) *Worker

+ func (w *Worker) Run()

+ func (w *Worker) Stop()