Lines Matching defs:io
28 #include "peer-io.h"
247 tr_peerIoGetAddrStr( msgs->peer->io ),
293 assert( tr_peerIoSupportsFEXT( msgs->peer->io ) );
366 tr_peerIo * io = msgs->peer->io;
369 assert( tr_peerIoSupportsFEXT( msgs->peer->io ) );
371 evbuffer_add_uint32( io, out, sizeof(uint8_t) + sizeof(uint32_t) );
372 evbuffer_add_uint8 ( io, out, BT_FEXT_ALLOWED_FAST );
373 evbuffer_add_uint32( io, out, pieceIndex );
398 assert( tr_peerIoSupportsFEXT( msgs->peer->io ) );
413 assert( tr_peerIoSupportsFEXT( msgs->peer->io ) );
623 const bool fext = tr_peerIoSupportsFEXT( msgs->peer->io );
629 const struct tr_address * addr = tr_peerIoGetAddress( msgs->peer->io, NULL );
712 const int mustSendCancel = tr_peerIoSupportsFEXT( msgs->peer->io );
864 tr_peerIoReadBytes( msgs->peer->io, inbuf, tmp, len );
903 tr_peerIoGetAddress( msgs->peer->io, NULL ),
925 if( tr_peerIoIsIncoming( msgs->peer->io )
934 if( tr_peerIoIsIncoming( msgs->peer->io )
962 tr_peerIoReadBytes( msgs->peer->io, inbuf, tmp, msglen );
1038 tr_peerIoReadBytes( msgs->peer->io, inbuf, tmp, msglen );
1098 tr_peerIoReadUint8( msgs->peer->io, inbuf, <ep_msgid );
1105 if( tr_peerIoSupportsLTEP( msgs->peer->io ) )
1138 tr_peerIoReadUint32( msgs->peer->io, inbuf, &len );
1161 tr_peerIoReadUint8( msgs->peer->io, inbuf, &id );
1210 const bool fext = tr_peerIoSupportsFEXT( msgs->peer->io );
1302 tr_peerIoReadUint32( msgs->peer->io, inbuf, &req->index );
1303 tr_peerIoReadUint32( msgs->peer->io, inbuf, &req->offset );
1323 tr_peerIoReadBytesToBuf( msgs->peer->io, inbuf, block_buffer, n );
1355 const bool fext = tr_peerIoSupportsFEXT( msgs->peer->io );
1397 tr_peerIoReadUint32( msgs->peer->io, inbuf, &ui32 );
1417 tr_peerIoReadBytes( msgs->peer->io, inbuf, tmp, msglen );
1428 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.index );
1429 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.offset );
1430 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.length );
1440 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.index );
1441 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.offset );
1442 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.length );
1464 tr_peerIoReadUint16( msgs->peer->io, inbuf, &msgs->peer->dht_port );
1473 tr_peerIoReadUint32( msgs->peer->io, inbuf, &ui32 );
1484 tr_peerIoReadUint32( msgs->peer->io, inbuf, &ui32 );
1522 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.index );
1523 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.offset );
1524 tr_peerIoReadUint32( msgs->peer->io, inbuf, &r.length );
1541 tr_peerIoDrain( msgs->peer->io, inbuf, msglen );
1597 didWrite( tr_peerIo * io UNUSED, size_t bytesWritten, int wasPieceData, void * vmsgs )
1602 if ( tr_isPeerIo( io ) && io->userData )
1607 canRead( tr_peerIo * io, void * vmsgs, size_t * piece )
1611 struct evbuffer * in = tr_peerIoGetReadBuffer( io );
1774 const bool fext = tr_peerIoSupportsFEXT( msgs->peer->io );
1789 dbgmsg( msgs, "flushing outMessages... to %p (length is %zu)", msgs->peer->io, len );
1790 tr_peerIoWriteBuf( msgs->peer->io, msgs->outMessages, false );
1801 if( ( tr_peerIoGetWriteBufferSpace( msgs->peer->io, now ) >= METADATA_PIECE_SIZE )
1867 if( ( tr_peerIoGetWriteBufferSpace( msgs->peer->io, now ) >= msgs->torrent->blockSize )
1908 tr_peerIoWriteBuf( msgs->peer->io, out, true );
1953 if ( tr_isPeerIo( msgs->peer->io ) ) {
1974 gotError( tr_peerIo * io UNUSED, short what, void * vmsgs )
2006 const bool fext = tr_peerIoSupportsFEXT( msgs->peer->io );
2335 assert( peer->io );
2357 if( tr_peerIoSupportsUTP( peer->io ) ) {
2358 const tr_address * addr = tr_peerIoGetAddress( peer->io, NULL );
2363 if( tr_peerIoSupportsLTEP( peer->io ) )
2368 if( tr_dhtEnabled( torrent->session ) && tr_peerIoSupportsDHT( peer->io ))
2371 const struct tr_address *addr = tr_peerIoGetAddress( peer->io, NULL );
2377 tr_peerIoSetIOFuncs( m->peer->io, canRead, didWrite, gotError, m );