]> granicus.if.org Git - ejabberd/commitdiff
Allow for "max_ack_queue: infinity", as documented
authorHolger Weiss <holger@zedat.fu-berlin.de>
Wed, 20 Aug 2014 10:53:26 +0000 (12:53 +0200)
committerHolger Weiss <holger@zedat.fu-berlin.de>
Wed, 20 Aug 2014 10:53:26 +0000 (12:53 +0200)
src/ejabberd_c2s.erl

index 368aacb39fc2fc2c895e70c934ffc80bd8dea460..cccd41b0785d91ef4c61690d531e802bb3a3a674 100644 (file)
@@ -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) ->