diff options
| author | Loïc Hoguin <[email protected]> | 2015-04-13 12:23:59 +0300 |
|---|---|---|
| committer | Loïc Hoguin <[email protected]> | 2015-04-13 12:23:59 +0300 |
| commit | 9b65246e55af95ace39befb90a8e5a0238830185 (patch) | |
| tree | 31af1ca7deb7877413504319e4d987f9f5028cba | |
| parent | 476147d068a281d456b2748cae7cd7537ec4b37a (diff) | |
| download | gun-9b65246e55af95ace39befb90a8e5a0238830185.tar.gz gun-9b65246e55af95ace39befb90a8e5a0238830185.tar.bz2 gun-9b65246e55af95ace39befb90a8e5a0238830185.zip | |
One more SPDY test
| -rw-r--r-- | test/spdy_SUITE.erl | 23 | ||||
| -rw-r--r-- | test/spdy_server.erl | 3 |
2 files changed, 25 insertions, 1 deletions
diff --git a/test/spdy_SUITE.erl b/test/spdy_SUITE.erl index 44fbbbe..b5a5666 100644 --- a/test/spdy_SUITE.erl +++ b/test/spdy_SUITE.erl @@ -29,12 +29,19 @@ wait() -> receive after 500 -> ok end. down() -> - receive {gun_down, ConnPid, _, _, _, _} -> + receive {gun_down, _, _, _, _, _} -> ok after 5000 -> exit(timeout) end. +not_down() -> + receive {gun_down, _, _, _, _, _} -> + exit(down) + after 0 -> + ok + end. + do_req_resp(ConnPid, ServerPid, ServerStreamID) -> StreamRef = gun:get(ConnPid, "/"), spdy_server:send(ServerPid, [ @@ -280,3 +287,17 @@ goaway_last_good_streamid(_) -> wait(), [{goaway, 6, protocol_error}] = spdy_server:stop(ServerPid), down(). + +dont_send_rst_stream_on_rst_stream(_) -> + doc("An endpoint must not send an RST_STREAM in response to an RST_STREAM. (spdy-protocol-draft3-1 2.4.2)"), + {ok, ServerPid, Port} = spdy_server:start_link(), + {ok, ConnPid} = gun:open("localhost", Port, #{transport=>ssl}), + {ok, spdy} = gun:await_up(ConnPid), + _ = gun:get(ConnPid, "/"), + spdy_server:send(ServerPid, [ + {rst_stream, 1, refused_stream} + ]), + wait(), + %% No RST_STREAM was received; only SYN_STREAM. + [_] = spdy_server:stop(ServerPid), + not_down(). diff --git a/test/spdy_server.erl b/test/spdy_server.erl index 2847d33..4690270 100644 --- a/test/spdy_server.erl +++ b/test/spdy_server.erl @@ -113,6 +113,9 @@ do_send([{syn_stream, StreamID, AssocToStreamID, IsFin, IsUnidirectional, Priori do_send([{syn_reply, StreamID, IsFin, Status, Version, Headers}|Tail], Socket, Zdef) -> ssl:send(Socket, cow_spdy:syn_reply(Zdef, StreamID, IsFin, Status, Version, Headers)), do_send(Tail, Socket, Zdef); +do_send([{rst_stream, StreamID, Status}|Tail], Socket, Zdef) -> + ssl:send(Socket, cow_spdy:rst_stream(StreamID, Status)), + do_send(Tail, Socket, Zdef); do_send([{window_update, StreamID, DeltaWindowSize}|Tail], Socket, Zdef) -> %% @todo ssl:send(Socket, cow_spdy:window_update(StreamID, DeltaWindowSize)), do_send(Tail, Socket, Zdef); |