Remove compatibility for flag listener_records_in_ets

Author: dcorbacho

deps/rabbit/src/rabbit_core_ff.erl

@@ -78,7 +78,6 @@
 -rabbit_feature_flag(
    {listener_records_in_ets,
     #{desc       => "Store listener records in ETS instead of Mnesia",
-      %%TODO remove compatibility code
       stability  => required,
       depends_on => [feature_flags_v2]
      }}).

deps/rabbit/src/rabbit_networking.erl

@@ -251,24 +251,7 @@ ranch_ref_of_protocol(Protocol) ->
 
 -spec listener_of_protocol(atom()) -> #listener{}.
 listener_of_protocol(Protocol) ->
-    case rabbit_feature_flags:is_enabled(listener_records_in_ets) of
-        true -> listener_of_protocol_ets(Protocol);
-        false -> listener_of_protocol_mnesia(Protocol)
-    end.
-
-listener_of_protocol_mnesia(Protocol) ->
-    rabbit_mnesia:execute_mnesia_transaction(
-        fun() ->
-            MatchSpec = #listener{
-                node = node(),
-                protocol = Protocol,
-                _ = '_'
-            },
-            case mnesia:match_object(rabbit_listener, MatchSpec, read) of
-                []    -> undefined;
-                [Row] -> Row
-            end
-        end).
+    listener_of_protocol_ets(Protocol).
 
 listener_of_protocol_ets(Protocol) ->
     MatchSpec = #listener{
@@ -378,13 +361,7 @@ tcp_listener_started(Protocol, Opts, IPAddress, Port) ->
                   ip_address = IPAddress,
                   port = Port,
                   opts = Opts},
-    case rabbit_feature_flags:is_enabled(listener_records_in_ets) of
-        true -> tcp_listener_started_ets(L);
-        false -> tcp_listener_started_mnesia(L)
-    end.
-
-tcp_listener_started_mnesia(L) ->
-    ok = mnesia:dirty_write(rabbit_listener, L).
+    tcp_listener_started_ets(L).
 
 tcp_listener_started_ets(L) ->
     true = ets:insert(?ETS_TABLE, L),
@@ -405,13 +382,7 @@ tcp_listener_stopped(Protocol, Opts, IPAddress, Port) ->
                   ip_address = IPAddress,
                   port = Port,
                   opts = Opts},
-    case rabbit_feature_flags:is_enabled(listener_records_in_ets) of
-        true -> tcp_listener_stopped_ets(L);
-        false -> tcp_listener_stopped_mnesia(L)
-    end.
-
-tcp_listener_stopped_mnesia(L) ->
-    ok = mnesia:dirty_delete_object(rabbit_listener, L).
+    tcp_listener_stopped_ets(L).
 
 tcp_listener_stopped_ets(L) ->
     true = ets:delete_object(?ETS_TABLE, L),
@@ -469,13 +440,7 @@ active_listeners() ->
 -spec node_listeners(node()) -> [rabbit_types:listener()].
 
 node_listeners(Node) ->
-    case rabbit_feature_flags:is_enabled(listener_records_in_ets) of
-        true -> node_listeners_ets(Node);
-        false -> node_listeners_mnesia(Node)
-    end.
-
-node_listeners_mnesia(Node) ->
-    mnesia:dirty_read(rabbit_listener, Node).
+    node_listeners_ets(Node).
 
 node_listeners_ets(Node) ->
     case rabbit_misc:rpc_call(Node, ets, tab2list, [?ETS_TABLE]) of
@@ -501,22 +466,8 @@ node_client_listeners(Node) ->
 
 -spec on_node_down(node()) -> 'ok'.
 
-on_node_down(Node) ->
-    case rabbit_feature_flags:is_enabled(listener_records_in_ets) of
-        true -> ok;
-        false -> on_node_down_mnesia(Node)
-    end.
-
-on_node_down_mnesia(Node) ->
-    case lists:member(Node, nodes()) of
-        false ->
-            rabbit_log:info(
-              "Node ~ts is down, deleting its listeners", [Node]),
-            ok = mnesia:dirty_delete(rabbit_listener, Node);
-        true  ->
-            rabbit_log:info(
-              "Keeping ~ts listeners: the node is already back", [Node])
-    end.
+on_node_down(_Node) ->
+    ok.
 
 -spec register_connection(pid()) -> ok.
 

deps/rabbit/src/rabbit_node_monitor.erl

@@ -815,7 +815,6 @@ handle_dead_rabbit(Node, State = #state{partitions = Partitions,
     ok = rabbit_amqqueue:on_node_down(Node),
     ok = rabbit_alarm:on_node_down(Node),
     ok = rabbit_mnesia:on_node_down(Node),
-    ok = rabbit_networking:on_node_down(Node),
     %% If we have been partitioned, and we are now in the only remaining
     %% partition, we no longer care about partitions - forget them. Note
     %% that we do not attempt to deal with individual (other) partitions

deps/rabbit/src/rabbit_table.erl

@@ -296,7 +296,6 @@ definitions(ram) ->
         {Tab, TabDef} <- definitions()].
 
 definitions() ->
-    Definitions =
     [{rabbit_user,
       [{record_name, internal_user},
        {attributes, internal_user:fields()},
@@ -396,21 +395,7 @@ definitions() ->
        {match, amqqueue:pattern_match_on_name(queue_name_match())}]}
     ]
         ++ gm:table_definitions()
-        ++ mirrored_supervisor:table_definitions(),
-
-    MaybeListener = case rabbit_feature_flags:is_enabled(listener_records_in_ets) of
-                        false ->
-                            [{rabbit_listener, rabbit_listener_definition()}];
-                        true ->
-                            []
-                    end,
-    Definitions ++ MaybeListener.
-
-rabbit_listener_definition() ->
-    [{record_name, listener},
-     {attributes, record_info(fields, listener)},
-     {type, bag},
-     {match, #listener{_='_'}}].
+        ++ mirrored_supervisor:table_definitions().
 
 binding_match() ->
     #binding{source = exchange_name_match(),