uzix/migresia
1
0
Fork 0
mirror of https://github.com/UzixLS/migresia.git synced 2025-07-19 07:11:28 +03:00
Code Issues Projects Releases Wiki Activity

Changing out to use a locally implemented ensure_started rather than be reliant on 16B01 OTP

Browse Source
This commit is contained in:
Christopher Phillips
2013-11-22 12:15:18 -05:00
parent 43df32f6de
commit a586545a2f
1 changed files with 12 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/migresia.erl
View File

@ -24,7 +24,7 @@
-module(migresia). -module(migresia).
-export([create_new_migration/2, check/1, migrate/1, list_nodes/0]). -export([create_new_migration/2, check/1, migrate/1, list_nodes/0, ensure_started/1]).
-define(TABLE, schema_migrations). -define(TABLE, schema_migrations).
@ -77,12 +77,12 @@ execute_up({Module, Short}) ->
-spec start_mnesia(boolean()) -> ok | {error, any()}. -spec start_mnesia(boolean()) -> ok | {error, any()}.
start_mnesia(RemoteToo) -> start_mnesia(RemoteToo) ->
io:format("Starting Mnesia...~n", []), io:format("Starting Mnesia...~n", []),
case application:ensure_started(mnesia) of case ensure_started(mnesia) of
Other when Other /= ok -> io:format(" => Error:~p~n", [Other]), Other; Other when Other /= ok -> io:format(" => Error:~p~n", [Other]), Other;
ok -> ok ->
case RemoteToo of case RemoteToo of
false -> ok; false -> ok;
true -> {ResultList, BadNodes} = rpc:multicall(list_nodes(), application, ensure_started, [mnesia]), true -> {ResultList, BadNodes} = rpc:multicall(list_nodes(), migresia, ensure_started, [mnesia]),
BadStatuses = [X || X <- ResultList, X /= ok], BadStatuses = [X || X <- ResultList, X /= ok],
if BadNodes /= [] -> io:format(" => Error:~p~n", [not_all_nodes_running]), {error, not_all_nodes_running}; if BadNodes /= [] -> io:format(" => Error:~p~n", [not_all_nodes_running]), {error, not_all_nodes_running};
BadStatuses /= [] -> io:format(" => Error:~p~n", [BadStatuses]), {error, BadStatuses}; BadStatuses /= [] -> io:format(" => Error:~p~n", [BadStatuses]), {error, BadStatuses};
@ -93,3 +93,11 @@ start_mnesia(RemoteToo) ->
list_nodes() -> list_nodes() ->
mnesia:table_info(schema, disc_copies). mnesia:table_info(schema, disc_copies).
-spec ensure_started(atom()) -> ok | {error, any()}.
ensure_started(App) ->
case application:start(App) of
ok -> ok;
{error,{already_started,App}} -> ok;
A -> A
end.