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 intermittent failure of max_frame_size_sent test

Browse source
This commit is contained in:
Loïc Hoguin 2018-05-20 18:17:49 +02:00
parent 4e896fabd5
commit 6e00600d7d
No known key found for this signature in database
GPG key ID: 8A9DF795F6FED764
1 changed files with 12 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

16
test/http2_SUITE.erl
View file

@ -109,13 +109,21 @@ max_frame_size_sent(Config) ->
cow_http2:data(1, fin, <<0:13616/unit:8>>) cow_http2:data(1, fin, <<0:13616/unit:8>>)
]), ]),
%% Receive a HEADERS frame as a response. %% Receive a HEADERS frame as a response.
{ok, <<Len:24, 1:8, _:40>>} = gen_tcp:recv(Socket, 9, 6000), {ok, << SkipLen:24, 1:8, _:8, 1:32 >>} = case gen_tcp:recv(Socket, 9, 1000) of
{ok, _} = gen_tcp:recv(Socket, Len, 6000), %% We received a WINDOW_UPDATE first. Skip it and the next.
{ok, <<4:24, 8:8, 0:40>>} ->
{ok, _} = gen_tcp:recv(Socket, 4 + 13, 1000),
gen_tcp:recv(Socket, 9, 1000);
Res ->
Res
end,
{ok, _} = gen_tcp:recv(Socket, SkipLen, 6000),
%% The DATA frames following must have lengths of 20000 %% The DATA frames following must have lengths of 20000
%% and then 10000 due to the limit. %% and then 10000 due to the limit.
{ok, <<20000:24, 0:8, _:40, _:20000/unit:8>>} = gen_tcp:recv(Socket, 20009, 6000), {ok, <<20000:24, 0:8, _:40, _:20000/unit:8>>} = gen_tcp:recv(Socket, 20009, 6000),
{ok, <<10000:24, 0:8, _:40, _:10000/unit:8>>} = gen_tcp:recv(Socket, 10009, 6000), {ok, <<10000:24, 0:8, _:40, _:10000/unit:8>>} = gen_tcp:recv(Socket, 10009, 6000),
ok. %% Stop the listener.
cowboy:stop_listener(name()).
preface_timeout_infinity(Config) -> preface_timeout_infinity(Config) ->
doc("Ensure infinity for preface_timeout is accepted."), doc("Ensure infinity for preface_timeout is accepted."),
@ -131,7 +139,7 @@ preface_timeout_infinity(Config) ->
{'DOWN', Ref, process, Pid, Reason} -> {'DOWN', Ref, process, Pid, Reason} ->
error(Reason) error(Reason)
after 1000 -> after 1000 ->
cowboy:stop_listener(preface_timeout_infinity) cowboy:stop_listener(name())
end. end.
resp_iolist_body(Config) -> resp_iolist_body(Config) ->