|
@@ -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.
|