peer

Documentation

Index

• type Message
• type Peer
  • func New(p *peerconn.Conn, snubTimeout time.Duration) *Peer
  • func (p *Peer) Close()
  • func (p *Peer) ResetSnubTimer()
  • func (p *Peer) Run(messages chan Message, pieces chan PieceMessage, ...)
  • func (p *Peer) StartPEX(initialPeers map[*Peer]struct{})
  • func (p *Peer) StopSnubTimer()
• type PieceMessage

Types

type Message

type Message struct {
	*Peer
	Message interface{}
}

type Peer

type Peer struct {
	*peerconn.Conn

	AmChoking      bool
	AmInterested   bool
	PeerChoking    bool
	PeerInterested bool

	OptimisticUnchoked bool

	// Snubbed means peer is sending pieces too slow.
	Snubbed bool

	Downloading bool

	BytesDownlaodedInChokePeriod int64
	BytesUploadedInChokePeriod   int64

	// Messages received while we don't have info yet are saved here.
	Messages []interface{}

	ExtensionHandshake *peerprotocol.ExtensionHandshakeMessage

	PEX *pex
	// contains filtered or unexported fields
}

func New

func New(p *peerconn.Conn, snubTimeout time.Duration) *Peer

func (*Peer) Close

func (p *Peer) Close()

func (*Peer) ResetSnubTimer

func (p *Peer) ResetSnubTimer()

func (*Peer) Run

func (p *Peer) Run(messages chan Message, pieces chan PieceMessage, snubbed, disconnect chan *Peer)

func (*Peer) StartPEX

func (p *Peer) StartPEX(initialPeers map[*Peer]struct{})

func (*Peer) StopSnubTimer

func (p *Peer) StopSnubTimer()

type PieceMessage

type PieceMessage struct {
	*Peer
	Piece peerreader.Piece
}