Changeset 11148

Timestamp:

Aug 7, 2010, 3:29:47 AM (12 years ago)

Author:

charles

Message:

(trunk libT) #3493 "transmission doesn't exit cleanly if LPD is disabled during the session" -- fixed.

File:

• trunk/libtransmission/session.c (modified) (5 diffs)

trunk/libtransmission/session.c

@@ -643 +643 @@
 
     if( session->isDHTEnabled )
-    {
         tr_dhtInit( session, &session->public_ipv4->addr );
-    }
-
-    if( !session->isLPDEnabled )
-        tr_ndbg( "LPD", _( "Local Peer Discovery disabled" ) );
-    else if( tr_lpdInit( session, &session->public_ipv4->addr ) )
-        tr_ninf( "LPD", _( "Local Peer Discovery active" ) );
+
+    if( session->isLPDEnabled )
+        tr_lpdInit( session, &session->public_ipv4->addr );
 
     /* cleanup */
@@ -1731 +1727 @@
     assert( tr_isSession( session ) );
 
-    dbgmsg( "shutting down transmission session %p", session );
+    dbgmsg( "shutting down transmission session %p... now is %zu, deadline is %zu", session, (size_t)time(NULL), (size_t)deadline );
 
     /* close the session */
@@ -1748 +1744 @@
            && !deadlineReached( deadline ) )
     {
-        dbgmsg( "waiting on port unmap (%p) or announcer (%p)",
-                session->shared, session->announcer );
+        dbgmsg( "waiting on port unmap (%p) or announcer (%p)... now %zu deadline %zu",
+                session->shared, session->announcer, (size_t)time(NULL), (size_t)deadline );
         tr_wait_msec( 100 );
     }
@@ -1760 +1756 @@
     {
         static tr_bool forced = FALSE;
-        dbgmsg( "waiting for libtransmission thread to finish" );
+        dbgmsg( "waiting for libtransmission thread to finish... now %zu deadline %zu", (size_t)time(NULL), (size_t)deadline );
         tr_wait_msec( 500 );
         if( deadlineReached( deadline ) && !forced )
         {
+            dbgmsg( "calling event_loopbreak()" );
+            forced = TRUE;
             event_loopbreak( );
-            forced = TRUE;
-
-            if( time( NULL ) >= deadline + 3 )
-                break;
+        }
+        if( deadlineReached( deadline+3 ) )
+        {
+            dbgmsg( "deadline+3 reached... calling break...\n" );
+            break;
         }
     }
@@ -1910 +1909 @@
 }
 
-void
-tr_sessionSetLPDEnabled( tr_session * session,
-                         tr_bool      enabled )
-{
-    assert( tr_isSession( session ) );
-
-    session->isLPDEnabled = ( enabled != 0 );
+static void
+toggleLPDImpl(  void * data )
+{
+    tr_session * session = data;
+    assert( tr_isSession( session ) );
+
+    if( session->isLPDEnabled )
+        tr_lpdUninit( session );
+
+    session->isLPDEnabled = !session->isLPDEnabled;
+
+    if( session->isLPDEnabled )
+        tr_lpdInit( session, &session->public_ipv4->addr );
+}
+
+void
+tr_sessionSetLPDEnabled( tr_session * session, tr_bool enabled )
+{
+    assert( tr_isSession( session ) );
+    assert( tr_isBool( enabled ) );
+
+    if( ( enabled != 0 ) != ( session->isLPDEnabled != 0 ) )
+        tr_runInEventThread( session, toggleLPDImpl, session );
 }