commit c275f924aac24bd113fbf27eefd1b95281491c92
author Adam Kocoloski <adam@cloudant.com> Thu Jun 06 15:53:24 2013 -0400
committer Robert Newson <rnewson@apache.org> Wed Jul 23 17:57:42 2014 +0100
tree cad6712bc13c6b7e831665b30e4954bb4e43f442
parent 4c994477d67352c5102ed773600089bd1037ab89

Tag all replies to the coordinator

BugzID: 20204

src/rexi.erl

diff --git a/src/rexi.erl b/src/rexi.erl
index c970f80..d37d360 100644
--- a/src/rexi.erl
+++ b/src/rexi.erl
@@ -95,7 +95,7 @@
 -spec reply(any()) -> any().
 reply(Reply) ->
     {Caller, Ref} = get(rexi_from),
-    erlang:send(Caller, {Ref,Reply}).
+    erlang:send(Caller, {rexi, Ref, Reply}).
 
 %% @equiv sync_reply(Reply, 300000)
 sync_reply(Reply) ->
@@ -108,7 +108,7 @@
 sync_reply(Reply, Timeout) ->
     {Caller, Ref} = get(rexi_from),
     Tag = make_ref(),
-    erlang:send(Caller, {Ref, {self(),Tag}, Reply}),
+    erlang:send(Caller, {rexi, Ref, {self(),Tag}, Reply}),
     receive {Tag, Response} ->
         Response
     after Timeout ->
@@ -132,7 +132,7 @@
         {ok, Count} ->
             put(rexi_unacked, Count+1),
             {Caller, Ref} = get(rexi_from),
-            erlang:send(Caller, {Ref, self(), Msg}),
+            erlang:send(Caller, {rexi, Ref, self(), Msg}),
             ok
     catch throw:timeout ->
         timeout