Changeset 7137

Timestamp:

Nov 23, 2008, 4:31:28 PM (12 years ago)

Author:

charles

Message:

(libT) #1468: speed display is very jumpy

Location:

trunk/libtransmission

Files:

• peer-io.c (modified) (9 diffs)
• peer-io.h (modified) (1 diff)
• peer-mgr.c (modified) (17 diffs)

trunk/libtransmission/peer-io.c

@@ -31 +31 @@
 #include "net.h"
 #include "peer-io.h"
-#include "ratecontrol.h"
 #include "trevent.h"
 #include "utils.h"
@@ -73 +72 @@
 struct tr_bandwidth
 {
-    unsigned int    isUnlimited : 1;
-    size_t          bytesUsed;
-    size_t          bytesLeft;
+    unsigned int  isUnlimited : 1;
+    size_t        bytesLeft;
 };
 
@@ -221 +219 @@
                 struct tr_bandwidth * b = &io->bandwidth[TR_UP];
                 b->bytesLeft -= MIN( b->bytesLeft, n );
-                b->bytesUsed += n;
             }
 
@@ -257 +254 @@
         struct tr_bandwidth * b = io->bandwidth + TR_DOWN;
         b->bytesLeft -= MIN( b->bytesLeft, (size_t)n );
-        b->bytesUsed += n;
-        dbgmsg( io, "%zu new input bytes. bytesUsed is %zu, bytesLeft is %zu", n, b->bytesUsed, b->bytesLeft );
+        dbgmsg( io, "%zu new input bytes. bytesLeft is %zu", n, b->bytesLeft );
 
         adjustInputBuffer( io );
@@ -617 +613 @@
 
 size_t
