erlang 虚机crash

init([Configs]) ->
    %hash_ring 需要先启动, link 需要同时重启
    link(whereis(hash_ring)),
    ets:new(?MODULE, [named_table, protected, set, {read_concurrency, true}]),
    ets:new(?ROUND_ROBIN_ETS, [named_table, public, set, {write_concurrency, true}]),
    ets:insert(?ROUND_ROBIN_ETS, {inc, 0}),
    {ok, Routes} = parse_configs(Configs),
    State = apply_routes(Routes, #state{}),
    start_check_timer(),
    {ok, State}.

monitor_route({Svc, Node} = Route) ->
    % monitor 无法立即返回是否成功,rpc:call 成功后再monitor
    case catch rpc:call(Node, erlang, whereis, [Svc], 3000) of
        {‘EXIT‘, Reason} ->
            {error, Reason};
        undefined ->
            {error, svc_undefined};
        Pid when is_pid(Pid) ->
            Ref = erlang:monitor(process, Route),
            {ok, Ref};
        Error ->
            {error, Error}
    end.

route_up(Name, Route, Ref, #state{mons=Mons, downs=Downs} = State) ->
    case lists:member(Route, get_all_routes(Name)) of
       true ->
           case lists:member(Route, get_routes(Name)) of
                false ->
                    ok = hash_ring:add_node({route, Name}, term_to_binary(Route)),
                    add_route(Name, Route);
                true ->
                    ok
            end,
            State#state{mons=dict:store(Ref, {Name, Route}, Mons),
                        downs=Downs -- [{Name, Route}]};
        _ ->
            catch erlang:demonitor(Ref),
            lager:info("igonre route_up:~p ~p ~p", [Name, Route, Ref]),
            State
    end.

route(Name, Key) ->
    case hash_ring:find_node({route, Name}, neo_util:to_binary(erlang:phash2(Key))) of
        {ok, Route} -> {ok, binary_to_term(Route)};
        Error -> Error
    end.

call(Name, Key, Req, Timeout) ->
    {ok, Dst} = route(Name, Key),
    gen_call(Dst, Req, Timeout).

%参考 whatsapp 做法
%使用场景:
%1. Process 需要被长期monitor
%2. Process 为node内常驻服务进程,不是临时进程
%3. 调用前需要先确认Process alive 状态
%优势:
%不需要monitor, 节省两次网络交互
%gen:call 需要monitor -> call -> demonitor dst node monitor 操作消耗资源
%影响:
%process down 瞬间, call 应答都会超时，但此调用返回的是timeout
%
gen_call(Process, Request) ->
    gen_call(Process, Request, 5000).

gen_call(Process, Request, Timeout) ->
    Ref = erlang:make_ref(),
    catch erlang:send(Process, {‘$gen_call‘, {self(), Ref}, Request}),
    receive
        {Ref, Reply} ->
            Reply
    after Timeout ->
            exit({timeout, {?MODULE, call, [Process, Request, Timeout]}})
    end.

    quicksort((void**)adds, ring->numReplicas, item_sort);
+    //ring->numNodes * ring->numReplicas
+    if(ring->items == NULL || ring-> numNodes == 1) {
+        ring->items = adds;
+    } else {
+        size_t size_new = sizeof(hash_ring_item_t*) * ring->numNodes * ring->numReplicas;
+        hash_ring_item_t **news = (hash_ring_item_t **)malloc(size_new);
+        hash_ring_item_t **olds = ring->items;
+        if(news == NULL) {
+            return HASH_RING_ERR;
+        }
+        int oldlen = (ring->numNodes - 1) * ring->numReplicas;
+        int addlen = ring->numReplicas;
+        int i=0, j=0, k=0;
+        while(1) {
+            if(i == oldlen && j == addlen) {
+                break;
+            }
+            if(j == addlen) {
+                news[k++] = olds[i++];
+                continue;
+            }
+            if(i == oldlen) {
+                news[k++] = adds[j++];
+                continue;
+            }
+            int ret = item_sort(olds[i], adds[j]);
+            if(ret == 0) {
+                news[k++] = olds[i++];
+                news[k++] = adds[j++];
+            } else if (ret < 0) {
+                news[k++] = olds[i++];
+            } else {
+                news[k++] = adds[j++];
+            }
+        };
+        free(adds);
+        free(olds);
+        ring->items = news;