2 writes to _connection
System.Net.Http (2)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (2)
73
_connection
= connection;
1489
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);
666
if (HttpTelemetry.Log.IsEnabled()) HttpTelemetry.Log.RequestHeadersStart(
_connection
.Id);
694
BufferBytes(
_connection
.Pool._http3EncodedAuthorityHostHeader);
709
BufferBytes(
_connection
.AltUsedEncodedHeaderBytes);
724
if (
_connection
.Pool.Settings._useCookies)
726
string cookiesFromContainer =
_connection
.Pool.Settings._cookieContainer!.GetCookieHeader(request.RequestUri);
729
Encoding? valueEncoding =
_connection
.Pool.Settings._requestHeaderEncodingSelector?.Invoke(HttpKnownHeaderNames.Cookie, request);
765
uint maxHeaderListSize =
_connection
.MaxHeaderListSize;
777
HeaderEncodingSelector<HttpRequestMessage>? encodingSelector =
_connection
.Pool.Settings._requestHeaderEncodingSelector;
970
throw new HttpRequestException(HttpRequestError.ConfigurationLimitExceeded, SR.Format(SR.net_http_response_headers_exceeded_length,
_connection
.Pool.Settings.MaxResponseHeadersByteLength));
1143
Encoding? encoding =
_connection
.Pool.Settings._responseHeaderEncodingSelector?.Invoke(descriptor.Name, _request);
1144
headerValue =
_connection
.GetResponseHeaderValueWithCaching(descriptor, literalValue, encoding);
1362
_connection
.Abort(exception);
1365
case QuicException e when (e.QuicError == QuicError.OperationAborted &&
_connection
.AbortException != null):
1367
HttpRequestError httpRequestError =
_connection
.AbortException is HttpProtocolException
1370
throw new HttpRequestException(httpRequestError, SR.net_http_client_execution_error,
_connection
.AbortException);
1378
_connection
.Abort(ex);
1433
_connection
.Trace(StreamId, message, memberName);
1488
stream.
_connection
.RemoveStream(stream._stream);