anchor.diff:              false
       end.
   
  -handle_command({check_myid_ready}, _Sender, S0) ->
  -    S1 = check_myid(S0),
  -    {reply, true, S1};
  -
   handle_command({check_tables_ready}, _Sender, SD0) ->
       {reply, true, SD0};
  +
  +handle_command({init_proxy, MyId}, _From, S0) ->
  +    groups_manager_serv:set_myid(MyId),
  +    {reply, ok, S0#state{myid=MyId}};
   
   handle_command({read, BKey, Clock}, From, S0=#state{myid=MyId, max_ts=MaxTS0, partition=Partition, connector=Connector}) ->
       case groups_manager_serv:do_replicate(BKey) of
  
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) ->
  