From f4a5315ec47fcf503f44608422bca30179bc593d Mon Sep 17 00:00:00 2001
From: Charles Kerr <charles@transmissionbt.com>
Date: Thu, 14 Aug 2008 02:12:29 +0000
Subject: [PATCH] #1156: make the RPC callbacks a little more flexible to make
 thread issues easier on the mac client

---
 gtk/main.c                     |  3 ++-
 libtransmission/rpc.c          | 13 +++++++++----
 libtransmission/transmission.h | 21 +++++++++++++++++----
 3 files changed, 28 insertions(+), 9 deletions(-)

diff --git a/gtk/main.c b/gtk/main.c
index 5dec78b9f..105a9ef27 100644
--- a/gtk/main.c
+++ b/gtk/main.c
@@ -316,7 +316,7 @@ onRPCIdle( void * vdata )
     return FALSE;
 }
 
-static void
+static tr_rpc_callback_status
 onRPCChanged( tr_handle            * handle UNUSED,
               tr_rpc_callback_type   type,
               struct tr_torrent    * tor,
@@ -331,6 +331,7 @@ onRPCChanged( tr_handle            * handle UNUSED,
     data->tor = type == TR_RPC_TORRENT_REMOVING ? NULL : tor;
     data->cbdata = cbdata;
     g_idle_add( onRPCIdle, data );
+    return TR_RPC_OK;
 }
 
 int
diff --git a/libtransmission/rpc.c b/libtransmission/rpc.c
index 39c5e45fc..b5357cebf 100644
--- a/libtransmission/rpc.c
+++ b/libtransmission/rpc.c
@@ -30,11 +30,15 @@
 ****
 ***/
 
-static void
+static tr_rpc_callback_status
 notify( tr_handle * session, int type, tr_torrent * tor )
 {
+    tr_rpc_callback_status status = 0;
+
     if( session->rpc_func )
-        session->rpc_func( session, type, tor, session->rpc_func_user_data );
+        status = session->rpc_func( session, type, tor, session->rpc_func_user_data );
+
+    return status;
 }
 
 /***
@@ -129,8 +133,9 @@ torrentRemove( tr_handle * h, tr_benc * args_in, tr_benc * args_out UNUSED )
     for( i=0; i<torrentCount; ++i )
     {
         tr_torrent * tor = torrents[i];
-        notify( h, TR_RPC_TORRENT_REMOVING, tor );
-        tr_torrentRemove( tor );
+        const tr_rpc_callback_status status = notify( h, TR_RPC_TORRENT_REMOVING, tor );
+        if( ! ( status & TR_RPC_NOREMOVE ) )
+            tr_torrentRemove( tor );
     }
     tr_free( torrents );
     return NULL;
diff --git a/libtransmission/transmission.h b/libtransmission/transmission.h
index 1ef3cfc5b..7a591a2f8 100644
--- a/libtransmission/transmission.h
+++ b/libtransmission/transmission.h
@@ -421,10 +421,23 @@ typedef enum
 }
 tr_rpc_callback_type;
 
-typedef void ( *tr_rpc_func )( tr_session           * handle,
-                               tr_rpc_callback_type   type,
-                               struct tr_torrent    * tor_or_null,
-                               void                 * user_data );
+typedef enum
+{
+    /* no special handling is needed by the caller */
+    TR_RPC_OK            = 0,
+
+    /* indicates to the caller that the client will take care of
+     * removing the torrent itself.  For example the client may
+     * need to keep the torrent alive long enough to cleanly close
+     * some resources in another thread. */
+    TR_RPC_NOREMOVE   = (1<<1)
+}
+tr_rpc_callback_status;
+
+typedef tr_rpc_callback_status ( *tr_rpc_func )( tr_session           * handle,
+                                                 tr_rpc_callback_type   type,
+                                                 struct tr_torrent    * tor_or_null,
+                                                 void                 * user_data );
 
 void tr_sessionSetRPCCallback( tr_session   * handle,
                                tr_rpc_func    func,
-- 
2.40.0