kcp

package
v1.18.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 4, 2016 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package kcp - A Fast and Reliable ARQ Protocol

Acknowledgement: 

skywind3000@github for inventing the KCP protocol
xtaci@github for translating to Golang

Index

Constants

View Source 
const (
	DataSegmentOverhead = 18
)

Variables

This section is empty.

Functions

func DialKCP 

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

func ListenKCP 

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

Types

type AckList added in v1.18.1 

type AckList struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewAckList added in v1.18.1 

func NewAckList(writer SegmentWriter) *AckList

func (*AckList) Add added in v1.18.1 

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

func (*AckList) Clear added in v1.18.1 

func (this *AckList) Clear(una uint32)

func (*AckList) Flush added in v1.18.1 

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

type AckSegment added in v1.18.1 

type AckSegment struct {
	Conv            uint16
	Opt             SegmentOption
	ReceivingWindow uint32
	ReceivingNext   uint32
	Count           byte
	NumberList      []uint32
	TimestampList   []uint32
}

func (*AckSegment) ByteSize added in v1.18.1 

func (this *AckSegment) ByteSize() int

func (*AckSegment) Bytes added in v1.18.1 

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

func (*AckSegment) Release added in v1.18.1 

func (this *AckSegment) Release()

type AuthenticationWriter added in v1.18.1 

type AuthenticationWriter struct {
	Authenticator Authenticator
	Writer        io.Writer
}

func (*AuthenticationWriter) Mtu added in v1.18.1 

func (this *AuthenticationWriter) Mtu() uint32

func (*AuthenticationWriter) Release added in v1.18.1 

func (this *AuthenticationWriter) Release()

func (*AuthenticationWriter) Write added in v1.18.1 

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

type Authenticator 

type Authenticator interface {
	HeaderSize() int
	// Encrypt encrypts the whole block in src into dst.
	// Dst and src may point at the same memory.
	Seal(buffer *alloc.Buffer)

	// Decrypt decrypts the whole block in src into dst.
	// Dst and src may point at the same memory.
	Open(buffer *alloc.Buffer) bool
}

func NewSimpleAuthenticator 

func NewSimpleAuthenticator() Authenticator

type BufferedSegmentWriter added in v1.18.1 

type BufferedSegmentWriter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSegmentWriter added in v1.18.1 

func NewSegmentWriter(writer *AuthenticationWriter) *BufferedSegmentWriter

func (*BufferedSegmentWriter) Flush added in v1.18.1 

func (this *BufferedSegmentWriter) Flush()

func (*BufferedSegmentWriter) FlushWithoutLock added in v1.18.1 

func (this *BufferedSegmentWriter) FlushWithoutLock()

func (*BufferedSegmentWriter) Write added in v1.18.1 

func (this *BufferedSegmentWriter) Write(seg ISegment)

type CmdOnlySegment added in v1.18.1 

type CmdOnlySegment struct {
	Conv         uint16
	Cmd          SegmentCommand
	Opt          SegmentOption
	SendingNext  uint32
	ReceivinNext uint32
}

func (*CmdOnlySegment) ByteSize added in v1.18.1 

func (this *CmdOnlySegment) ByteSize() int

func (*CmdOnlySegment) Bytes added in v1.18.1 

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

func (*CmdOnlySegment) Release added in v1.18.1 

func (this *CmdOnlySegment) Release()

type Config 

type Config struct {
	Mtu              uint32 // Maximum transmission unit
	Tti              uint32
	UplinkCapacity   uint32
	DownlinkCapacity uint32
	Congestion       bool
	WriteBuffer      uint32
	ReadBuffer       uint32
}

func DefaultConfig 

func DefaultConfig() Config

func (*Config) Apply 

func (this *Config) Apply()

func (*Config) GetReceivingQueueSize added in v1.18.1 

func (this *Config) GetReceivingQueueSize() uint32

func (*Config) GetReceivingWindowSize 

func (this *Config) GetReceivingWindowSize() uint32

func (*Config) GetSendingQueueSize added in v1.18.1 

func (this *Config) GetSendingQueueSize() uint32

func (*Config) GetSendingWindowSize 

func (this *Config) GetSendingWindowSize() uint32

type Connection 

type Connection struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Connection is a KCP connection over UDP.

func NewConnection 

func NewConnection(conv uint16, writerCloser io.WriteCloser, local *net.UDPAddr, remote *net.UDPAddr, block Authenticator) *Connection

NewConnection create a new KCP connection between local and remote.

func (*Connection) Close 

func (this *Connection) Close() error

Close closes the connection.

func (*Connection) Elapsed 

func (this *Connection) Elapsed() uint32

func (*Connection) FetchInputFrom 

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

func (*Connection) LocalAddr 

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

LocalAddr returns the local network address. The Addr returned is shared by all invocations of LocalAddr, so do not modify it.

func (*Connection) Read 

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

Read implements the Conn Read method.

