udt

README

go-udtwrapper

This is a cgo wrapper around the main C++ UDT implementation.

Usage

• Godoc: https://godoc.org/github.com/jbenet/go-udtwrapper/udt

Tools:

• udtcat - netcat using the udt pkg

Try:

(cd udtcat; go build; ./test_simple.sh)

Documentation

Index

• Variables
• func Dial(network, address string) (c net.Conn, err error)
• func Listen(network, address string) (net.Listener, error)
• type Dialer
  • func (d *Dialer) Dial(network, address string) (c net.Conn, err error)
  • func (d *Dialer) DialUDT(network string, raddr *UDTAddr) (*UDTConn, error)
• type UDTAddr
  • func ResolveUDTAddr(n, addr string) (*UDTAddr, error)
  • func WrapUDPAddr(ua *net.UDPAddr) *UDTAddr
  • func (a *UDTAddr) AF() int
  • func (a *UDTAddr) IPPROTO() int
  • func (a *UDTAddr) Network() string
  • func (a *UDTAddr) String() string
• type UDTConn
  • func DialUDT(net string, laddr, raddr *UDTAddr) (*UDTConn, error)
  • func (fd UDTConn) Close() error
  • func (fd UDTConn) LocalAddr() net.Addr
  • func (fd UDTConn) Read(buf []byte) (readcnt int, err error)
  • func (fd UDTConn) RemoteAddr() net.Addr
  • func (fd UDTConn) SetDeadline(t time.Time) error
  • func (fd UDTConn) SetReadDeadline(t time.Time) error
  • func (fd UDTConn) SetWriteDeadline(t time.Time) error
  • func (fd UDTConn) Write(buf []byte) (writecnt int, err error)
• type UDTListener
  • func ListenUDT(network string, laddr *UDTAddr) (*UDTListener, error)
  • func (l *UDTListener) Accept() (c net.Conn, err error)
  • func (l *UDTListener) Addr() net.Addr
  • func (l *UDTListener) Close() error

Variables

var (
	// UDP_RCVBUF_SIZE is the default UDP_RCVBUF size.
	UDP_RCVBUF_SIZE = uint32(20971520) // 20MB

	// UDT_SNDTIMEO is the udt_send() timeout in milliseconds
	// note this doesnt change the interface, we use it as a poor polling
	UDT_SNDTIMEO_MS = C.int(UDT_ASYNC_TIMEOUT)

	// UDT_RCVTIMEO is the udt_recv() timeout in milliseconds
	// note this doesnt change the interface, we use it as a poor polling
	UDT_RCVTIMEO_MS = C.int(UDT_ASYNC_TIMEOUT)

	// UDT_ASYNC_TIMEOUT (in ms)
	UDT_ASYNC_TIMEOUT = 40
)

Functions

func Dial

func Dial(network, address string) (c net.Conn, err error)

Dial connects to the remote address raddr on the network net, which must be "udt", "udt4", or "udt6". If laddr is not nil, it is used as the local address for the connection.

func Listen

func Listen(network, address string) (net.Listener, error)

Listen listens for incoming UDT packets addressed to the local address laddr. Net must be "udt", "udt4", or "udt6". If laddr has a port of 0, ListenUDT will choose an available port. The LocalAddr method of the returned UDTConn can be used to discover the port. The returned connection's ReadFrom and WriteTo methods can be used to receive and send UDT packets with per-packet addressing.

Types

type Dialer

type Dialer struct {
	LocalAddr net.Addr
}

func (*Dialer) Dial

func (d *Dialer) Dial(network, address string) (c net.Conn, err error)

Dial connects to the remote address raddr on the network net, which must be "udt", "udt4", or "udt6".

func (*Dialer) DialUDT

func (d *Dialer) DialUDT(network string, raddr *UDTAddr) (*UDTConn, error)

DialUDT connects to the remote address raddr on the network net, which must be "udt", "udt4", or "udt6".

type UDTAddr

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

func ResolveUDTAddr

func ResolveUDTAddr(n, addr string) (*UDTAddr, error)

func WrapUDPAddr

func WrapUDPAddr(ua *net.UDPAddr) *UDTAddr

func (*UDTAddr) AF

func (a *UDTAddr) AF() int

AF returns UDTAddr's AF (Address Family)

func (*UDTAddr) IPPROTO

func (a *UDTAddr) IPPROTO() int

IPPROTO returns UDTAddr's IPPROTO (IPPROTO_UDP)

func (*UDTAddr) Network

func (a *UDTAddr) Network() string

func (*UDTAddr) String

func (a *UDTAddr) String() string

type UDTConn

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

UDTConn is the implementation of the Conn and PacketConn interfaces for UDT network connections.

func DialUDT

func DialUDT(net string, laddr, raddr *UDTAddr) (*UDTConn, error)

DialUDT connects to the remote address raddr on the network net, which must be "udt", "udt4", or "udt6". If laddr is not nil, it is used as the local address for the connection.

func (UDTConn) Close

func (fd UDTConn) Close() error

func (UDTConn) LocalAddr

func (fd UDTConn) LocalAddr() net.Addr

func (UDTConn) Read

func (fd UDTConn) Read(buf []byte) (readcnt int, err error)

func (UDTConn) RemoteAddr

func (fd UDTConn) RemoteAddr() net.Addr

func (UDTConn) SetDeadline

func (fd UDTConn) SetDeadline(t time.Time) error

func (UDTConn) SetReadDeadline

func (fd UDTConn) SetReadDeadline(t time.Time) error

func (UDTConn) SetWriteDeadline

func (fd UDTConn) SetWriteDeadline(t time.Time) error

func (UDTConn) Write

func (fd UDTConn) Write(buf []byte) (writecnt int, err error)

type UDTListener

type UDTListener struct {
	net.Listener
	// contains filtered or unexported fields
}

UDTListener is a network listener for UDT.

func ListenUDT

func ListenUDT(network string, laddr *UDTAddr) (*UDTListener, error)

ListenUDT listens for incoming UDT packets addressed to the local address laddr. Net must be "udt", "udt4", or "udt6". If laddr has a port of 0, ListenUDT will choose an available port. The LocalAddr method of the returned UDTConn can be used to discover the port. The returned connection's ReadFrom and WriteTo methods can be used to receive and send UDT packets with per-packet addressing.

func (*UDTListener) Accept

func (l *UDTListener) Accept() (c net.Conn, err error)

func (*UDTListener) Addr

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

func (*UDTListener) Close

func (l *UDTListener) Close() error