anchor.diff:    Host = get_host(CCM),
   
     ?assertEqual(ok, rpc:call(CCM, ?MODULE, ccm_code1, [])),
  -  test_utils:wait_for_cluster_cast(),
  +  nodes_manager:wait_for_cluster_cast(),
     RunWorkerCode = fun(Node) ->
       ?assertEqual(ok, rpc:call(Node, ?MODULE, worker_code, [])),
  -    test_utils:wait_for_cluster_cast({?Node_Manager_Name, Node})
  +    nodes_manager:wait_for_cluster_cast({?Node_Manager_Name, Node})
     end,
     lists:foreach(RunWorkerCode, WorkerNodes),
     ?assertEqual(ok, rpc:call(CCM, ?MODULE, ccm_code2, [])),
  -  test_utils:wait_for_cluster_init(),
  +  nodes_manager:wait_for_cluster_init(),
   
     {Workers, _} = gen_server:call({global, ?CCM}, get_workers, 1000),
     StartAdditionalWorker = fun(Node) ->
  
positive.code: 
  %% This test checks if dns works well with multi-node cluster
  distributed_test(Config) ->
    NodesUp = ?config(nodes, Config),
  
    [CCM | WorkerNodes] = NodesUp,
  
negative.code:     end
    end,
    lists:foreach(StartAdditionalWorker, NodesUp),
    nodes_manager:wait_for_cluster_init(length(NodesUp) - 1),
  
    {ConAns, Socket} = gen_tcp:connect(Host, DNS_Port, [{active, false}, binary, {packet, 2}]),
    ?assertEqual(ok, ConAns),
  