summaryrefslogtreecommitdiff
path: root/src/fabric/src/fabric_design_doc_count.erl
diff options
context:
space:
mode:
Diffstat (limited to 'src/fabric/src/fabric_design_doc_count.erl')
-rw-r--r--src/fabric/src/fabric_design_doc_count.erl62
1 files changed, 0 insertions, 62 deletions
diff --git a/src/fabric/src/fabric_design_doc_count.erl b/src/fabric/src/fabric_design_doc_count.erl
deleted file mode 100644
index b0efc3007..000000000
--- a/src/fabric/src/fabric_design_doc_count.erl
+++ /dev/null
@@ -1,62 +0,0 @@
-% Licensed under the Apache License, Version 2.0 (the "License"); you may not
-% use this file except in compliance with the License. You may obtain a copy of
-% the License at
-%
-% http://www.apache.org/licenses/LICENSE-2.0
-%
-% Unless required by applicable law or agreed to in writing, software
-% distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
-% WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
-% License for the specific language governing permissions and limitations under
-% the License.
-
--module(fabric_design_doc_count).
-
--export([go/1]).
-
--include_lib("fabric/include/fabric.hrl").
--include_lib("mem3/include/mem3.hrl").
--include_lib("couch/include/couch_db.hrl").
-
-go(DbName) ->
- Shards = mem3:shards(DbName),
- Workers = fabric_util:submit_jobs(Shards, get_design_doc_count, []),
- RexiMon = fabric_util:create_monitors(Shards),
- Acc0 = {fabric_dict:init(Workers, nil), []},
- try fabric_util:recv(Workers, #shard.ref, fun handle_message/3, Acc0) of
- {timeout, {WorkersDict, _}} ->
- DefunctWorkers = fabric_util:remove_done_workers(WorkersDict, nil),
- fabric_util:log_timeout(DefunctWorkers, "get_design_doc_count"),
- {error, timeout};
- Else ->
- Else
- after
- rexi_monitor:stop(RexiMon)
- end.
-
-handle_message({rexi_DOWN, _, {_,NodeRef},_}, _Shard, {Counters, Resps}) ->
- case fabric_ring:node_down(NodeRef, Counters, Resps) of
- {ok, Counters1} -> {ok, {Counters1, Resps}};
- error -> {error, {nodedown, <<"progress not possible">>}}
- end;
-
-handle_message({rexi_EXIT, Reason}, Shard, {Counters, Resps}) ->
- case fabric_ring:handle_error(Shard, Counters, Resps) of
- {ok, Counters1} -> {ok, {Counters1, Resps}};
- error -> {error, Reason}
- end;
-
-handle_message({ok, Count}, Shard, {Counters, Resps}) ->
- case fabric_ring:handle_response(Shard, Count, Counters, Resps) of
- {ok, {Counters1, Resps1}} ->
- {ok, {Counters1, Resps1}};
- {stop, Resps1} ->
- Total = fabric_dict:fold(fun(_, C, A) -> A + C end, 0, Resps1),
- {stop, Total}
- end;
-
-handle_message(Reason, Shard, {Counters, Resps}) ->
- case fabric_ring:handle_error(Shard, Counters, Resps) of
- {ok, Counters1} -> {ok, {Counters1, Resps}};
- error -> {error, Reason}
- end.