]> granicus.if.org Git - transmission/commitdiff
(libT) #1417: overhead should be counted in the global stats
authorCharles Kerr <charles@transmissionbt.com>
Tue, 4 Nov 2008 17:37:51 +0000 (17:37 +0000)
committerCharles Kerr <charles@transmissionbt.com>
Tue, 4 Nov 2008 17:37:51 +0000 (17:37 +0000)
libtransmission/peer-io.c
libtransmission/peer-mgr.c
libtransmission/stats.h

index 109a4ed3df0958df993325ffb74112375a5990bf..3e1f46088a8c2cadbdb973c40176a6b3244d298d 100644 (file)
@@ -30,6 +30,7 @@
 #include "net.h"
 #include "peer-io.h"
 #include "ratecontrol.h"
+#include "stats.h"  /* tr_statsAddUploaded(), tr_statsAddDownloaded() */
 #include "trevent.h"
 #include "utils.h"
 
@@ -181,6 +182,7 @@ didWriteWrapper( struct bufferevent * e,
         b->bytesLeft -= MIN( b->bytesLeft, (size_t)n );
         b->bytesUsed += n;
         tr_rcTransferred( io->speedometer[TR_UP], n );
+        tr_statsAddUploaded( io->session, n );
         dbgmsg( io,
                 "wrote %zu bytes to peer... upload bytesLeft is now %zu",
                 n,
@@ -213,6 +215,7 @@ canReadWrapper( struct bufferevent * e,
         b->bytesLeft -= MIN( b->bytesLeft, (size_t)n );
         b->bytesUsed += n;
         tr_rcTransferred( io->speedometer[TR_DOWN], n );
+        tr_statsAddDownloaded( io->session, n );
         dbgmsg( io,
                 "%zu new input bytes. bytesUsed is %zu, bytesLeft is %zu",
                 n, b->bytesUsed,
index 1f8532341879c2aa7d18701a0a8cb156675ff8fa..40a3828a3b2c229da1b88b9fc8bfa7546fa5a0a3 100644 (file)
@@ -31,7 +31,6 @@
 #include "peer-mgr-private.h"
 #include "peer-msgs.h"
 #include "ptrarray.h"
-#include "stats.h" /* tr_statsAddDownloaded */
 #include "torrent.h"
 #include "trevent.h"
 #include "utils.h"
@@ -1008,7 +1007,6 @@ peerCallbackFunc( void * vpeer,
             tr_torrent * tor = t->tor;
             tor->activityDate = now;
             tor->uploadedCur += e->length;
-            tr_statsAddUploaded( tor->session, e->length );
             if( peer )
             {
                 struct peer_atom * a = getExistingAtom( t, &peer->in_addr );
@@ -1030,7 +1028,6 @@ peerCallbackFunc( void * vpeer,
              * into the jurisdiction of the tracker." */
             if( peer )
                 tor->downloadedCur += e->length;
-            tr_statsAddDownloaded( tor->session, e->length );
             if( peer ) {
                 struct peer_atom * a = getExistingAtom( t, &peer->in_addr );
                 a->piece_data_time = now;
index 79e36a3e0bf54bc330d6670b8fd23e76aebdf1ee..262a676eb799131828a4424693b36f18a2fea7bb 100644 (file)
 #ifndef TR_STATS_H
 #define TR_STATS_H
 
-void tr_statsInit( tr_handle * handle );
+void tr_statsInit           ( tr_session  * session );
 
-void tr_statsClose( tr_handle * handle );
+void tr_statsClose          ( tr_session  * session );
 
-void tr_statsAddUploaded( tr_handle * handle,
-                          uint32_t    bytes );
+void tr_statsAddUploaded    ( tr_session  * session,
+                              uint32_t      bytes );
 
-void tr_statsAddDownloaded( tr_handle * handle,
-                            uint32_t    bytes );
+void tr_statsAddDownloaded  ( tr_session  * session,
+                              uint32_t      bytes );
 
-void tr_statsFileCreated( tr_handle * handle );
+void tr_statsFileCreated    ( tr_session  * session );
 
 #endif