summaryrefslogtreecommitdiff
path: root/src/fabric_create_db.erl
diff options
context:
space:
mode:
authorAdam Kocoloski <adam@cloudant.com>2010-06-01 10:58:17 -0400
committerAdam Kocoloski <adam@cloudant.com>2010-06-01 10:58:17 -0400
commitbd976a5a78ba88a25996fc7e94c22e8a8925ccec (patch)
tree4a3ee571dd3a937b166ee246473bce2b71b55885 /src/fabric_create_db.erl
parent9b7831dbbddc97b4134be2fa3b3ec2d2ebc9462b (diff)
add sync_reply, change msg format to be more like gen_server
Diffstat (limited to 'src/fabric_create_db.erl')
-rw-r--r--src/fabric_create_db.erl12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/fabric_create_db.erl b/src/fabric_create_db.erl
index 1e9bf256..21b093bf 100644
--- a/src/fabric_create_db.erl
+++ b/src/fabric_create_db.erl
@@ -37,26 +37,26 @@ send_create_calls(Fullmap, Options) ->
end, Fullmap).
%% @doc handle create messages from shards
-handle_create_msg(_, file_exists, _) ->
+handle_create_msg(file_exists, _, _) ->
{error, file_exists};
-handle_create_msg(_, {rexi_EXIT, _Reason}, {Complete, N, Parts}) ->
+handle_create_msg({rexi_EXIT, _Reason}, _, {Complete, N, Parts}) ->
{ok, {Complete, N-1, Parts}};
-handle_create_msg(_, {rexi_DOWN, _, _, _}, {Complete, _N, _Parts}) ->
+handle_create_msg({rexi_DOWN, _, _, _}, _, {Complete, _N, _Parts}) ->
if
Complete -> {stop, ok};
true -> {error, create_db_fubar}
end;
handle_create_msg(_, _, {true, 1, _Acc}) ->
{stop, ok};
-handle_create_msg({_, #shard{range=[Beg,_]}}, {ok, _}, {false, 1, PartResults0}) ->
+handle_create_msg({ok, _}, {_, #shard{range=[Beg,_]}}, {false, 1, PartResults0}) ->
PartResults = lists:keyreplace(Beg, 1, PartResults0, {Beg, true}),
case is_complete(PartResults) of
true -> {stop, ok};
false -> {error, create_db_fubar}
end;
-handle_create_msg(_RefPart, {ok, _}, {true, N, Parts}) ->
+handle_create_msg({ok, _}, _RefPart, {true, N, Parts}) ->
{ok, {true, N-1, Parts}};
-handle_create_msg({_Ref, #shard{range=[Beg,_]}}, {ok, _}, {false, Rem, PartResults0}) ->
+handle_create_msg({ok, _}, {_Ref, #shard{range=[Beg,_]}}, {false, Rem, PartResults0}) ->
PartResults = lists:keyreplace(Beg, 1, PartResults0, {Beg, true}),
{ok, {is_complete(PartResults), Rem-1, PartResults}}.