anchor.diff:    Res = lists:append([{nodes, NodesUp}, {assertions, Assertions}], Config),
   
     ?assertEqual(ok, rpc:call(CCM, ?MODULE, ccm_code1, [])),
  -  timer:sleep(500),
  +  nodes_manager:wait_for_cluster_cast(),
     RunWorkerCode = fun(Node) ->
  -    ?assertEqual(ok, rpc:call(Node, ?MODULE, worker_code, []))
  +    ?assertEqual(ok, rpc:call(Node, ?MODULE, worker_code, [])),
  +    nodes_manager:wait_for_cluster_cast({?Node_Manager_Name, Node})
     end,
     lists:foreach(RunWorkerCode, WorkerNodes),
  -  timer:sleep(1000),
   
     {Workers, _} = gen_server:call({global, ?CCM}, get_workers),
   
  
positive.code: 
    receive
      ok -> ok
    after 100 ->
      ?assert(false)
    end,
  
  
negative.code:   lists:foreach(fun(Node) -> StartAdditionalWorker(Node, cluster_rengine) end, NodesUp),
    StartAdditionalWorker(CCM, dao),
  
    nodes_manager:wait_for_cluster_init(length(NodesUp) - 1),
    Res.
  
  end_per_testcase(distributed_test, Config) ->
  