diff options
| author | Daniil Fedotov <hairyhum@gmail.com> | 2019-05-15 12:09:21 -0400 |
|---|---|---|
| committer | Daniil Fedotov <hairyhum@gmail.com> | 2019-05-15 12:09:21 -0400 |
| commit | 7dd47cb7f3f49b25171d1ce860e431d8fab22175 (patch) | |
| tree | cc0066e7e5fe092dbad4499d35e0cd8f84cc7a5f /src/rabbit_queue_index.erl | |
| parent | 29935dbcdd786a22d327f65857eda16a8fd5804a (diff) | |
| download | rabbitmq-server-git-rabbit_data_dir.tar.gz | |
Create rabbit_data module to extract data dir configuration.rabbit_data_dir
Diffstat (limited to 'src/rabbit_queue_index.erl')
| -rw-r--r-- | src/rabbit_queue_index.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 9de86ee232..11a3eec367 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -582,9 +582,6 @@ queue_name_to_dir_name_legacy(Name = #resource { kind = queue }) -> <<Num:128>> = erlang:md5(term_to_binary_compat:term_to_binary_1(Name)), rabbit_misc:format("~.36B", [Num]). -queues_base_dir() -> - rabbit_mnesia:dir(). - blank_state_name_dir_funs(Name, Dir, OnSyncFun, OnSyncMsgFun) -> {ok, MaxJournal} = application:get_env(rabbit, queue_index_max_journal_entries), @@ -1469,7 +1466,7 @@ drive_transform_fun(Fun, Hdl, Contents) -> end. move_to_per_vhost_stores(#resource{} = QueueName) -> - OldQueueDir = filename:join([queues_base_dir(), "queues", + OldQueueDir = filename:join([legacy_queues_base_dir(), queue_name_to_dir_name_legacy(QueueName)]), NewQueueDir = queue_dir(QueueName), rabbit_log_upgrade:info("About to migrate queue directory '~s' to '~s'", @@ -1513,10 +1510,13 @@ read_global_recovery_terms(DurableQueueNames) -> {OrderedTerms, {fun queue_index_walker/1, {start, DurableQueueNames}}}. cleanup_global_recovery_terms() -> - rabbit_file:recursive_delete([filename:join([queues_base_dir(), "queues"])]), + rabbit_file:recursive_delete([legacy_queues_base_dir()]), rabbit_recovery_terms:delete_global_table(), ok. +%% Legacy queues directory +legacy_queues_base_dir() -> + filename:join(rabbit_data:mnesia_dir(), "queues"). update_recovery_term(#resource{virtual_host = VHost} = QueueName, Term) -> Key = queue_name_to_dir_name(QueueName), |