Rename ramnesia to mnevis

Author: hairyhum

src/gm.erl

@@ -488,7 +488,7 @@ create_tables() ->
 create_tables([]) ->
     ok;
 create_tables([{Table, Attributes} | Tables]) ->
-    case ramnesia:create_table(Table, Attributes) of
+    case mnevis:create_table(Table, Attributes) of
         {atomic, ok}                       -> create_tables(Tables);
         {aborted, {already_exists, Table}} -> create_tables(Tables);
         Err                                -> Err
@@ -535,7 +535,7 @@ validate_members(Server, Members) ->
 -spec forget_group(group_name()) -> 'ok'.
 
 forget_group(GroupName) ->
-    {atomic, ok} = ramnesia:transaction(
+    {atomic, ok} = mnevis:transaction(
                      fun () ->
                              mnesia:delete({?GROUP_TABLE, GroupName})
                      end),

src/rabbit.erl

@@ -1077,7 +1077,7 @@ recover() ->
 maybe_insert_default_data() ->
     case rabbit_table:needs_default_data() of
         true  ->
-            {ok, _, {_, Leader}} = ra:members(ramnesia_node:node_id()),
+            {ok, _, {_, Leader}} = ra:members(mnevis_node:node_id()),
             case Leader == node() of
                 true ->
                     insert_default_data();

src/rabbit_amqqueue.erl

@@ -1509,7 +1509,7 @@ forget_all_durable(Node) ->
     %% Note rabbit is not running so we avoid e.g. the worker pool. Also why
     %% we don't invoke the return from rabbit_binding:process_deletions/1.
     {atomic, ok} =
-        ramnesia:transaction(
+        mnevis:transaction(
           fun () ->
                   Qs = mnesia:match_object(rabbit_durable_queue,
                                            amqqueue:pattern_match_all(), write),

src/rabbit_connection_tracking.erl

@@ -184,7 +184,7 @@ ensure_per_vhost_tracked_connections_table_for_this_node() ->
 
 ensure_tracked_connections_table_for_node(Node) ->
     TableName = tracked_connection_table_name_for(Node),
-    case ramnesia:create_table(TableName, [{record_name, tracked_connection},
+    case mnevis:create_table(TableName, [{record_name, tracked_connection},
                                          {attributes, record_info(fields, tracked_connection)}]) of
         {atomic, ok}                   -> ok;
         {aborted, {already_exists, _}} -> ok;
@@ -198,7 +198,7 @@ ensure_tracked_connections_table_for_node(Node) ->
 
 ensure_per_vhost_tracked_connections_table_for_node(Node) ->
     TableName = tracked_connection_per_vhost_table_name_for(Node),
-    case ramnesia:create_table(TableName, [{record_name, tracked_connection_per_vhost},
+    case mnevis:create_table(TableName, [{record_name, tracked_connection_per_vhost},
                                          {attributes, record_info(fields, tracked_connection_per_vhost)}]) of
         {atomic, ok}                   -> ok;
         {aborted, {already_exists, _}} -> ok;
@@ -225,7 +225,7 @@ clear_tracked_connection_tables_for_this_node() ->
 
 delete_tracked_connections_table_for_node(Node) ->
     TableName = tracked_connection_table_name_for(Node),
-    case ramnesia:delete_table(TableName) of
+    case mnevis:delete_table(TableName) of
         {atomic, ok}              -> ok;
         {aborted, {no_exists, _}} -> ok;
         {aborted, Error} ->
@@ -238,7 +238,7 @@ delete_tracked_connections_table_for_node(Node) ->
 
 delete_per_vhost_tracked_connections_table_for_node(Node) ->
     TableName = tracked_connection_per_vhost_table_name_for(Node),
-    case ramnesia:delete_table(TableName) of
+    case mnevis:delete_table(TableName) of
         {atomic, ok}              -> ok;
         {aborted, {no_exists, _}} -> ok;
         {aborted, Error} ->
@@ -344,7 +344,7 @@ count_connections_in(VirtualHost) ->
     lists:foldl(fun (Node, Acc) ->
                         Tab = tracked_connection_per_vhost_table_name_for(Node),
                         try
-                            N = case ramnesia:transaction(
+                            N = case mnevis:transaction(
                                        fun() ->
                                                case mnesia:dirty_read({Tab, VirtualHost}) of
                                                    []    -> 0;

src/rabbit_mnesia.erl

@@ -80,14 +80,15 @@ init() ->
     %% Create schema on all nodes
     ok = create_schema(),
 
-    ramnesia_node:start(),
-    ramnesia_node:trigger_election(),
+    %% TODO mnevis: node start
+    mnevis_node:start(),
+    mnevis_node:trigger_election(),
 
-    {ok, _, _} = ra:members(ramnesia_node:node_id()),
+    {ok, _, _} = ra:members(mnevis_node:node_id()),
 
-    io:format("~nDb nodes ~p~n", [ramnesia:db_nodes()]),
+    io:format("~nDb nodes ~p~n", [mnevis:db_nodes()]),
 
-    io:format("~nRunning Db nodes ~p~n", [ramnesia:running_db_nodes()]),
+    io:format("~nRunning Db nodes ~p~n", [mnevis:running_db_nodes()]),
 
     io:format("Get cluster status ~n"),
     {ok, Status} = cluster_status_from_mnesia(),
@@ -405,7 +406,7 @@ remove_node_offline_node(Node) ->
     %% want - we need to know the running nodes *now*.  If the current node is a
     %% RAM node it will return bogus results, but we don't care since we only do
     %% this operation from disc nodes.
-    case {ramnesia:running_db_nodes() -- [Node], node_type()} of
+    case {mnevis:running_db_nodes() -- [Node], node_type()} of
         {[], disc} ->
             start_mnesia(),
             try
@@ -509,7 +510,7 @@ cluster_status_from_mnesia() ->
             %            end,
             % case rabbit_table:is_present() of
                 % true  ->
-                AllNodes = ramnesia:db_nodes(),
+                AllNodes = mnevis:db_nodes(),
 
                          %% Ignoring disk node setting
                          % DiscCopies = mnesia:table_info(schema, disc_copies),
@@ -519,7 +520,7 @@ cluster_status_from_mnesia() ->
                                      % end,
                          %% `mnesia:system_info(running_db_nodes)' is safe since
                          %% we know that mnesia is running
-                         RunningNodes = ramnesia:running_db_nodes(),
+                         RunningNodes = mnevis:running_db_nodes(),
                          {ok, {AllNodes, AllNodes, RunningNodes}}
                 % false -> {error, tables_not_present}
             % end

src/rabbit_mnesia_rename.erl

@@ -254,7 +254,7 @@ rename_in_running_mnesia(FromNode, ToNode) ->
     ok.
 
 transform_table(Table, Map) ->
-    ramnesia:transaction(
+    mnevis:transaction(
       fun () ->
               mnesia:lock({table, Table}, write),
               transform_table(Table, Map, mnesia:first(Table))

src/rabbit_node_monitor.erl

@@ -829,7 +829,7 @@ legacy_cluster_nodes(Nodes) ->
     %% We get all the info that we can, including the nodes from
     %% mnesia, which will be there if the node is a disc node (empty
     %% list otherwise)
-    lists:usort(Nodes ++ ramnesia:db_nodes()).
+    lists:usort(Nodes ++ mnevis:db_nodes()).
 
 legacy_disc_nodes(AllNodes) ->
     case AllNodes == [] orelse lists:member(node(), AllNodes) of

src/rabbit_table.erl

@@ -54,7 +54,7 @@ ensure_secondary_indexes() ->
   ensure_secondary_index(rabbit_queue, vhost),
   ok.
 
-%% TODO ramnesia add table index
+%% TODO mnevis add table index
 ensure_secondary_index(Table, Field) ->
   case mnesia:add_table_index(Table, Field) of
     {atomic, ok}                          -> ok;

src/rabbit_upgrade_functions.erl

@@ -418,7 +418,7 @@ internal_system_x() ->
 -spec cluster_name() -> 'ok'.
 
 cluster_name() ->
-    {atomic, ok} = ramnesia:transaction(fun cluster_name_tx/0),
+    {atomic, ok} = mnevis:transaction(fun cluster_name_tx/0),
     ok.
 
 cluster_name_tx() ->
@@ -656,7 +656,7 @@ transform(TableName, Fun, FieldList, NewRecordName) ->
     ok.
 
 create(Tab, TabDef) ->
-    {atomic, ok} = ramnesia:create_table(Tab, TabDef),
+    {atomic, ok} = mnevis:create_table(Tab, TabDef),
     ok.
 
 %% Dumb replacement for rabbit_exchange:declare that does not require

test/mirrored_supervisor_SUITE.erl

@@ -48,7 +48,7 @@ init_per_suite(Config) ->
     lists:foreach(
       fun ({Tab, TabDef}) ->
               TabDef1 = proplists:delete(match, TabDef),
-              case ramnesia:create_table(Tab, TabDef1) of
+              case mnevis:create_table(Tab, TabDef1) of
                   {atomic, ok} ->
                       ok;
                   {aborted, Reason} ->
@@ -277,7 +277,7 @@ pid_of(Id) ->
     Pid.
 
 tx_fun(Fun) ->
-    case ramnesia:transaction(Fun) of
+    case mnevis:transaction(Fun) of
         {atomic,  Result}         -> Result;
         {aborted, Reason}         -> throw({error, Reason})
     end.