anchor.diff:                  {ok, Pid} ->
                       {ok, Pid}
               end
  +    end.
  +
  +monitor_remote_coordinator(CoordNode, StateData) ->
  +    receive
  +        {ack, CoordNode, now_executing} ->
  +            {stop, normal, StateData}
  +    after 3000 ->
  +            Bad = StateData#state.bad_coordinators,
  +            prepare(timeout, StateData#state{bad_coordinators=[CoordNode|Bad]})
       end.
   
   %% ===================================================================
  
positive.code:                 timing = [] :: [{atom(), {non_neg_integer(), non_neg_integer(),
                                            non_neg_integer()}}],
                  reply, % reply sent to client,
                  tracked_bucket=false :: boolean() %% tracke per bucket stats
                 }).
  
  -include("riak_kv_dtrace.hrl").
  
negative.code: %% @private
  prepare(timeout, StateData0 = #state{from = From, robj = RObj,
                                       bkey = BKey,
                                       options = Options,
                                       bad_coordinators = BadCoordinators}) ->
      BucketProps = riak_core_bucket:get_bucket(riak_object:bucket(RObj)),
      DocIdx = riak_core_util:chash_key(BKey),
      Bucket_N = proplists:get_value(n_val,BucketProps),
  