anchor.diff:                                    key      = Key,
                                     callback = Callback}) ->
       receive
  -        {Ref, Reply} ->
  +        %% Receive only messages sent from SubParent (_From in this context)
  +        {?LEO_STORAGE_REPLICATOR_MSG_TAG, Ref, Reply} ->
               Callback(Reply)
       after
           (?DEF_REQ_TIMEOUT + timer:seconds(1)) ->
  
positive.code: %% for unavailable node
  replicate_1([#redundant_node{node = Node,
                               available = false}|Rest], Ref, From, State) ->
      erlang:send(From, {Ref, {error, {Node, nodedown}}}),
      replicate_1(Rest, Ref, From, State).
  
  
negative.code:             {W_1, State_1} =
                  case ((W - 1) < 1) of
                      true when IsReply == false ->
                          %% This message is sent to Parent so need to add a tag
                          erlang:send(From, {?LEO_STORAGE_REPLICATOR_MSG_TAG, Ref, {ok, Method, hd(ResL_1)}}),
                          {0, State#state{is_reply = true}};
                      true ->
                          {0, State};
  