Chapril/xmpp.chapril.org-ejabberd
25
1
Fork 0
mirror of https://github.com/processone/ejabberd.git synced 2024-11-22 16:20:52 +01:00
Code Releases Activity

get rid of queue:filter/2 to keep compatibility with older Erlang versions

Browse Source
This commit is contained in:
Evgeniy Khramtsov 2010-02-20 20:14:34 +09:00
parent 62ad40b1e4
commit 9890cc89b6
1 changed files with 7 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/odbc/ejabberd_odbc.erl
View File

@ -197,11 +197,10 @@ connecting(connect, #state{host = Host} = State) ->
case ConnectRes of
{ok, Ref} ->
erlang:monitor(process, Ref),
queue:filter(
lists:foreach(
fun(Req) ->
?GEN_FSM:send_event(self(), Req),
false
end, PendingRequests),
?GEN_FSM:send_event(self(), Req)
end, queue:to_list(PendingRequests)),
{next_state, session_established,
State#state{db_ref = Ref,
pending_requests = {0, queue:new()}}};
@ -229,12 +228,11 @@ connecting({sql_cmd, Command} = Req, From, State) ->
if Len < State#state.max_pending_requests_len ->
{Len + 1, queue:in({sql_cmd, Command, From}, PendingRequests)};
true ->
queue:filter(
lists:foreach(
fun({sql_cmd, _, To}) ->
?GEN_FSM:reply(To,
{error, "SQL connection failed"}),
false
end, PendingRequests),
?GEN_FSM:reply(
To, {error, "SQL connection failed"})
end, queue:to_list(PendingRequests)),
{1, queue:from_list([{sql_cmd, Command, From}])}
end,
{next_state, connecting,