Changeset 7320

Timestamp:

Dec 8, 2008, 8:23:10 PM (13 years ago)

Author:

charles

Message:

(libT) #1577: honor the peer's BEP 10 reqq key, if they provide it.

File:

• trunk/libtransmission/peer-msgs.c (modified) (3 diffs)

trunk/libtransmission/peer-msgs.c

@@ -307 +307 @@
 
     tr_pex *              pex;
+
+    /* if the peer supports the Extension Protocol in BEP 10 and
+       supplied a reqq argument, it's stored here.  otherwise the
+       value is zero and should be ignored. */
+    int64_t               reqq;
 };
 
@@ -1145 +1150 @@
         dbgmsg( msgs, "msgs->port is now %hu", msgs->info->port );
     }
+
+    /* get peer's maximum request queue size */
+    if( tr_bencDictFindInt( &val, "reqq", &i ) )
+        msgs->reqq = i;
 
     tr_bencFree( &val );
@@ -1723 +1732 @@
 
 static int
-ratePulse( void * vpeer )
-{
-    tr_peermsgs * peer = vpeer;
-    const double rateToClient = tr_peerGetPieceSpeed( peer->info,
-                                                      TR_PEER_TO_CLIENT );
+ratePulse( void * vmsgs )
+{
+    tr_peermsgs * msgs = vmsgs;
+    const double rateToClient = tr_peerGetPieceSpeed( msgs->info, TR_PEER_TO_CLIENT );
     const int estimatedBlocksInNext30Seconds =
-                  ( rateToClient * 30 * 1024 ) / peer->torrent->blockSize;
-
-    peer->minActiveRequests = 8;
-    peer->maxActiveRequests = peer->minActiveRequests + estimatedBlocksInNext30Seconds;
+                  ( rateToClient * 30 * 1024 ) / msgs->torrent->blockSize;
+    msgs->minActiveRequests = 8;
+    msgs->maxActiveRequests = msgs->minActiveRequests + estimatedBlocksInNext30Seconds;
+    if( msgs->reqq > 0 )
+        msgs->maxActiveRequests = MIN( msgs->maxActiveRequests, msgs->reqq );
     return TRUE;
 }