-tr_peerIoGetBandwidthUsed( const tr_peerIo * io,
-                           tr_direction      direction )
-{
-    assert( io );
-    assert( direction == TR_UP || direction == TR_DOWN );
-    return io->bandwidth[direction].bytesUsed;
-}
-
-size_t
 tr_peerIoGetWriteBufferSpace( const tr_peerIo * io )
 {
@@ -650 +637 @@
 
 void
-tr_peerIoSetBandwidth( tr_peerIo *  io,
-                       tr_direction direction,
-                       size_t       bytesLeft )
+tr_peerIoAllocateBandwidth( tr_peerIo     * io,
+                            tr_direction    direction,
+                            size_t          bytesLeft )
 {
     struct tr_bandwidth * b;
@@ -661 +648 @@
     b = io->bandwidth + direction;
     b->isUnlimited = 0;
-    b->bytesUsed = 0;
     b->bytesLeft = bytesLeft;
 
@@ -679 +665 @@
     b = io->bandwidth + direction;
     b->isUnlimited = 1;
-    b->bytesUsed = 0;
     b->bytesLeft = 0;
 
@@ -883 +868 @@
     return time( NULL ) - io->timeCreated;
 }
-

trunk/libtransmission/peer-io.h

@@ -199 +199 @@
 **/
 
-size_t            tr_peerIoGetBandwidthUsed( const tr_peerIo * io,
-                                             tr_direction      direction );
-
 size_t            tr_peerIoGetWriteBufferSpace( const tr_peerIo * io );
 
-void              tr_peerIoSetBandwidth( tr_peerIo *  io,
-                                         tr_direction direction,
-                                         size_t       bytesLeft );
+void              tr_peerIoAllocateBandwidth( tr_peerIo *  io,
+                                              tr_direction direction,
+                                              size_t       bytesLeft );
 
 void              tr_peerIoSetBandwidthUnlimited( tr_peerIo *  io,

trunk/libtransmission/peer-mgr.c

@@ -68 +68 @@
     /* number of unchoked peers per torrent.
      * FIXME: this probably ought to be configurable */
-    MAX_UNCHOKED_PEERS = 12,
+    MAX_UNCHOKED_PEERS = 14,
 
     /* number of bad pieces a peer is allowed to send before we ban them */
@@ -131 +131 @@
     tr_ptrArray     * incomingHandshakes; /* tr_handshake */
     tr_timer        * bandwidthTimer;
-    tr_ratecontrol  * globalPoolRawSpeed[2];
 };
 
@@ -521 +520 @@
     m->torrents = tr_ptrArrayNew( );
     m->incomingHandshakes = tr_ptrArrayNew( );
-    m->globalPoolRawSpeed[TR_CLIENT_TO_PEER] = tr_rcInit( );
-    m->globalPoolRawSpeed[TR_PEER_TO_CLIENT] = tr_rcInit( );
     m->bandwidthTimer = tr_timerNew( session, bandwidthPulse, m, BANDWIDTH_PERIOD_MSEC );
     return m;
@@ -533 +530 @@
 
     tr_timerFree( &manager->bandwidthTimer );
-    tr_rcClose( manager->globalPoolRawSpeed[TR_CLIENT_TO_PEER] );
-    tr_rcClose( manager->globalPoolRawSpeed[TR_PEER_TO_CLIENT] );
 
     /* free the handshakes.  Abort invokes handshakeDoneCB(), which removes
@@ -2363 +2358 @@
 ****/
 
+#if 0
+#define DEBUG_DIRECTION TR_UP
+#endif
+
 static double
-allocateHowMuch( double                  desired_average_kb_per_sec,
-                 const tr_ratecontrol  * ratecontrol )
+bytesPerPulse( double KiB_per_second )
+{
+    return KiB_per_second * ( 1024.0 * BANDWIDTH_PERIOD_MSEC / 1000.0 );
+}
+
+/*
+ * @param currentSpeed current speed in KiB/s
+ * @param desiredSpeed desired speed in KiB/s
+ */
+static double
+allocateHowMuch( tr_direction dir UNUSED, double currentSpeed, double desiredSpeed )
 {
     const int pulses_per_history = TR_RATECONTROL_HISTORY_MSEC / BANDWIDTH_PERIOD_MSEC;
-    const double seconds_per_pulse = BANDWIDTH_PERIOD_MSEC / 1000.0;
-    const double baseline_bytes_per_pulse = desired_average_kb_per_sec * 1024.0 * seconds_per_pulse;
-    const double min = baseline_bytes_per_pulse * 0.80;
-    const double max = baseline_bytes_per_pulse * 1.20;
-    const double current_bytes_per_pulse = tr_rcRate( ratecontrol ) * 1024.0 * seconds_per_pulse;
-    const double next_pulse_bytes = baseline_bytes_per_pulse * ( pulses_per_history + 1 )
+    const double current_bytes_per_pulse = bytesPerPulse( currentSpeed );
+    const double desired_bytes_per_pulse = bytesPerPulse( desiredSpeed );
+    const double min = desired_bytes_per_pulse * 0.90;
+    const double max = desired_bytes_per_pulse * 1.25;
+    const double next_pulse_bytes = desired_bytes_per_pulse * ( pulses_per_history + 1 )
                                   - ( current_bytes_per_pulse * pulses_per_history );
     double clamped;
@@ -2382 +2389 @@
     clamped = MIN( clamped, max );
 
-#if 0
-fprintf( stderr, "desiredAvgKB is %5.2f, rate is %5.2f, allocating %5.2f (%5.2f)\n",
-         desired_average_kb_per_sec,
-         tr_rcRate( ratecontrol ),
+#ifdef DEBUG_DIRECTION
+if( dir == DEBUG_DIRECTION )
+fprintf( stderr, "currentSpeed(%5.2f) desiredSpeed(%5.2f), allocating %5.2f (%5.2f)\n",
+         currentSpeed,
+         desiredSpeed,
          clamped/1024.0,
          next_pulse_bytes/1024.0 );
@@ -2392 +2400 @@
     return clamped;
 }
-
 /**
  * Distributes a fixed amount of bandwidth among a set of peers.
@@ -2398 +2405 @@
  * @param peerArray peers whose client-to-peer bandwidth will be set
  * @param direction whether to allocate upload or download bandwidth
- * @param history recent bandwidth history for these peers
- * @param desiredAvgKB overall bandwidth goal for this set of peers
+ * @param currentSpeed current speed in KiB/s for this set of peers
+ * @param desiredSpeed desired speed in KiB/s for this set of peers
  */
 static void
 setPeerBandwidth( tr_ptrArray          * peerArray,
                   const tr_direction     direction,
-                  const tr_ratecontrol * ratecontrol,
-                  double                 desiredAvgKB )
-{
-    const int    peerCount = tr_ptrArraySize( peerArray );
-    const double bytes = allocateHowMuch( desiredAvgKB, ratecontrol );
-    const double welfareBytes = MIN( 2048, bytes * 0.2 );
-    const double meritBytes = MAX( 0, bytes - welfareBytes );
-    tr_peer **   peers = (tr_peer**) tr_ptrArrayBase( peerArray );
+                  double                 currentSpeed,
+                  double                 desiredSpeed )
+{
+    const int    MINIMUM_WELFARE_BYTES = bytesPerPulse( 5 );
     int          i;
     double       welfare;
-    size_t       bytesUsed;
-
-    assert( meritBytes >= 0.0 );
-    assert( welfareBytes >= 0.0 );
-    assert( direction == TR_UP || direction == TR_DOWN );
-
-    for( i=bytesUsed=0; i<peerCount; ++i )
-        bytesUsed += tr_peerIoGetBandwidthUsed( peers[i]->io, direction );
-
-   welfare = welfareBytes / peerCount; 
+    double       meritBytes;
+    double       meritMultiplier;
+    double       welfareBytes;
+    const int    peerCount      = tr_ptrArraySize( peerArray );
+    const double bytes          = allocateHowMuch( direction, currentSpeed, desiredSpeed );
+    tr_peer **   peers          = (tr_peer**) tr_ptrArrayBase( peerArray );
+
+    /* how many bytes we'll allocate based on merit. 
+     *
+     * 1. When just getting started we want to give all the peers a lot
+     *    of `welfare' allocation because we don't know which ones will
+     *    turn out to be productive for us.
+     *
+     * 2. When we've reached steady state and are near our bandwidth limit,
+     *    the bandwidth spent on `welfare' is going to come from peers that
+     *    we already know are productive... which is probably a waste.
+     *
+     * 3. So we tie the merit/welfare allocations to the current speed.
+     *    the closer the current speed gets to the maximum speed, the less
+     *    welfare we allocate.
+     *
+     * 4. We always need to allocate /some/ welfare bytes, otherwise
+     *    the other peers will starve.
+     */
+    meritBytes = bytesPerPulse( MIN( currentSpeed * 1.2, desiredSpeed ) );
+    welfareBytes = bytes > meritBytes ?  bytes - meritBytes : 0;
+    if( welfareBytes < MINIMUM_WELFARE_BYTES )
+        welfareBytes = MINIMUM_WELFARE_BYTES;
+    meritBytes = bytes - welfareBytes;
+    meritMultiplier = currentSpeed > 0.01 ?  meritBytes / currentSpeed : 0.0;
+
+#ifdef DEBUG_DIRECTION
+if( direction == DEBUG_DIRECTION )
+fprintf( stderr, "currentSpeed(%5.2f) desiredSpeed(%5.2f) - k[%.1f] merit [%.1f] welfare [%.1f]\n", currentSpeed, desiredSpeed, bytes/1024.0, meritBytes/1024.0, welfareBytes/1024.0 );
+#endif
+
+    /* how much welfare each peer gets */
+    welfare = welfareBytes / peerCount; 
 
     for( i=0; i<peerCount; ++i )
     {
         tr_peer * peer = peers[i];
-        const double merit = bytesUsed
-                           ? ( meritBytes * tr_peerIoGetBandwidthUsed( peer->io, direction ) ) / bytesUsed
-                           : ( meritBytes / peerCount );
-        tr_peerIoSetBandwidth( peer->io, direction, merit + welfare );
-    }
-}
-
-static size_t
-countHandshakeBandwidth( tr_ptrArray * handshakes,
-                         tr_direction  direction )
-{
-    const int n = tr_ptrArraySize( handshakes );
-    int       i;
-    size_t    total;
-
-    for( i = total = 0; i < n; ++i )
-    {
-        tr_peerIo * io = tr_handshakeGetIO( tr_ptrArrayNth( handshakes, i ) );
-        total += tr_peerIoGetBandwidthUsed( io, direction );
-    }
-    return total;
-}
-
-static size_t
-countPeerBandwidth( tr_ptrArray * peers,
-                    tr_direction  direction )
-{
-    const int n = tr_ptrArraySize( peers );
-    int       i;
-    size_t    total;
-
-    for( i = total = 0; i < n; ++i )
-    {
-        tr_peer * peer = tr_ptrArrayNth( peers, i );
-        total += tr_peerIoGetBandwidthUsed( peer->io, direction );
-    }
-    return total;
+        const size_t merit = tr_rcRate( peers[i]->pieceSpeed[direction] ) * meritMultiplier;
+        tr_peerIoAllocateBandwidth( peer->io, direction, merit + welfare );
+    }
 }
 
@@ -2500 +2497 @@
 static void
 getBandwidthPeers( Torrent       * t,
-                   tr_direction    direction,
-                   tr_ptrArray   * appendme )
+                   tr_direction    dir,
+                   tr_ptrArray   * appendme,
+                   double        * speed )
 {
     int i, peerCount;
     tr_peer ** peers;
 
+    assert( t );
     assert( torrentIsLocked( t ) );
+    assert( dir == TR_UP || dir == TR_DOWN );
+    assert( appendme );
+    assert( speed );
 
     peers = (tr_peer **) tr_ptrArrayPeek( t->peers, &peerCount );
 
     for( i=0; i<peerCount; ++i )
-        if( peers[i]->msgs )
-            if(    ( ( direction == TR_PEER_TO_CLIENT ) && clientIsDownloadingFrom( peers[i] ) )
-                || ( ( direction == TR_CLIENT_TO_PEER ) && clientIsUploadingTo( peers[i] ) ) )
-                    tr_ptrArrayAppend( appendme, peers[i] );
+    {
+        tr_peer * p = peers[i];
+
+        if( p->msgs )
+        {
+            if( ( ( dir == TR_DOWN ) && clientIsDownloadingFrom( p ) ) || ( ( dir == TR_UP ) && clientIsUploadingTo( p ) ) )
+            {
+                tr_ptrArrayAppend( appendme, p );
+                *speed += tr_rcRate( p->pieceSpeed[dir] );
+            }
+        }
+    }
 }
 
