diff options
| author | Tony Han <[email protected]> | 2019-04-28 10:51:50 +0800 |
|---|---|---|
| committer | Loïc Hoguin <[email protected]> | 2019-07-26 13:56:39 +0200 |
| commit | 00b0b29eacf3eb8a51273dc43064c6367573c4c4 (patch) | |
| tree | 9e70f93b3f15ef4f9f2a20132c7072ce6454341a /src | |
| parent | e4df3bb7c726571640c2799bc7a6fbb687b3bdae (diff) | |
| download | gun-00b0b29eacf3eb8a51273dc43064c6367573c4c4.tar.gz gun-00b0b29eacf3eb8a51273dc43064c6367573c4c4.tar.bz2 gun-00b0b29eacf3eb8a51273dc43064c6367573c4c4.zip | |
Data received after RST_STREAM counts toward window
Diffstat (limited to 'src')
| -rw-r--r-- | src/gun_http2.erl | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/gun_http2.erl b/src/gun_http2.erl index 78b137b..20e21ec 100644 --- a/src/gun_http2.erl +++ b/src/gun_http2.erl @@ -142,6 +142,9 @@ frame(State=#http2_state{http2_machine=HTTP2Machine0}, Frame, EvHandler, EvHandl {ok, {data, StreamID, IsFin, Data}, HTTP2Machine} -> data_frame(State#http2_state{http2_machine=HTTP2Machine}, StreamID, IsFin, Data, EvHandler, EvHandlerState); + {ok, {lingering_data, _StreamID, DataLen}, HTTP2Machine} -> + {lingering_data_frame(State#http2_state{http2_machine=HTTP2Machine}, DataLen), + EvHandlerState}; {ok, {headers, StreamID, IsFin, Headers, PseudoHeaders, BodyLen}, HTTP2Machine} -> headers_frame(State#http2_state{http2_machine=HTTP2Machine}, StreamID, IsFin, Headers, PseudoHeaders, BodyLen, @@ -180,6 +183,12 @@ maybe_ack(State=#http2_state{socket=Socket, transport=Transport}, Frame) -> end, State. +lingering_data_frame(State=#http2_state{socket=Socket, transport=Transport, + http2_machine=HTTP2Machine0}, DataLen) -> + Transport:send(Socket, cow_http2:window_update(DataLen)), + HTTP2Machine1 = cow_http2_machine:update_window(DataLen, HTTP2Machine0), + State#http2_state{http2_machine=HTTP2Machine1}. + data_frame(State=#http2_state{socket=Socket, transport=Transport, http2_machine=HTTP2Machine0}, StreamID, IsFin, Data, EvHandler, EvHandlerState0) -> |