anchor.diff:                  {ok, Res} ->
                       {ok, {CurRingHash, _PrevRingHash}} =
                           leo_redundant_manager_api:checksum(?CHECKSUM_RING),
  -                    ok = sync_vnodes(Node, CurRingHash, Res),
  -                    notify_rebalance_message_to_manager(ToVNodeId);
  +                    sync_vnodes(Node, CurRingHash, Res);
                   Error ->
                       ?error("handle_call/1 - QUEUE_ID_SYNC_BY_VNODE_ID", "error:~p", [Error]),
                       ok = leo_storage_mq_client:publish(?QUEUE_TYPE_SYNC_BY_VNODE_ID, ToVNodeId, Node),
  
positive.code:     true;
  find_node_from_redundancies([_|Rest], Node) ->
      find_node_from_redundancies(Rest, Node).
  
  
  %% @doc Notify a message to manager node(s)
  %%
  -spec(notify_message_to_manager(list(), integer(), atom()) ->
               ok | {error, any()}).
  notify_message_to_manager([],_VNodeId,_Node) ->
      {error, 'fail_notification'};
  notify_message_to_manager([Manager|T], VNodeId, Node) ->
      Res = case rpc:call(list_to_atom(Manager), leo_manager_api, notify,
                          [synchronized, VNodeId, Node], ?DEF_REQ_TIMEOUT) of
                ok ->
                    ok;
                {_, Cause} ->
                    ?warn("notify_message_to_manager/3","vnode-id:~w, node:~w, cause:~p",
                          [VNodeId, Node, Cause]),
                    {error, Cause};
                timeout = Cause ->
                    {error, Cause}
            end,
  
      case Res of
          ok ->
              ok;
          _Error ->
              notify_message_to_manager(T, VNodeId, Node)
      end.
  
  
  %% @doc correct_redundancies/1 - first.
  
negative.code:           end,
  
      catch leo_object_storage_api:fetch_by_addr_id(FromAddrId, Fun),
      sync_vnodes(Node, RingHash, T).
  
  
  