kcp

Aug 7, 2016

Changes in this version

+ const DistroSize

+ const NumDistro

+ var ErrClosedConnection = errors.New("Connection closed.")

+ var ErrClosedListener = errors.New("Listener closed.")

+ var ErrIOTimeout = errors.New("Read/Write timeout")

+ func AllocateBuffer() *alloc.Buffer

type AckSegment

+ Timestamp uint32

+ func (this *AckSegment) PutTimestamp(timestamp uint32)

+ type Buffer struct

+ func NewBuffer() *Buffer

+ func (this *Buffer) Allocate() *alloc.Buffer

+ func (this *Buffer) Free(b *alloc.Buffer)

+ func (this *Buffer) IsEmpty() bool

+ func (this *Buffer) Release()

+ func (this *Buffer) ReleaseBuffer()

type CmdOnlySegment

+ PeerRTO uint32

type Config

+ HeaderConfig internet.AuthenticatorConfig

+ HeaderType string

+ func (this *Config) GetAuthenticator() (internet.Authenticator, error)

+ type RoundTripInfo struct

+ func (this *RoundTripInfo) SmoothedTime() uint32

+ func (this *RoundTripInfo) Timeout() uint32

+ func (this *RoundTripInfo) Update(rtt uint32, current uint32)

+ func (this *RoundTripInfo) UpdatePeerRTO(rto uint32, current uint32)

type SendingQueue

+ func (this *SendingQueue) Last() *alloc.Buffer

type SimpleAuthenticator

+ func (this *SimpleAuthenticator) Overhead() int

Jul 27, 2016

Changes in this version

type State

+ func (this State) Is(states ...State) bool

Jul 25, 2016

Changes in this version

type AckSegment

+ Option SegmentOption

type CmdOnlySegment

+ Command Command

+ Option SegmentOption

type Command

+ const CommandACK

+ const CommandPing

type DataSegment

+ Option SegmentOption

type SendingWorker

+ func (this *SendingWorker) FillWindow(current uint32)

type State

+ const StatePeerTerminating

Jul 13, 2016

Changes in this version

+ const DataSegmentOverhead

+ type AckList struct

+ func NewAckList(writer SegmentWriter) *AckList

+ func (this *AckList) Add(number uint32, timestamp uint32)

+ func (this *AckList) Clear(una uint32)

+ func (this *AckList) Flush(current uint32, rto uint32)

+ type AckSegment struct

+ Conv uint16

+ Count byte

+ NumberList []uint32

+ Opt SegmentOption

+ ReceivingNext uint32

+ ReceivingWindow uint32

+ TimestampList []uint32

+ func NewAckSegment() *AckSegment

+ func (this *AckSegment) ByteSize() int

+ func (this *AckSegment) Bytes(b []byte) []byte

+ func (this *AckSegment) IsFull() bool

+ func (this *AckSegment) PutNumber(number uint32, timestamp uint32)

+ func (this *AckSegment) Release()

+ type AuthenticationWriter struct

+ Authenticator Authenticator

+ Writer io.Writer

+ func (this *AuthenticationWriter) Mtu() uint32

+ func (this *AuthenticationWriter) Release()

+ func (this *AuthenticationWriter) Write(payload *alloc.Buffer) error

+ type BufferedSegmentWriter struct

+ func NewSegmentWriter(writer *AuthenticationWriter) *BufferedSegmentWriter

+ func (this *BufferedSegmentWriter) Flush()

+ func (this *BufferedSegmentWriter) FlushWithoutLock()

+ func (this *BufferedSegmentWriter) Write(seg Segment)

+ type CmdOnlySegment struct

+ Cmd SegmentCommand

+ Conv uint16

+ Opt SegmentOption

+ ReceivinNext uint32

+ SendingNext uint32

+ func NewCmdOnlySegment() *CmdOnlySegment

+ func (this *CmdOnlySegment) ByteSize() int

+ func (this *CmdOnlySegment) Bytes(b []byte) []byte

+ func (this *CmdOnlySegment) Release()

type Config

+ ReadBuffer uint32

+ func (this *Config) GetReceivingQueueSize() uint32

+ func (this *Config) GetSendingInFlightSize() uint32

+ func (this *Config) GetSendingQueueSize() uint32

type Connection

+ func (this *Connection) HandleOption(opt SegmentOption)

+ func (this *Connection) Input(data []byte) int

+ func (this *Connection) OnPeerClosed()

+ func (this *Connection) SetState(state State)

+ func (this *Connection) State() State

+ type DataSegment struct

+ Conv uint16

+ Data *alloc.Buffer

+ Number uint32

+ Opt SegmentOption

+ SendingNext uint32

+ Timestamp uint32

+ func NewDataSegment() *DataSegment

+ func (this *DataSegment) ByteSize() int

+ func (this *DataSegment) Bytes(b []byte) []byte

