Lines Matching refs:tr_peermsgs
152 struct tr_peermsgs
220 getSession( struct tr_peermsgs * msgs )
231 const struct tr_peermsgs * msgs,
273 pokeBatchPeriod( tr_peermsgs * msgs, int interval )
283 dbgOutMessageLen( tr_peermsgs * msgs )
289 protocolSendReject( tr_peermsgs * msgs, const struct peer_request * req )
306 protocolSendRequest( tr_peermsgs * msgs, const struct peer_request * req )
322 protocolSendCancel( tr_peermsgs * msgs, const struct peer_request * req )
338 protocolSendPort(tr_peermsgs *msgs, uint16_t port)
349 protocolSendHave( tr_peermsgs * msgs, uint32_t index )
364 protocolSendAllowedFast( tr_peermsgs * msgs, uint32_t pieceIndex )
381 protocolSendChoke( tr_peermsgs * msgs, int choke )
394 protocolSendHaveAll( tr_peermsgs * msgs )
409 protocolSendHaveNone( tr_peermsgs * msgs )
428 publish( tr_peermsgs * msgs, tr_peer_event * e )
438 fireError( tr_peermsgs * msgs, int err )
447 fireGotBlock( tr_peermsgs * msgs, const struct peer_request * req )
458 fireGotRej( tr_peermsgs * msgs, const struct peer_request * req )
469 fireGotChoke( tr_peermsgs * msgs )
477 fireClientGotHaveAll( tr_peermsgs * msgs )
485 fireClientGotHaveNone( tr_peermsgs * msgs )
493 fireClientGotData( tr_peermsgs * msgs, uint32_t length, int wasPieceData )
504 fireClientGotSuggest( tr_peermsgs * msgs, uint32_t pieceIndex )
513 fireClientGotPort( tr_peermsgs * msgs, tr_port port )
522 fireClientGotAllowedFast( tr_peermsgs * msgs, uint32_t pieceIndex )
531 fireClientGotBitfield( tr_peermsgs * msgs, tr_bitfield * bitfield )
540 fireClientGotHave( tr_peermsgs * msgs, tr_piece_index_t index )
549 firePeerGotData( tr_peermsgs * msgs, uint32_t length, bool wasPieceData )
621 updateFastSet( tr_peermsgs * msgs UNUSED )
649 sendInterest( tr_peermsgs * msgs, bool clientIsInterested )
666 updateInterest( tr_peermsgs * msgs UNUSED )
672 tr_peerMsgsSetInterested( tr_peermsgs * msgs, bool clientIsInterested )
681 popNextMetadataRequest( tr_peermsgs * msgs, int * piece )
695 popNextRequest( tr_peermsgs * msgs, struct peer_request * setme )
709 cancelAllRequestsToClient( tr_peermsgs * msgs )
720 tr_peerMsgsSetChoke( tr_peermsgs * msgs, bool peerIsChoked )
748 tr_peerMsgsHave( tr_peermsgs * msgs, uint32_t index )
761 reqIsValid( const tr_peermsgs * peer,
770 requestIsValid( const tr_peermsgs * msgs, const struct peer_request * req )
776 tr_peerMsgsCancel( tr_peermsgs * msgs, tr_block_index_t block )
789 sendLtepHandshake( tr_peermsgs * msgs )
852 parseLtepHandshake( tr_peermsgs * msgs, int len, struct evbuffer * inbuf )
952 parseUtMetadata( tr_peermsgs * msgs, int msglen, struct evbuffer * inbuf )
1029 parseUtPex( tr_peermsgs * msgs, int msglen, struct evbuffer * inbuf )
1091 static void sendPex( tr_peermsgs * msgs );
1094 parseLtep( tr_peermsgs * msgs, int msglen, struct evbuffer * inbuf )
1131 readBtLength( tr_peermsgs * msgs, struct evbuffer * inbuf, size_t inlen )
1151 static int readBtMessage( tr_peermsgs *, struct evbuffer *, size_t );
1154 readBtId( tr_peermsgs * msgs, struct evbuffer * inbuf, size_t inlen )
1179 updatePeerProgress( tr_peermsgs * msgs )
1188 prefetchPieces( tr_peermsgs *msgs )
1208 peerMadeRequest( tr_peermsgs * msgs, const struct peer_request * req )
1237 messageLengthIsCorrect( const tr_peermsgs * msg, uint8_t id, uint32_t len )
1282 static int clientGotBlock( tr_peermsgs * msgs,
1287 readBtPiece( tr_peermsgs * msgs,
1344 static void updateDesiredRequestCount( tr_peermsgs * msgs );
1347 readBtMessage( tr_peermsgs * msgs, struct evbuffer * inbuf, size_t inlen )
1554 clientGotBlock( tr_peermsgs * msgs,
1599 tr_peermsgs * msgs = vmsgs;
1610 tr_peermsgs * msgs = vmsgs;
1650 tr_peerMsgsIsReadingBlock( const tr_peermsgs * msgs, tr_block_index_t block )
1665 updateDesiredRequestCount( tr_peermsgs * msgs )
1709 updateMetadataRequests( tr_peermsgs * msgs, time_t now )
1743 updateBlockRequests( tr_peermsgs * msgs )
1768 fillOutputBuffer( tr_peermsgs * msgs, time_t now )
1950 tr_peermsgs * msgs = vmsgs;
1967 tr_peerMsgsPulse( tr_peermsgs * msgs )
1985 sendBitfield( tr_peermsgs * msgs )
2004 tellPeerWhatWeHave( tr_peermsgs * msgs )
2145 sendPex( tr_peermsgs * msgs )
2314 struct tr_peermsgs * msgs = vmsgs;
2326 tr_peermsgs*
2332 tr_peermsgs * m;
2337 m = tr_new0( tr_peermsgs, 1 );
2384 tr_peerMsgsFree( tr_peermsgs* msgs )
2398 memset( msgs, ~0, sizeof( tr_peermsgs ) );