Http2Connection

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (6)

57internal uint _lastSeenHttp2MaxConcurrentStreams = Http2Connection.InitialMaxConcurrentStreams; 257_http2RequestQueue = new RequestQueue<Http2Connection?>(); 415HttpConnectionWaiter<Http2Connection?>? http2ConnectionWaiter = null; 460if (!TryGetPooledHttp2Connection(request, out Http2Connection? connection, out http2ConnectionWaiter) && 972ReadOnlySpan<Http2Connection> http2Connections = default; 981foreach (Http2Connection connection in http2Connections)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http2.cs (28)

21private List<Http2Connection>? _availableHttp2Connections; 29private List<Http2Connection>? _http2ConnectionsForHeartBeat; 35private RequestQueue<Http2Connection?> _http2RequestQueue; 46/// Used by <see cref="Http2Connection"/> to test ALTSVC frames for our origin. 73private bool TryGetPooledHttp2Connection(HttpRequestMessage request, [NotNullWhen(true)] out Http2Connection? connection, out HttpConnectionWaiter<Http2Connection?>? waiter) 176RequestQueue<Http2Connection?>.QueueItem queueItem = _http2RequestQueue.PeekNextRequestForConnectionAttempt(); 181private async Task InjectNewHttp2ConnectionAsync(RequestQueue<Http2Connection?>.QueueItem queueItem) 189Http2Connection? connection = null; 191HttpConnectionWaiter<Http2Connection?> waiter = queueItem.Waiter; 255private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, long connectionId, CancellationToken cancellationToken) 259Http2Connection http2Connection = new Http2Connection(this, stream, activity, remoteEndPoint, connectionId); 279private void HandleHttp2ConnectionFailure(HttpConnectionWaiter<Http2Connection?> requestWaiter, Exception e) 315HttpConnectionWaiter<Http2Connection?>? waiter = null; 384private void ReturnHttp2Connection(Http2Connection connection, bool isNewConnection, HttpConnectionWaiter<Http2Connection?>? initialRequestWaiter = null) 410HttpConnectionWaiter<Http2Connection?>? waiter = null; 450_availableHttp2Connections ??= new List<Http2Connection>(); 518private void DisableHttp2Connection(Http2Connection connection) 524async Task DisableHttp2ConnectionAsync(Http2Connection connection) 556public void InvalidateHttp2Connection(Http2Connection connection) 592/// Called from the <see cref="Http2Connection"/> constructor so that the connection is tracked even if it 595public void AddHttp2ConnectionForHeartBeat(Http2Connection connection) 606(_http2ConnectionsForHeartBeat ??= new List<Http2Connection>()).Add(connection); 611public void RemoveHttp2ConnectionFromHeartBeat(Http2Connection connection) 633Http2Connection[]? localHttp2Connections; 647foreach (Http2Connection http2Connection in localHttp2Connections) 656private static int ScavengeHttp2ConnectionList(List<Http2Connection> list, ref List<HttpConnectionBase>? toDispose, long nowTicks, TimeSpan pooledConnectionLifetime, TimeSpan pooledConnectionIdleTimeout)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionWaiter.cs (1)

33Debug.Assert(typeof(T) == typeof(HttpConnection) || typeof(T) == typeof(Http2Connection));

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (2)

1217return Task.FromException(ExceptionDispatchInfo.SetCurrentStackTrace(new ObjectDisposedException(nameof(Http2Connection)))); 2266public sealed override string ToString() => $"{nameof(Http2Connection)}({_pool})"; // Description for diagnostic purposes

System\Net\Http\SocketsHttpHandler\Http2Stream.cs (3)

33private readonly Http2Connection _connection; 92public Http2Stream(HttpRequestMessage request, Http2Connection connection) 160public Http2Connection Connection => _connection;

System\Net\Http\SocketsHttpHandler\Http2StreamWindowManager.cs (7)

23public Http2StreamWindowManager(Http2Connection connection, Http2Stream stream) 80Http2Connection connection = stream.Connection; 96Http2Connection connection = stream.Connection; 195internal void OnInitialSettingsAckReceived(Http2Connection connection) 202internal void OnDataOrHeadersReceived(Http2Connection connection, bool sendWindowUpdateBeforePing) 229internal void OnPingAckReceived(long payload, Http2Connection connection) 269private void RefreshRtt(Http2Connection connection)

System\Net\Http\SocketsHttpHandler\HttpConnectionBase.cs (5)

73Debug.Assert(this is HttpConnection or Http2Connection or Http3Connection); 111this is HttpConnection ? HttpVersion.Version11 : this is Http2Connection ? HttpVersion.Version20 : HttpVersion.Version30, 125this is Http2Connection ? "2" : 152else if (this is Http2Connection) HttpTelemetry.Log.Http20ConnectionEstablished(Id, scheme, host, port, remoteEndPoint); 171else if (this is Http2Connection) HttpTelemetry.Log.Http20ConnectionClosed(Id);