anchor.diff:      MyDHT = pid_groups:get_my(dht_node),
       comm:send_local(MyDHT, {get_state, comm:this(), my_range}).
   
  +-spec request_dht_load() -> ok.
  +request_dht_load() ->
  +    MyDHT = pid_groups:find_a(dht_node),
  +    comm:send_local(MyDHT, {lb_active, {request_load, self()}}).
  +
   -spec int_to_str(integer()) -> string().
   int_to_str(N) ->
       erlang:integer_to_list(N).
  
positive.code:     ?TRACE("~p: I am responsible for ~p~n", [self(), MyDirectories]),
      State#state{my_dirs = MyDirectories};
  
  %% we received load because of publish load trigger or emergency
  handle_msg({post_load, LoadInfo, DirKey}, State) ->
      ?TRACE("Posting load ~p~n", [LoadInfo]),
      post_load_to_directory(LoadInfo, DirKey),
      %% TODO Emergency Threshold has been already check at the node overloaded...
      EmergencyThreshold = State#state.threshold_emergency,
      case LoadInfo#lb_info.utilization > EmergencyThreshold of
          true  ->
              MySchedule = State#state.schedule,
              directory_routine(DirKey, emergency, MySchedule);
          false -> State
      end;
  
  handle_msg(Msg, State) ->
      ?TRACE("Unknown message: ~p~n", [Msg]),
      State.
  
negative.code:         {TLog2, {ok, Directory}} ->
              case api_tx:req_list(TLog2, [{write, DirKey, dir_clear_load(Directory)}, {commit}]) of
                  {[], ok, ok} -> Directory;
                  Error -> log:log(warn, "~p: Failed to save directory ~p because of failed transaction: ~p", [?MODULE, DirKey, Error]),
                           pop_load_in_directory(DirKey)
              end;
          {_TLog2, {fail, not_found}} ->
              log:log(warn, "~p: Directory not found while posting load. This should never happen...", [?MODULE])
  