@@ -2524 +2534 @@
  * @return the amount of directional bandwidth used since the last pulse.
  */
-static double
+static void
 allocateBandwidth( tr_peerMgr * mgr,
                    tr_direction direction )
@@ -2532 +2542 @@
     Torrent **    torrents = (Torrent **) tr_ptrArrayBase( mgr->torrents );
     tr_ptrArray * globalPool = tr_ptrArrayNew( );
-    double        allBytesUsed = 0;
-    size_t        poolBytesUsed = 0;
+    double        globalPoolSpeed = 0;
     int           i;
 
@@ -2545 +2554 @@
     {
         Torrent * t = torrents[i];
-        size_t used;
         tr_speedlimit speedMode;
 
@@ -2551 +2559 @@
         if( tr_torrentGetActivity( t->tor ) == TR_STATUS_STOPPED )
             continue;
-
-        used = countPeerBandwidth( t->peers, direction );
-        countHandshakeBandwidth( t->outgoingHandshakes, direction );
-
-        /* remember this torrent's bytes used */
-        tr_rcTransferred( t->tor->rawSpeed[direction], used );
-
-        /* add this torrent's bandwidth use to allBytesUsed */
-        allBytesUsed += used;
 
         /* if piece data is disallowed, don't bother limiting bandwidth --
@@ -2575 +2574 @@
                 break;
 
-            case TR_SPEEDLIMIT_SINGLE:
-            {
+            case TR_SPEEDLIMIT_SINGLE: {
                 tr_ptrArray * peers = tr_ptrArrayNew( );
-                getBandwidthPeers( t, direction, peers );
-                setPeerBandwidth( peers, direction,
-                                  t->tor->rawSpeed[direction],
-                                  tr_torrentGetSpeedLimit( t->tor, direction ) );
+                double speed = 0;
+                getBandwidthPeers( t, direction, peers, &speed );
+                setPeerBandwidth( peers, direction, speed, tr_torrentGetSpeedLimit( t->tor, direction ) );
                 tr_ptrArrayFree( peers, NULL );
                 break;
@@ -2587 +2584 @@
 
             case TR_SPEEDLIMIT_GLOBAL:
-                getBandwidthPeers( t, direction, globalPool );
-                poolBytesUsed += used;
+                getBandwidthPeers( t, direction, globalPool, &globalPoolSpeed );
                 break;
         }
     }
-
-    /* add incoming handshakes to the global pool */
-    i = countHandshakeBandwidth( mgr->incomingHandshakes, direction );
-    allBytesUsed += i;
-    poolBytesUsed += i;
-
-    tr_rcTransferred( mgr->globalPoolRawSpeed[direction], poolBytesUsed );
 
     /* handle the global pool's connections */
@@ -2604 +2593 @@
         givePeersUnlimitedBandwidth( globalPool, direction );
     else
-        setPeerBandwidth( globalPool, direction,
-                          mgr->globalPoolRawSpeed[direction],
+        setPeerBandwidth( globalPool, direction, globalPoolSpeed,
                           tr_sessionGetSpeedLimit( session, direction ) );
 
@@ -2613 +2601 @@
     /* cleanup */
     tr_ptrArrayFree( globalPool, NULL );
-    return allBytesUsed;
 }