anchor.diff:  
                       Futures = datastore_disc_writer:flush_async(ToFlush2),
                       gen_server:cast(Pid, {wait_flush, Ref, Futures}),
  -                    {Waiting, KiF2}
  +
  +                    Timestamp = os:timestamp(),
  +                    FT2 = maps:fold(fun(K, _V, Acc) ->
  +                        maps:put(K, Timestamp, Acc)
  +                    end, FT, ToFlush2),
  +
  +                    {Waiting, KiF2, FT2}
               end;
           _ ->
               tp_router:delete_process_size(Pid),
  
positive.code:     keys_in_flush = #{} :: #{key() => reference()},
      keys_to_inactivate = #{} :: cached_keys(),
      keys_times = #{} :: #{key() => erlang:timestamp()},
      requests_ref = undefined :: undefined | reference(),
      flush_ref = undefined :: undefined | reference()
  }).
  
negative.code:     {noreply, State#state{
          cached_keys_to_flush = NewCachedKeys,
          keys_in_flush = NewKiF,
          keys_to_inactivate = maps:merge(ToInactivate, CachedKeys),
          flush_times = NewFT
      }};
  handle_info(Info, #state{} = State) ->
      ?log_bad_request(Info),
  