ranch_listener_sup.erl 1.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. %% Copyright (c) 2011-2015, Loïc Hoguin <essen@ninenines.eu>
  2. %%
  3. %% Permission to use, copy, modify, and/or distribute this software for any
  4. %% purpose with or without fee is hereby granted, provided that the above
  5. %% copyright notice and this permission notice appear in all copies.
  6. %%
  7. %% THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
  8. %% WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
  9. %% MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
  10. %% ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
  11. %% WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
  12. %% ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
  13. %% OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  14. -module(ranch_listener_sup).
  15. -behaviour(supervisor).
  16. -export([start_link/6]).
  17. -export([init/1]).
  18. -spec start_link(ranch:ref(), non_neg_integer(), module(), any(), module(), any())
  19. -> {ok, pid()}.
  20. start_link(Ref, NumAcceptors, Transport, TransOpts, Protocol, ProtoOpts) ->
  21. MaxConns = proplists:get_value(max_connections, TransOpts, 1024),
  22. ranch_server:set_new_listener_opts(Ref, MaxConns, ProtoOpts),
  23. supervisor:start_link(?MODULE, {
  24. Ref, NumAcceptors, Transport, TransOpts, Protocol
  25. }).
  26. init({Ref, NumAcceptors, Transport, TransOpts, Protocol}) ->
  27. AckTimeout = proplists:get_value(ack_timeout, TransOpts, 5000),
  28. ConnType = proplists:get_value(connection_type, TransOpts, worker),
  29. Shutdown = proplists:get_value(shutdown, TransOpts, 5000),
  30. ChildSpecs = [
  31. {ranch_conns_sup, {ranch_conns_sup, start_link,
  32. [Ref, ConnType, Shutdown, Transport, AckTimeout, Protocol]},
  33. permanent, infinity, supervisor, [ranch_conns_sup]},
  34. {ranch_acceptors_sup, {ranch_acceptors_sup, start_link,
  35. [Ref, NumAcceptors, Transport, TransOpts]},
  36. permanent, infinity, supervisor, [ranch_acceptors_sup]}
  37. ],
  38. {ok, {{rest_for_one, 1, 5}, ChildSpecs}}.