diff options
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 -> |