3 writes to _currentHeadersStream
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http2\Http2Connection.cs (3)
835
_currentHeadersStream
= stream;
867
_currentHeadersStream
= GetStream(application);
1364
_currentHeadersStream
= null;
44 references to _currentHeadersStream
Microsoft.AspNetCore.Server.Kestrel.Core (44)
Internal\Http2\Http2Connection.cs (44)
425
Debug.Assert(
_currentHeadersStream
!= null);
427
Log.HPackDecodingError(ConnectionId,
_currentHeadersStream
.StreamId, ex);
706
if (
_currentHeadersStream
!= null)
777
Debug.Assert(
_currentHeadersStream
!= null, "Only throw this error if parsing headers.");
778
return new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId,
_currentHeadersStream
.StreamId), Http2ErrorCode.PROTOCOL_ERROR, ConnectionEndReason.UnexpectedFrame);
788
if (
_currentHeadersStream
!= null)
916
if (
_currentHeadersStream
!= null)
941
if (
_currentHeadersStream
!= null)
981
if (
_currentHeadersStream
!= null)
1065
if (
_currentHeadersStream
!= null)
1099
if (
_currentHeadersStream
!= null)
1118
if (
_currentHeadersStream
!= null)
1186
if (
_currentHeadersStream
== null)
1191
if (_incomingFrame.StreamId !=
_currentHeadersStream
.StreamId)
1215
if (
_currentHeadersStream
!= null)
1225
Debug.Assert(
_currentHeadersStream
!= null);
1229
_highestOpenedStreamId =
_currentHeadersStream
.StreamId;
1234
_currentHeadersStream
.OnHeadersComplete();
1242
_currentHeadersStream
.Dispose();
1252
Debug.Assert(
_currentHeadersStream
!= null);
1258
_currentHeadersStream
.OnEndStreamReceived();
1267
Debug.Assert(
_currentHeadersStream
!= null);
1270
_streams[_incomingFrame.StreamId] =
_currentHeadersStream
;
1276
_currentHeadersStream
.TotalParsedHeaderSize = _totalParsedHeaderSize;
1279
_currentHeadersStream
.InputRemaining =
_currentHeadersStream
.RequestHeaders.ContentLength;
1285
_currentHeadersStream
.OnEndStreamReceived();
1293
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.HttpErrorMissingMandatoryPseudoHeaderFields, Http2ErrorCode.PROTOCOL_ERROR);
1306
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.Http2ErrorMaxStreams, Http2ErrorCode.REFUSED_STREAM);
1331
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.Http2TellClientToCalmDown, Http2ErrorCode.ENHANCE_YOUR_CALM);
1342
_currentHeadersStream
.DecrementActiveClientStreamCount();
1343
_currentHeadersStream
.CompleteStream(errored: true);
1347
KestrelEventSource.Log.RequestQueuedStart(
_currentHeadersStream
, AspNetCore.Http.HttpProtocol.Http2);
1354
ThreadPool.UnsafeQueueUserWorkItem(
_currentHeadersStream
, preferLocal: false);
1358
_currentHeadersStream
.Execute();
1440
if (stream ==
_currentHeadersStream
)
1578
Debug.Assert(
_currentHeadersStream
!= null);
1599
_currentHeadersStream
.OnTrailer(name, value);
1610
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: true, name, value);
1616
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: false, name, value);
1624
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: false, name, value);
1630
_currentHeadersStream
.OnHeader(name, value, checkForNewlineChars: false);
1638
_currentHeadersStream
.OnHeader(name, value, checkForNewlineChars: true);
1663
=>
_currentHeadersStream
!.OnHeadersComplete();