diff options
| author | Holger Weiss <holger@zedat.fu-berlin.de> | 2014-08-20 12:53:26 +0200 |
|---|---|---|
| committer | Holger Weiss <holger@zedat.fu-berlin.de> | 2014-08-20 12:53:26 +0200 |
| commit | 2802b6cee279786e8521e83a06bd9661470fad52 (patch) | |
| tree | e466d18e36ee57540e8ff9d2f5b9a84417eb6644 /src | |
| parent | Merge pull request #280 from weiss/store-persistent-muc-on-init (diff) | |
Allow for "max_ack_queue: infinity", as documented
Diffstat (limited to 'src')
| -rw-r--r-- | src/ejabberd_c2s.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/ejabberd_c2s.erl b/src/ejabberd_c2s.erl index 368aacb39..cccd41b07 100644 --- a/src/ejabberd_c2s.erl +++ b/src/ejabberd_c2s.erl @@ -307,6 +307,7 @@ init([{SockMod, Socket}, Opts]) -> end, MaxAckQueue = case proplists:get_value(max_ack_queue, Opts) of Limit when is_integer(Limit), Limit > 0 -> Limit; + infinity -> infinity; _ -> 500 end, 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 = NewQueue}. -check_queue_length(#state{mgmt_max_queue = Limit} = StateData) - when Limit == infinity; - Limit == unlimited -> +check_queue_length(#state{mgmt_max_queue = infinity} = StateData) -> StateData; check_queue_length(#state{mgmt_queue = Queue, mgmt_max_queue = Limit} = StateData) -> |