_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)

160_keepAlivePingDelay = TimeSpanToMs(_pool.Settings._keepAlivePingDelay); 161_keepAlivePingTimeout = TimeSpanToMs(_pool.Settings._keepAlivePingTimeout); 163_keepAlivePingPolicy = _pool.Settings._keepAlivePingPolicy; 165uint maxHeaderListSize = _pool._lastSeenHttp2MaxHeaderListSize; 216BinaryPrimitives.WriteUInt32BigEndian(_outgoingBuffer.AvailableSpan, (uint)_pool.Settings._initialHttp2StreamWindowSize); 274Debug.Assert(!_pool.HasSyncObjLock); 282_pool.InvalidateHttp2Connection(this); 294Debug.Assert(!_pool.HasSyncObjLock); 317Debug.Assert(!_pool.HasSyncObjLock); 348Debug.Assert(!_pool.HasSyncObjLock); 765if ((frameHeader.StreamId != 0 && originLength == 0) || (frameHeader.StreamId == 0 && span.Length >= originLength && span.Slice(0, originLength).SequenceEqual(_pool.Http2AltSvcOriginUri))) 772_pool.HandleAltSvc(new[] { altSvcHeaderValue }, null); 896_pool._lastSeenHttp2MaxHeaderListSize = _maxHeaderListSize; 1329Debug.Assert(!_pool.HasSyncObjLock); 1429HeaderEncodingSelector<HttpRequestMessage>? encodingSelector = _pool.Settings._requestHeaderEncodingSelector; 1503WriteIndexedHeader(_pool.IsSecure ? H2StaticTable.SchemeHttps : H2StaticTable.SchemeHttp, ref headerBuffer); 1511WriteBytes(_pool._http2EncodedAuthorityHostHeader, ref headerBuffer); 1538Encoding? protocolEncoding = _pool.Settings._requestHeaderEncodingSelector?.Invoke(":protocol", request); 1547if (_pool.Settings._useCookies) 1549string cookiesFromContainer = _pool.Settings._cookieContainer!.GetCookieHeader(request.RequestUri); 1553Encoding? cookieEncoding = _pool.Settings._requestHeaderEncodingSelector?.Invoke(KnownHeaders.Cookie.Name, request); 2000Debug.Assert(!_pool.HasSyncObjLock); 2159public sealed override string ToString() => $"{nameof(Http2Connection)}({_pool})"; // Description for diagnostic purposes 2166_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 (10)

51public HttpConnectionPool Pool => _pool; 84uint maxHeaderListSize = _pool._lastSeenHttp3MaxHeaderListSize; 186bool singleConnection = !_pool.Settings.EnableMultipleHttp3Connections; 212Debug.Assert(!_pool.Settings.EnableMultipleHttp3Connections || _availableRequestStreamsCount >= 0); 243Debug.Assert(_pool.Settings.EnableMultipleHttp3Connections, "Calling WaitForAvailableStreamsAsync() is invalid when EnableMultipleHttp3Connections is false."); 381_pool.InvalidateHttp3Connection(this, dispose: false); 416_pool.InvalidateHttp3Connection(this, dispose: false); 478_pool?.GetHashCode() ?? 0, // pool ID 499await _clientControl.WriteAsync(_pool.Settings.Http3SettingsFrame, CancellationToken.None).ConfigureAwait(false); 871_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); 599_allowedReadLineBytes = _pool.Settings.MaxResponseHeadersByteLength; 797_pool.InvalidateHttp11Connection(this); 808_pool.InvalidateHttp11Connection(this); 837if (_pool.Settings._useCookies) 839CookieHelper.ProcessReceivedCookies(response, _pool.Settings._cookieContainer!); 1278Encoding? valueEncoding = _pool.Settings._responseHeaderEncodingSelector?.Invoke(descriptor.Name, _currentRequest!); 1332throw new HttpRequestException(HttpRequestError.ConfigurationLimitExceeded, SR.Format(SR.net_http_response_headers_exceeded_length, _pool.Settings.MaxResponseHeadersByteLength)); 2093if (!await responseStream.DrainAsync(_pool.Settings._maxResponseDrainSize).ConfigureAwait(false) || 2131_pool.RecycleHttp11Connection(this); 2135public sealed override string ToString() => $"{nameof(HttpConnection)}({_pool})"; // Description for diagnostic purposes 2139_pool?.GetHashCode() ?? 0, // pool ID

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

61Debug.Assert(_pool.Settings._metrics is not null); 63SocketsHttpHandlerMetrics metrics = _pool.Settings._metrics!; 72Debug.Assert(_pool.TelemetryServerAddress is not null, "TelemetryServerAddress should not be null when System.Diagnostics.Metrics.Meter.IsSupported is true."); 76_pool.IsSecure ? "https" : "http", 77_pool.TelemetryServerAddress, 78_pool.OriginAuthority.Port, 91string scheme = _pool.IsSecure ? "https" : "http"; 92string host = _pool.OriginAuthority.HostValue; 93int 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");