func (*Connection) RemoteAddr 

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

RemoteAddr returns the remote network address. The Addr returned is shared by all invocations of RemoteAddr, so do not modify it.

func (*Connection) Reusable 

func (this *Connection) Reusable() bool

func (*Connection) SetDeadline 

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

SetDeadline sets the deadline associated with the listener. A zero time value disables the deadline.

func (*Connection) SetReadDeadline 

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

SetReadDeadline implements the Conn SetReadDeadline method.

func (*Connection) SetReusable 

func (this *Connection) SetReusable(b bool)

func (*Connection) SetWriteDeadline 

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

SetWriteDeadline implements the Conn SetWriteDeadline method.

func (*Connection) Terminate 

func (this *Connection) Terminate()

func (*Connection) Write 

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

Write implements the Conn Write method.

type DataSegment added in v1.18.1 

type DataSegment struct {
	Conv        uint16
	Opt         SegmentOption
	Timestamp   uint32
	Number      uint32
	SendingNext uint32
	Data        *alloc.Buffer
	// contains filtered or unexported fields
}

func (*DataSegment) ByteSize added in v1.18.1 

func (this *DataSegment) ByteSize() int

func (*DataSegment) Bytes added in v1.18.1 

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

func (*DataSegment) Release added in v1.18.1 

func (this *DataSegment) Release()

type ISegment added in v1.18.1 

type ISegment interface {
	common.Releasable
	ByteSize() int
	Bytes([]byte) []byte
}

func ReadSegment added in v1.18.1 

func ReadSegment(buf []byte) (ISegment, []byte)

type KCP 

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

KCP defines a single KCP connection

func NewKCP 

func NewKCP(conv uint16, output *AuthenticationWriter) *KCP

NewKCP create a new kcp control object, 'conv' must equal in two endpoint from the same connection.

func (*KCP) HandleOption added in v1.18.1 

func (kcp *KCP) HandleOption(opt SegmentOption)

func (*KCP) Input 

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

Input when you received a low level packet (eg. UDP packet), call it

func (*KCP) OnClose added in v1.18.1 

func (kcp *KCP) OnClose()

func (*KCP) OnPeerClosed added in v1.18.1 

func (kcp *KCP) OnPeerClosed()

func (*KCP) SetState added in v1.18.1 

func (kcp *KCP) SetState(state State)

func (*KCP) Update 

func (kcp *KCP) Update(current uint32)

Update updates state (call it repeatedly, every 10ms-100ms), or you can ask ikcp_check when to call it again (without ikcp_input/_send calling). 'current' - current timestamp in millisec.

type Listener 

type Listener struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Listener defines a server listening for connections

func NewListener 

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

func (*Listener) Accept 

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

Accept implements the Accept method in the Listener interface; it waits for the next call and returns a generic Conn.

func (*Listener) Addr 

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

Addr returns the listener's network address, The Addr returned is shared by all invocations of Addr, so do not modify it.

func (*Listener) Close 

func (this *Listener) Close() error

Close stops listening on the UDP address. Already Accepted connections are not closed.

func (*Listener) OnReceive 

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

func (*Listener) Remove 

func (this *Listener) Remove(dest string)

type ReceivingQueue added in v1.18.1 

type ReceivingQueue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewReceivingQueue added in v1.18.1 

func NewReceivingQueue(size uint32) *ReceivingQueue

func (*ReceivingQueue) Close added in v1.18.1 

func (this *ReceivingQueue) Close()

func (*ReceivingQueue) Put added in v1.18.1 

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

func (*ReceivingQueue) Read added in v1.18.1 

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

func (*ReceivingQueue) SetReadDeadline added in v1.18.1 

func (this *ReceivingQueue) SetReadDeadline(t time.Time) error

type ReceivingWindow added in v1.17.3 

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

func NewReceivingWindow added in v1.17.3 

func NewReceivingWindow(size uint32) *ReceivingWindow

func (*ReceivingWindow) Advance added in v1.17.3 

func (this *ReceivingWindow) Advance()

func (*ReceivingWindow) Position added in v1.17.3 

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

func (*ReceivingWindow) Remove added in v1.17.3 

func (this *ReceivingWindow) Remove(idx uint32) *DataSegment

func (*ReceivingWindow) RemoveFirst added in v1.17.3 

func (this *ReceivingWindow) RemoveFirst() *DataSegment

func (*ReceivingWindow) Set added in v1.17.3 

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

func (*ReceivingWindow) Size added in v1.17.3 

func (this *ReceivingWindow) Size() uint32

type ReceivingWorker added in v1.18.1 

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

func NewReceivingWorker added in v1.18.1 

func NewReceivingWorker(kcp *KCP) *ReceivingWorker

func (*ReceivingWorker) CloseRead added in v1.18.1 

func (this *ReceivingWorker) CloseRead()

func (*ReceivingWorker) Flush added in v1.18.1 

