core

README

BitTorrent protocol implementation files

• PWP
• THP

Documentation

Index

• type ConnectionStatus
• type PWPNode
  • func NewPWPNode(peerAddress string, log *logging.Logger) *PWPNode
  • func (n *PWPNode) Connect(peerAddress string) error
  • func (n *PWPNode) Listen()
  • func (n *PWPNode) Send(data interface{}) error
• type PWPStatus
• type ReceiveWorker
  • func NewReceiveWorker(reader bencode.BencodeReader, recvChan chan []byte, log *logging.Logger) *ReceiveWorker
  • func (w *ReceiveWorker) Start()
• type TorrentSession
  • func NewTorrentSession(connection net.Conn, log *logging.Logger) *TorrentSession
  • func (s *TorrentSession) AwaitHandshake() bool
  • func (s *TorrentSession) Close()
  • func (s *TorrentSession) GetConnection() net.Conn
  • func (s *TorrentSession) Receive(conn net.Conn) (string, error)
  • func (s *TorrentSession) Send(data interface{}) error
  • func (s *TorrentSession) SendMessage(msg message.PWPMessage) error
  • func (s *TorrentSession) Start()
  • func (s *TorrentSession) StartHandshake() error

Types

type ConnectionStatus

type ConnectionStatus struct {
	HandshakeComplete bool // NOT USED
}

type PWPNode

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

func NewPWPNode

func NewPWPNode(peerAddress string, log *logging.Logger) *PWPNode

func (*PWPNode) Connect

func (n *PWPNode) Connect(peerAddress string) error

func (*PWPNode) Listen

func (n *PWPNode) Listen()

func (*PWPNode) Send

func (n *PWPNode) Send(data interface{}) error

type PWPStatus

type PWPStatus struct {
	AmChoking      bool
	AmInterested   bool
	PeerChoking    bool
	PeerInterested bool
}

type ReceiveWorker

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

func NewReceiveWorker

func NewReceiveWorker(reader bencode.BencodeReader, recvChan chan []byte, log *logging.Logger) *ReceiveWorker

func (*ReceiveWorker) Start

func (w *ReceiveWorker) Start()

type TorrentSession

type TorrentSession struct {
	PWPStatus        PWPStatus
	ConnectionStatus *ConnectionStatus
	// contains filtered or unexported fields
}

func NewTorrentSession

func NewTorrentSession(connection net.Conn, log *logging.Logger) *TorrentSession

func (*TorrentSession) AwaitHandshake

func (s *TorrentSession) AwaitHandshake() bool

func (*TorrentSession) Close

func (s *TorrentSession) Close()

func (*TorrentSession) GetConnection

func (s *TorrentSession) GetConnection() net.Conn

func (*TorrentSession) Receive

func (s *TorrentSession) Receive(conn net.Conn) (string, error)

func (*TorrentSession) Send

func (s *TorrentSession) Send(data interface{}) error

func (*TorrentSession) SendMessage

func (s *TorrentSession) SendMessage(msg message.PWPMessage) error

func (*TorrentSession) Start

func (s *TorrentSession) Start()

func (*TorrentSession) StartHandshake

func (s *TorrentSession) StartHandshake() error