Use two pools of delegates, one for each of outgoing and incoming messages. Prevents deadlocks.bug23429

1 files changed, 6 insertions, 4 deletions

diff --git a/src/delegate_sup.erl b/src/delegate_sup.erl
index ff303ee2..544546f1 100644
--- a/src/delegate_sup.erl
+++ b/src/delegate_sup.erl
@@ -55,9 +55,11 @@ start_link() ->
 %%----------------------------------------------------------------------------
 
 init(_Args) ->
-    {ok, {{one_for_one, 10, 10},
-          [{Hash, {delegate, start_link, [Hash]},
-            transient, 16#ffffffff, worker, [delegate]} ||
-              Hash <- lists:seq(0, delegate:process_count() - 1)]}}.
+    {ok, {{one_for_one, 10, 10}, specs(incoming) ++ specs(outgoing)}}.
+
+specs(Prefix) ->
+    [{{Prefix, Hash}, {delegate, start_link, [Prefix, Hash]},
+      transient, 16#ffffffff, worker, [delegate]} ||
+        Hash <- lists:seq(0, delegate:process_count() - 1)].
 
 %%----------------------------------------------------------------------------