pool

Documentation

Index

• Constants
• func FreeBytes(b []byte)
• func NewBytes(size int) []byte
• type Allocator
  • func NewAllocator() *Allocator
  • func (alloc *Allocator) Get(size int) []byte
  • func (alloc *Allocator) Put(buf []byte) error
• type Interface
  • func OpenTunDevice(tunFd int) (*Interface, error)
  • func (tunDev *Interface) Copy(dst io.Writer)
  • func (tunDev *Interface) Run(ctx context.Context)
  • func (tunDev *Interface) Stop()

Constants

const BufSize = 20 * 1024

Functions

func FreeBytes

func FreeBytes(b []byte)

func NewBytes

func NewBytes(size int) []byte

Types

type Allocator

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

Allocator for incoming frames, optimized to prevent overwriting after zeroing

func NewAllocator

func NewAllocator() *Allocator

NewAllocator initiates a []byte allocator for frames less than 65536 bytes, the waste(memory fragmentation) of space allocation is guaranteed to be no more than 50%.

func (*Allocator) Get

func (alloc *Allocator) Get(size int) []byte

Get a []byte from pool with most appropriate cap

func (*Allocator) Put

func (alloc *Allocator) Put(buf []byte) error

Put returns a []byte to pool for future use, which the cap must be exactly 2^n

type Interface

type Interface struct {
	io.ReadWriteCloser
	ReadCh chan []byte
	StopCh chan bool
}

func OpenTunDevice

func OpenTunDevice(tunFd int) (*Interface, error)

func (*Interface) Copy

func (tunDev *Interface) Copy(dst io.Writer)

func (*Interface) Run

func (tunDev *Interface) Run(ctx context.Context)

func (*Interface) Stop

func (tunDev *Interface) Stop()