anchor.diff:      case logging_vnode:append(Node,LogId,LogRecord) of
           {ok, _} ->
               riak_core_vnode:reply(Sender, ok),
  -            case ets:lookup(OpsCache, Key) of
  -                []->
  -                    OpsDict=orddict:new();
  -                [{_, OpsDict}]->
  -                    OpsDict
  -            end,
  -            op_insert_gc(Key,DownstreamOp, OpsDict, OpsCache, SnapshotCache),
  +            op_insert_gc(Key,DownstreamOp, OpsCache, SnapshotCache),
               ok;
           {error, Reason} ->
               riak_core_vnode:reply(Sender, {error, Reason})
  
positive.code:             NewSnapshot=clocksi_materializer:new(Type),
              case ets:lookup(OpsCache, Key) of
                  [] ->
                      riak_core_vnode:reply(Sender, {ok, NewSnapshot});
                  [{_, OpsDict}] ->
                      {ok, Ops}= filter_ops(OpsDict),
                      LastOp=lists:last(Ops),
  
negative.code: %% operations for a given key, just perform a read, that will trigger
  %% the GC mechanism.
  -spec op_insert_gc(term(), clocksi_payload(),
                     atom() , atom() )-> true.
  op_insert_gc(Key,DownstreamOp, OpsCache, SnapshotCache)->
      OpsDict = case ets:lookup(OpsCache, Key) of
                    []->
                        orddict:new();
                    [{_, Dict}]->
                        Dict
                end,
      case (orddict:size(OpsDict))>=?OPS_THRESHOLD of
          true ->
              Type=DownstreamOp#clocksi_payload.type,
  