Merge pull request #3068 from rabbitmq/mk-segment-entry-count-fallback-during-3.6-upgrade

Handle cases where virtual host config file does not yet exist

(cherry picked from commit e91c918)

Author: michaelklishin

deps/rabbit/src/rabbit_vhost.erl

@@ -15,7 +15,7 @@
          set_limits/2, vhost_cluster_state/1, is_running_on_all_nodes/1, await_running_on_all_nodes/2,
         list/0, count/0, list_names/0, all/0, parse_tags/1]).
 -export([info/1, info/2, info_all/0, info_all/1, info_all/2, info_all/3]).
--export([dir/1, msg_store_dir_path/1, msg_store_dir_wildcard/0, config_file_path/1]).
+-export([dir/1, msg_store_dir_path/1, msg_store_dir_wildcard/0, config_file_path/1, ensure_config_file/1]).
 -export([delete_storage/1]).
 -export([vhost_down/1]).
 -export([put_vhost/5]).
@@ -80,7 +80,7 @@ ensure_config_file(VHost) ->
                 %% default of 16384 for forward compatibility. Historic
                 %% default calculated as trunc(math:pow(2,?REL_SEQ_BITS)).
                 _ ->
-                    16384
+                    ?LEGACY_INDEX_SEGMENT_ENTRY_COUNT
             end,
             _ = rabbit_log:info("Setting segment_entry_count for vhost '~s' with ~b queues to '~b'",
                                 [VHost, length(QueueDirs), SegmentEntryCount]),
@@ -91,8 +91,15 @@ ensure_config_file(VHost) ->
     end.
 
 read_config(VHost) ->
-    {ok, Config} = file:consult(config_file_path(VHost)),
-    maps:from_list(Config).
+    Config = case file:consult(config_file_path(VHost)) of
+        {ok, Val}       -> Val;
+        %% the file does not exist yet, likely due to an upgrade from a pre-3.7
+        %% message store layout so use the history default.
+        {error, _}      -> #{
+            segment_entry_count => ?LEGACY_INDEX_SEGMENT_ENTRY_COUNT
+        }
+    end,
+    rabbit_data_coercion:to_map(Config).
 
 -define(INFO_KEYS, vhost:info_keys()).
 

deps/rabbit_common/include/rabbit.hrl

@@ -266,3 +266,6 @@
 %% Execution timeout of connection and channel tracking operations
 -define(TRACKING_EXECUTION_TIMEOUT,
         rabbit_misc:get_env(rabbit, tracking_execution_timeout, 5000)).
+
+%% 3.6, 3.7, early 3.8
+-define(LEGACY_INDEX_SEGMENT_ENTRY_COUNT, 16384).