mirror of
https://github.com/processone/ejabberd.git
synced 2024-11-26 16:26:24 +01:00
Forward old messages to newly spawned extauth process (thanks to Mika Seppänen)(EJAB-1385)
This commit is contained in:
parent
7f899ee179
commit
61e4fde247
@ -126,7 +126,8 @@ loop(Port, Timeout, ProcessName, ExtPrg) ->
|
|||||||
?ERROR_MSG("extauth call '~p' didn't receive response", [Msg]),
|
?ERROR_MSG("extauth call '~p' didn't receive response", [Msg]),
|
||||||
Caller ! {eauth, false},
|
Caller ! {eauth, false},
|
||||||
unregister(ProcessName),
|
unregister(ProcessName),
|
||||||
spawn(?MODULE, init, [ProcessName, ExtPrg]),
|
Pid = spawn(?MODULE, init, [ProcessName, ExtPrg]),
|
||||||
|
flush_buffer_and_forward_messages(Pid),
|
||||||
exit(port_terminated)
|
exit(port_terminated)
|
||||||
end;
|
end;
|
||||||
stop ->
|
stop ->
|
||||||
@ -140,6 +141,15 @@ loop(Port, Timeout, ProcessName, ExtPrg) ->
|
|||||||
exit(port_terminated)
|
exit(port_terminated)
|
||||||
end.
|
end.
|
||||||
|
|
||||||
|
flush_buffer_and_forward_messages(Pid) ->
|
||||||
|
receive
|
||||||
|
Message ->
|
||||||
|
Pid ! Message,
|
||||||
|
flush_buffer_and_forward_messages(Pid)
|
||||||
|
after 0 ->
|
||||||
|
true
|
||||||
|
end.
|
||||||
|
|
||||||
join(List, Sep) ->
|
join(List, Sep) ->
|
||||||
lists:foldl(fun(A, "") -> A;
|
lists:foldl(fun(A, "") -> A;
|
||||||
(A, Acc) -> Acc ++ Sep ++ A
|
(A, Acc) -> Acc ++ Sep ++ A
|
||||||
|
Loading…
Reference in New Issue
Block a user