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_missing_revs.erl | |
| parent | 9b7831dbbddc97b4134be2fa3b3ec2d2ebc9462b (diff) | |
add sync_reply, change msg format to be more like gen_server
Diffstat (limited to 'src/fabric_missing_revs.erl')
| -rw-r--r-- | src/fabric_missing_revs.erl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/fabric_missing_revs.erl b/src/fabric_missing_revs.erl index ee7ea421..ff756425 100644 --- a/src/fabric_missing_revs.erl +++ b/src/fabric_missing_revs.erl @@ -13,14 +13,14 @@ go(DbName, AllIdsRevs) -> Acc0 = {length(Workers), ResultDict}, fabric_util:recv(Workers, #shard.ref, fun handle_message/3, Acc0). -handle_message(_Worker, {rexi_DOWN, _, _, _}, Acc0) -> +handle_message({rexi_DOWN, _, _, _}, _Worker, Acc0) -> skip_message(Acc0); -handle_message(_Worker, {rexi_EXIT, _, _, _}, Acc0) -> +handle_message({rexi_EXIT, _, _, _}, _Worker, Acc0) -> skip_message(Acc0); -handle_message(_Worker, {ok, Results}, {1, D0}) -> +handle_message({ok, Results}, _Worker, {1, D0}) -> D = update_dict(D0, Results), {stop, dict:fold(fun force_reply/3, [], D)}; -handle_message(_Worker, {ok, Results}, {WaitingCount, D0}) -> +handle_message({ok, Results}, _Worker, {WaitingCount, D0}) -> D = update_dict(D0, Results), case dict:fold(fun maybe_reply/3, {stop, []}, D) of continue -> |