]> granicus.if.org Git - transmission/commitdiff
(trunk libT) the functions tr_peerMsgsSetChoke() and tr_peerMsgsSetInterested() have...
authorJordan Lee <jordan@transmissionbt.com>
Sun, 1 May 2011 19:10:34 +0000 (19:10 +0000)
committerJordan Lee <jordan@transmissionbt.com>
Sun, 1 May 2011 19:10:34 +0000 (19:10 +0000)
libtransmission/peer-msgs.c
libtransmission/peer-msgs.h

index aa868f7ea84643581b2880a5a1b650902c9004ca..899e712479b894e774018b0dcd5f7fb6cbc3b426 100644 (file)
@@ -668,12 +668,12 @@ updateInterest( tr_peermsgs * msgs UNUSED )
 }
 
 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
@@ -716,25 +716,25 @@ cancelAllRequestsToClient( tr_peermsgs * msgs )
 }
 
 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;
     }
 }
index 4960f021a8800649d25a7b80be8c5306900bb565..29dc5f6f2c482071ce18cd39d285e29c9aa75e1f 100644 (file)
@@ -37,11 +37,11 @@ tr_peermsgs* tr_peerMsgsNew( struct tr_torrent    * torrent,
                              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 );