anchor.diff:              end;
           _ ->
               Redundancies
  -    end.
  -
  -
  -%% @doc Notify a rebalance-progress messages to manager.
  -%%      - Retrieve # of published messages for rebalance,
  -%%        after notify a message to manager.
  -%%
  --spec(notify_rebalance_message_to_manager(integer()) ->
  -             ok | {error, any()}).
  -notify_rebalance_message_to_manager(VNodeId) ->
  -    case ets_lookup(?TBL_REBALANCE_COUNTER, VNodeId) of
  -        {ok, NumOfMessages} ->
  -            Fun = fun(_Manager, true) ->
  -                          void;
  -                     (Manager0, false = Res) ->
  -                          Manager1 = case is_atom(Manager0) of
  -                                         true  -> Manager0;
  -                                         false -> list_to_atom(Manager0)
  -                                     end,
  -                          case catch rpc:call(Manager1, leo_manager_api, notify,
  -                                              [rebalance, VNodeId,
  -                                               erlang:node(), NumOfMessages],
  -                                              ?DEF_REQ_TIMEOUT) of
  -                              ok ->
  -                                  true;
  -                              {_, Cause} ->
  -                                  ?error("notify_rebalance_message_to_manager/1",
  -                                         [{manager, Manager1},
  -                                          {vnode_id, VNodeId}, {cause, Cause}]),
  -                                  Res;
  -                              timeout ->
  -                                  Res
  -                          end
  -                  end,
  -            lists:foldl(Fun, false, ?env_manager_nodes(leo_storage)),
  -            ok;
  -        Error ->
  -            Error
       end.
   
   
  
positive.code:                                key = Key} = Msg) ->
      case leo_redundant_manager_api:get_member_by_node(Node) of
          {ok, #member{state = ?STATE_RUNNING}} ->
              ok = decrement_counter(?TBL_REBALANCE_COUNTER, VNodeId),
  
              case leo_redundant_manager_api:get_redundancies_by_key(Key) of
                  {ok, #redundancies{nodes = Redundancies}} ->
  
negative.code:             {error, ?ERROR_COULD_NOT_GET_META}
      end.
  
  