summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2013-12-10 14:30:02 +0000
committerSimon MacMullen <simon@rabbitmq.com>2013-12-10 14:30:02 +0000
commit6392ac1f070bf039b9eb37a49decff3230794ec6 (patch)
tree2cb49b6c88ba8193b25d604ee400510e9bca58ea
parent14d5456b27f95bb65a5d224f3af77f5a46d865b1 (diff)
parent79c905c57216c2128a74f9f976a35686a586d7c2 (diff)
downloadrabbitmq-server-6392ac1f070bf039b9eb37a49decff3230794ec6.tar.gz
Merge bug24829
-rw-r--r--src/rabbit_mnesia.erl13
1 files changed, 1 insertions, 12 deletions
diff --git a/src/rabbit_mnesia.erl b/src/rabbit_mnesia.erl
index 3a8fae7f..f27f77c6 100644
--- a/src/rabbit_mnesia.erl
+++ b/src/rabbit_mnesia.erl
@@ -434,10 +434,8 @@ init_db(ClusterNodes, NodeType, CheckOtherNodes) ->
%% First disc node up
maybe_force_load(),
ok;
- {[AnotherNode | _], _, _} ->
+ {[_ | _], _, _} ->
%% Subsequent node in cluster, catch up
- ensure_version_ok(
- rpc:call(AnotherNode, rabbit_version, recorded, [])),
maybe_force_load(),
ok = rabbit_table:wait_for_replicated(),
ok = rabbit_table:create_local_copy(NodeType)
@@ -639,15 +637,6 @@ schema_ok_or_move() ->
ok = create_schema()
end.
-ensure_version_ok({ok, DiscVersion}) ->
- DesiredVersion = rabbit_version:desired(),
- case rabbit_version:matches(DesiredVersion, DiscVersion) of
- true -> ok;
- false -> throw({error, {version_mismatch, DesiredVersion, DiscVersion}})
- end;
-ensure_version_ok({error, _}) ->
- ok = rabbit_version:record_desired().
-
%% We only care about disc nodes since ram nodes are supposed to catch
%% up only
create_schema() ->