anchor.diff:              {noreply, State#state{dedup=Dedup2}, hibernate}
       end;
   handle_cast({do_log, Entry}, State) ->
  -    {noreply, schedule_save(add_pending(State, maybe_upgrade_entry(Entry))), hibernate};
  +    {noreply, schedule_save(add_pending(State, Entry)), hibernate};
   handle_cast({sync, SrcNode, Compressed}, StateBefore) ->
       State = flush_pending(StateBefore),
       Recent = State#state.unique_recent,
  
positive.code:             {noreply, State, hibernate};
          Logs ->
              State1 = schedule_save(State),
              UpgradedLogs = upgrade_entries(Logs),
              NewRecent = tail_of_length(lists:umerge(fun order_entries/2, Recent, UpgradedLogs),
                                         ?RB_SIZE),
              case NewRecent =/= UpgradedLogs of
                  %% send back sync with fake src node. To avoid
                  %% infinite sync exchange just in case.
                  true -> send_sync_to(NewRecent, SrcNode, SrcNode);
  
negative.code: do_log(#log_entry{code=Code, tstamp=TStamp} = Entry) when is_integer(Code) ->
      EntryNew = Entry#log_entry{server_time=calendar:now_to_local_time(TStamp)},
  
      Nodes = ns_node_disco:nodes_actual_proper(),
      gen_server:abcast(Nodes, ?MODULE, {do_log, EntryNew}).
  
  %% API
  
  