diff options
| author | Adam Kocoloski <adam@cloudant.com> | 2013-06-06 15:53:24 -0400 |
|---|---|---|
| committer | Robert Newson <rnewson@apache.org> | 2014-07-23 17:57:42 +0100 |
| commit | c275f924aac24bd113fbf27eefd1b95281491c92 (patch) | |
| tree | cad6712bc13c6b7e831665b30e4954bb4e43f442 | |
| parent | 4c994477d67352c5102ed773600089bd1037ab89 (diff) | |
| download | couchdb-c275f924aac24bd113fbf27eefd1b95281491c92.tar.gz | |
Tag all replies to the coordinator
BugzID: 20204
| -rw-r--r-- | src/rexi.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rexi.erl b/src/rexi.erl index c970f8051..d37d360a3 100644 --- a/src/rexi.erl +++ b/src/rexi.erl @@ -95,7 +95,7 @@ async_server_call(Server, Caller, Request) -> -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) -> 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 @@ stream(Msg, Limit, Timeout) -> {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 |