anchor.diff:                      N ->
                           N
                   end,
  -            case get_candidates(Members, MaxNumOfNodes, []) of
  -                {ok, Candidates} ->
  -                    lists:member(erlang:node(), Candidates);
  -                not_found ->
  -                    false
  -            end;
  +            is_candidates(Members, MaxNumOfNodes, []);
           _ ->
               false
       end.
  
positive.code: 
                      case (ActiveSizeRatio =< (ThresholdActiveSizeRatio + ActiveSizeRatioDiff)) of
                          true ->
                              [Node|Acc];
                          false ->
                              case rpc:call(Node, leo_storage_api, compact, [status], ?DEF_REQ_TIMEOUT) of
                                  {ok, #compaction_stats{status = ?ST_RUNNING}} ->
                                      [Node|Acc];
                                  _ ->
                                      Acc
                              end
  
negative.code: handle_notify(?WD_SUB_ID_2, #watchdog_alarm{state = #watchdog_state{
                                                         level = Level,
                                                         props = Props}},_Unixtime) ->
      %% Clear the current status
      _ = elarm:clear('leo_storage_watchdog_fragment', ?WD_ITEM_ACTIVE_SIZE_RATIO),
      %% Execution data-compacion or not
      case (Level >= ?WD_LEVEL_ERROR) of
          true ->
              case can_start_compaction() of
                  true ->
                      timer:sleep(?DEF_WAIT_TIME),
                      ThisTime = leo_date:now(),
                      AutoCompactionInterval = ?env_auto_compaction_interval(),
  