udp

package

v2.1.2+incompatible Latest Latest Go to latest Published: Sep 19, 2016 License: MIT Imports: 12 Imported by: 0

Details

Rendered for

This section is empty.

This section is empty.

func ReadUDPMsg(conn *net.UDPConn, payload []byte, oob []byte) (int, int, int, *net.UDPAddr, error)

func RetrieveOriginalDest(oob []byte) v2net.Destination

func SetOriginalDestOptions(fd int) error

type Connection struct {
	net.UDPConn
}

func (this *Connection) Reusable() bool

func (this *Connection) SetReusable(b bool)

type ListenOption struct {
	Callback            UDPPayloadHandler
	ReceiveOriginalDest bool
}

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

func NewTimedInboundRay(name string, inboundRay ray.InboundRay, server *UDPServer) *TimedInboundRay

func (this *TimedInboundRay) InboundInput() ray.OutputStream

func (this *TimedInboundRay) InboundOutput() ray.InputStream

func (this *TimedInboundRay) Monitor()

func (this *TimedInboundRay) Release()

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

func ListenUDP(address v2net.Address, port v2net.Port, option ListenOption) (*UDPHub, error)

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

func (this *UDPHub) Close()

func (this *UDPHub) Connection() net.Conn

Connection return the net.Conn underneath this hub. Private: Visible for testing only

func (this *UDPHub) Running() bool

func (this *UDPHub) WriteTo(payload []byte, dest v2net.Destination) (int, error)

type UDPPayloadHandler func(*alloc.Buffer, *proxy.SessionInfo)

type UDPResponseCallback func(destination v2net.Destination, payload *alloc.Buffer)

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

func NewUDPServer(meta *proxy.InboundHandlerMeta, packetDispatcher dispatcher.PacketDispatcher) *UDPServer

func (this *UDPServer) Dispatch(session *proxy.SessionInfo, payload *alloc.Buffer, callback UDPResponseCallback)

func (this *UDPServer) RemoveRay(name string)