Changeset 7584

Timestamp:

Jan 2, 2009, 8:42:35 PM (14 years ago)

Author:

charles

Message:

(trunk libT) avoid some unnecessary memory fragmentation... for composited objects that have a tr_ratecontrol, contain the it directly rather than a pointer to one allocated elsewhere on the heap.

Location:

trunk/libtransmission

Files:

• peer-msgs.c (modified) (1 diff)
• ratecontrol.c (modified) (4 diffs)
• ratecontrol.h (modified) (1 diff)
• torrent.c (modified) (3 diffs)
• torrent.h (modified) (2 diffs)
• webseed.c (modified) (5 diffs)

trunk/libtransmission/peer-msgs.c

@@ -1458 +1458 @@
             }
             updatePeerProgress( msgs );
-            tr_rcTransferred( msgs->torrent->swarmSpeed,
+            tr_rcTransferred( &msgs->torrent->swarmSpeed,
                               msgs->torrent->info.pieceSize );
             break;

trunk/libtransmission/ratecontrol.c

@@ -30 +30 @@
 #include "utils.h"
 
-enum
-{
-    INTERVAL_MSEC = TR_RATECONTROL_HISTORY_MSEC,
-
-    GRANULARITY_MSEC = 250,
-
-    HISTORY_SIZE = ( INTERVAL_MSEC / GRANULARITY_MSEC )
-};
-
-struct tr_transfer
-{
-    uint64_t    date;
-    uint64_t    size;
-};
-
-struct tr_ratecontrol
-{
-    int                   newest;
-    struct tr_transfer    transfers[HISTORY_SIZE];
-};
-
 /* return the xfer rate over the last `interval' seconds in KiB/sec */
 static float
@@ -67 +46 @@
         bytes += r->transfers[i].size;
 
-        if( --i == -1 ) i = HISTORY_SIZE - 1; /* circular history */
+        if( --i == -1 ) i = TR_RC_HISTORY_SIZE - 1; /* circular history */
         if( i == r->newest ) break; /* we've come all the way around */
     }
 
     return ( bytes / 1024.0 ) * ( 1000.0 / interval_msec );
-}
-
-/***
-****
-***/
-
-tr_ratecontrol*
-tr_rcInit( void )
-{
-    return tr_new0( tr_ratecontrol, 1 );
-}
-
-void
-tr_rcClose( tr_ratecontrol * r )
-{
-    memset( r, 0, sizeof( tr_ratecontrol ) );
-    tr_free( r );
 }
 
@@ -101 +63 @@
 
     if( r )
-        ret = rateForInterval( r, INTERVAL_MSEC );
+        ret = rateForInterval( r, TR_RC_HISTORY_MSEC );
 
     return ret;
@@ -116 +78 @@
     const uint64_t now = tr_date ( );
 
