anchor.diff:      list_to_atom(?PROCESSOR_ETS_NAME ++ pid_to_list(self()))
     end,
   
  -  CreateEventProcessEtsIfNeeded = fun(EtsName, InitCounter) ->
  -    try
  -      ets:new(EtsName, [named_table, private, set]),
  -      ets:insert(EtsName, {counter, InitCounter})
  -    catch
  -      error:badarg -> ok
  +  InitCounterIfNeeded = fun(EtsName, InitCounter) ->
  +    case ets:lookup(EtsName, counter) of
  +      [] -> ets:insert(EtsName, {counter, InitCounter});
  +      _ -> ok
       end
     end,
   
  
positive.code: 
    Node = erlang:node(self()),
  
    gen_server:call({cluster_rengine, Node}, {register_sub_proc, TreeId, 2, 2, ProcFun, NewMapFun, RM, DM}).
  %%   nodes_manager:wait_for_cluster_cast({cluster_rengine, Node}),
  
  get_request_map_fun() ->
  
negative.code: %% ====================================================================
  %% API functions
  %% ====================================================================
  -export([init/1, handle/2, cleanup/0]).
  
  %% functions for manual tests
  -export([register_mkdir_handler/1, send_mkdir_event/0, delete_file/0]).
  