anchor.diff:              S0
       end,
       Label = create_label(update, BKey, TimeStamp, {Partition, node()}, MyId, {}),
  -    saturn_leaf_producer:new_label(MyId, Label, Partition),
  +    saturn_leaf_producer:new_label(MyId, Label, Partition, true),
       case groups_manager_serv:get_datanodes_ids(BKey) of
           {ok, Group} ->
               lists:foreach(fun(Id) ->
  
positive.code:             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({read, BKey, Clock}, From, S0=#state{myid=MyId, max_ts=MaxTS0, partition=Partition, connector=Connector}) ->
      case groups_manager_serv:do_replicate(BKey) of
  
negative.code:     Client = Payload#payload_remote.client,
      Source = Label#label.sender,
      NewLabel = create_label(remote_reply, {Bucket, routing}, TimeStamp, {Partition, node()}, MyId, #payload_reply{value=Value, to=Source, client=Client}),
      saturn_leaf_producer:new_label(MyId, NewLabel, Partition, false),
      {reply, ok, S0#state{max_ts=TimeStamp, last_label=NewLabel}};
  
  handle_command(heartbeat, _From, S0=#state{partition=Partition, max_ts=MaxTS0, myid=MyId}) ->
      Clock = max(saturn_utilities:now_microsec(), MaxTS0+1),
      saturn_leaf_producer:partition_heartbeat(MyId, Partition, Clock),
      riak_core_vnode:send_command_after(?HEARTBEAT_FREQ, heartbeat),
      {noreply, S0#state{max_ts=Clock}};
  
  handle_command(last_label, _Sender, S0=#state{last_label=LastLabel}) ->
      {reply, {ok, LastLabel}, S0};
  