aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorFrank Diebolt <frank.diebolt@al-enterprise.com>2019-01-29 18:13:28 +0100
committerFrank Diebolt <frank.diebolt@al-enterprise.com>2019-01-29 18:13:28 +0100
commitdd57950103f960da32fc8988835af5209f47c78a (patch)
tree2288fea34b0524aca621422461ce59835b3864eb /src
parentMerge pull request #2622 from aquarhead/rename-functions (diff)
Fix ping IQ reply/timeout processing ("mod_ping" regression since 17.x that may cause resources leakage)
Diffstat (limited to 'src')
-rw-r--r--src/mod_ping.erl41
1 files changed, 21 insertions, 20 deletions
diff --git a/src/mod_ping.erl b/src/mod_ping.erl
index ffdee2f01..25d2b60ed 100644
--- a/src/mod_ping.erl
+++ b/src/mod_ping.erl
@@ -122,30 +122,31 @@ handle_cast({start_ping, JID}, State) ->
handle_cast({stop_ping, JID}, State) ->
Timers = del_timer(JID, State#state.timers),
{noreply, State#state{timers = Timers}};
-handle_cast({iq_reply, timeout, JID}, State) ->
- ejabberd_hooks:run(user_ping_timeout, State#state.host,
- [JID]),
- Timers = case State#state.timeout_action of
- kill ->
- #jid{user = User, server = Server,
- resource = Resource} =
- JID,
- case ejabberd_sm:get_session_pid(User, Server, Resource)
- of
- Pid when is_pid(Pid) -> ejabberd_c2s:close(Pid, ping_timeout);
- _ -> ok
- end,
- del_timer(JID, State#state.timers);
- _ ->
- State#state.timers
- end,
- {noreply, State#state{timers = Timers}};
-handle_cast({iq_reply, #iq{}, _JID}, State) ->
- {noreply, State};
handle_cast(Msg, State) ->
?WARNING_MSG("unexpected cast: ~p", [Msg]),
{noreply, State}.
+handle_info({iq_reply, #iq{type = error}, JID}, State) ->
+ handle_info({iq_reply, timeout, JID}, State);
+handle_info({iq_reply, #iq{}, _JID}, State) ->
+ {noreply, State};
+handle_info({iq_reply, timeout, JID}, State) ->
+ Timers = del_timer(JID, State#state.timers),
+ ejabberd_hooks:run(user_ping_timeout, State#state.host,
+ [JID]),
+ case State#state.timeout_action of
+ kill ->
+ #jid{user = User, server = Server,
+ resource = Resource} =
+ JID,
+ case ejabberd_sm:get_session_pid(User, Server, Resource)
+ of
+ Pid when is_pid(Pid) -> ejabberd_c2s:close(Pid, ping_timeout);
+ _ -> ok
+ end;
+ _ -> ok
+ end,
+ {noreply, State#state{timers = Timers}};
handle_info({timeout, _TRef, {ping, JID}}, State) ->
Host = State#state.host,
From = jid:remove_resource(JID),