anchor.diff:  
   on_active({rm_changed, NewNode}, {Cache, _OldNode, Cycles, TriggerState, MonitorTable}) ->
       {Cache, NewNode, Cycles, TriggerState, MonitorTable};
  -
  -on_active({check_state}, State) ->
  -    check_state(State),
  -    State;
   
   on_active({cy_subset, SourcePid, PSubset}, {Cache, Node, Cycles, TriggerState, MonitorTable}) ->
       %io:format("subset~n", []),
  
positive.code: -type(message() ::
      {cy_shuffle} |
      {rm_changed, NewNode::node:node_type()} |
      {check_state} |
      {cy_subset, SourcePid::comm:mypid(), PSubset::cyclon_cache:cache()} |
      {cy_subset_response, QSubset::cyclon_cache:cache(), PSubset::cyclon_cache:cache()} |
      {get_node_details_response, node_details:node_details()} |
  
negative.code:     rm_loop:subscribe(self(), cyclon, fun erlang:'=/='/2,
                        fun cyclon:rm_send_changes/4, inf),
      request_node_details([node, pred, succ]),
      TriggerState2 = trigger:now(TriggerState),
      msg_queue:send(QueuedMessages),
      comm:send_local_after(monitor:proc_get_report_interval() * 1000, self(),
  