diff options
author | Adam Kocoloski <adam@cloudant.com> | 2010-06-01 10:58:17 -0400 |
---|---|---|
committer | Adam Kocoloski <adam@cloudant.com> | 2010-06-01 10:58:17 -0400 |
commit | bd976a5a78ba88a25996fc7e94c22e8a8925ccec (patch) | |
tree | 4a3ee571dd3a937b166ee246473bce2b71b55885 /src/fabric_open_doc.erl | |
parent | 9b7831dbbddc97b4134be2fa3b3ec2d2ebc9462b (diff) |
add sync_reply, change msg format to be more like gen_server
Diffstat (limited to 'src/fabric_open_doc.erl')
-rw-r--r-- | src/fabric_open_doc.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/fabric_open_doc.erl b/src/fabric_open_doc.erl index 3ea7d4ab..e2ea3023 100644 --- a/src/fabric_open_doc.erl +++ b/src/fabric_open_doc.erl @@ -18,11 +18,11 @@ go(DbName, Id, Options) -> Error end. -handle_message(_Worker, {rexi_DOWN, _, _, _}, Acc0) -> +handle_message({rexi_DOWN, _, _, _}, _Worker, Acc0) -> skip_message(Acc0); -handle_message(_Worker, {rexi_EXIT, _Reason}, Acc0) -> +handle_message({rexi_EXIT, _Reason}, _Worker, Acc0) -> skip_message(Acc0); -handle_message(_Worker, Reply, {WaitingCount, R, Replies}) -> +handle_message(Reply, _Worker, {WaitingCount, R, Replies}) -> case merge_read_reply(make_key(Reply), Reply, Replies) of {_, KeyCount} when KeyCount =:= R -> {stop, Reply}; |