anchor.diff:          	op_insert_gc(Key,DownstreamOp, OpsDict, OpsCache, SnapshotCache),
               ok;
           {error, Reason} ->
  -            {error, Reason}
  +            riak_core_vnode:reply(Sender, {error, Reason})
       end.
   
   
  
positive.code: 	    SnapshotTime=DownstreamOp#clocksi_payload.snapshot_time,
  	    Type=DownstreamOp#clocksi_payload.type,
  	    SnapshotTime=DownstreamOp#clocksi_payload.snapshot_time,
  	    _Read=internal_read(Key, Type, SnapshotTime, OpsCache, SnapshotCache),
  		OpsDict1=orddict:append(DownstreamOp#clocksi_payload.commit_time, DownstreamOp, OpsDict),
  		ets:insert(OpsCache, {Key, OpsDict1});
  	false ->
  		OpsDict1=orddict:append(DownstreamOp#clocksi_payload.commit_time, DownstreamOp, OpsDict),
  
negative.code:     %% TODO: what if all of the following was done asynchronously?
      case logging_vnode:append(Node,LogId,LogRecord) of
          {ok, _} ->
          	riak_core_vnode:reply(Sender, ok),
          	case ets:lookup(OpsCache, Key) of
          	[]->
          		OpsDict=orddict:new();
  