27 references to StreamId
InMemory.FunctionalTests (2)
Http2\Http2ConnectionTests.cs (1)
598
await WaitForStreamAsync(stream.
StreamId
).DefaultTimeout();
Http2\Http2TestBase.cs (1)
537
if (_httpTestBase._runningStreams.TryGetValue(stream.
StreamId
, out var tcs))
Microsoft.AspNetCore.Server.Kestrel.Core (23)
Internal\Http2\FlowControl\StreamInputFlowControl.cs (1)
26
private int StreamId => _stream.
StreamId
;
Internal\Http2\Http2Connection.cs (11)
427
Log.HPackDecodingError(ConnectionId, _currentHeadersStream.
StreamId
, ex);
740
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorStreamHalfClosedRemote(_incomingFrame.Type, stream.
StreamId
), Http2ErrorCode.STREAM_CLOSED, ConnectionEndReason.FrameAfterStreamClose);
762
return new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorStreamAborted(_incomingFrame.Type, stream.
StreamId
), Http2ErrorCode.STREAM_CLOSED, ConnectionEndReason.FrameAfterStreamClose);
778
return new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorHeadersInterleaved(_incomingFrame.Type, _incomingFrame.StreamId, _currentHeadersStream.
StreamId
), Http2ErrorCode.PROTOCOL_ERROR, ConnectionEndReason.UnexpectedFrame);
825
throw new Http2ConnectionErrorException(CoreStrings.FormatHttp2ErrorStreamHalfClosedRemote(_incomingFrame.Type, stream.
StreamId
), Http2ErrorCode.STREAM_CLOSED, ConnectionEndReason.FrameAfterStreamClose);
1187
if (_incomingFrame.StreamId != _currentHeadersStream.
StreamId
)
1225
_highestOpenedStreamId = _currentHeadersStream.
StreamId
;
1289
throw new Http2StreamErrorException(_currentHeadersStream.
StreamId
, CoreStrings.HttpErrorMissingMandatoryPseudoHeaderFields, Http2ErrorCode.PROTOCOL_ERROR);
1302
throw new Http2StreamErrorException(_currentHeadersStream.
StreamId
, CoreStrings.Http2ErrorMaxStreams, Http2ErrorCode.REFUSED_STREAM);
1327
throw new Http2StreamErrorException(_currentHeadersStream.
StreamId
, CoreStrings.Http2TellClientToCalmDown, Http2ErrorCode.ENHANCE_YOUR_CALM);
1458
_streams.Remove(stream.
StreamId
);
Internal\Http2\Http2FrameWriter.cs (6)
247
WriteResponseHeaders(stream.
StreamId
, stream.StatusCode, Http2HeadersFrameFlags.NONE, (HttpResponseHeaders)stream.ResponseHeaders);
284
_log.Http2UnexpectedDataRemaining(stream.
StreamId
, _connectionId);
490
WriteResponseHeadersUnsynchronized(stream.
StreamId
, stream.StatusCode, Http2HeadersFrameFlags.END_STREAM, (HttpResponseHeaders)stream.ResponseHeaders);
575
var streamId = stream.
StreamId
;
796
WriteResponseHeadersUnsynchronized(stream.
StreamId
, stream.StatusCode, Http2HeadersFrameFlags.NONE, (HttpResponseHeaders)stream.ResponseHeaders);
803
WriteDataUnsynchronized(stream.
StreamId
, data, dataLength, endStream);
Internal\Http2\Http2OutputProducer.cs (2)
24
private int StreamId => _stream.
StreamId
;
99
internal (int, long, State, State, long) SchedulingState => (Stream.
StreamId
, _unconsumedBytes, _unobservedState, _currentState, _streamWindow);
Internal\Http2\Http2Stream.cs (3)
192
=> StringUtilities.ConcatAsHexSuffix(ConnectionId, ':', (uint)
StreamId
);
495
throw new Http2StreamErrorException(
StreamId
, CoreStrings.Http2StreamErrorMoreDataThanLength, Http2ErrorCode.PROTOCOL_ERROR);
540
throw new Http2StreamErrorException(
StreamId
, CoreStrings.Http2StreamErrorLessDataThanLength, Http2ErrorCode.PROTOCOL_ERROR);
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (2)
PooledStreamStackTests.cs (2)
33
Assert.Equal(1, ((Http2Stream)streams._array[0]).
StreamId
);
72
Assert.Equal(2, ((Http2Stream)streams._array[0]).
StreamId
);