jacob.eva
/
ejabberd-contrib
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

mod_message_log: Use global process 

Start only one mod_message_log process for all virtual hosts.
This commit is contained in:
Holger Weiss 2018-04-04 01:55:35 +02:00
parent 450f2eb5f4
commit 9c3943b703
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
mod_message_log/src/mod_message_log.erl
View File

@ -52,7 +52,6 @@
-include("xmpp.hrl"). -include("xmpp.hrl").
-define(PROCNAME, ?MODULE).
-define(DEFAULT_FILENAME, <<"message.log">>). -define(DEFAULT_FILENAME, <<"message.log">>).
-define(FILE_MODES, [append, raw]). -define(FILE_MODES, [append, raw]).
@ -75,7 +74,7 @@ start(Host, Opts) ->
log_packet_receive, 42), log_packet_receive, 42),
ejabberd_hooks:add(offline_message_hook, Host, ?MODULE, ejabberd_hooks:add(offline_message_hook, Host, ?MODULE,
log_packet_offline, 42), log_packet_offline, 42),
case gen_mod:start_child(?MODULE, Host, Opts) of case gen_mod:start_child(?MODULE, global, Opts) of
{ok, Ref} -> {ok, Ref} ->
{ok, Ref}; {ok, Ref};
{error, {already_started, Ref}} -> {error, {already_started, Ref}} ->
@ -92,7 +91,7 @@ stop(Host) ->
log_packet_receive, 42), log_packet_receive, 42),
ejabberd_hooks:delete(offline_message_hook, Host, ?MODULE, ejabberd_hooks:delete(offline_message_hook, Host, ?MODULE,
log_packet_offline, 42), log_packet_offline, 42),
gen_mod:stop_child(?MODULE, Host), gen_mod:stop_child(?MODULE, global),
ok. ok.
-spec mod_opt_type(atom()) -> fun((term()) -> term()). -spec mod_opt_type(atom()) -> fun((term()) -> term()).
@ -173,7 +172,8 @@ log_packet_offline({_Action, Msg} = Acc) ->
-spec reopen_log() -> any(). -spec reopen_log() -> any().
reopen_log() -> reopen_log() ->
gen_server:cast(?PROCNAME, reopen_log). Proc = gen_mod:get_module_proc(global, ?MODULE),
gen_server:cast(Proc, reopen_log).
%% ------------------------------------------------------------------- %% -------------------------------------------------------------------
%% Internal functions. %% Internal functions.
@ -188,7 +188,8 @@ log_packet(Direction, #message{from = From, to = To, type = Type} = Msg) ->
false -> false ->
{Type, Direction} {Type, Direction}
end, end,
gen_server:cast(?PROCNAME, {message, Direction1, From, To, Type1}); Proc = gen_mod:get_module_proc(global, ?MODULE),
gen_server:cast(Proc, {message, Direction1, From, To, Type1});
false -> false ->
ok ok
end. end.