umgeher/cowboy
0
Fork 0
mirror of https://github.com/ninenines/cowboy.git synced 2025-07-14 20:30:23 +00:00
Code Issues Wiki Activity

Fix stream_handler_SUITE test failures

Browse source
This commit is contained in:
Loïc Hoguin 2017-11-01 19:24:24 +00:00
parent 5bb6438e10
commit af58babd94
No known key found for this signature in database
GPG key ID: 8A9DF795F6FED764
2 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

2
test/handlers/stream_handler_h.erl
View file

@ -81,7 +81,7 @@ info(StreamID, Info, State=#state{pid=Pid}) ->
Pid ! {Pid, self(), info, StreamID, Info, State}, Pid ! {Pid, self(), info, StreamID, Info, State},
case Info of case Info of
please_stop -> {[stop], State}; please_stop -> {[stop], State};
_ -> {[], State} _ -> {[Info], State}
end. end.
terminate(StreamID, Reason, State=#state{pid=Pid, test=crash_in_terminate}) -> terminate(StreamID, Reason, State=#state{pid=Pid, test=crash_in_terminate}) ->

4
test/stream_handler_SUITE.erl
View file

@ -245,7 +245,7 @@ shutdown_on_stream_stop(Config) ->
receive {'DOWN', MRef, process, Spawn, shutdown} -> ok after 1000 -> error(timeout) end, receive {'DOWN', MRef, process, Spawn, shutdown} -> ok after 1000 -> error(timeout) end,
%% The response is still sent. %% The response is still sent.
{response, nofin, 200, _} = gun:await(ConnPid, Ref), {response, nofin, 200, _} = gun:await(ConnPid, Ref),
{ok, <<>>} = gun:await_body(ConnPid, Ref), {ok, _} = gun:await_body(ConnPid, Ref),
ok. ok.
shutdown_on_socket_close(Config) -> shutdown_on_socket_close(Config) ->
@ -295,7 +295,7 @@ shutdown_timeout_on_stream_stop(Config) ->
receive {'DOWN', MRef, process, Spawn, killed} -> ok after 1000 -> error(timeout) end, receive {'DOWN', MRef, process, Spawn, killed} -> ok after 1000 -> error(timeout) end,
%% The response is still sent. %% The response is still sent.
{response, nofin, 200, _} = gun:await(ConnPid, Ref), {response, nofin, 200, _} = gun:await(ConnPid, Ref),
{ok, <<>>} = gun:await_body(ConnPid, Ref), {ok, _} = gun:await_body(ConnPid, Ref),
ok. ok.
shutdown_timeout_on_socket_close(Config) -> shutdown_timeout_on_socket_close(Config) ->