aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/cowboy_http_protocol.erl8
-rw-r--r--src/cowboy_ssl_transport.erl3
-rw-r--r--src/cowboy_tcp_transport.erl3
3 files changed, 5 insertions, 9 deletions
diff --git a/src/cowboy_http_protocol.erl b/src/cowboy_http_protocol.erl
index a25f87a..b68980d 100644
--- a/src/cowboy_http_protocol.erl
+++ b/src/cowboy_http_protocol.erl
@@ -169,7 +169,7 @@ handler_terminate(HandlerState, Req, State=#state{handler={Handler, _Opts}}) ->
BodyRes = ensure_body_processed(Req),
ensure_response(Req, State),
case {HandlerRes, BodyRes, State#state.connection} of
- {ok, ok, keepalive} -> next_request(State);
+ {ok, ok, keepalive} -> ?MODULE:wait_request(State);
_Closed -> terminate(State)
end.
@@ -210,12 +210,6 @@ terminate(#state{socket=Socket, transport=Transport}) ->
Transport:close(Socket),
ok.
--spec next_request(State::#state{}) -> ok.
-next_request(State=#state{connection=keepalive}) ->
- ?MODULE:wait_request(State);
-next_request(State=#state{connection=close}) ->
- terminate(State).
-
%% Internal.
-spec version_to_connection(Version::http_version()) -> keepalive | close.
diff --git a/src/cowboy_ssl_transport.erl b/src/cowboy_ssl_transport.erl
index 0e80e4e..41577fc 100644
--- a/src/cowboy_ssl_transport.erl
+++ b/src/cowboy_ssl_transport.erl
@@ -31,11 +31,12 @@ messages() -> {ssl, ssl_closed, ssl_error}.
-> {ok, LSocket::ssl:sslsocket()} | {error, Reason::atom()}.
listen(Opts) ->
{port, Port} = lists:keyfind(port, 1, Opts),
+ Backlog = proplists:get_value(backlog, Opts, 128),
{certfile, CertFile} = lists:keyfind(certfile, 1, Opts),
{keyfile, KeyFile} = lists:keyfind(keyfile, 1, Opts),
{password, Password} = lists:keyfind(password, 1, Opts),
ssl:listen(Port, [binary, {active, false},
- {packet, raw}, {reuseaddr, true},
+ {backlog, Backlog}, {packet, raw}, {reuseaddr, true},
{certfile, CertFile}, {keyfile, KeyFile}, {password, Password}]).
-spec accept(LSocket::ssl:sslsocket(), Timeout::timeout())
diff --git a/src/cowboy_tcp_transport.erl b/src/cowboy_tcp_transport.erl
index 45c87df..49003bd 100644
--- a/src/cowboy_tcp_transport.erl
+++ b/src/cowboy_tcp_transport.erl
@@ -30,8 +30,9 @@ messages() -> {tcp, tcp_closed, tcp_error}.
-> {ok, LSocket::inet:socket()} | {error, Reason::atom()}.
listen(Opts) ->
{port, Port} = lists:keyfind(port, 1, Opts),
+ Backlog = proplists:get_value(backlog, Opts, 128),
gen_tcp:listen(Port, [binary, {active, false},
- {packet, raw}, {reuseaddr, true}]).
+ {backlog, Backlog}, {packet, raw}, {reuseaddr, true}]).
-spec accept(LSocket::inet:socket(), Timeout::timeout())
-> {ok, Socket::inet:socket()}