func (this *ReceivingWorker) Flush()

func (*ReceivingWorker) PingNecessary added in v1.18.1 

func (this *ReceivingWorker) PingNecessary() bool

func (*ReceivingWorker) ProcessSegment added in v1.18.1 

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

func (*ReceivingWorker) ProcessSendingNext added in v1.18.1 

func (this *ReceivingWorker) ProcessSendingNext(number uint32)

func (*ReceivingWorker) Read added in v1.18.1 

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

func (*ReceivingWorker) SetReadDeadline added in v1.18.1 

func (this *ReceivingWorker) SetReadDeadline(t time.Time)

func (*ReceivingWorker) Write added in v1.18.1 

func (this *ReceivingWorker) Write(seg ISegment)

type SegmentCommand added in v1.18.1 

type SegmentCommand byte
const (
	SegmentCommandACK        SegmentCommand = 0
	SegmentCommandData       SegmentCommand = 1
	SegmentCommandTerminated SegmentCommand = 2
	SegmentCommandPing       SegmentCommand = 3
)

type SegmentOption added in v1.18.1 

type SegmentOption byte
const (
	SegmentOptionClose SegmentOption = 1
)

type SegmentWriter added in v1.18.1 

type SegmentWriter interface {
	Write(seg ISegment)
}

type SendingQueue added in v1.17.3 

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

func NewSendingQueue added in v1.17.3 

func NewSendingQueue(size uint32) *SendingQueue

func (*SendingQueue) Clear added in v1.17.3 

func (this *SendingQueue) Clear()

func (*SendingQueue) IsEmpty added in v1.17.3 

func (this *SendingQueue) IsEmpty() bool

func (*SendingQueue) IsFull added in v1.17.3 

func (this *SendingQueue) IsFull() bool

func (*SendingQueue) Len added in v1.17.3 

func (this *SendingQueue) Len() uint32

func (*SendingQueue) Pop added in v1.17.3 

func (this *SendingQueue) Pop() *DataSegment

func (*SendingQueue) Push added in v1.17.3 

func (this *SendingQueue) Push(seg *DataSegment)

type SendingWindow added in v1.18.1 

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

func NewSendingWindow added in v1.18.1 

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

func (*SendingWindow) Clear added in v1.18.1 

func (this *SendingWindow) Clear(una uint32)

func (*SendingWindow) First added in v1.18.1 

func (this *SendingWindow) First() *DataSegment

func (*SendingWindow) Flush added in v1.18.1 

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

func (*SendingWindow) HandleFastAck added in v1.18.1 

func (this *SendingWindow) HandleFastAck(number uint32)

func (*SendingWindow) Len added in v1.18.1 

func (this *SendingWindow) Len() int

func (*SendingWindow) Push added in v1.18.1 

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

func (*SendingWindow) Remove added in v1.18.1 

func (this *SendingWindow) Remove(idx uint32)

type SendingWorker added in v1.18.1 

type SendingWorker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSendingWorker added in v1.18.1 

func NewSendingWorker(kcp *KCP) *SendingWorker

func (*SendingWorker) CloseWrite added in v1.18.1 

func (this *SendingWorker) CloseWrite()

func (*SendingWorker) FindFirstUnacknowledged added in v1.18.1 

func (this *SendingWorker) FindFirstUnacknowledged()

@Private

func (*SendingWorker) Flush added in v1.18.1 

func (this *SendingWorker) Flush()

func (*SendingWorker) OnPacketLoss added in v1.18.1 

func (this *SendingWorker) OnPacketLoss(lost bool)

func (*SendingWorker) PingNecessary added in v1.18.1 

func (this *SendingWorker) PingNecessary() bool

func (*SendingWorker) ProcessAck added in v1.18.1 

func (this *SendingWorker) ProcessAck(number uint32)

func (*SendingWorker) ProcessAckSegment added in v1.18.1 

func (this *SendingWorker) ProcessAckSegment(seg *AckSegment)

func (*SendingWorker) ProcessReceivingNext added in v1.18.1 

func (this *SendingWorker) ProcessReceivingNext(nextNumber uint32)

func (*SendingWorker) Push added in v1.18.1 

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

func (*SendingWorker) Write added in v1.18.1 

func (this *SendingWorker) Write(seg ISegment)

type SimpleAuthenticator 

type SimpleAuthenticator struct{}

func (*SimpleAuthenticator) HeaderSize 

func (this *SimpleAuthenticator) HeaderSize() int

func (*SimpleAuthenticator) Open 

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

func (*SimpleAuthenticator) Seal 

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

type State added in v1.18.1 

type State int
const (
	StateActive       State = 0
	StateReadyToClose State = 1
	StatePeerClosed   State = 2
	StateTerminating  State = 3
	StateTerminated   State = 4
)

type Writer 

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

func (*Writer) Close 

func (this *Writer) Close() error

func (*Writer) Write 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.