Chapril/xmpp.chapril.org-ejabberd
25
1
Fork 0
mirror of https://github.com/processone/ejabberd.git synced 2024-12-24 17:29:28 +01:00
Code Releases Activity

Do not add p1:pushed more than once

Browse Source
This commit is contained in:
Evgeniy Khramtsov 2011-05-03 23:01:05 +10:00
parent 38693a670b
commit 613214da18
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/mod_ack.erl
View File

@ -215,14 +215,15 @@ handle_cast({del, Pid}, State) ->
lists:foreach( lists:foreach(
fun({_, _, {TRef, {From, To, El}}}) -> fun({_, _, {TRef, {From, To, El}}}) ->
cancel_timer(TRef), cancel_timer(TRef),
El1 = xml:append_subtags( El1 = xml:remove_subtags(El, "x", {"xmlns", ?NS_P1_PUSHED}),
El, [{xmlelement, "x", [{"xmlns", ?NS_P1_PUSHED}], []}]), El2 = xml:append_subtags(
El1, [{xmlelement, "x", [{"xmlns", ?NS_P1_PUSHED}], []}]),
?DEBUG("Resending message:~n" ?DEBUG("Resending message:~n"
"** From: ~p~n" "** From: ~p~n"
"** To: ~p~n" "** To: ~p~n"
"** El: ~p", "** El: ~p",
[From, To, El1]), [From, To, El2]),
ejabberd_router:route(From, To, El1) ejabberd_router:route(From, To, El2)
end, to_list(Pid, State#state.timers)), end, to_list(Pid, State#state.timers)),
Timers = delete(Pid, State#state.timers), Timers = delete(Pid, State#state.timers),
{noreply, State#state{timers = Timers}}; {noreply, State#state{timers = Timers}};