aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorLoïc Hoguin <[email protected]>2019-10-10 17:06:24 +0200
committerLoïc Hoguin <[email protected]>2019-10-10 17:06:24 +0200
commit3ae228897a94d2506859bf351bf6c2aa9e02a6a4 (patch)
treee916a41f57fec448fc163d0f97036f24200c19ee /src
parent525eeeecc92f54c1187cf21b9f8e5e03e2aef506 (diff)
downloadcowboy-3ae228897a94d2506859bf351bf6c2aa9e02a6a4.tar.gz
cowboy-3ae228897a94d2506859bf351bf6c2aa9e02a6a4.tar.bz2
cowboy-3ae228897a94d2506859bf351bf6c2aa9e02a6a4.zip
Don't log stray messages for lingering HTTP/2 streams
Diffstat (limited to 'src')
-rw-r--r--src/cowboy_http2.erl11
1 files changed, 8 insertions, 3 deletions
diff --git a/src/cowboy_http2.erl b/src/cowboy_http2.erl
index 66f129e..2754e9c 100644
--- a/src/cowboy_http2.erl
+++ b/src/cowboy_http2.erl
@@ -572,7 +572,7 @@ down(State=#state{opts=Opts, children=Children0}, Pid, Msg) ->
State
end.
-info(State=#state{opts=Opts, streams=Streams}, StreamID, Msg) ->
+info(State=#state{opts=Opts, http2_machine=HTTP2Machine, streams=Streams}, StreamID, Msg) ->
case Streams of
#{StreamID := Stream=#stream{state=StreamState0}} ->
try cowboy_stream:info(StreamID, Msg, StreamState0) of
@@ -587,8 +587,13 @@ info(State=#state{opts=Opts, streams=Streams}, StreamID, Msg) ->
'Unhandled exception in cowboy_stream:info/3.'})
end;
_ ->
- cowboy:log(warning, "Received message ~p for unknown or terminated stream ~p.",
- [Msg, StreamID], Opts),
+ case cow_http2_machine:is_lingering_stream(StreamID, HTTP2Machine) of
+ true ->
+ ok;
+ false ->
+ cowboy:log(warning, "Received message ~p for unknown stream ~p.",
+ [Msg, StreamID], Opts)
+ end,
State
end.