Connection re-registration after network split WIP

src/rabbit_networking.erl

@@ -343,9 +343,13 @@ node_listeners(Node) ->
 
 on_node_down(Node) ->
     case lists:member(Node, nodes()) of
-        false -> ok = mnesia:dirty_delete(rabbit_listener, Node);
-        true  -> rabbit_log:info(
-                   "Keep ~s listeners: the node is already back~n", [Node])
+        false ->
+            rabbit_log:info(
+                   "Node ~s is down, deleting its listeners~n", [Node]),
+            ok = mnesia:dirty_delete(rabbit_listener, Node);
+        true  ->
+            rabbit_log:info(
+                   "Keeping ~s listeners: the node is already back~n", [Node])
     end.
 
 register_connection(Pid) -> pg_local:join(rabbit_connections, Pid).

src/rabbit_reader.erl

@@ -565,6 +565,11 @@ handle_other({channel_exit, Channel, Reason}, State) ->
     handle_exception(State, Channel, Reason);
 handle_other({'DOWN', _MRef, process, ChPid, Reason}, State) ->
     handle_dependent_exit(ChPid, Reason, State);
+%% We were asked to re-register in rabbit_tracked_connection.
+%% See rabbit_connection_tracking, rabbit_connection_tracker.
+handle_other(reregister, State = #v1{connection = ConnState}) ->
+    rabbit_event:notify(connection_reregistered, [{state, ConnState}]),
+    State;
 handle_other(terminate_connection, State) ->
     maybe_emit_stats(State),
     stop;