-    if( r->transfers[r->newest].date + GRANULARITY_MSEC >= now )
+    if( r->transfers[r->newest].date + TR_RC_GRANULARITY_MSEC >= now )
         r->transfers[r->newest].size += size;
     else
     {
-        if( ++r->newest == HISTORY_SIZE ) r->newest = 0;
+        if( ++r->newest == TR_RC_HISTORY_SIZE ) r->newest = 0;
         r->transfers[r->newest].date = now;
         r->transfers[r->newest].size = size;

trunk/libtransmission/ratecontrol.h

@@ -30 +30 @@
 #define _TR_RATECONTROL_H_
 
+#include <string.h> /* memset() */
+
+#include "transmission.h"
+
+/* these are PRIVATE IMPLEMENTATION details that should not be touched.
+ * it's included in the header for inlining and composition. */
 enum
 {
-    TR_RATECONTROL_HISTORY_MSEC = 2000
+    TR_RC_HISTORY_MSEC = 2000,
+    TR_RC_GRANULARITY_MSEC = 250,
+    TR_RC_HISTORY_SIZE = ( TR_RC_HISTORY_MSEC / TR_RC_GRANULARITY_MSEC )
 };
 
-typedef struct tr_ratecontrol tr_ratecontrol;
+/* these are PRIVATE IMPLEMENTATION details that should not be touched.
+ * it's included in the header for inlining and composition. */
+struct tr_transfer
+{
+    uint64_t    date;
+    uint64_t    size;
+};
 
+/* these are PRIVATE IMPLEMENTATION details that should not be touched.
+ * it's included in the header for inlining and composition. */
+typedef struct tr_ratecontrol
+{
+    int                   newest;
+    struct tr_transfer    transfers[TR_RC_HISTORY_SIZE];
+}
+tr_ratecontrol;
 
-tr_ratecontrol * tr_rcInit        ( void );
+/***
+****
+***/
 
-void             tr_rcClose       ( tr_ratecontrol         * ratecontrol );
+static inline void tr_rcConstruct ( tr_ratecontrol * rc ) { memset( rc, 0, sizeof( tr_ratecontrol ) ); }
+
+static inline void tr_rcDestruct  ( tr_ratecontrol * rc ) { memset( rc, 0xDEAD, sizeof( tr_ratecontrol ) ); }
 
 void             tr_rcTransferred ( tr_ratecontrol         * ratecontrol,

trunk/libtransmission/torrent.c

@@ -502 +502 @@
     tr_torrentInitFilePieces( tor );
 
-    tor->swarmSpeed = tr_rcInit( );
+    tr_rcConstruct( &tor->swarmSpeed );
 
     tr_sha1( tor->obfuscatedHash, "req2", 4,
@@ -793 +793 @@
                        : 0.0;
 
-    s->swarmSpeed = tr_rcRate( tor->swarmSpeed );
+    s->swarmSpeed = tr_rcRate( &tor->swarmSpeed );
 
     s->activityDate = tor->activityDate;
@@ -1035 +1035 @@
     tr_cpDestruct( &tor->completion );
 
-    tr_rcClose( tor->swarmSpeed );
+    tr_rcDestruct( &tor->swarmSpeed );
 
     tr_trackerUnsubscribe( tor->tracker, tor->trackerSubscription );

trunk/libtransmission/torrent.h

@@ -31 +31 @@
 
 #include "completion.h" /* tr_completion */
+#include "ratecontrol.h" /* tr_ratecontrol */
 #include "session.h" /* tr_globalLock(), tr_globalUnlock() */
 #include "utils.h" /* tr_bitfield */
@@ -147 +148 @@
     tr_speedlimit            speedLimitMode[2];
 
-    struct tr_ratecontrol *  swarmSpeed;
+    struct tr_ratecontrol    swarmSpeed;
 
     int                      error;

trunk/libtransmission/webseed.c

@@ -41 +41 @@
     uint32_t            byteCount;
 
-    tr_ratecontrol    * rateDown;
+    tr_ratecontrol      rateDown;
 
     tr_session        * session;
@@ -170 +170 @@
         {
             fireClientGotData( w, response_byte_count );
-            tr_rcTransferred( w->rateDown, response_byte_count );
+            tr_rcTransferred( &w->rateDown, response_byte_count );
         }
 
@@ -257 +257 @@
     const int isActive = tr_webseedIsActive( w );
 
-    *setme_KiBs = isActive ? tr_rcRate( w->rateDown ) : 0.0f;
+    *setme_KiBs = isActive ? tr_rcRate( &w->rateDown ) : 0.0f;
     return isActive;
 }
@@ -276 +276 @@
     w->session = torrent->session;
     w->content = evbuffer_new( );
-    w->rateDown = tr_rcInit( );
     w->url = tr_strdup( url );
     w->callback = callback;
     w->callback_userdata = callback_userdata;
+    tr_rcConstruct( &w->rateDown );
 /*fprintf( stderr, "w->callback_userdata is %p\n", w->callback_userdata );*/
     return w;
@@ -296 +296 @@
         {
             evbuffer_free( w->content );
-            tr_rcClose( w->rateDown );
+            tr_rcDestruct( &w->rateDown );
             tr_free( w->url );
             tr_free( w );