listen

Documentation

Index

• func CreateListener(flags *conf.Flags) (listener net.Listener, externalPort int, err error)
• func CreatePortMapping(flags *conf.Flags) (translate nat.NAT, err error)
• func ListenForPeerConnections(flags *conf.Flags) (conChan chan *BtConn, listenPort int, err error)
• func ReadHeader(conn net.Conn) (h []byte, err error)
• type BtConn
  • func NewBtConn(conn net.Conn, remoteAddr net.Addr, header []byte, infoHash string, id string) *BtConn
  • func (b *BtConn) ID() string
  • func (b *BtConn) ReadHeader() []byte

Functions

func CreateListener

func CreateListener(flags *conf.Flags) (listener net.Listener, externalPort int, err error)

func CreatePortMapping

func CreatePortMapping(flags *conf.Flags) (translate nat.NAT, err error)

createPortMapping creates a NAT port mapping, or nil if none requested or found.

func ListenForPeerConnections

func ListenForPeerConnections(flags *conf.Flags) (conChan chan *BtConn, listenPort int, err error)

ListenForPeerConnections listens on a TCP port for incoming connections and demuxes them to the appropriate active torrentSession based on the InfoHash in the header.

func ReadHeader

func ReadHeader(conn net.Conn) (h []byte, err error)

Types

type BtConn

type BtConn struct {
	Conn       net.Conn
	RemoteAddr net.Addr

	Infohash string
	// contains filtered or unexported fields
}

btConn wraps an incoming network connection and contains metadata that helps identify which active torrentSession it's relevant for.

func NewBtConn

func NewBtConn(conn net.Conn, remoteAddr net.Addr, header []byte, infoHash string, id string) *BtConn

func (*BtConn) ID

func (b *BtConn) ID() string

ID returns the id of the BtConn

func (*BtConn) ReadHeader

func (b *BtConn) ReadHeader() []byte