1 files changed, 0 insertions, 162 deletions
diff --git a/src/mem3/src/mem3_seeds.erl b/src/mem3/src/mem3_seeds.erl
deleted file mode 100644
index f1aceb996..000000000
--- a/src/mem3/src/mem3_seeds.erl
+++ /dev/null
@@ -1,162 +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(mem3_seeds).
--behaviour(gen_server).
-
--export([
-    init/1,
-    handle_call/3,
-    handle_cast/2,
-    handle_info/2,
-    code_change/3,
-    terminate/2
-]).
-
--export([
-    start_link/0,
-    get_seeds/0,
-    get_status/0
-]).
-
--record(st, {
-    ready = false,
-    seeds = [],
-    jobref = nil,
-    status = [] % nested proplist keyed on node name
-}).
-
--define(REPLICATION_INTERVAL, 60000).
-
-start_link() ->
-    gen_server:start_link({local, ?MODULE}, ?MODULE, [], []).
-
-get_seeds() ->
-    case config:get("cluster", "seedlist") of
-        undefined ->
-            [];
-        List ->
-            Nodes = string:tokens(List, ","),
-            Seeds = [list_to_atom(Node) || Node <- Nodes] -- [node()],
-            mem3_util:rotate_list(node(), Seeds)
-    end.
-
-get_status() ->
-    gen_server:call(?MODULE, get_status).
-
-init([]) ->
-    Seeds = get_seeds(),
-    InitStatus = [{Seed, {[]}} || Seed <- Seeds],
-    State = #st{
-        seeds = Seeds,
-        ready = case Seeds of [] -> true; _ -> false end,
-        jobref = start_replication(Seeds),
-        status = InitStatus
-    },
-    {ok, State}.
-
-handle_call(get_status, _From, St) ->
-    Status = {[
-        {status, case St#st.ready of true -> ok; false -> seeding end},
-        {seeds, {St#st.status}}
-    ]},
-    {reply, {ok, Status}, St}.
-
-handle_cast(_Msg, St) ->
-    {noreply, St}.
-
-handle_info(start_replication, #st{jobref=nil} = St) ->
-    JobRef = start_replication(St#st.seeds),
-    {noreply, St#st{jobref = JobRef}};
-
-handle_info({'DOWN', Ref, _, Pid, Output}, #st{jobref = {Pid, Ref}} = St) ->
-    {noreply, update_state(St, Output)};
-
-handle_info(_Msg, St) ->
-    {noreply, St}.
-
-terminate(_Reason, _St) ->
-    ok.
-
-code_change(_OldVsn, St, _Extra) ->
-    {ok, St}.
-
-% internal functions
-
-start_replication([]) ->
-    nil;
-start_replication([Seed | _]) ->
-    spawn_monitor(fun() ->
-        Reply = mem3_rpc:pull_replication(Seed),
-        exit({ok, Reply})
-    end).
-
-update_state(State, {ok, Data}) ->
-    #st{seeds = [Current | Tail], status = Status} = State,
-    Report = {[
-        {timestamp, list_to_binary(mem3_util:iso8601_timestamp())},
-        {last_replication_status, ok},
-        format_data(Data)
-    ]},
-    NewStatus = lists:ukeymerge(1, [{Current, Report}], Status),
-    Ready = is_ready(State#st.ready, Data),
-    case Ready of
-        true ->
-            Seeds = Tail ++ [Current],
-            Job = nil;
-        false ->
-            % Try to progress this same seed again
-            Seeds = [Current | Tail],
-            Job = start_replication([Current | Tail])
-    end,
-    State#st{
-        seeds = Seeds,
-        jobref = Job,
-        ready = Ready,
-        status = NewStatus
-    };
-update_state(State, {_Error, _Stack}) ->
-    #st{seeds = [Current | Tail], status = Status} = State,
-    Report = {[
-        {timestamp, list_to_binary(mem3_util:iso8601_timestamp())},
-        {last_replication_status, error}
-    ]},
-    NewStatus = lists:ukeymerge(1, [{Current, Report}], Status),
-    Seeds = Tail ++ [Current],
-    if not State#st.ready ->
-        erlang:send_after(1000, self(), start_replication);
-    true ->
-        ok
-    end,
-    State#st{
-        seeds = Seeds,
-        jobref = nil,
-        status = NewStatus
-    }.
-
-is_ready(true, _) ->
-    true;
-is_ready(false, Data) ->
-    lists:all(fun({_DbName, Pending}) -> Pending =:= {ok, 0} end, Data).
-
-format_data(Data) ->
-    Formatted = lists:map(fun({DbName, Status}) ->
-        case Status of
-            {ok, Pending} when is_number(Pending) ->
-                {DbName, Pending};
-            {error, Tag} ->
-                {DbName, list_to_binary(io_lib:format("~p", [Tag]))};
-            _Else ->
-                {DbName, unknown_error}
-        end
-    end, Data),
-    {pending_updates, {Formatted}}.