2 writes to _connection
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (2)
73
_connection
= connection;
1485
stream.
_connection
= null!;
36 references to _connection
System.Net.Http (36)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (36)
95
_connection
.LogExceptions(_stream.DisposeAsync().AsTask());
109
_connection
.RemoveStream(_stream);
121
_connection
.LogExceptions(_stream.DisposeAsync().AsTask());
133
_connection
.RemoveStream(_stream);
219
_connection
.LogExceptions(readResponseTask);
232
_connection
.LogExceptions(sendRequestTask);
275
if (
_connection
.Pool.Settings._useCookies)
277
CookieHelper.ProcessReceivedCookies(_response,
_connection
.Pool.Settings._cookieContainer!);
309
Exception innerException =
_connection
.AbortException ?? HttpProtocolException.CreateHttp3StreamException(code, ex);
320
Exception abortException =
_connection
.Abort(HttpProtocolException.CreateHttp3ConnectionException(code, SR.net_http_http3_connection_close));
329
catch (QuicException ex) when (ex.QuicError == QuicError.OperationAborted &&
_connection
.AbortException != null)
332
HttpRequestError httpRequestError =
_connection
.AbortException is HttpProtocolException
336
throw new HttpRequestException(httpRequestError, SR.net_http_client_execution_error,
_connection
.AbortException);
341
_connection
.Abort(ex);
361
_connection
.Abort(ex);
366
Exception abortException =
_connection
.Abort(HttpProtocolException.CreateHttp3ConnectionException(Http3ErrorCode.QPackDecompressionFailed));
458
if (
_connection
.Pool.Settings._expect100ContinueTimeout != Timeout.InfiniteTimeSpan)
461
this,
_connection
.Pool.Settings._expect100ContinueTimeout, Timeout.InfiniteTimeSpan);
662
if (HttpTelemetry.Log.IsEnabled()) HttpTelemetry.Log.RequestHeadersStart(
_connection
.Id);
690
BufferBytes(
_connection
.Pool._http3EncodedAuthorityHostHeader);
705
BufferBytes(
_connection
.AltUsedEncodedHeaderBytes);
720
if (
_connection
.Pool.Settings._useCookies)
722
string cookiesFromContainer =
_connection
.Pool.Settings._cookieContainer!.GetCookieHeader(request.RequestUri);
725
Encoding? valueEncoding =
_connection
.Pool.Settings._requestHeaderEncodingSelector?.Invoke(HttpKnownHeaderNames.Cookie, request);
761
uint maxHeaderListSize =
_connection
.MaxHeaderListSize;
773
HeaderEncodingSelector<HttpRequestMessage>? encodingSelector =
_connection
.Pool.Settings._requestHeaderEncodingSelector;
966
throw new HttpRequestException(HttpRequestError.ConfigurationLimitExceeded, SR.Format(SR.net_http_response_headers_exceeded_length,
_connection
.Pool.Settings.MaxResponseHeadersByteLength));
1139
Encoding? encoding =
_connection
.Pool.Settings._responseHeaderEncodingSelector?.Invoke(descriptor.Name, _request);
1140
headerValue =
_connection
.GetResponseHeaderValueWithCaching(descriptor, literalValue, encoding);
1358
_connection
.Abort(exception);
1361
case QuicException e when (e.QuicError == QuicError.OperationAborted &&
_connection
.AbortException != null):
1363
HttpRequestError httpRequestError =
_connection
.AbortException is HttpProtocolException
1366
throw new HttpRequestException(httpRequestError, SR.net_http_client_execution_error,
_connection
.AbortException);
1374
_connection
.Abort(ex);
1429
_connection
.Trace(StreamId, message, memberName);
1484
stream.
_connection
.RemoveStream(stream._stream);