anchor.diff:                _RemotePids = [],
                 _LastPong = Now,
                 _CrashedAfter = util:time_plus_ms(Now, delayfactor() * failureDetectorInterval()),
  -              TableName).
  +              LocalSubscriberTab, MonitorTab).
   
   -spec on(comm:message(), state()) -> state() | kill.
   on({add_subscriber, Subscriber, WatchedPid, Cookie} = _Msg, State) ->
  
positive.code: state_set_crashed_after(State, Val) -> setelement(4, State, Val).
  -spec state_get_table(state()) -> pdb:tableid().
  state_get_table(State)              -> element(5, State).
  -spec state_get_monitors(state())   -> [{comm:mypid(), reference()}].
  state_get_monitors(State)           -> element(6, State).
  -spec state_set_monitors(state(), [{comm:mypid(), reference()}]) -> state().
  state_set_monitors(State, Val)      -> setelement(6, State, Val).
  
  -spec state_add_entry(state(), {pid(), comm:mypid(), fd:cookie()}) -> state().
  state_add_entry(State, {Subscriber, WatchedPid, Cookie}) ->
  
negative.code:        [rempid()],  %% subscribed rem. pids + ref counting
         erlang_timestamp(),  %% local time of last pong arrival
         erlang_timestamp(),  %% remote is crashed if no pong arrives until this
         LocalSubscriberTab::pdb:tableid(),
         %% locally erlang:monitored() pids for a remote hbs:
         MonitorTab::pdb:tableid()
       }).
  
  -define(SEND_OPTIONS, [{channel, prio}]).
  