ptcp

Documentation

Index

• Constants
• Variables
• func Dial(proto string, remoteAddr string) (net.Conn, error)
• func GetLocalAddr(remoteAddr string) (net.Addr, error)
• func Init(interfaceName string)
• func Listen(proto, addr string) (net.Listener, error)
• type Addr
  • func NewAddr(addr string) *Addr
  • func (a *Addr) Network() string
  • func (a *Addr) String() string
• type Conn
  • func NewConn(localAddr string, remoteAddr string, state int) *Conn
  • func (conn *Conn) Close() error
  • func (conn *Conn) CloseRequest() (err error)
  • func (conn *Conn) CloseResponse() (err error)
  • func (conn *Conn) IsTimeout() bool
  • 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 Listener
  • func NewListener(addr string) (*Listener, error)
  • func (l *Listener) Accept() (net.Conn, error)
  • func (l *Listener) Addr() net.Addr
  • func (l *Listener) Close() error
• type PTCP
  • func NewPTCP(interfaceName string) (*PTCP, error)
  • func (p *PTCP) CleanTimeoutConns()
  • func (p *PTCP) CloseConn(key string)
  • func (p *PTCP) CloseListener(key string)
  • func (p *PTCP) CreateConn(localAddr string, remoteAddr string, conn *Conn)
  • func (p *PTCP) CreateListener(key string, listener *Listener)
  • func (p *PTCP) Start()
• type Raw
  • func NewRaw(interfaceName string) (*Raw, error)
  • func (r *Raw) Read() ([]byte, error)
  • func (r *Raw) Write(data []byte) error

Constants

const (
	CONNECTING = iota
	CONNECTED
	CLOSING
	CLOSED
)

const (
	RETRYTIME     = 5
	RETRYINTERVAL = 500
)

Variables

var BUFFERSIZE = 65535

var CHANBUFFERSIZE = 1024

var CONNCHANBUFSIZE = 1024

var CONNTIMEOUT = 60

var LISTENERBUFSIZE = 1024

var RAWBUFSIZE = 65535

Functions

func Dial

func Dial(proto string, remoteAddr string) (net.Conn, error)

func GetLocalAddr

func GetLocalAddr(remoteAddr string) (net.Addr, error)

func Init

func Init(interfaceName string)

func Listen

func Listen(proto, addr string) (net.Listener, error)

Types

type Addr

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

func NewAddr

func NewAddr(addr string) *Addr

func (*Addr) Network

func (a *Addr) Network() string

func (*Addr) String

func (a *Addr) String() string

type Conn

type Conn struct {
	InputChan  chan string
	OutputChan chan string
	State      int
	LastUpdate time.Time
	// contains filtered or unexported fields
}

func NewConn

func NewConn(localAddr string, remoteAddr string, state int) *Conn

func (*Conn) Close

func (conn *Conn) Close() error

func (*Conn) CloseRequest

func (conn *Conn) CloseRequest() (err error)

func (*Conn) CloseResponse

func (conn *Conn) CloseResponse() (err error)

func (*Conn) IsTimeout

func (conn *Conn) IsTimeout() bool

func (*Conn) LocalAddr

func (conn *Conn) LocalAddr() net.Addr

func (*Conn) Read

func (conn *Conn) Read(b []byte) (n int, err error)

Block

func (*Conn) ReadWithHeader

func (conn *Conn) ReadWithHeader(b []byte) (n int, err error)

NoBlock

func (*Conn) RemoteAddr

func (conn *Conn) RemoteAddr() net.Addr

func (*Conn) SetDeadline

func (conn *Conn) SetDeadline(t time.Time) error

func (*Conn) SetReadDeadline

func (conn *Conn) SetReadDeadline(t time.Time) error

func (*Conn) SetWriteDeadline

func (conn *Conn) SetWriteDeadline(t time.Time) error

func (*Conn) UpdateTime

func (conn *Conn) UpdateTime()

func (*Conn) Write

func (conn *Conn) Write(b []byte) (n int, err error)

Block

func (*Conn) WriteWithHeader

func (conn *Conn) WriteWithHeader(b []byte) (n int, err error)

NoBlock

type Listener

type Listener struct {
	Address    string
	InputChan  chan string
	OutputChan chan string
	// contains filtered or unexported fields
}

func NewListener

func NewListener(addr string) (*Listener, error)

func (*Listener) Accept

func (l *Listener) Accept() (net.Conn, error)

func (*Listener) Addr

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

func (*Listener) Close

func (l *Listener) Close() error

type PTCP

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

func NewPTCP

func NewPTCP(interfaceName string) (*PTCP, error)

func (*PTCP) CleanTimeoutConns

func (p *PTCP) CleanTimeoutConns()

func (*PTCP) CloseConn

func (p *PTCP) CloseConn(key string)

func (*PTCP) CloseListener

func (p *PTCP) CloseListener(key string)

func (*PTCP) CreateConn

func (p *PTCP) CreateConn(localAddr string, remoteAddr string, conn *Conn)

func (*PTCP) CreateListener

func (p *PTCP) CreateListener(key string, listener *Listener)

func (*PTCP) Start

func (p *PTCP) Start()

type Raw

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

func NewRaw

func NewRaw(interfaceName string) (*Raw, error)

func (*Raw) Read

func (r *Raw) Read() ([]byte, error)

func (*Raw) Write

func (r *Raw) Write(data []byte) error