anchor.diff:  terminate(_Reason, _State) ->
       ok.
   
  -check_myid(S0) ->
  -    Value = riak_core_metadata:get(?MYIDPREFIX, ?MYIDKEY),
  -    case Value of
  -        undefined ->
  -            timer:sleep(100),
  -            check_myid(S0);
  -        MyId ->
  -            groups_manager_serv:set_myid(MyId),
  -            S0#state{myid=MyId}
  -    end.
  -    
   create_label(Operation, BKey, TimeStamp, Node, Id, Payload) ->
       #label{operation=Operation,
              bkey=BKey,
  
positive.code:                                         last_label,
                                          ?PROXY_MASTER).
  
  read(Node, BKey, Clock) ->
      riak_core_vnode_master:sync_command(Node,
                                          {read, BKey, Clock},
                                          ?PROXY_MASTER).
  heartbeat(Node, MyId) ->
      riak_core_vnode_master:command(Node,
                                     {heartbeat, MyId},
                                     {fsm, undefined, self()},
                                     ?PROXY_MASTER).
  
  
negative.code:             S0
      end,
      Label = create_label(update, BKey, TimeStamp, {Partition, node()}, MyId, {}),
      saturn_leaf_producer:new_label(MyId, Label, Partition, true),
      case groups_manager_serv:get_datanodes_ids(BKey) of
          {ok, Group} ->
              lists:foreach(fun(Id) ->
  