소스 검색

fix(router): update membership when node sends "mnesia up" event

This helps to avoid test flakiness because nodes in tests are joined
and killed quite quickly.
Andrew Mayorov 1 년 전
부모
커밋
4c1135eb4b
1개의 변경된 파일2개의 추가작업 그리고 0개의 파일을 삭제
  1. 2 0
      apps/emqx/src/emqx_router_helper.erl

+ 2 - 0
apps/emqx/src/emqx_router_helper.erl

@@ -240,6 +240,8 @@ handle_membership_event({node, leaving, Node}, State) ->
 handle_membership_event({node, up, Node}, State) ->
     _ = record_node_alive(Node),
     State;
+handle_membership_event({mnesia, up, Node}, State = #{last_membership := Membership}) ->
+    State#{last_membership := lists:usort([Node | Membership])};
 handle_membership_event(_Event, State) ->
     State.