}
void
-tr_peerMsgsSetInterested( tr_peermsgs * msgs, int isInterested )
+tr_peerMsgsSetInterested( tr_peermsgs * msgs, bool clientIsInterested )
{
- assert( tr_isBool( isInterested ) );
+ assert( tr_isBool( clientIsInterested ) );
- if( isInterested != msgs->peer->clientIsInterested )
- sendInterest( msgs, isInterested );
+ if( clientIsInterested != msgs->peer->clientIsInterested )
+ sendInterest( msgs, clientIsInterested );
}
static bool
}
void
-tr_peerMsgsSetChoke( tr_peermsgs * msgs, int choke )
+tr_peerMsgsSetChoke( tr_peermsgs * msgs, bool peerIsChoked )
{
const time_t now = tr_time( );
const time_t fibrillationTime = now - MIN_CHOKE_PERIOD_SEC;
assert( msgs );
assert( msgs->peer );
- assert( choke == 0 || choke == 1 );
+ assert( tr_isBool( peerIsChoked ) );
if( msgs->peer->chokeChangedAt > fibrillationTime )
{
- dbgmsg( msgs, "Not changing choke to %d to avoid fibrillation", choke );
+ dbgmsg( msgs, "Not changing choke to %d to avoid fibrillation", peerIsChoked );
}
- else if( msgs->peer->peerIsChoked != choke )
+ else if( msgs->peer->peerIsChoked != peerIsChoked )
{
- msgs->peer->peerIsChoked = choke;
- if( choke )
+ msgs->peer->peerIsChoked = peerIsChoked;
+ if( peerIsChoked )
cancelAllRequestsToClient( msgs );
- protocolSendChoke( msgs, choke );
+ protocolSendChoke( msgs, peerIsChoked );
msgs->peer->chokeChangedAt = now;
}
}
tr_peer_callback * callback,
void * callback_data );
-void tr_peerMsgsSetChoke( tr_peermsgs *, int doChoke );
+void tr_peerMsgsSetChoke( tr_peermsgs *, bool peerIsChoked );
int tr_peerMsgsIsReadingBlock( const tr_peermsgs * msgs, tr_block_index_t block );
-void tr_peerMsgsSetInterested( tr_peermsgs *, int isInterested );
+void tr_peerMsgsSetInterested( tr_peermsgs *, bool clientIsInterested );
void tr_peerMsgsHave( tr_peermsgs * msgs,
uint32_t pieceIndex );