+ func (this *DataSegment) Release()

type Listener

+ func (this *Listener) ActiveConnections() int

+ type ReceivingQueue struct

+ func NewReceivingQueue(size uint32) *ReceivingQueue

+ func (this *ReceivingQueue) Close()

+ func (this *ReceivingQueue) IsEmpty() bool

+ func (this *ReceivingQueue) IsFull() bool

+ func (this *ReceivingQueue) Put(payload *alloc.Buffer)

+ func (this *ReceivingQueue) Read(buf []byte) int

+ type ReceivingWorker struct

+ func NewReceivingWorker(kcp *Connection) *ReceivingWorker

+ func (this *ReceivingWorker) CloseRead()

+ func (this *ReceivingWorker) Flush(current uint32)

+ func (this *ReceivingWorker) MarkPingNecessary(b bool)

+ func (this *ReceivingWorker) PingNecessary() bool

+ func (this *ReceivingWorker) ProcessSegment(seg *DataSegment)

+ func (this *ReceivingWorker) ProcessSendingNext(number uint32)

+ func (this *ReceivingWorker) Read(b []byte) int

+ func (this *ReceivingWorker) Write(seg Segment)

+ type RountTripInfo struct

+ func (this *RountTripInfo) SmoothedTime() uint32

+ func (this *RountTripInfo) Timeout() uint32

+ func (this *RountTripInfo) Update(rtt uint32)

type Segment

+ func ReadSegment(buf []byte) (Segment, []byte)

+ ByteSize func() int

+ Bytes func([]byte) []byte

+ type SegmentCommand byte

+ const SegmentCommandACK

+ const SegmentCommandData

+ const SegmentCommandPing

+ const SegmentCommandTerminated

+ type SegmentOption byte

+ const SegmentOptionClose

+ type SegmentWriter interface

+ Write func(seg Segment)

+ type SendingWindow struct

+ func NewSendingWindow(size uint32, writer SegmentWriter, onPacketLoss func(uint32)) *SendingWindow

+ func (this *SendingWindow) Clear(una uint32)

+ func (this *SendingWindow) First() *DataSegment

+ func (this *SendingWindow) Flush(current uint32, resend uint32, rto uint32, maxInFlightSize uint32)

+ func (this *SendingWindow) HandleFastAck(number uint32)

+ func (this *SendingWindow) IsEmpty() bool

+ func (this *SendingWindow) IsFull() bool

+ func (this *SendingWindow) Len() int

+ func (this *SendingWindow) Push(seg *DataSegment)

+ func (this *SendingWindow) Remove(idx uint32)

+ func (this *SendingWindow) Size() uint32

+ type SendingWorker struct

+ func NewSendingWorker(kcp *Connection) *SendingWorker

+ func (this *SendingWorker) CloseWrite()

+ func (this *SendingWorker) FindFirstUnacknowledged()

+ func (this *SendingWorker) Flush(current uint32)

+ func (this *SendingWorker) IsEmpty() bool

+ func (this *SendingWorker) MarkPingNecessary(b bool)

+ func (this *SendingWorker) OnPacketLoss(lossRate uint32)

+ func (this *SendingWorker) PingNecessary() bool

+ func (this *SendingWorker) ProcessAck(number uint32)

+ func (this *SendingWorker) ProcessReceivingNext(nextNumber uint32)

+ func (this *SendingWorker) ProcessReceivingNextWithoutLock(nextNumber uint32)

+ func (this *SendingWorker) ProcessSegment(current uint32, seg *AckSegment)

+ func (this *SendingWorker) Push(b []byte) int

+ func (this *SendingWorker) Write(seg Segment)

+ type State int32

+ const StateActive

+ const StatePeerClosed

+ const StateReadyToClose

+ const StateTerminated

+ const StateTerminating

Jun 27, 2016

Changes in this version

type Config

+ WriteBuffer uint32

type KCP

+ func (kcp *KCP) DumpReceivingBuf()

+ func (this *KCP) ClearSendQueue()

+ type ReceivingWindow struct

+ func NewReceivingWindow(size uint32) *ReceivingWindow

+ func (this *ReceivingWindow) Advance()

+ func (this *ReceivingWindow) Position(idx uint32) uint32

+ func (this *ReceivingWindow) Remove(idx uint32) *Segment

+ func (this *ReceivingWindow) RemoveFirst() *Segment

+ func (this *ReceivingWindow) Set(idx uint32, value *Segment) bool

+ func (this *ReceivingWindow) Size() uint32

+ type SendingQueue struct

+ func NewSendingQueue(size uint32) *SendingQueue

+ func (this *SendingQueue) Clear()

+ func (this *SendingQueue) IsEmpty() bool

+ func (this *SendingQueue) IsFull() bool

+ func (this *SendingQueue) Len() uint32

+ func (this *SendingQueue) Pop() *Segment

