Changeset 8910

Timestamp:

Aug 13, 2009, 2:47:56 PM (13 years ago)

Author:

charles

Message:

(trunk libT) fix #2162: .resume file doesn't get saved often enough when its contents change

Location:

trunk/libtransmission

Files:

• session.c (modified) (4 diffs)
• session.h (modified) (1 diff)
• torrent.c (modified) (2 diffs)
• torrent.h (modified) (1 diff)

trunk/libtransmission/session.c

@@ -47 +47 @@
 #include "version.h"
 #include "web.h"
+
+enum
+{
+    SAVE_INTERVAL_SECS = 120
+};
+
 
 #define dbgmsg( ... ) \
@@ -531 +537 @@
 }
 
+/***
+****
+***/
+
+/**
+ * Periodically save the .resume files of any torrents whose
+ * status has recently changed.  This prevents loss of metadata
+ * in the case of a crash, unclean shutdown, clumsy user, etc.
+ */
+static void
+onSaveTimer( int foo UNUSED, short bar UNUSED, void * vsession )
+{
+    tr_torrent * tor = NULL;
+    tr_session * session = vsession;
+
+    while(( tor = tr_torrentNext( session, tor )))
+        tr_torrentSave( tor );
+
+    tr_timerAdd( session->saveTimer, SAVE_INTERVAL_SECS, 0 );
+}
+
+/***
+****
+***/
+
 static void tr_sessionInitImpl( void * );
 static void onAltTimer( int, short, void* );
@@ -835 +866 @@
     setAltTimer( session );
 
+    session->saveTimer = tr_new0( struct event, 1 );
+    evtimer_set( session->saveTimer, onSaveTimer, session );
+    tr_timerAdd( session->saveTimer, SAVE_INTERVAL_SECS, 0 );
+
     /* first %s is the application name
        second %s is the version number */
@@ -1423 +1458 @@
     if( session->isDHTEnabled )
         tr_dhtUninit( session );
+
+    evtimer_del( session->saveTimer );
+    tr_free( session->saveTimer );
+    session->saveTimer = NULL;
 
     evtimer_del( session->altTimer );

trunk/libtransmission/session.h

@@ -125 +125 @@
 
     struct event               * altTimer;
+    struct event               * saveTimer;
 
     /* the size of the output buffer for peer connections */

trunk/libtransmission/torrent.c

@@ -1355 +1355 @@
 }
 
+void
+tr_torrentSave( tr_torrent * tor )
+{
+    assert( tr_isTorrent( tor ) );
+
+    if( tor->isDirty ) {
+        tor->isDirty = FALSE;
+        tr_torrentSaveResume( tor );
+    }
+}
+
 static void
 stopTorrent( void * vtor )
@@ -1368 +1379 @@
     tr_fdTorrentClose( tor->uniqueId );
 
-    if( tor->isDirty ) {
-        tor->isDirty = 0;
-        if( !tor->isDeleting )
-            tr_torrentSaveResume( tor );
-    }
+    if( !tor->isDeleting )
+        tr_torrentSave( tor );
 }
 

trunk/libtransmission/torrent.h

@@ -119 +119 @@
 void             tr_torrentCheckSeedRatio( tr_torrent * tor );
 
+/** save a torrent's .resume file if it's changed since the last time it was saved */
+void             tr_torrentSave( tr_torrent * tor );
+