Handle new aten:[un]register return values.

rabbitmq · Jan 3, 2024 · 4e6ec70 · 4e6ec70
1 parent 3503c79
commit 4e6ec70
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/ra_server_proc.erl b/src/ra_server_proc.erl
@@ -1486,7 +1486,7 @@ follower_leader_change(Old, #state{pending_commands = Pending,
             LeaderNode = ra_lib:ra_server_id_node(NewLeader),
             ok = aten_register(LeaderNode),
             OldLeaderNode = ra_lib:ra_server_id_node(OldLeader),
-            ok = aten:unregister(OldLeaderNode),
+            _ = aten:unregister(OldLeaderNode),
             ok = record_leader_change(NewLeader, New),
             % leader has either changed or just been set
             ?INFO("~ts: detected a new leader ~w in term ~b",
@@ -1502,7 +1502,12 @@ aten_register(Node) ->
     case node() of
         Node -> ok;
         _ ->
-            aten:register(Node)
+            case aten:register(Node) of
+                ignore ->
+                    ok;
+                Res ->
+                    Res
+            end
     end.
 
 swap_monitor(MRef, L) ->