anchor.diff:  
     Node = erlang:node(self()),
   
  -  gen_server:call({cluster_rengine, Node}, {register_sub_proc, TreeId, 2, 2, ProcFun, NewMapFun, RM, DM}).
  +  LocalCacheName = list_to_atom(atom_to_list(TreeId) ++ "_local_cache"),
  +  case Config#processing_config.init_counter of
  +    undefined -> gen_server:call({cluster_rengine, Node}, {register_sub_proc, TreeId, 2, 2, ProcFun, NewMapFun, RM, DM});
  +    _ -> gen_server:call({cluster_rengine, Node}, {register_sub_proc, TreeId, 2, 2, ProcFun, NewMapFun, RM, DM, LocalCacheName})
  +  end.
   %%   nodes_manager:wait_for_cluster_cast({cluster_rengine, Node}),
   
   get_request_map_fun() ->
  
positive.code: 
  delete_file() ->
    rpc:call(node(), dao_lib, apply, [dao_vfs, remove_file, ["plgmsitko/todelete"], 1]).
  
  log(Msg) ->
    ?info(Msg).
  
  log(Msg, Arg) ->
    ?info("LOGGGG ::: ~p: ~p", [Msg, Arg]).
negative.code:   ProcFun = case Config#processing_config.init_counter of
      undefined ->
        fun(_ProtocolVersion, {final_stage_tree, _TreeId, Event}) ->
          HandlerFun(Event)
        end;
      InitCounter ->
        fun(_ProtocolVersion, {final_stage_tree, _TreeId, Event}, EtsName) ->
          InitCounterIfNeeded(EtsName, InitCounter),
          CurrentCounter = ets:update_counter(EtsName, counter, {2, -1, 1, InitCounter}),
          case CurrentCounter of
            InitCounter ->
              HandlerFun(Event);
            _ -> ok
          end
  