1 files changed, 0 insertions, 72 deletions
diff --git a/src/fabric_create.erl b/src/fabric_create.erl
deleted file mode 100644
index 79bf1040..00000000
--- a/src/fabric_create.erl
+++ /dev/null
@@ -1,72 +0,0 @@
--module(fabric_create).
--author('Brad Anderson <brad@cloudant.com>').
-
--include("../../couch/src/couch_db.hrl").
--include("../../dynomite/include/membership.hrl").
-
-%% api
--export([create_db/2]).
-
-
-%% =====================
-%%   api
-%% =====================
-
-%% @doc Create a new database, and all its partition files across the cluster
-%%      Options is proplist with user_ctx, n, q
--spec create_db(binary(), list()) -> {ok, #db{}} | {error, any()}.
-create_db(DbName, Options) ->
-    Fullmap = partitions:fullmap(DbName, Options),
-    {ok, FullNodes} = mem3:fullnodes(),
-    RefPartMap = send_create_calls(DbName, Options, Fullmap),
-    Acc0 = {false, length(RefPartMap), lists:usort([ {Beg, false} ||
-         {_,#shard{range=[Beg,_]}} <- RefPartMap])},
-    case fabric_util:receive_loop(
-        RefPartMap, 1, fun handle_create_msg/3, Acc0, 5000, infinity) of
-    {ok, _Results} ->
-        partitions:install_fullmap(DbName, Fullmap, FullNodes, Options),
-        ok;
-    Error -> Error
-    end.
-
-
-%% =====================
-%%   internal
-%% =====================
-
-%% @doc create the partitions on all appropriate nodes (rexi calls)
--spec send_create_calls(binary(), list(), fullmap()) -> [{reference(), part()}].
-send_create_calls(DbName, Options, Fullmap) ->
-    lists:map(fun(#shard{node=Node, range=[Beg,_]} = Part) ->
-        ShardName = showroom_utils:shard_name(Beg, DbName),
-        Ref = rexi:async_server_call({couch_server, Node},
-                                     {create, ShardName, Options}),
-        {Ref, Part}
-    end, Fullmap).
-
-handle_create_msg(_, file_exists, _) ->
-    {error, file_exists};
-handle_create_msg(_, {rexi_EXIT, _Reason}, {Complete, N, Parts}) ->
-    {ok, {Complete, N-1, 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}) ->
-    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}) ->
-    {ok, {true, N-1, Parts}};
-handle_create_msg({_Ref, #shard{range=[Beg,_]}}, {ok, _}, {false, Rem, PartResults0}) ->
-    PartResults = lists:keyreplace(Beg, 1, PartResults0, {Beg, true}),
-    {ok, {is_complete(PartResults), Rem-1, PartResults}}.
-
-
-is_complete(List) ->
-    lists:all(fun({_,Bool}) -> Bool end, List).