3 writes to _currentHeadersStream
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http2\Http2Connection.cs (3)
835
_currentHeadersStream
= stream;
879
_currentHeadersStream
= GetStream(application);
1390
_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)
928
if (
_currentHeadersStream
!= null)
953
if (
_currentHeadersStream
!= null)
993
if (
_currentHeadersStream
!= null)
1077
if (
_currentHeadersStream
!= null)
1111
if (
_currentHeadersStream
!= null)
1130
if (
_currentHeadersStream
!= null)
1198
if (
_currentHeadersStream
== null)
1203
if (_incomingFrame.StreamId !=
_currentHeadersStream
.StreamId)
1232
if (
_currentHeadersStream
!= null)
1242
Debug.Assert(
_currentHeadersStream
!= null);
1246
_highestOpenedStreamId =
_currentHeadersStream
.StreamId;
1251
_currentHeadersStream
.OnHeadersComplete();
1259
_currentHeadersStream
.Dispose();
1269
Debug.Assert(
_currentHeadersStream
!= null);
1277
_currentHeadersStream
.OnEndStreamReceived();
1283
_currentHeadersStream
.Dispose();
1293
Debug.Assert(
_currentHeadersStream
!= null);
1296
_streams[_incomingFrame.StreamId] =
_currentHeadersStream
;
1302
_currentHeadersStream
.TotalParsedHeaderSize = _totalParsedHeaderSize;
1305
_currentHeadersStream
.InputRemaining =
_currentHeadersStream
.RequestHeaders.ContentLength;
1311
_currentHeadersStream
.OnEndStreamReceived();
1319
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.HttpErrorMissingMandatoryPseudoHeaderFields, Http2ErrorCode.PROTOCOL_ERROR);
1332
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.Http2ErrorMaxStreams, Http2ErrorCode.REFUSED_STREAM);
1357
throw new Http2StreamErrorException(
_currentHeadersStream
.StreamId, CoreStrings.Http2TellClientToCalmDown, Http2ErrorCode.ENHANCE_YOUR_CALM);
1368
_currentHeadersStream
.DecrementActiveClientStreamCount();
1369
_currentHeadersStream
.CompleteStream(errored: true);
1373
KestrelEventSource.Log.RequestQueuedStart(
_currentHeadersStream
, AspNetCore.Http.HttpProtocol.Http2);
1380
ThreadPool.UnsafeQueueUserWorkItem(
_currentHeadersStream
, preferLocal: false);
1384
_currentHeadersStream
.Execute();
1466
if (stream ==
_currentHeadersStream
)
1604
Debug.Assert(
_currentHeadersStream
!= null);
1625
_currentHeadersStream
.OnTrailer(name, value);
1636
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: true, name, value);
1642
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: false, name, value);
1650
_currentHeadersStream
.OnHeader(staticTableIndex.GetValueOrDefault(), indexOnly: false, name, value);
1656
_currentHeadersStream
.OnHeader(name, value, checkForNewlineChars: false);
1664
_currentHeadersStream
.OnHeader(name, value, checkForNewlineChars: true);
1689
=>
_currentHeadersStream
!.OnHeadersComplete();