libflux/rpc: stop continuation on rpc completion

flux-framework · Jul 23, 2015 · cca0a95 · cca0a95
1 parent 2ea8438
commit cca0a95
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/common/libflux/rpc.c b/src/common/libflux/rpc.c
@@ -194,7 +194,8 @@ static void rpc_cb (flux_t h, flux_msg_watcher_t *w,
         rpc->rx_msg = NULL;
     }
 done: /* no good way to report flux_requeue() errors */
-    ;
+    if (flux_rpc_completed (rpc))
+        flux_msg_watcher_stop (rpc->h, rpc->w);
 }
 
 int flux_rpc_then (flux_rpc_t *rpc, flux_then_f cb, void *arg)