sharpshooter

Nov 2, 2021

Changes in this version

+ const STATUS_CLOSEING1

+ const STATUS_CLOSEING2

+ const STATUS_CLOSEING3

+ const STATUS_NONE

+ const STATUS_NORMAL

+ const STATUS_SECONDHANDSHACK

+ const STATUS_THIRDHANDSHACK

+ var RCVAMMOBAGEMPTY = make([]*protocol.Ammo, DEFAULT_INIT_RECEWIND)

type Sniper

+ func (s *Sniper) CleanStatistics()

+ func (s *Sniper) Debug()

+ func (s *Sniper) OpenStaTraffic()

+ func (s *Sniper) SetPackageSize(size int64)

+ func (s *Sniper) TrafficStatistics() Statistics

+ type Statistics struct

+ EffectivePacket int64

+ EffectiveTraffic int64

+ RTO int64

+ RTT int64

+ ReceiveWin int64

+ SendWin int64

+ TotalPacket int64

+ TotalTraffic int64

Feb 6, 2021

Changes in this version

+ type TimedSched struct

+ var SystemTimedSched *TimedSched = NewTimedSched(runtime.NumCPU())

+ func NewTimedSched(parallel int) *TimedSched

+ func (ts *TimedSched) Close()

+ func (ts *TimedSched) Put(f func(), deadline time.Time)

Dec 14, 2020

Changes in this version

+ const DEFAULT_HEAD_SIZE

+ const DEFAULT_INIT_DELAY_ACK

+ const DEFAULT_INIT_HANDSHACK_TIMEOUT

+ const DEFAULT_INIT_HEALTHCHECK_TIMEOUT_TRY_COUNT

+ const DEFAULT_INIT_HEALTHTICKER

+ const DEFAULT_INIT_INTERVAL

+ const DEFAULT_INIT_PACKSIZE

+ const DEFAULT_INIT_RECEWIND

+ const DEFAULT_INIT_RTO_UNIT

+ const DEFAULT_INIT_SENDWIND

+ var CLOSEERROR = errors.New("the connection is closed")

+ var HEALTHTIMEOUTERROR = errors.New("health monitor timeout ")

+ var TIMEOUERROR = errors.New("i/o timeout")

+ func Dial(addr string) (net.Conn, error)

+ func Listen(addr string) (*headquarters, error)

+ func NewHeadquarters() *headquarters

+ type Sniper struct

+ func NewSniper(conn *net.UDPConn, aim *net.UDPAddr) *Sniper

+ func (s *Sniper) Close() error

+ func (s *Sniper) FlowStatistics() (total int64, effective int64)

+ func (s *Sniper) LocalAddr() net.Addr

+ func (s *Sniper) OpenFec(dataShards, parShards int)

+ func (s *Sniper) OpenStaFlow()

+ func (s *Sniper) Read(b []byte) (n int, err error)

+ func (s *Sniper) RemoteAddr() net.Addr

+ func (s *Sniper) SetDeadline(t time.Time) error

+ func (s *Sniper) SetInterval(interval int64)

+ func (s *Sniper) SetReadDeadline(t time.Time) error

+ func (s *Sniper) SetRecWin(size int64)

+ func (s *Sniper) SetSendWin(size int32)

+ func (s *Sniper) SetWriteDeadline(t time.Time) error

+ func (s *Sniper) Write(b []byte) (n int, err error)