You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by rn...@apache.org on 2014/08/01 11:06:36 UTC
[07/27] rexi commit: updated refs/heads/windsor-merge to 096f0cf
Tag all replies to the coordinator
BugzID: 20204
Project: http://git-wip-us.apache.org/repos/asf/couchdb-rexi/repo
Commit: http://git-wip-us.apache.org/repos/asf/couchdb-rexi/commit/c275f924
Tree: http://git-wip-us.apache.org/repos/asf/couchdb-rexi/tree/c275f924
Diff: http://git-wip-us.apache.org/repos/asf/couchdb-rexi/diff/c275f924
Branch: refs/heads/windsor-merge
Commit: c275f924aac24bd113fbf27eefd1b95281491c92
Parents: 4c99447
Author: Adam Kocoloski <ad...@cloudant.com>
Authored: Thu Jun 6 15:53:24 2013 -0400
Committer: Robert Newson <rn...@apache.org>
Committed: Wed Jul 23 17:57:42 2014 +0100
----------------------------------------------------------------------
src/rexi.erl | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/couchdb-rexi/blob/c275f924/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 @@ 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