anchor.diff:    [Node | _] = ?config(nodes, Config),
     gen_server:cast({?Node_Manager_Name, Node}, do_heart_beat),
     gen_server:cast({global, ?CCM}, {set_monitoring, on}),
  -  test_utils:wait_for_cluster_cast(),
  +  nodes_manager:wait_for_cluster_cast(),
     gen_server:cast({global, ?CCM}, init_cluster),
     ok.
   
  
positive.code: %% ====================================================================
  
  init_per_testcase(distributed_test, Config) ->
    ?INIT_CODE_PATH,?CLEAN_TEST_DIRS,
    test_node_starter:start_deps_for_tester_node(),
  
    NodesUp = test_node_starter:start_test_nodes(4),
    [CCM | _] = NodesUp,
    DBNode = ?DB_NODE,
  
    test_node_starter:start_app_on_nodes(?APP_Name, ?VEIL_DEPS, NodesUp, [
      [{node_type, ccm_test}, {dispatcher_port, 5055}, {control_panel_port, 1350}, {control_panel_redirect_port, 1354}, {rest_port, 8443}, {ccm_nodes, [CCM]}, {dns_port, 1308}, {db_nodes, [DBNode]}, {heart_beat, 1},{nif_prefix, './'},{ca_dir, './cacerts/'}],
      [{node_type, worker}, {dispatcher_port, 6666}, {control_panel_port, 1351}, {control_panel_redirect_port, 1355}, {rest_port, 8444}, {ccm_nodes, [CCM]}, {dns_port, 1308}, {db_nodes, [DBNode]}, {heart_beat, 1},{nif_prefix, './'},{ca_dir, './cacerts/'}],
      [{node_type, worker}, {dispatcher_port, 7777}, {control_panel_port, 1352}, {control_panel_redirect_port, 1356}, {rest_port, 8445}, {ccm_nodes, [CCM]}, {dns_port, 1308}, {db_nodes, [DBNode]}, {heart_beat, 1},{nif_prefix, './'},{ca_dir, './cacerts/'}],
      [{node_type, worker}, {dispatcher_port, 8888}, {control_panel_port, 1353}, {control_panel_redirect_port, 1357}, {rest_port, 8446}, {ccm_nodes, [CCM]}, {dns_port, 1308}, {db_nodes, [DBNode]}, {heart_beat, 1},{nif_prefix, './'},{ca_dir, './cacerts/'}]]),
  
    lists:append([{nodes, NodesUp}], Config);
  
  init_per_testcase(_, Config) ->
    ?INIT_CODE_PATH,?CLEAN_TEST_DIRS,
  
    NodesUp = test_node_starter:start_test_nodes(1),
    [Node | _] = NodesUp,
  
    DNS_Port = 1312,
    Env = [{node_type, ccm_test}, {dispatcher_port, 6666}, {ccm_nodes, [Node]}, {dns_port, DNS_Port}, {heart_beat, 1},{nif_prefix, './'},{ca_dir, './cacerts/'}],
  
    test_node_starter:start_app_on_nodes(?APP_Name, ?VEIL_DEPS, NodesUp, [Env]),
  
    lists:append([{dns_port, DNS_Port}, {nodes, NodesUp}], Config).
  
  end_per_testcase(distributed_test, Config) ->
    Nodes = ?config(nodes, Config),
    test_node_starter:stop_app_on_nodes(?APP_Name, ?VEIL_DEPS, Nodes),
    test_node_starter:stop_test_nodes(Nodes),
    test_node_starter:stop_deps_for_tester_node();
  
  end_per_testcase(_, Config) ->
    Nodes = ?config(nodes, Config),
    test_node_starter:stop_app_on_nodes(?APP_Name, ?VEIL_DEPS, Nodes),
    test_node_starter:stop_test_nodes(Nodes).
  
  %% ====================================================================
  %% Helping functions
  
negative.code:   Host = get_host(CCM),
  
    ?assertEqual(ok, rpc:call(CCM, ?MODULE, ccm_code1, [])),
    nodes_manager:wait_for_cluster_cast(),
    RunWorkerCode = fun(Node) ->
      ?assertEqual(ok, rpc:call(Node, ?MODULE, worker_code, [])),
      nodes_manager:wait_for_cluster_cast({?Node_Manager_Name, Node})
    end,
    lists:foreach(RunWorkerCode, WorkerNodes),
    ?assertEqual(ok, rpc:call(CCM, ?MODULE, ccm_code2, [])),
    nodes_manager:wait_for_cluster_init(),
  
    {Workers, _} = gen_server:call({global, ?CCM}, get_workers, 1000),
    StartAdditionalWorker = fun(Node) ->
  