diff --git a/internal/wire/log.go b/internal/wire/log.go index b6d626a28..790523d7b 100644 --- a/internal/wire/log.go +++ b/internal/wire/log.go @@ -40,6 +40,13 @@ func LogFrame(logger utils.Logger, frame Frame, sent bool) { case protocol.StreamTypeBidi: logger.Debugf("\t%s &wire.MaxStreamsFrame{Type: bidi, MaxStreams: %d}", dir, f.MaxStreams) } + case *StreamsBlockedFrame: + switch f.Type { + case protocol.StreamTypeUni: + logger.Debugf("\t%s &wire.StreamsBlockedFrame{Type: uni, MaxStreams: %d}", dir, f.StreamLimit) + case protocol.StreamTypeBidi: + logger.Debugf("\t%s &wire.StreamsBlockedFrame{Type: bidi, MaxStreams: %d}", dir, f.StreamLimit) + } case *NewConnectionIDFrame: logger.Debugf("\t%s &wire.NewConnectionIDFrame{SequenceNumber: %d, ConnectionID: %s, StatelessResetToken: %#x}", dir, f.SequenceNumber, f.ConnectionID, f.StatelessResetToken) case *NewTokenFrame: diff --git a/internal/wire/log_test.go b/internal/wire/log_test.go index 804ab8f47..f611e5f4c 100644 --- a/internal/wire/log_test.go +++ b/internal/wire/log_test.go @@ -96,6 +96,15 @@ var _ = Describe("Frame logging", func() { Expect(buf.String()).To(ContainSubstring("\t<- &wire.MaxStreamsFrame{Type: bidi, MaxStreams: 42}\n")) }) + It("logs STREAMS_BLOCKED frames", func() { + frame := &StreamsBlockedFrame{ + Type: protocol.StreamTypeBidi, + StreamLimit: 42, + } + LogFrame(logger, frame, false) + Expect(buf.String()).To(ContainSubstring("\t<- &wire.StreamsBlockedFrame{Type: bidi, MaxStreams: 42}\n")) + }) + It("logs NEW_CONNECTION_ID frames", func() { LogFrame(logger, &NewConnectionIDFrame{ SequenceNumber: 42,