diff options
author | Evgeniy Khramtsov <ekhramtsov@process-one.net> | 2017-02-18 09:36:27 +0300 |
---|---|---|
committer | Evgeniy Khramtsov <ekhramtsov@process-one.net> | 2017-02-18 09:36:27 +0300 |
commit | 940ca9311d7097e593bddc7bfc8ed9ba504d66bc (patch) | |
tree | ca86e6f5aae6b3d142675334ace94fb21452fd35 /src/ejabberd_sm.erl | |
parent | Merge pull request #1553 from lemenkov/config_functions_deprecation (diff) |
Fix some dialyzer warnings
Diffstat (limited to 'src/ejabberd_sm.erl')
-rw-r--r-- | src/ejabberd_sm.erl | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/ejabberd_sm.erl b/src/ejabberd_sm.erl index 83647054c..eaa1ab4ae 100644 --- a/src/ejabberd_sm.erl +++ b/src/ejabberd_sm.erl @@ -494,7 +494,7 @@ do_route(To, Term) -> Session = lists:max(Ss), Pid = element(2, Session#session.sid), ?DEBUG("sending to process ~p: ~p", [Pid, Term]), - Pid ! Term + ejabberd_c2s:route(Pid, Term) end. -spec do_route(stanza()) -> any(). @@ -520,7 +520,7 @@ do_route(#presence{from = From, to = To, type = T, status = Status} = Packet) Packet1 = Packet#presence{to = jid:replace_resource(To, R)}, ?DEBUG("sending to process ~p:~n~s", [Pid, xmpp:pp(Packet1)]), - Pid ! {route, Packet1}; + ejabberd_c2s:route(Pid, {route, Packet1}); (_) -> ok end, online(Mod:get_sessions(LUser, LServer))); @@ -571,7 +571,7 @@ do_route(Packet) -> Session = lists:max(Ss), Pid = element(2, Session#session.sid), ?DEBUG("sending to process ~p:~n~s", [Pid, xmpp:pp(Packet)]), - Pid ! {route, Packet} + ejabberd_c2s:route(Pid, {route, Packet}) end. %% The default list applies to the user as a whole, @@ -611,7 +611,7 @@ route_message(#message{to = To, type = Type} = Packet) -> LResource, LMaxRes, P, MaxPrio), - Pid ! {route, Packet1} + ejabberd_c2s:route(Pid, {route, Packet1}) end; %% Ignore other priority: ({_Prio, _Res}) -> ok @@ -680,7 +680,7 @@ check_existing_resources(LUser, LServer, LResource) -> SIDs = [SID || #session{sid = SID} <- OnlineSs], MaxSID = lists:max(SIDs), lists:foreach(fun ({_, Pid} = S) when S /= MaxSID -> - Pid ! replaced; + ejabberd_c2s:route(Pid, replaced); (_) -> ok end, SIDs) @@ -708,7 +708,7 @@ check_max_sessions(LUser, LServer) -> if length(OnlineSs) =< MaxSessions -> ok; true -> #session{sid = {_, Pid}} = lists:min(OnlineSs), - Pid ! replaced + ejabberd_c2s:route(Pid, replaced) end, if length(OfflineSs) =< MaxSessions -> ok; true -> @@ -762,7 +762,7 @@ force_update_presence({LUser, LServer}) -> Mod = get_sm_backend(LServer), Ss = online(Mod:get_sessions(LUser, LServer)), lists:foreach(fun (#session{sid = {_, Pid}}) -> - Pid ! force_update_presence + ejabberd_c2s:route(Pid, force_update_presence) end, Ss). @@ -842,7 +842,7 @@ kick_user(User, Server) -> lists:foreach( fun(Resource) -> PID = get_session_pid(User, Server, Resource), - PID ! kick + ejabberd_c2s:route(PID, kick) end, Resources), length(Resources). |