anchor.diff:  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),
  -    DelayTimeMS = 300,                          % TODO make configurable!
  -    [erlang:send_after(DelayTimeMS, self(), {adjust_down_list, FLU}) ||
  -        FLU <- ChangedServers],
  +    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) ->
  +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].
   
   %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
   
  
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: 
  -define(LWWREG, riak_dt_lwwreg).
  -define(MAP, riak_dt_map).
  
  -define(DELAY_TIME_MS, 300).                 % TODO make configurable!
  
  %% API
  -export([start_link/1,
  