Chapril/xmpp.chapril.org-ejabberd
24
1
Fork 0
mirror of https://github.com/processone/ejabberd.git synced 2024-09-27 14:30:55 +02:00
Code Releases Activity

Merge pull request #283 from weiss/allow-unlimited-ack-queue

Browse Source 
Support "max_ack_queue: infinity"
This commit is contained in:
Evgeny Khramtsov 2014-08-20 17:47:04 +04:00
commit 33e0bf1c19
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/ejabberd_c2s.erl
View File

@ -307,6 +307,7 @@ init([{SockMod, Socket}, Opts]) ->
end, end,
MaxAckQueue = case proplists:get_value(max_ack_queue, Opts) of MaxAckQueue = case proplists:get_value(max_ack_queue, Opts) of
Limit when is_integer(Limit), Limit > 0 -> Limit; Limit when is_integer(Limit), Limit > 0 -> Limit;
infinity -> infinity;
_ -> 500 _ -> 500
end, end,
ResumeTimeout = case proplists:get_value(resume_timeout, Opts) of ResumeTimeout = case proplists:get_value(resume_timeout, Opts) of
@ -2789,9 +2790,7 @@ mgmt_queue_drop(StateData, NumHandled) ->
StateData#state.mgmt_queue), StateData#state.mgmt_queue),
StateData#state{mgmt_queue = NewQueue}. StateData#state{mgmt_queue = NewQueue}.
check_queue_length(#state{mgmt_max_queue = Limit} = StateData) check_queue_length(#state{mgmt_max_queue = infinity} = StateData) ->
when Limit == infinity;
Limit == unlimited ->
StateData; StateData;
check_queue_length(#state{mgmt_queue = Queue, check_queue_length(#state{mgmt_queue = Queue,
mgmt_max_queue = Limit} = StateData) -> mgmt_max_queue = Limit} = StateData) ->