anchor.diff:  init({ResetTrigger, ClusterTrigger}) ->
       ResetTriggerState = trigger:init(ResetTrigger, fun get_clustering_reset_interval/0, reset_clustering),
       ClusterTriggerState = trigger:init(ClusterTrigger, fun get_clustering_interval/0, start_clustering_shuffle),
  -    {inactive, msg_queue:new(), ResetTriggerState, ClusterTriggerState}.
  +    Radius = case config:read(dc_clustering_radius) of
  +        failed -> exit(dc_clustering_radius_not_set);
  +        R when R > 0 -> R;
  +        _Else -> exit(dc_clustering_radius_invalid)
  +    end,
  +    #state_inactive{
  +        queued_messages = msg_queue:new()
  +        , reset_trigger_state = ResetTriggerState
  +        , cluster_trigger_state = ClusterTriggerState
  +        , radius=Radius
  +    }
  +    .
   
   %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
   % Message Loop
  
positive.code:                 ignore -> ok;
                  R -> comm:send(R, {clustering_shuffle_reply, comm:this(), Centroids, Epoch})
              end,
              {Epoch, cluster(Centroids, RemoteCentroids)}
      end,
      case NewEpoch of % reset needed?
          Epoch -> {NewCentroids, Epoch, ResetTriggerState, ClusterTriggerState};
          _Else ->
              NewResetTriggerState = trigger:next(ResetTriggerState),
              NewClusterTriggerState = trigger:next(ClusterTriggerState),
              % Note: NewEpoch - 1 because we will increment it in the handler for the
              % vivaldi reply
              {NewCentroids, NewEpoch - 1, NewResetTriggerState, NewClusterTriggerState}
      end
      .
  
negative.code:     {cy_cache, [node:node_type()]} |
      {clustering_shuffle, comm:mypid(), dc_centroids:centroids(), non_neg_integer()} |
      {clustering_shuffle_reply, comm:mypid(), dc_centroids:centroids(), non_neg_integer()} |
      {query_clustering, comm:mypid()} |
      {query_epoch, comm:mypid()}
  ).
  
  %% @doc Sends an initialization message to the node's dc_clustering process.
  -spec activate() -> ok | ignore.
  