3 writes to _currentHeadersStream
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http2\Http2Connection.cs (3)
756
_currentHeadersStream
= stream;
788
_currentHeadersStream
= GetStream(application);
1275
_currentHeadersStream
= null;
52 references to _currentHeadersStream
Microsoft.AspNetCore.Server.Kestrel.Core (52)
Internal\Http2\Http2Connection.cs (52)
378
Debug.Assert(
_currentHeadersStream
!= null);
380
Log.HPackDecodingError(ConnectionId,
_currentHeadersStream
.StreamId, ex);
653
if (
_currentHeadersStream
!= null)
655
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
709
if (
_currentHeadersStream
!= null)
711
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
837
if (
_currentHeadersStream
!= null)
839
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
862
if (
_currentHeadersStream
!= null)
864
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
902
if (
_currentHeadersStream
!= null)
904
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
982
if (
_currentHeadersStream
!= null)
984
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
1014
if (
_currentHeadersStream
!= null)
1016
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
1033
if (
_currentHeadersStream
!= null)
1035
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
1097
if (
_currentHeadersStream
== null)
1102
if (_incomingFrame.StreamId !=
_currentHeadersStream
.StreamId)
1104
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
1126
if (
_currentHeadersStream
!= null)
1128
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR);
1136
Debug.Assert(
_currentHeadersStream
!= null);
1140
_highestOpenedStreamId =
_currentHeadersStream
.StreamId;
1145
_currentHeadersStream
.OnHeadersComplete();
1153
_currentHeadersStream
.Dispose();
1163
Debug.Assert(
_currentHeadersStream
!= null);
1169
_currentHeadersStream
.OnEndStreamReceived();
1178
Debug.Assert(
_currentHeadersStream
!= null);
1181
_streams[_incomingFrame.StreamId] =
_currentHeadersStream
;
1187
_currentHeadersStream
.TotalParsedHeaderSize = _totalParsedHeaderSize;
1190
_currentHeadersStream
.InputRemaining =
_currentHeadersStream
.RequestHeaders.ContentLength;
1196
_currentHeadersStream
.OnEndStreamReceived();
1204
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.HttpErrorMissingMandatoryPseudoHeaderFields, Http2ErrorCode.PROTOCOL_ERROR);
1217
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.Http2ErrorMaxStreams, Http2ErrorCode.REFUSED_STREAM);
1242
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.Http2TellClientToCalmDown, Http2ErrorCode.ENHANCE_YOUR_CALM);
1253
_currentHeadersStream
.DecrementActiveClientStreamCount();
1254
_currentHeadersStream
.CompleteStream(errored: true);
1258
KestrelEventSource.Log.RequestQueuedStart(
_currentHeadersStream
, AspNetCore.Http.HttpProtocol.Http2);
1265
ThreadPool.UnsafeQueueUserWorkItem(
_currentHeadersStream
, preferLocal: false);
1269
_currentHeadersStream
.Execute();
1351
if (stream ==
_currentHeadersStream
)
1488
Debug.Assert(
_currentHeadersStream
!= null);
1509
_currentHeadersStream
.OnTrailer(name, value);
1520
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: true, name, value);
1526
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: false, name, value);
1534
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: false, name, value);
1540
_currentHeadersStream
.OnHeader(name, value, checkForNewlineChars: false);
1548
_currentHeadersStream
.OnHeader(name, value, checkForNewlineChars: true);
1567
=>
_currentHeadersStream
!.OnHeadersComplete();