diff --git a/apps/roster/src/protocol/micro_auth.erl b/apps/roster/src/protocol/micro_auth.erl index e97661e8f10647619b5b940441e2e44b8201ce83..aeca814a428f102c10ce7f9b96d2256badc38104 100644 --- a/apps/roster/src/protocol/micro_auth.erl +++ b/apps/roster/src/protocol/micro_auth.erl @@ -118,7 +118,9 @@ info(#'Auth'{phone = Phone} = Auth, Req, #cx{params = ClientId} = State) -> %% micro_auth handlers proc(init, #handler{name = micro_auth} = Async) -> - {ok, C} = emqttc:start_link([{client_id, <<"micro_auth">>}, {logger, {console, error}}, {reconnect, 5}]), + {ok, C} = emqttc:start_link([{client_id, <<"micro_auth">>}, + {logger, {error_logger, error}}, + {reconnect, 5}]), ?LOG_INFO("ASYNC AUTH PROC started", []), {ok, Async#handler{state = C, seq = 0}}; diff --git a/apps/roster/src/protocol/roster_auth.erl b/apps/roster/src/protocol/roster_auth.erl index 0c22755a789908fd08f6944cb2a02ddd3e9fd6b8..da4a8dede9c55c3c51b4698bc1a09cf96b770cc0 100644 --- a/apps/roster/src/protocol/roster_auth.erl +++ b/apps/roster/src/protocol/roster_auth.erl @@ -592,7 +592,7 @@ info(#'Auth'{phone = Phone} = Auth, proc(init, #handler{name = roster_auth} = Async) -> {ok, C} = emqttc:start_link([ {client_id, <<"roster_auth">>}, - {logger, {console, error}}, + {logger, {error_logger, error}}, {reconnect, 5} ]), catch locus:start_loader(city, application:get_env(locus, url, ?GEO_URL)), diff --git a/apps/roster/src/protocol/roster_bpe.erl b/apps/roster/src/protocol/roster_bpe.erl index 96b89d4649b5d02ee2ad1fb87630ae56dcea653d..31a8e7a9ee68825e6e7de1796e089c86e6c8062f 100644 --- a/apps/roster/src/protocol/roster_bpe.erl +++ b/apps/roster/src/protocol/roster_bpe.erl @@ -196,7 +196,9 @@ info(#'Job'{feed_id = Feed} = RequestData, R, S) -> info(M, R, S) -> ?LOG_INFO("UNKNOWN:~w", [M]), {unknown, M, R, S}. proc(init, #handler{name = roster_bpe} = Async) -> - {ok, C} = emqttc:start_link([{client_id, <<"sys_bpe">>}, {logger, {console, error}}, {reconnect, 5}]), + {ok, C} = emqttc:start_link([{client_id, <<"sys_bpe">>}, + {logger, {error_logger, error}}, + {reconnect, 5}]), Table = process, Proc = case kvs:get(feed, Table) of {ok, #feed{top = Top} =_Feed} -> diff --git a/apps/roster/src/protocol/roster_message.erl b/apps/roster/src/protocol/roster_message.erl index 0469b1a96352eac7c6a314079095c02e669df887..d3b289946ec85c1ad1fa18373b52c2aa5219cdac 100644 --- a/apps/roster/src/protocol/roster_message.erl +++ b/apps/roster/src/protocol/roster_message.erl @@ -448,7 +448,9 @@ info(#'Message'{from = From, to = To} = ReqData, Req, State) -> proc(init, #handler{name = roster_message} = Async) -> ?LOG_INFO("ASYNC:~p", [?MODULE]), - {ok, C} = emqttc:start_link([{client_id, <<"roster_message">>}, {logger, {console, error}}, {reconnect, 5}]), + {ok, C} = emqttc:start_link([{client_id, <<"roster_message">>}, + {logger, {error_logger, error}}, + {reconnect, 5}]), {ok, Async#handler{state = C, seq = 0}}; proc({send_push, From, To, #'Message'{type = TypeList} = Msg, Action}, #handler{} = H) -> diff --git a/apps/roster/src/rest/helpers/rest_main_helper.erl b/apps/roster/src/rest/helpers/rest_main_helper.erl index 33bc6dea6df810a030589b048a9766f6f0cc8fe9..2b46f3929ed91933d2a104ac17ebfd5ff8ad96f7 100644 --- a/apps/roster/src/rest/helpers/rest_main_helper.erl +++ b/apps/roster/src/rest/helpers/rest_main_helper.erl @@ -26,7 +26,8 @@ rest_pid() -> case whereis(?REST_HELPER_NAME) of undefined -> {ok, C} = emqttc:start_link([{client_id, ?SYS_REST_CLIENT}, - {logger, {console, error}}, {reconnect, 5}]), + {logger, {error_logger, error}}, + {reconnect, 5}]), register(?REST_HELPER_NAME, C), unlink(C), C; diff --git a/apps/roster/src/roster_client.erl b/apps/roster/src/roster_client.erl index ae94ab202a839561a04e321a68fde7964b38906f..aec8cd2b449c7a12903ab351d9feb3725bf32464 100644 --- a/apps/roster/src/roster_client.erl +++ b/apps/roster/src/roster_client.erl @@ -74,7 +74,9 @@ proc(init, #handler{name = ?SYS_REST_CLIENT, state = #state{receive_pid = Self} Self ! init, {ok, Async#handler{state = State#state{mqttc = C, client_id = ?SYS_REST_CLIENT}, seq = 0}}; proc(init, #handler{name = ?SYS_BRIDGE_TEST_CLIENT, state = #state{receive_pid = Self} = State} = Async) -> - {ok, C} = emqttc:start_link([{client_id, ?SYS_BRIDGE_TEST_CLIENT}, {logger, {console, error}}, {reconnect, 5}]), + {ok, C} = emqttc:start_link([{client_id, ?SYS_BRIDGE_TEST_CLIENT}, + {logger, {error_logger, error}}, + {reconnect, 5}]), ?LOG_INFO("MICRO BRIDGE SIMULATOR PROC started", []), register(sys_bridge, C), Self ! init, @@ -82,8 +84,9 @@ proc(init, #handler{name = ?SYS_BRIDGE_TEST_CLIENT, state = #state{receive_pid = proc(init, #handler{name = ClientId, state = #state{mqtt_opts = Opts, receive_pid = Self, username = Username} = State} = Async) -> ?LOG_INFO("ClientInit:~p\r", [ClientId]), {ok, C} = emqttc:start_link([{client_id, ClientId}, - {clean_sess, false}, {logger, {console, error}}, - {username, Username}, {reconnect, 5}] ++ Opts), + {clean_sess, false}, + {logger, {error_logger, error}}, + {username, Username}, {reconnect, 5}] ++ Opts), Self ! init, {ok, Async#handler{state = State#state{mqttc = C, client_id = ClientId}, seq = 0}}; diff --git a/apps/roster/src/roster_n2o_log_backend.erl b/apps/roster/src/roster_n2o_log_backend.erl new file mode 100644 index 0000000000000000000000000000000000000000..2d353d12abf3d1abbd418fb795114fec34492244 --- /dev/null +++ b/apps/roster/src/roster_n2o_log_backend.erl @@ -0,0 +1,18 @@ +%%%------------------------------------------------------------------- +%%% @doc Logging backend for n2o interfacing with logger. +%%% +%%% @end +%%%------------------------------------------------------------------- + +-module(roster_n2o_log_backend). + +-export([info/3, warning/3, error/3]). + +info(Module, FormatString, Args) -> + logger:info(FormatString, Args, #{mfa => {Module, 'undefined', 0}}). + +warning(Module, FormatString, Args) -> + logger:warning(FormatString, Args, #{mfa => {Module, 'undefined', 0}}). + +error(Module, FormatString, Args) -> + logger:error(FormatString, Args, #{mfa => {Module, 'undefined', 0}}). diff --git a/sys.config b/sys.config index a50aeb27c92ce4a2d6559cc2484d00c6289f330c..b147321d41d4af74bfce1dc5ce34844f5fb86f0b 100644 --- a/sys.config +++ b/sys.config @@ -115,6 +115,7 @@ {protocols,[n2o_nitro,n2o_ftp,roster_proto]}, {log_modules,[roster, n2o_vnode]}, {log_level,roster}, + {logger, roster_n2o_log_backend}, {vnode, {roster, get_vnode}}, {validate, {roster, validate}} ]}, @@ -209,6 +210,7 @@ {large_heap,67108864}, {busy_port,false}, {busy_dist_port,true}]}]}, + {esockd, [{logger, {error_logger, info}}]}, {kvs, [{dba,store_mnesia}, {schema, [kvs_user, kvs_acl, kvs_feed, kvs_subscription, roster, micro, emqttd_kvs, bpe_metainfo]} %% ,{generation, {roster_test, limit}}