anchor.diff:      ?BACKEND_CONNECTOR_FSM:start_link(update, {Key, Value, TimeStamp, Seq1}),
       {reply, {ok, TimeStamp}, S0#state{max_ts=TimeStamp, seq=Seq1, last_label={Key, TimeStamp, {Partition, node()}}}};
   
  -handle_command({update_completed, Key, Value, TimeStamp, Seq}, _From, S0=#state{partition=Partition, myid=MyId, delay=Delay}) ->
  +handle_command({update_completed, Key, Value, TimeStamp, Seq}, _From, S0=#state{partition=Partition, myid=MyId}) ->
       Label = {Key, TimeStamp, {Partition, node()}},
  -    spawn(saturn_proxy_vnode, send_label_delay, [MyId, Label, Partition, Seq, Delay]),
  +    saturn_leaf_producer:new_label(MyId, Label, Partition, Seq),
       case groups_manager_serv:get_datanodes(Key) of
           {ok, Group} ->
               lists:foreach(fun({Host, Port}) ->
  
positive.code:     {ok, #state{partition=Partition,
                  max_ts=0,
                  last_label=none,
                  delay=100,
                  seq=0}}.
  
  %% @doc The table holding the prepared transactions is shared with concurrent
  
negative.code: terminate(_Reason, _State) ->
      ok.
  
  check_myid(S0) ->
      Value = riak_core_metadata:get(?MYIDPREFIX, ?MYIDKEY),
      case Value of
  