Changeset 5749

Timestamp:

May 5, 2008, 8:11:03 PM (14 years ago)

Author:

charles

Message:

fix multitracker problem reported by BentMyWookie?

Location:

trunk/libtransmission

Files:

• torrent.c (modified) (4 diffs)
• tracker.c (modified) (10 diffs)

trunk/libtransmission/torrent.c

@@ -299 +299 @@
 
     assert( tor != NULL );
-    assert( 0 <= pos && pos < tor->info.trackerCount );
-
+    assert( ( 0 <= pos ) && ( pos < tor->info.trackerCount ) );
+
+    /* the tier of the tracker we're promoting */
     tier = tor->info.trackers[pos].tier;
 
-    /* find the index of the first tracker in that tier */
+    /* find the index of that tier's first tracker */
     for( i=0; i<tor->info.trackerCount; ++i )
         if( tor->info.trackers[i].tier == tier )
@@ -310 +311 @@
     assert( i < tor->info.trackerCount );
 
-    /* swap them if they're not the same */
+    /* promote the tracker at `pos' to the front of the tier */
     if( i != pos ) {
-        tr_tracker_info tmp = tor->info.trackers[i];
+        const tr_tracker_info tmp = tor->info.trackers[i];
         tor->info.trackers[i] = tor->info.trackers[pos];
         tor->info.trackers[pos] = tmp;
@@ -327 +328 @@
 };
 
+/* the tiers will be sorted from lowest to highest,
+ * and trackers are randomized within the tiers */
 static int
 compareRandomTracker( const void * va, const void * vb )
@@ -344 +347 @@
     int i;
     const int n = info->trackerCount;
-    struct RandomTracker * r;
-    r = tr_new0( struct RandomTracker, n );
+    struct RandomTracker * r = tr_new0( struct RandomTracker, n );
     for( i=0; i<n; ++i ) {
         r[i].tracker = info->trackers[i];

trunk/libtransmission/tracker.c

@@ -225 +225 @@
 static void onReqDone( tr_session * session );
 
-static void
-updateAddresses( tr_tracker  * t,
-                 long          response_code,
-                 int           moveToNextAddress,
-                 int         * tryAgain )
-{
+static int
+updateAddresses( tr_tracker  * t, int success )
+{
+    int retry;
+
     tr_torrent * torrent = tr_torrentFindFromHash( t->session, t->hash );
 
-
-    if( !response_code ) /* tracker didn't respond */
-    {
-        tr_ninf( t->name, _( "Tracker hasn't responded yet.  Retrying..." ) );
-        moveToNextAddress = TRUE;
-    }
-    else if( response_code == HTTP_OK )
+    if( success )
     {
         /* multitracker spec: "if a connection with a tracker is
            successful, it will be moved to the front of the tier." */
         t->trackerIndex = tr_torrentPromoteTracker( torrent, t->trackerIndex );
-    }
-    else 
-    {
-        moveToNextAddress = TRUE;
-    }
-
-    *tryAgain = moveToNextAddress;
-    if( moveToNextAddress )
-    {
-        if ( ++t->trackerIndex >= torrent->info.trackerCount ) /* we've tried them all */
-        {
-            *tryAgain = FALSE;
-            t->trackerIndex = 0;
-        }
-        else
-        {
-            const tr_tracker_info * n = getCurrentAddressFromTorrent( t, torrent );
-            tr_ninf( t->name, _( "Trying tracker \"%s\"" ), n->announce );
-        }
-    }
+        retry = FALSE; /* we succeeded; no need to retry */
+    }
+    else if ( ++t->trackerIndex >= torrent->info.trackerCount )
+    {
+        t->trackerIndex = 0;
+        retry = FALSE; /* we've tried them all */
+    }
+    else
+    {
+        const tr_tracker_info * n = getCurrentAddressFromTorrent( t, torrent );
+        tr_ninf( t->name, _( "Trying tracker \"%s\"" ), n->announce );
+        retry = TRUE;
+    }
+
+    return retry;
 }
 
@@ -322 +310 @@
                    void          * torrent_hash )
 {
-    int moveToNextAddress = FALSE;
-    int tryAgain;
+    int retry;
+    int success = FALSE;
     tr_tracker * t;
 
@@ -348 +336 @@
             const char * str;
 
+            success = TRUE;
+
             if(( tr_bencDictFindStr( &benc, "failure reason", &str ))) {
                // publishErrorMessageAndStop( t, str );
-                moveToNextAddress = TRUE;
                 publishMessage( t, str, TR_TRACKER_ERROR );
+                success = FALSE;
             }
 
@@ -398 +388 @@
     }
 
-    updateAddresses( t, responseCode, moveToNextAddress, &tryAgain );
+    retry = updateAddresses( t, success );
 
     /**
@@ -404 +394 @@
     **/
 
-    if( tryAgain )
+    if( retry )
         responseCode = 300;
 
@@ -459 +449 @@
                   void         * torrent_hash )
 {
-    int moveToNextAddress = FALSE;
-    int tryAgain;
+    int success = FALSE;
+    int retry;
     tr_tracker * t;
 
@@ -505 +495 @@
                         t->scrapeIntervalSec = i;
 
+                success = TRUE;
+
                 tr_ndbg( t->name, "Scrape successful.  Rescraping in %d seconds.",
                          t->scrapeIntervalSec );
@@ -511 +503 @@
             }
         }
-        else
-            moveToNextAddress = TRUE;
 
         if( bencLoaded )
@@ -518 +508 @@
     }
 
-    updateAddresses( t, responseCode, moveToNextAddress, &tryAgain );
+    retry = updateAddresses( t, success );
 
     /**
@@ -524 +514 @@
     **/
 
-    if( tryAgain )
+    if( retry )
         responseCode = 300;