Browse Source

add additional information on kvs:join().

Maxim Sokhatsky 10 years ago
parent
commit
b08caa4418
2 changed files with 6 additions and 3 deletions
  1. 1 1
      src/kvs.erl
  2. 5 2
      src/store_mnesia.erl

+ 1 - 1
src/kvs.erl

@@ -285,7 +285,7 @@ log_modules() -> [].
 
 
 log(Module, String, Args, Fun) ->
 log(Module, String, Args, Fun) ->
     case lists:member(Module,?ALLOWED:log_modules()) of
     case lists:member(Module,?ALLOWED:log_modules()) of
-         true -> error_logger:Fun(String, Args);
+         true -> error_logger:Fun("~p:"++String, [Module|Args]);
          false -> skip end.
          false -> skip end.
 
 
 info(Module,String, Args) ->  log(Module,String, Args, info_msg).
 info(Module,String, Args) ->  log(Module,String, Args, info_msg).

+ 5 - 2
src/store_mnesia.erl

@@ -19,7 +19,7 @@ join(Node) ->
                                || T <- mnesia:system_info(tables)], Node==N].
                                || T <- mnesia:system_info(tables)], Node==N].
 
 
 initialize() ->
 initialize() ->
-    kvs:info(?MODULE,"[store_mnesia] mnesia init.~n"),
+    kvs:info(?MODULE,"[store_mnesia] mnesia init.~n",[]),
     mnesia:create_schema([node()]),
     mnesia:create_schema([node()]),
     [ kvs:init(store_mnesia,Module) || Module <- kvs:modules() ],
     [ kvs:init(store_mnesia,Module) || Module <- kvs:modules() ],
     mnesia:wait_for_tables([ T#table.name || T <- kvs:tables()],infinity).
     mnesia:wait_for_tables([ T#table.name || T <- kvs:tables()],infinity).
@@ -41,7 +41,10 @@ all(R) -> lists:flatten(many(fun() -> L= mnesia:all_keys(R), [ mnesia:read({R, G
 next_id(RecordName, Incr) -> mnesia:dirty_update_counter({id_seq, RecordName}, Incr).
 next_id(RecordName, Incr) -> mnesia:dirty_update_counter({id_seq, RecordName}, Incr).
 many(Fun) -> case mnesia:transaction(Fun) of {atomic, R} -> R; _ -> [] end.
 many(Fun) -> case mnesia:transaction(Fun) of {atomic, R} -> R; _ -> [] end.
 void(Fun) -> case mnesia:transaction(Fun) of {atomic, ok} -> ok; {aborted, Error} -> {error, Error} end.
 void(Fun) -> case mnesia:transaction(Fun) of {atomic, ok} -> ok; {aborted, Error} -> {error, Error} end.
-create_table(Name,Options) -> mnesia:create_table(Name, Options).
+create_table(Name,Options) -> 
+    X = mnesia:create_table(Name, Options),
+    kvs:info("Create table ~p ~nOptions ~p~nReturn ~p~n",[Name, Options,X]),
+    X.
 add_table_index(Record, Field) -> mnesia:add_table_index(Record, Field).
 add_table_index(Record, Field) -> mnesia:add_table_index(Record, Field).
 exec(Q) -> F = fun() -> qlc:e(Q) end, {atomic, Val} = mnesia:transaction(F), Val.
 exec(Q) -> F = fun() -> qlc:e(Q) end, {atomic, Val} = mnesia:transaction(F), Val.
 just_one(Fun) ->
 just_one(Fun) ->