anchor.diff:      rm_loop:subscribe(self(), cyclon, fun erlang:'=/='/2,
                         fun cyclon:rm_send_changes/4, inf),
       request_node_details([node, pred, succ]),
  -    comm:send_local_after(100, self(), {check_state}),
       TriggerState2 = trigger:now(TriggerState),
       msg_queue:send(QueuedMessages),
       comm:send_local_after(monitor:proc_get_report_interval() * 1000, self(),
  
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:     if 
          length(NeedsInfo) > 0 ->
              request_node_details(NeedsInfo),
              fail;
          true ->
              ok
  