Http2Connection

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

246_http2RequestQueue = new RequestQueue<Http2Connection?>(); 412HttpConnectionWaiter<Http2Connection?>? http2ConnectionWaiter = null; 456if (!TryGetPooledHttp2Connection(request, out Http2Connection? connection, out http2ConnectionWaiter) &&

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

21private List<Http2Connection>? _availableHttp2Connections; 27private RequestQueue<Http2Connection?> _http2RequestQueue; 37/// Used by <see cref="Http2Connection"/> to test ALTSVC frames for our origin. 64private bool TryGetPooledHttp2Connection(HttpRequestMessage request, [NotNullWhen(true)] out Http2Connection? connection, out HttpConnectionWaiter<Http2Connection?>? waiter) 167RequestQueue<Http2Connection?>.QueueItem queueItem = _http2RequestQueue.PeekNextRequestForConnectionAttempt(); 172private async Task InjectNewHttp2ConnectionAsync(RequestQueue<Http2Connection?>.QueueItem queueItem) 180Http2Connection? connection = null; 182HttpConnectionWaiter<Http2Connection?> waiter = queueItem.Waiter; 247private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken) 251Http2Connection http2Connection = new Http2Connection(this, stream, activity, remoteEndPoint); 271private void HandleHttp2ConnectionFailure(HttpConnectionWaiter<Http2Connection?> requestWaiter, Exception e) 295HttpConnectionWaiter<Http2Connection?>? waiter = null; 364private void ReturnHttp2Connection(Http2Connection connection, bool isNewConnection, HttpConnectionWaiter<Http2Connection?>? initialRequestWaiter = null) 390HttpConnectionWaiter<Http2Connection?>? waiter = null; 430_availableHttp2Connections ??= new List<Http2Connection>(); 498private void DisableHttp2Connection(Http2Connection connection) 504async Task DisableHttp2ConnectionAsync(Http2Connection connection) 536public void InvalidateHttp2Connection(Http2Connection connection) 569Http2Connection[]? localHttp2Connections; 578foreach (Http2Connection http2Connection in localHttp2Connections) 585private static int ScavengeHttp2ConnectionList(List<Http2Connection> list, ref List<HttpConnectionBase>? toDispose, long nowTicks, TimeSpan pooledConnectionLifetime, TimeSpan pooledConnectionIdleTimeout)

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

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

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

1187return Task.FromException(new ObjectDisposedException(nameof(Http2Connection))); 2145public 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 (4)

45Debug.Assert(this is HttpConnection or Http2Connection or Http3Connection); 67this is Http2Connection ? "2" : 92else if (this is Http2Connection) HttpTelemetry.Log.Http20ConnectionEstablished(Id, scheme, host, port, remoteEndPoint); 107else if (this is Http2Connection) HttpTelemetry.Log.Http20ConnectionClosed(Id);