Changeset 4608

Timestamp:

Jan 11, 2008, 2:09:20 AM (14 years ago)

Author:

charles

Message:

follow the spec's suggestion that new connections be 3x as likely for optimistic unchoke

Location:

trunk/libtransmission

Files:

• peer-io.c (modified) (3 diffs)
• peer-io.h (modified) (1 diff)
• peer-mgr.c (modified) (4 diffs)
• torrent-ctor.c (modified) (1 diff)

trunk/libtransmission/peer-io.c

@@ -59 +59 @@
     struct bufferevent * bufev;
     uint8_t peerId[20];
+    time_t timeCreated;
 
     tr_extensions extensions;
@@ -147 +148 @@
     c->isIncoming = isIncoming ? 1 : 0;
     c->timeout = IO_TIMEOUT_SECS;
+    c->timeCreated = time( NULL );
     c->bufev = bufferevent_new( c->socket,
                                 canReadWrapper,
@@ -583 +585 @@
     tr_free( tmp );
 }
+
+int
+tr_peerGetAge( const tr_peerIo * io )
+{
+    return time( NULL ) - io->timeCreated;
+}

trunk/libtransmission/peer-io.h

@@ -81 +81 @@
 int   tr_peerIoIsIncoming( const tr_peerIo * io );
 
-void tr_peerIoSetTimeoutSecs( tr_peerIo * io, int secs );
+void  tr_peerIoSetTimeoutSecs( tr_peerIo * io, int secs );
+
+int   tr_peerIoGetAge( const tr_peerIo * io );
 
 

trunk/libtransmission/peer-mgr.c

@@ -141 +141 @@
     tr_timer * swiftTimer;
     tr_torrent * tor;
+    tr_peer * optimistic; /* the optimistic peer, or NULL if none */
     tr_bitfield * requested;
 
@@ -1481 +1482 @@
 
         pch = stat->flagStr;
+        if( t->optimistic == peer ) *pch++ = 'O';
         if( stat->isDownloadingFrom ) *pch++ = 'D';
         else if( stat->clientIsInterested ) *pch++ = 'd';
@@ -1518 +1520 @@
     const struct ChokeData * b = vb;
     return -tr_compareUint32( a->rate, b->rate );
+}
+
+static int
+isNew( const tr_peer * peer )
+{
+    return peer && peer->io && tr_peerIoGetAge( peer->io ) < 45;
+}
+
+static int
+isSame( const tr_peer * peer )
+{
+    return peer && peer->client && strstr( peer->client, "Transmission" );
 }
 
@@ -1581 +1595 @@
 
     /* optimistic unchoke */
-    if( i != size ) {
-        i = n + tr_rand( size - n );
-        choke[i].doUnchoke = 1;
+    if( i < size )
+    {
+        struct ChokeData * c;
+        tr_ptrArray * randPool = tr_ptrArrayNew( );
+        for( ; i<size; ++i )
+        {
+            const tr_peer * peer = choke[i].peer;
+            int x=1, y;
+            if( isNew( peer ) ) x *= 3;
+            if( isSame( peer ) ) x *= 3;
+            for( y=0; y<x; ++y )
+                tr_ptrArrayAppend( randPool, choke );
+        }
+        i = tr_rand( tr_ptrArraySize( randPool ) );
+        c = ( struct ChokeData* )tr_ptrArrayNth( randPool, i);
+        c->doUnchoke = 1;
+        t->optimistic = c->peer;
+        tr_ptrArrayFree( randPool, NULL );
     }
 

trunk/libtransmission/torrent-ctor.c

@@ -18 +18 @@
 #include "utils.h"
 
-#define DEFAULT_MAX_UNCHOKED_PEERS 16
+#define DEFAULT_MAX_UNCHOKED_PEERS 12
 #define DEFAULT_MAX_CONNECTED_PEERS 50