12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576 |
- %% Copyright (c) 2011, Loïc Hoguin <essen@dev-extend.eu>
- %%
- %% Permission to use, copy, modify, and/or distribute this software for any
- %% purpose with or without fee is hereby granted, provided that the above
- %% copyright notice and this permission notice appear in all copies.
- %%
- %% THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
- %% WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
- %% MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
- %% ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
- %% WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
- %% ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
- %% OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
- %% @doc Cowboy API to start and stop listeners.
- -module(cowboy).
- -export([start_listener/6, stop_listener/1, child_spec/6]).
- %% @doc Start a listener for the given transport and protocol.
- %%
- %% A listener is effectively a pool of <em>NbAcceptors</em> acceptors.
- %% Acceptors accept connections on the given <em>Transport</em> and forward
- %% requests to the given <em>Protocol</em> handler. Both transport and protocol
- %% modules can be given options through the <em>TransOpts</em> and the
- %% <em>ProtoOpts</em> arguments. Available options are documented in the
- %% <em>listen</em> transport function and in the protocol module of your choice.
- %%
- %% All acceptor and request processes are supervised by the listener.
- %%
- %% It is recommended to set a large enough number of acceptors to improve
- %% performance. The exact number depends of course on your hardware, on the
- %% protocol used and on the number of expected simultaneous connections.
- %%
- %% The <em>Transport</em> option <em>max_connections</em> allows you to define
- %% the maximum number of simultaneous connections for this listener. It defaults
- %% to 1024. See <em>cowboy_listener</em> for more details on limiting the number
- %% of connections.
- %%
- %% Although Cowboy includes a <em>cowboy_http_protocol</em> handler, other
- %% handlers can be created for different protocols like IRC, FTP and more.
- %%
- %% <em>Ref</em> can be used to stop the listener later on.
- -spec start_listener(any(), non_neg_integer(), module(), any(), module(), any())
- -> {ok, pid()}.
- start_listener(Ref, NbAcceptors, Transport, TransOpts, Protocol, ProtoOpts)
- when is_integer(NbAcceptors) andalso is_atom(Transport)
- andalso is_atom(Protocol) ->
- supervisor:start_child(cowboy_sup, child_spec(Ref, NbAcceptors,
- Transport, TransOpts, Protocol, ProtoOpts)).
- %% @doc Stop a listener identified by <em>Ref</em>.
- %% @todo Currently request processes aren't terminated with the listener.
- -spec stop_listener(any()) -> ok | {error, not_found}.
- stop_listener(Ref) ->
- case supervisor:terminate_child(cowboy_sup, {cowboy_listener_sup, Ref}) of
- ok ->
- supervisor:delete_child(cowboy_sup, {cowboy_listener_sup, Ref});
- {error, Reason} ->
- {error, Reason}
- end.
- %% @doc Return a child spec suitable for embedding.
- %% When you want to embed cowboy in another application, you can use this
- %% function to create a <em>ChildSpec</em> suitable for use in a supervisor.
- %% The parameters are the same as in <em>start_listener/6</em> but rather
- %% than hooking the listener to the cowboy internal supervisor, it just returns
- %% the spec.
- -spec child_spec(any(), non_neg_integer(), module(), any(), module(), any())
- -> supervisor:child_spec().
- child_spec(Ref, NbAcceptors, Transport, TransOpts, Protocol, ProtoOpts)
- when is_integer(NbAcceptors) andalso is_atom(Transport)
- andalso is_atom(Protocol) ->
- {{cowboy_listener_sup, Ref}, {cowboy_listener_sup, start_link, [
- NbAcceptors, Transport, TransOpts, Protocol, ProtoOpts
- ]}, permanent, 5000, supervisor, [cowboy_listener_sup]}.
|