anchor.diff:  
   -define(LWWREG, riak_dt_lwwreg).
   -define(MAP, riak_dt_map).
  +
  +-define(DELAY_TIME_MS, 300).                 % TODO make configurable!
   
   %% API
   -export([start_link/1,
  
positive.code:     Added_to_new     = NewUnfit -- ActiveUnfit,
      Dropped_from_new = ActiveUnfit -- NewUnfit,
      io:format(user, "adjust_down_list: ~w: adjust ~w: add ~p drop ~p\n", [S#state.my_flu_name, FLU, Added_to_new, Dropped_from_new]),
      case {lists:member(FLU,Added_to_new), lists:member(FLU,Dropped_from_new)} of
          {true, true} ->
              error({bad, ?MODULE, ?LINE, FLU, ActiveUnfit, NewUnfit});
  
negative.code: do_map_change(NewMap, DontSendList, MembersDict,
                #state{my_flu_name=_MyFluName, pending_map=OldMap}=S) ->
      send_spam(NewMap, DontSendList, MembersDict, S),
      ChangedServers = find_changed_servers(OldMap, NewMap, _MyFluName),
      schedule_adjust_messages(ChangedServers),
      %% _OldMapV = map_value(OldMap),
      %% _MapV = map_value(NewMap),
      %% io:format(user, "TODO: ~w async tick trigger/scheduling... ~w for:\n"
      %%           "    ~p\n    ~p\n",[_MyFluName,ChangedServers,_OldMapV,_MapV]),
      S#state{pending_map=NewMap, members_dict=MembersDict}.
  
  find_changed_servers(OldMap, NewMap, _MyFluName) ->
      AddBad = fun({_Who, {_Time, BadList, _Props}}, Acc) -> BadList ++ Acc end,
      OldBad = map_fold(AddBad, [], OldMap),
      NewBad = map_fold(AddBad, [], NewMap),
      lists:usort((OldBad -- NewBad) ++ (NewBad -- OldBad)).
  
  schedule_adjust_messages(FLU_list) ->
      [erlang:send_after(?DELAY_TIME_MS, self(), {adjust_down_list, FLU}) ||
          FLU <- FLU_list].
  
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
  