anchor.diff:  responsible_dht_node(State, Key) ->
       responsible_dht_node(element(2, State), Key).
   
  --spec set_local_dht_node(state(), comm:mypid(), comm:mypid(), intervals:interval()) -> state().
  +-spec set_local_dht_node(state(), comm:mypid(), comm:erl_local_pid(), intervals:interval()) -> state().
   set_local_dht_node(State, GlobalPid, LocalPid, Interval) ->
       setelement(3, State, {Interval, GlobalPid, LocalPid}).
  --spec local_dht_node(state()) -> cached_dht_node().
  +-spec local_dht_node(state()) -> local_dht_node().
   local_dht_node(State) -> element(3, State).
   
  
positive.code:     DhtList = element(2, State),
      setelement(2, State, [{Interval, DhtNodePid} | DhtList]).
  
  -spec responsible_dht_node(state() | [cached_dht_node()], ?RT:key()) ->
      unknown | cached_dht_node().
  responsible_dht_node([], _Key) -> unknown;
  responsible_dht_node([{Interval, Pid} | T], Key) ->
      case intervals:in(Key, Interval) of
  
negative.code:                                        end, AllMsgs),
      {setelement(1, State, Rest), Matching}.
  
  -spec pop_undelivered_local_messages(state()) -> {state(), [undelivered_msg()]}.
  pop_undelivered_local_messages(State) ->
      AllMsgs = element(1, State),
      {Matching, Rest} = lists:partition(fun({{local, _Key, _KeyPos}, _Msg}) -> true;
  