+ func (this *SendingQueue) Push(seg *Segment)

Jun 20, 2016

Changes in this version

+ const IKCP_ACK_FAST

+ const IKCP_ASK_SEND

+ const IKCP_ASK_TELL

+ const IKCP_CMD_ACK

+ const IKCP_CMD_PUSH

+ const IKCP_CMD_WASK

+ const IKCP_CMD_WINS

+ const IKCP_DEADLINK

+ const IKCP_INTERVAL

+ const IKCP_MTU_DEF

+ const IKCP_OVERHEAD

+ const IKCP_PROBE_INIT

+ const IKCP_PROBE_LIMIT

+ const IKCP_RTO_DEF

+ const IKCP_RTO_MAX

+ const IKCP_RTO_MIN

+ const IKCP_RTO_NDL

+ const IKCP_THRESH_INIT

+ const IKCP_THRESH_MIN

+ const IKCP_WND_RCV

+ const IKCP_WND_SND

+ var ErrUnknownDestination = errors.New("Destination IP can't be resolved.")

+ func DialKCP(src v2net.Address, dest v2net.Destination) (internet.Connection, error)

+ func ListenKCP(address v2net.Address, port v2net.Port) (internet.Listener, error)

+ type Authenticator interface

+ HeaderSize func() int

+ Open func(buffer *alloc.Buffer) bool

+ Seal func(buffer *alloc.Buffer)

+ func NewSimpleAuthenticator() Authenticator

+ type Command byte

+ var CommandData Command = 0

+ var CommandTerminate Command = 1

+ type Config struct

+ Congestion bool

+ DownlinkCapacity int

+ Mtu int

+ Tti int

+ UplinkCapacity int

+ func DefaultConfig() Config

+ func (this *Config) Apply()

+ func (this *Config) GetReceivingWindowSize() int

+ func (this *Config) GetSendingWindowSize() int

+ type ConnState byte

+ var ConnStateActive ConnState = 0

+ var ConnStateClosed ConnState = 4

+ var ConnStatePeerClosed ConnState = 2

+ var ConnStateReadyToClose ConnState = 1

+ type Connection struct

+ func NewConnection(conv uint32, writerCloser io.WriteCloser, local *net.UDPAddr, ...) *Connection

+ func (this *Connection) Close() error

+ func (this *Connection) Elapsed() uint32

+ func (this *Connection) FetchInputFrom(conn net.Conn)

+ func (this *Connection) ForceTimeout()

+ func (this *Connection) LocalAddr() net.Addr

+ func (this *Connection) MarkPeerClose()

+ func (this *Connection) NotifyTermination()

+ func (this *Connection) Read(b []byte) (int, error)

+ func (this *Connection) RemoteAddr() net.Addr

+ func (this *Connection) Reusable() bool

+ func (this *Connection) SetDeadline(t time.Time) error

+ func (this *Connection) SetReadDeadline(t time.Time) error

+ func (this *Connection) SetReusable(b bool)

+ func (this *Connection) SetWriteDeadline(t time.Time) error

+ func (this *Connection) Terminate()

+ func (this *Connection) Write(b []byte) (int, error)

+ type KCP struct

+ func NewKCP(conv uint32, mtu uint32, output Output) *KCP

+ func (kcp *KCP) Check(current uint32) uint32

+ func (kcp *KCP) Input(data []byte) int

+ func (kcp *KCP) NoDelay(nodelay, interval, resend int, congestionControl bool) int

+ func (kcp *KCP) Recv(buffer []byte) (n int)

+ func (kcp *KCP) Send(buffer []byte) int

+ func (kcp *KCP) SetMtu(mtu int) int

+ func (kcp *KCP) Update(current uint32)

+ func (kcp *KCP) WaitRcv() int

+ func (kcp *KCP) WaitSnd() int

+ func (kcp *KCP) WndSize(sndwnd, rcvwnd int) int

+ type Listener struct

+ func NewListener(address v2net.Address, port v2net.Port) (*Listener, error)

+ func (this *Listener) Accept() (internet.Connection, error)

+ func (this *Listener) Addr() net.Addr

+ func (this *Listener) Close() error

+ func (this *Listener) OnReceive(payload *alloc.Buffer, src v2net.Destination)

+ func (this *Listener) Remove(dest string)

+ type Option byte

+ var OptionClose Option = 1

+ type Output func(buf []byte)

+ type Segment struct

+ func NewSegment() *Segment

+ func (this *Segment) Release()

+ type SimpleAuthenticator struct

+ func (this *SimpleAuthenticator) HeaderSize() int

+ func (this *SimpleAuthenticator) Open(buffer *alloc.Buffer) bool

+ func (this *SimpleAuthenticator) Seal(buffer *alloc.Buffer)

+ type Writer struct

+ func (this *Writer) Close() error

+ func (this *Writer) Write(payload []byte) (int, error)