anchor.diff:           }).
   
   -define(MASTER, metric_vnode_master).
  +-define(MAX_Q_LEN, 20).
   
   %% API
   start_vnode(I) ->
  
positive.code:             k6_bytea:set(Array, 0, Value),
              k6_bytea:set(Array, Len * ?DATA_SIZE, <<0:(?DATA_SIZE * 8 * (CT - Len))>>),
              ets:update_element(T, BM, [{2, Time}, {3, Len}, {4, Time + CT}]),
              metric_io:write(IO, Bucket, Metric, Start, Bin);
          %% In the case the data is already longer then the cache we flush the
          %% cache
          [{BM, Start, Size, _End, Array}]
  
negative.code:             ets:delete(T, {Bucket,Metric}),
              Bin = k6_bytea:get(Array, 0, Size * ?DATA_SIZE),
              k6_bytea:delete(Array),
              metric_io:write(IO, Bucket, Metric, Start, Bin, Sync),
              metric_io:write(IO, Bucket, Metric, Time, Value, Sync);
          [{BM, Start, _Size, _End, Array}] ->
              Idx = Time - Start,
              k6_bytea:set(Array, Idx * ?DATA_SIZE, Value),
  