3 writes to _currentHeadersStream
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http2\Http2Connection.cs (3)
835
_currentHeadersStream
= stream;
867
_currentHeadersStream
= GetStream(application);
1373
_currentHeadersStream
= null;
45 references to _currentHeadersStream
Microsoft.AspNetCore.Server.Kestrel.Core (45)
Internal\Http2\Http2Connection.cs (45)
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);
1260
_currentHeadersStream
.OnEndStreamReceived();
1266
_currentHeadersStream
.Dispose();
1276
Debug.Assert(
_currentHeadersStream
!= null);
1279
_streams[_incomingFrame.StreamId] =
_currentHeadersStream
;
1285
_currentHeadersStream
.TotalParsedHeaderSize = _totalParsedHeaderSize;
1288
_currentHeadersStream
.InputRemaining =
_currentHeadersStream
.RequestHeaders.ContentLength;
1294
_currentHeadersStream
.OnEndStreamReceived();
1302
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.HttpErrorMissingMandatoryPseudoHeaderFields, Http2ErrorCode.PROTOCOL_ERROR);
1315
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.Http2ErrorMaxStreams, Http2ErrorCode.REFUSED_STREAM);
1340
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.Http2TellClientToCalmDown, Http2ErrorCode.ENHANCE_YOUR_CALM);
1351
_currentHeadersStream
.DecrementActiveClientStreamCount();
1352
_currentHeadersStream
.CompleteStream(errored: true);
1356
KestrelEventSource.Log.RequestQueuedStart(
_currentHeadersStream
, AspNetCore.Http.HttpProtocol.Http2);
1363
ThreadPool.UnsafeQueueUserWorkItem(
_currentHeadersStream
, preferLocal: false);
1367
_currentHeadersStream
.Execute();
1449
if (stream ==
_currentHeadersStream
)
1587
Debug.Assert(
_currentHeadersStream
!= null);
1608
_currentHeadersStream
.OnTrailer(name, value);
1619
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: true, name, value);
1625
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: false, name, value);
1633
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: false, name, value);
1639
_currentHeadersStream
.OnHeader(name, value, checkForNewlineChars: false);
1647
_currentHeadersStream
.OnHeader(name, value, checkForNewlineChars: true);
1672
=>
_currentHeadersStream
!.OnHeadersComplete();