Просмотр исходного кода

chore: choose core node's max tnxid as source conf

Zhongwen Deng 3 лет назад
Родитель
Сommit
130d1f7d9c
1 измененных файлов с 7 добавлено и 3 удалено
  1. 7 3
      apps/emqx_conf/src/emqx_conf_app.erl

+ 7 - 3
apps/emqx_conf/src/emqx_conf_app.erl

@@ -140,10 +140,14 @@ copy_override_conf_from_core_node() ->
                     end;
                 _ ->
                     SortFun = fun(
-                        {ok, #{wall_clock := W1}},
-                        {ok, #{wall_clock := W2}}
+                        {ok, #{wall_clock := W1, tnx_id := TnxId1}},
+                        {ok, #{wall_clock := W2, tnx_id := TnxId2}}
                     ) ->
-                        W1 > W2
+                        if
+                            TnxId1 > TnxId2 -> true;
+                            TnxId1 =:= TnxId2 -> W1 > W2;
+                            true -> false
+                        end
                     end,
                     [{ok, Info} | _] = lists:sort(SortFun, Ready),
                     #{node := Node, conf := RawOverrideConf, tnx_id := TnxId} = Info,