Documentation ¶
Index ¶
- Constants
- Variables
- func Dial(proto string, remoteAddr string) (net.Conn, error)
- func GetLocalAddr(remoteAddr string) (net.Addr, error)
- type Conn
- func (conn *Conn) Close() error
- func (conn *Conn) CloseRequest() (err error)
- func (conn *Conn) LocalAddr() net.Addr
- func (conn *Conn) Read(b []byte) (n int, err error)
- func (conn *Conn) ReadWithHeader(b []byte) (n int, err error)
- func (conn *Conn) RemoteAddr() net.Addr
- func (conn *Conn) SetDeadline(t time.Time) error
- func (conn *Conn) SetReadDeadline(t time.Time) error
- func (conn *Conn) SetWriteDeadline(t time.Time) error
- func (conn *Conn) UpdateTime()
- func (conn *Conn) Write(b []byte) (n int, err error)
- func (conn *Conn) WriteWithHeader(b []byte) (n int, err error)
- type IpPortPair
- type PacketConn
- func (conn *PacketConn) Close() error
- func (conn *PacketConn) LocalAddr() net.Addr
- func (conn *PacketConn) ReadFrom(b []byte) (n int, addr *IpPortPair, err error)
- func (conn *PacketConn) RemoteAddr() net.Addr
- func (conn *PacketConn) SetDeadline(t time.Time) error
- func (conn *PacketConn) SetReadDeadline(t time.Time) error
- func (conn *PacketConn) SetWriteDeadline(t time.Time) error
- func (conn *PacketConn) WriteTo(p []byte, addr *IpPortPair) (n int, err error)
Constants ¶
View Source
const ( CONNECTING = iota CONNECTED CLOSING CLOSED )
View Source
const ( RETRYTIME = 5 RETRYINTERVAL = 500 BUFFERSIZE = 65535 )
Variables ¶
View Source
var CONNCHANBUFSIZE = 1024
View Source
var CONNTIMEOUT = 60
View Source
var LISTENERBUFSIZE = 1024
View Source
var PACKETCONNBUFFERSIZE = 1024
Functions ¶
Types ¶
type Conn ¶
func (*Conn) CloseRequest ¶
func (*Conn) ReadWithHeader ¶
Blocks and Reads
func (*Conn) RemoteAddr ¶
func (*Conn) UpdateTime ¶
func (conn *Conn) UpdateTime()
type IpPortPair ¶
type PacketConn ¶
type PacketConn struct { TcpSquatter *net.TCPListener // fd int InputChan chan dataAdressPair OutputChan chan dataAdressPair // contains filtered or unexported fields }
func ListenPacket ¶
func ListenPacket(proto, addr string) (*PacketConn, error)
func NewPacketConn ¶
func NewPacketConn(localAddr uint32, localPort int, internalConn *net.IPConn, tcpSquatter *net.TCPListener) *PacketConn
func (*PacketConn) Close ¶
func (conn *PacketConn) Close() error
func (*PacketConn) ReadFrom ¶
func (conn *PacketConn) ReadFrom(b []byte) (n int, addr *IpPortPair, err error)
//Block needs upto 40 bytes extra :(
func (*PacketConn) RemoteAddr ¶
func (conn *PacketConn) RemoteAddr() net.Addr
func (*PacketConn) SetDeadline ¶
func (conn *PacketConn) SetDeadline(t time.Time) error
func (*PacketConn) SetReadDeadline ¶
func (conn *PacketConn) SetReadDeadline(t time.Time) error
func (*PacketConn) SetWriteDeadline ¶
func (conn *PacketConn) SetWriteDeadline(t time.Time) error
func (*PacketConn) WriteTo ¶
func (conn *PacketConn) WriteTo(p []byte, addr *IpPortPair) (n int, err error)
Click to show internal directories.
Click to hide internal directories.