_pool

System\Net\Http\SocketsHttpHandler\ChunkedEncodingReadStream.cs (1)

502TimeSpan drainTime = _connection._pool.Settings._maxResponseDrainTime;

System\Net\Http\SocketsHttpHandler\ContentLengthReadStream.cs (1)

214TimeSpan drainTime = _connection._pool.Settings._maxResponseDrainTime;

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

159_keepAlivePingDelay = TimeSpanToMs(_pool.Settings._keepAlivePingDelay); 160_keepAlivePingTimeout = TimeSpanToMs(_pool.Settings._keepAlivePingTimeout); 162_keepAlivePingPolicy = _pool.Settings._keepAlivePingPolicy; 164uint maxHeaderListSize = _pool._lastSeenHttp2MaxHeaderListSize; 213BinaryPrimitives.WriteUInt32BigEndian(_outgoingBuffer.AvailableSpan, (uint)_pool.Settings._initialHttp2StreamWindowSize); 260Debug.Assert(!_pool.HasSyncObjLock); 268_pool.InvalidateHttp2Connection(this); 280Debug.Assert(!_pool.HasSyncObjLock); 303Debug.Assert(!_pool.HasSyncObjLock); 334Debug.Assert(!_pool.HasSyncObjLock); 751if ((frameHeader.StreamId != 0 && originLength == 0) || (frameHeader.StreamId == 0 && span.Length >= originLength && span.Slice(0, originLength).SequenceEqual(_pool.Http2AltSvcOriginUri))) 758_pool.HandleAltSvc(new[] { altSvcHeaderValue }, null); 882_pool._lastSeenHttp2MaxHeaderListSize = _maxHeaderListSize; 1315Debug.Assert(!_pool.HasSyncObjLock); 1415HeaderEncodingSelector<HttpRequestMessage>? encodingSelector = _pool.Settings._requestHeaderEncodingSelector; 1489WriteIndexedHeader(_pool.IsSecure ? H2StaticTable.SchemeHttps : H2StaticTable.SchemeHttp, ref headerBuffer); 1497WriteBytes(_pool._http2EncodedAuthorityHostHeader, ref headerBuffer); 1524Encoding? protocolEncoding = _pool.Settings._requestHeaderEncodingSelector?.Invoke(":protocol", request); 1533if (_pool.Settings._useCookies) 1535string cookiesFromContainer = _pool.Settings._cookieContainer!.GetCookieHeader(request.RequestUri); 1539Encoding? cookieEncoding = _pool.Settings._requestHeaderEncodingSelector?.Invoke(KnownHeaders.Cookie.Name, request); 1986Debug.Assert(!_pool.HasSyncObjLock); 2145public sealed override string ToString() => $"{nameof(Http2Connection)}({_pool})"; // Description for diagnostic purposes 2152_pool?.GetHashCode() ?? 0, // pool ID

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

106_headerBudgetRemaining = connection._pool.Settings.MaxResponseHeadersByteLength; 353}, this, _connection._pool.Settings._expect100ContinueTimeout, Timeout.InfiniteTimeSpan).ConfigureAwait(false)) 609throw new HttpRequestException(HttpRequestError.ConfigurationLimitExceeded, SR.Format(SR.net_http_response_headers_exceeded_length, _connection._pool.Settings.MaxResponseHeadersByteLength)); 704Encoding? valueEncoding = _connection._pool.Settings._responseHeaderEncodingSelector?.Invoke(descriptor.Name, _request); 1100if (_connection._pool.Settings._useCookies) 1102CookieHelper.ProcessReceivedCookies(_response, _connection._pool.Settings._cookieContainer!);

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

25HttpConnectionSettings settings = connection._pool.Settings;

System\Net\Http\SocketsHttpHandler\Http3Connection.cs (8)

50public HttpConnectionPool Pool => _pool; 83uint maxHeaderListSize = _pool._lastSeenHttp3MaxHeaderListSize; 287_pool.Settings._metrics!.RequestLeftQueue(request, Pool, duration, versionMajor: 3); 363_pool.InvalidateHttp3Connection(this); 396_pool.InvalidateHttp3Connection(this); 458_pool?.GetHashCode() ?? 0, // pool ID 479await _clientControl.WriteAsync(_pool.Settings.Http3SettingsFrame, CancellationToken.None).ConfigureAwait(false); 851_pool._lastSeenHttp3MaxHeaderListSize = _maxHeaderListSize;

System\Net\Http\SocketsHttpHandler\HttpConnection.cs (18)

108_pool.InvalidateHttp11Connection(this, disposing); 297public HttpConnectionKind Kind => _pool.Kind; 349if (_pool.HostHeaderLineBytes is byte[] hostHeaderLineBytes) 365if (_pool.Settings._useCookies) 367cookiesFromContainer = _pool.Settings._cookieContainer!.GetCookieHeader(request.RequestUri); 421HeaderEncodingSelector<HttpRequestMessage>? encodingSelector = _pool.Settings._requestHeaderEncodingSelector; 590allowExpect100ToContinue, _pool.Settings._expect100ContinueTimeout, Timeout.InfiniteTimeSpan); 597_allowedReadLineBytes = _pool.Settings.MaxResponseHeadersByteLength; 795_pool.InvalidateHttp11Connection(this); 806_pool.InvalidateHttp11Connection(this); 835if (_pool.Settings._useCookies) 837CookieHelper.ProcessReceivedCookies(response, _pool.Settings._cookieContainer!); 1276Encoding? valueEncoding = _pool.Settings._responseHeaderEncodingSelector?.Invoke(descriptor.Name, _currentRequest!); 1330throw new HttpRequestException(HttpRequestError.ConfigurationLimitExceeded, SR.Format(SR.net_http_response_headers_exceeded_length, _pool.Settings.MaxResponseHeadersByteLength)); 2086if (!await responseStream.DrainAsync(_pool.Settings._maxResponseDrainSize).ConfigureAwait(false) || 2123_pool.RecycleHttp11Connection(this); 2127public sealed override string ToString() => $"{nameof(HttpConnection)}({_pool})"; // Description for diagnostic purposes 2131_pool?.GetHashCode() ?? 0, // pool ID

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

59Debug.Assert(_pool.Settings._metrics is not null); 61SocketsHttpHandlerMetrics metrics = _pool.Settings._metrics; 73_pool.IsSecure ? "https" : "http", 74_pool.OriginAuthority.HostValue, 75_pool.OriginAuthority.Port, 87string scheme = _pool.IsSecure ? "https" : "http"; 88string host = _pool.OriginAuthority.HostValue; 89int port = _pool.OriginAuthority.Port;

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

78bool drained = await DrainAsync(connection._pool.Settings._maxResponseDrainSize).ConfigureAwait(false); 84$"Connection drain failed when MaxResponseDrainSize={connection._pool.Settings._maxResponseDrainSize} bytes or MaxResponseDrainTime=={connection._pool.Settings._maxResponseDrainTime} exceeded");