162 instantiations of HttpRequestMessage
aspire (2)
Mcp\Docs\DocsFetcher.cs (2)
42using var request = new HttpRequestMessage(HttpMethod.Get, SmallDocsUrl); 70using var retryRequest = new HttpRequestMessage(HttpMethod.Get, SmallDocsUrl);
Aspire.Dashboard (1)
Model\Assistant\ChatClientFactory.cs (1)
137using var httpRequest = new HttpRequestMessage(HttpMethod.Get, ghcpInfoAddress);
Aspire.Dashboard.Tests (19)
Integration\HealthTests.cs (1)
30var request = new HttpRequestMessage(HttpMethod.Get, $"/{DashboardUrls.HealthBasePath}");
Integration\McpServiceTests.cs (3)
328var request = new HttpRequestMessage(HttpMethod.Post, "/mcp") 362var notificationRequest = new HttpRequestMessage(HttpMethod.Post, "/mcp") 389var request = new HttpRequestMessage(HttpMethod.Post, "/mcp")
Integration\OtlpCorsHttpServiceTests.cs (5)
29var preflightRequest = new HttpRequestMessage(HttpMethod.Options, "/v1/logs"); 54var preflightRequest1 = new HttpRequestMessage(HttpMethod.Options, "/v1/logs"); 68var preflightRequest2 = new HttpRequestMessage(HttpMethod.Options, "/v1/logs"); 94var preflightRequest = new HttpRequestMessage(HttpMethod.Options, "/v1/logs"); 122var preflightRequest = new HttpRequestMessage(HttpMethod.Options, "/v1/logs");
Integration\OtlpHttpJsonTests.cs (1)
658var requestMessage = new HttpRequestMessage(HttpMethod.Post, "/v1/logs");
Integration\OtlpHttpServiceTests.cs (3)
143var requestMessage = new HttpRequestMessage(HttpMethod.Post, "/v1/logs"); 171var requestMessage = new HttpRequestMessage(HttpMethod.Post, "/v1/logs"); 313var requestMessage = new HttpRequestMessage(new HttpMethod(method), "/v1/logs");
Integration\ResponseCompressionTests.cs (2)
25var request = new HttpRequestMessage(HttpMethod.Get, DashboardUrls.StructuredLogsBasePath); 47var request = new HttpRequestMessage(HttpMethod.Get, path);
Integration\StartupTests.cs (4)
342var request = new HttpRequestMessage(HttpMethod.Get, "/"); 398var request = new HttpRequestMessage(HttpMethod.Get, "/"); 523var request = new HttpRequestMessage(HttpMethod.Get, "/"); 1062var request = new HttpRequestMessage(HttpMethod.Get, "/");
Aspire.Hosting (3)
Dcp\DcpKubernetesClient.cs (2)
96var httpRequest = new HttpRequestMessage 122var httpRequest = new HttpRequestMessage
ResourceBuilderExtensions.cs (1)
2470var request = new HttpRequestMessage(commandOptions.Method, uri);
Aspire.Hosting.GitHub.Models (1)
GitHubModelsHealthCheck.cs (1)
38using var request = new HttpRequestMessage(HttpMethod.Post, new Uri($"{builder["Endpoint"]}/chat/completions"));
Aspire.Hosting.OpenAI (2)
OpenAIHealthCheck.cs (1)
66using var req = new HttpRequestMessage(HttpMethod.Get, s_statusPageUri);
OpenAIModelHealthCheck.cs (1)
40using var request = new HttpRequestMessage(HttpMethod.Get, new Uri($"{endpoint}/models/{model}"));
dotnet-sourcelink (1)
dotnet-svcutil-lib (2)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpChannelFactory.cs (2)
594var requestMessage = new HttpRequestMessage(HttpMethod.Post, httpRequestUri); 1235HttpRequestMessage headHttpRequestMessage = new HttpRequestMessage()
GenerateDocumentationAndConfigFiles (1)
Program.cs (1)
855var request = new HttpRequestMessage(HttpMethod.Head, uri);
Microsoft.AspNetCore.Authentication.OAuth (1)
OAuthHandler.cs (1)
218var requestMessage = new HttpRequestMessage(HttpMethod.Post, Options.TokenEndpoint);
Microsoft.AspNetCore.Diagnostics.Middleware.Tests (2)
Logging\AcceptanceTests.cs (2)
378using var request = new HttpRequestMessage(HttpMethod.Post, "/") 442using var httpMessage = new HttpRequestMessage(HttpMethod.Get, "/");
Microsoft.AspNetCore.Testing.Tests (2)
FakeCertificateHttpClientHandlerTests.cs (1)
18private readonly HttpRequestMessage _request = new();
FakesExtensionsTests.cs (1)
89using var response = await client.SendAsync(new HttpRequestMessage());
Microsoft.Deployment.DotNet.Releases (1)
Utils.cs (1)
30var httpRequest = new HttpRequestMessage(HttpMethod.Head, address);
Microsoft.Extensions.AI.Evaluation.Safety (1)
ContentSafetyService.cs (1)
414using var request = new HttpRequestMessage(requestMethod, requestUrl);
Microsoft.Extensions.Http.Diagnostics.PerformanceTests (4)
Benchmarks\HeadersReaderBenchmark.cs (1)
35Request = new HttpRequestMessage(HttpMethod.Post, "https://www.microsoft.com");
Benchmarks\HugeHttpCLientLoggingBenchmark.cs (1)
17private static HttpRequestMessage Request => new(HttpMethod.Post, "https://www.microsoft.com");
Benchmarks\MediumHttpClientLoggingBenchmark.cs (1)
17private static HttpRequestMessage Request => new(HttpMethod.Post, "https://www.microsoft.com");
Benchmarks\SmallHttpClientLoggingBenchmark.cs (1)
17private static HttpRequestMessage Request => new(HttpMethod.Post, "https://www.microsoft.com");
Microsoft.Extensions.Http.Diagnostics.Tests (58)
Latency\Internal\HttpLatencyTelemetryHandlerTest.cs (1)
58using var req = new HttpRequestMessage
Logging\AcceptanceTests.cs (12)
107using var httpRequestMessage = new HttpRequestMessage 162using var httpRequestMessage = new HttpRequestMessage 178using var httpRequestMessage2 = new HttpRequestMessage 243using var httpRequestMessage = new HttpRequestMessage 265using var httpRequestMessage2 = new HttpRequestMessage 308using var httpRequestMessage = new HttpRequestMessage 355using var httpRequestMessage = new HttpRequestMessage 420using var httpRequestMessage = new HttpRequestMessage 591using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, _unreachableRequestUri); 617using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, _unreachableRequestUri); 640using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, _unreachableRequestUri); 681using var httpRequestMessage = new HttpRequestMessage
Logging\HttpClientLoggerTest.cs (15)
83using var httpRequestMessage = new HttpRequestMessage 121using var httpRequestMessage = new HttpRequestMessage 183using var httpRequestMessage = new HttpRequestMessage 280using var httpRequestMessage = new HttpRequestMessage 387using var httpRequestMessage = new HttpRequestMessage 484using var httpRequestMessage = new HttpRequestMessage 600using var httpRequestMessage = new HttpRequestMessage 693using var httpRequestMessage = new HttpRequestMessage 736using var httpRequestMessage = new HttpRequestMessage 774using var httpRequestMessage = new HttpRequestMessage 818using var httpRequestMessage = new HttpRequestMessage 868using var httpRequestMessage = new HttpRequestMessage 965using var httpRequestMessage = new HttpRequestMessage 990using var httpRequestMessage = new HttpRequestMessage(); 1009using var httpRequestMessage = new HttpRequestMessage();
Logging\HttpHeadersReaderTest.cs (4)
23using var httpRequest = new HttpRequestMessage(); 41using var httpRequest = new HttpRequestMessage(); 136using var httpRequest = new HttpRequestMessage { Content = requestContent }; 177using var httpRequest = new HttpRequestMessage();
Logging\HttpRequestBodyReaderTest.cs (9)
39using var httpRequest = new HttpRequestMessage 59using var httpRequest = new HttpRequestMessage 83using var httpRequest = new HttpRequestMessage 104using var httpRequest = new HttpRequestMessage 132using var httpRequest = new HttpRequestMessage 156using var httpRequest = new HttpRequestMessage 183using var httpRequest = new HttpRequestMessage 209using var httpRequest = new HttpRequestMessage 230using var httpRequest = new HttpRequestMessage
Logging\HttpRequestReaderTest.cs (15)
83using var httpRequestMessage = new HttpRequestMessage 148using var httpRequestMessage = new HttpRequestMessage 213using var httpRequestMessage = new HttpRequestMessage 289using var httpRequestMessage = new HttpRequestMessage 362using var httpRequestMessage = new HttpRequestMessage 422using var httpRequestMessage = new HttpRequestMessage 495using var httpRequestMessage = new HttpRequestMessage 564using var httpRequestMessage = new HttpRequestMessage 626using var httpRequestMessage = new HttpRequestMessage 660using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 690using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 726using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 774using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 815using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 862using var httpRequestMessage = new HttpRequestMessage();
Telemetry\HttpDependencyMetadataResolverTests.cs (2)
48using var requestMessage = new HttpRequestMessage 68using var requestMessage = new HttpRequestMessage
Microsoft.Extensions.Http.Resilience (2)
Internal\RequestMessageSnapshot.cs (1)
34var clone = new HttpRequestMessage(_method!, _requestUri)
Resilience\ResilienceHttpClientBuilderExtensions.Resilience.cs (1)
128using var request = new HttpRequestMessage(HttpMethod.Get, "https://localhost:123");
Microsoft.Extensions.Http.Resilience.PerformanceTests (4)
HedgingBenchmark.cs (1)
16private static HttpRequestMessage Request => new(HttpMethod.Post, _uri);
HttpResilienceBenchmark.cs (1)
27var request = new HttpRequestMessage(HttpMethod.Post, _uri);
RetryBenchmark.cs (1)
25private static HttpRequestMessage Request => new(HttpMethod.Post, _uri);
StandardResilienceBenchmark.cs (1)
25private static HttpRequestMessage Request => new(HttpMethod.Post, _uri);
Microsoft.Extensions.Http.Resilience.Tests (35)
Hedging\HedgingTests.cs (9)
83using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 123using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 142using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 164using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 189using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 213using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 237using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 265using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 289using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query");
Hedging\StandardHedgingTests.cs (6)
121using var request = new HttpRequestMessage(); 223using var request = new HttpRequestMessage(HttpMethod.Get, "https://key:80/discarded"); 256using var firstRequest = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 263using var secondRequest = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 291using var request = new HttpRequestMessage(HttpMethod.Get, "https://some-endpoint:1234/some-path?query"); 338using var request = new HttpRequestMessage(HttpMethod.Get, $"https://{FailingEndpoint}:3000");
Internal\RequestMessageSnapshotStrategyTests.cs (1)
22using var request = new HttpRequestMessage();
Polly\HttpRetryStrategyOptionsExtensionsTests.cs (4)
49using var request = new HttpRequestMessage { Method = new HttpMethod(httpMethod) }; 61using var request = new HttpRequestMessage { Method = HttpMethod.Get }; 73using var request = new HttpRequestMessage { Method = HttpMethod.Post }; 108using var request = new HttpRequestMessage { Method = new HttpMethod(httpMethod) };
Resilience\HttpClientBuilderExtensionsTests.BySelector.cs (3)
38using var request = new HttpRequestMessage(HttpMethod.Head, url); 53using var request = new HttpRequestMessage(); 84using var request = new HttpRequestMessage(HttpMethod.Head, url);
Resilience\HttpClientBuilderExtensionsTests.Standard.cs (1)
41using var request = new HttpRequestMessage(HttpMethod.Get, url);
Resilience\HttpResilienceContextExtensionsTests.cs (3)
42using var request = new HttpRequestMessage(); 52using var request = new HttpRequestMessage(); 71using var request = new HttpRequestMessage();
Resilience\RequestMessageSnapshotTests.cs (2)
21var initialRequest = new HttpRequestMessage 55var initialRequest = new HttpRequestMessage
Resilience\ResilienceHandlerTest.cs (5)
30using var request = new HttpRequestMessage(); 68using var request = new HttpRequestMessage(); 100using var request = new HttpRequestMessage(); 131using var request = new HttpRequestMessage(); 155using var request = new HttpRequestMessage();
Routing\RoutingResilienceStrategyTests.cs (1)
37using var request = new HttpRequestMessage();
Microsoft.Extensions.ML (1)
ModelLoaders\UriModelLoader.cs (1)
109var headRequest = new HttpRequestMessage(HttpMethod.Head, uri);
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
200var httpRequest = new HttpRequestMessage(HttpMethod.Get, "http://basket");
Microsoft.ML.Tokenizers (1)
Utils\Helpers.netcoreapp.cs (1)
31HttpResponseMessage response = client.Send(new HttpRequestMessage(HttpMethod.Get, url), HttpCompletionOption.ResponseHeadersRead);
Microsoft.ML.Tokenizers.Tests (1)
src\Microsoft.ML.Tokenizers\Utils\Helpers.netcoreapp.cs (1)
31HttpResponseMessage response = client.Send(new HttpRequestMessage(HttpMethod.Get, url), HttpCompletionOption.ResponseHeadersRead);
Microsoft.NET.Build.Containers (6)
AuthHandshakeMessageHandler.cs (2)
483HttpRequestMessage postMessage = new(HttpMethod.Post, realmUri) 529var message = new HttpRequestMessage(HttpMethod.Get, builder.ToString());
Registry\DefaultBlobOperations.cs (2)
33using HttpResponseMessage response = await _client.SendAsync(new HttpRequestMessage(HttpMethod.Head, new Uri(_baseUri, $"/v2/{repositoryName}/blobs/{digest}")), cancellationToken).ConfigureAwait(false); 65using HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, new Uri(_baseUri, $"/v2/{repositoryName}/blobs/{digest}")).AcceptManifestFormats();
Registry\DefaultBlobUploadOperations.cs (1)
97HttpRequestMessage patchMessage = new(HttpMethod.Patch, finalUri)
Registry\DefaultManifestOperations.cs (1)
30using HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, new Uri(_baseUri, $"/v2/{repositoryName}/manifests/{reference}")).AcceptManifestFormats();
Microsoft.NET.Sdk.Publish.Tasks (2)
Kudu\KuduVfsDeploy.cs (1)
66using (var req = new HttpRequestMessage(HttpMethod.Put, apiUrl))
Kudu\KuduZipDeploy.cs (1)
57using (var req = new HttpRequestMessage(HttpMethod.Put, DestinationUrl))
NuGet.Protocol (3)
HttpSource\HttpRequestMessageExtensions.cs (1)
25var clone = new HttpRequestMessage(request.Method, request.RequestUri)
HttpSource\HttpRequestMessageFactory.cs (2)
73var request = new HttpRequestMessage(method, requestUri); 101var request = new HttpRequestMessage(method, requestUri);
System.Net.Http (2)
System\Net\Http\HttpClient.cs (1)
830new HttpRequestMessage(method, uri) { Version = _defaultRequestVersion, VersionPolicy = _defaultVersionPolicy };
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
781HttpRequestMessage tunnelRequest = new HttpRequestMessage(HttpMethod.Connect, _proxyUri);
System.Net.Requests (1)
System\Net\HttpWebRequest.cs (1)
1201_sendRequestMessage = new HttpRequestMessage(HttpMethod.Parse(_originVerb), _requestUri);
System.ServiceModel.Http (2)
System\ServiceModel\Channels\HttpChannelFactory.cs (2)
690var requestMessage = new HttpRequestMessage(HttpMethod.Post, httpRequestUri); 1350HttpRequestMessage headHttpRequestMessage = new HttpRequestMessage()
656 references to HttpRequestMessage
aspire (2)
Mcp\Docs\DocsFetcher.cs (2)
42using var request = new HttpRequestMessage(HttpMethod.Get, SmallDocsUrl); 70using var retryRequest = new HttpRequestMessage(HttpMethod.Get, SmallDocsUrl);
Aspire.Cli.Tests (6)
Mcp\Docs\DocsFetcherTests.cs (1)
370HttpRequestMessage request,
Utils\MockHttpMessageHandler.cs (5)
12private readonly Func<HttpRequestMessage, HttpResponseMessage>? _responseFactory; 15private readonly Action<HttpRequestMessage>? _requestValidator; 27public MockHttpMessageHandler(HttpResponseMessage response, Action<HttpRequestMessage>? requestValidator = null) 37public MockHttpMessageHandler(Func<HttpRequestMessage, HttpResponseMessage> responseFactory) 52HttpRequestMessage request,
Aspire.Dashboard (1)
Model\Assistant\ChatClientFactory.cs (1)
137using var httpRequest = new HttpRequestMessage(HttpMethod.Get, ghcpInfoAddress);
Aspire.Dashboard.Tests (37)
Integration\HealthTests.cs (1)
30var request = new HttpRequestMessage(HttpMethod.Get, $"/{DashboardUrls.HealthBasePath}");
Integration\McpServiceTests.cs (17)
36var request = CreateListToolsRequest(sessionId); 63var request = CreateListToolsRequest(); 86var requestMessage = CreateListToolsRequest(); 109void AddApiKey(HttpRequestMessage r) => r.Headers.TryAddWithoutValidation(McpApiKeyAuthenticationHandler.McpApiKeyHeaderName, apiKey); 113var listRequest = CreateListToolsRequest(sessionId); 138var request = CreateListToolsRequest(sessionId); 175var request = CreateListToolsRequest(sessionId); 207var request = CreateListToolsRequest(); 236var request = CreateListToolsRequest(sessionId); 274var request = CreateListToolsRequest(sessionId); 308internal static HttpRequestMessage CreateInitializeRequest(string? sessionId = null) 328var request = new HttpRequestMessage(HttpMethod.Post, "/mcp") 341internal static async Task<string> InitializeSessionAsync(HttpClient httpClient, Action<HttpRequestMessage>? configureRequest = null) 343var initRequest = CreateInitializeRequest(); 362var notificationRequest = new HttpRequestMessage(HttpMethod.Post, "/mcp") 376internal static HttpRequestMessage CreateListToolsRequest(string? sessionId = null) 389var request = new HttpRequestMessage(HttpMethod.Post, "/mcp")
Integration\OtlpCorsHttpServiceTests.cs (5)
29var preflightRequest = new HttpRequestMessage(HttpMethod.Options, "/v1/logs"); 54var preflightRequest1 = new HttpRequestMessage(HttpMethod.Options, "/v1/logs"); 68var preflightRequest2 = new HttpRequestMessage(HttpMethod.Options, "/v1/logs"); 94var preflightRequest = new HttpRequestMessage(HttpMethod.Options, "/v1/logs"); 122var preflightRequest = new HttpRequestMessage(HttpMethod.Options, "/v1/logs");
Integration\OtlpHttpJsonTests.cs (1)
658var requestMessage = new HttpRequestMessage(HttpMethod.Post, "/v1/logs");
Integration\OtlpHttpServiceTests.cs (3)
143var requestMessage = new HttpRequestMessage(HttpMethod.Post, "/v1/logs"); 171var requestMessage = new HttpRequestMessage(HttpMethod.Post, "/v1/logs"); 313var requestMessage = new HttpRequestMessage(new HttpMethod(method), "/v1/logs");
Integration\ResponseCompressionTests.cs (2)
25var request = new HttpRequestMessage(HttpMethod.Get, DashboardUrls.StructuredLogsBasePath); 47var request = new HttpRequestMessage(HttpMethod.Get, path);
Integration\StartupTests.cs (5)
342var request = new HttpRequestMessage(HttpMethod.Get, "/"); 398var request = new HttpRequestMessage(HttpMethod.Get, "/"); 420var mcpRequest = McpServiceTests.CreateListToolsRequest(mcpSessionId); 523var request = new HttpRequestMessage(HttpMethod.Get, "/"); 1062var request = new HttpRequestMessage(HttpMethod.Get, "/");
Telemetry\DashboardTelemetrySenderTests.cs (3)
151private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _value; 153public TestHttpMessageHandler(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> value) 158protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Aspire.Hosting (6)
ApplicationModel\HttpCommandContext.cs (2)
7/// Context passed to callback to configure <see cref="HttpRequestMessage"/> when using 41public required HttpRequestMessage Request { get; init; }
Dcp\DcpKubernetesClient.cs (3)
77var httpRequest = httpResponse.RequestMessage; 96var httpRequest = new HttpRequestMessage 122var httpRequest = new HttpRequestMessage
ResourceBuilderExtensions.cs (1)
2470var request = new HttpRequestMessage(commandOptions.Method, uri);
Aspire.Hosting.Foundry (1)
HostedAgent\HostedAgentBuilderExtension.cs (1)
173var request = ctx.Request;
Aspire.Hosting.GitHub.Models (1)
GitHubModelsHealthCheck.cs (1)
38using var request = new HttpRequestMessage(HttpMethod.Post, new Uri($"{builder["Endpoint"]}/chat/completions"));
Aspire.Hosting.OpenAI (2)
OpenAIHealthCheck.cs (1)
66using var req = new HttpRequestMessage(HttpMethod.Get, s_statusPageUri);
OpenAIModelHealthCheck.cs (1)
40using var request = new HttpRequestMessage(HttpMethod.Get, new Uri($"{endpoint}/models/{model}"));
Aspire.Hosting.Tests (1)
WithHttpCommandTests.cs (1)
264protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Binding.Http.IntegrationTests (2)
HttpBindingTestHelpers.cs (2)
30public Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> OnSendingAsync { get; set; } 45protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Binding.ReliableSession.IntegrationTests (2)
src\System.Private.ServiceModel\tests\Scenarios\Binding\Http\HttpBindingTestHelpers.cs (2)
30public Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> OnSendingAsync { get; set; } 45protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
dotnet-sourcelink (1)
dotnet-svcutil-lib (35)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpChannelFactory.cs (8)
590internal HttpRequestMessage GetHttpRequestMessage(Uri via) 594var requestMessage = new HttpRequestMessage(HttpMethod.Post, httpRequestUri); 850internal HttpRequestMessage GetHttpRequestMessage(Uri via) 855internal virtual void OnHttpRequestCompleted(HttpRequestMessage request) 878private HttpRequestMessage _httpRequestMessage; 986var httpRequestMessageSnapshot = _httpRequestMessage; 1211private void TryCompleteHttpRequest(HttpRequestMessage request) 1235HttpRequestMessage headHttpRequestMessage = new HttpRequestMessage()
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpChannelHelpers.cs (2)
112public static HttpResponseMessage ProcessGetResponseWebException(HttpRequestException requestException, HttpRequestMessage request, HttpAbortReason abortReason) 126public static Exception ConvertHttpRequestException(HttpRequestException exception, HttpRequestMessage request, HttpAbortReason abortReason)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpRequestMessageExtensionMethods.cs (4)
23internal static void CopyPropertiesFromMessage(this HttpRequestMessage httpRequestMessage, Message message) 68public static bool CreateContentIfNull(this HttpRequestMessage httpRequestMessage) 81internal static void MergeWebHeaderCollection(this HttpRequestMessage requestMessage, WebHeaderCollection headersToMerge) 102internal static WebHeaderCollection ToWebHeaderCollection(this HttpRequestMessage httpRequest)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpRequestMessageProperty.cs (6)
31internal HttpRequestMessageProperty(HttpRequestMessage httpRequestMessage) 128public HttpRequestMessage HttpRequestMessage 141internal static HttpRequestMessage GetHttpRequestMessageFromMessage(Message message) 143HttpRequestMessage httpRequestMessage = null; 264public HttpRequestMessageBackedProperty(HttpRequestMessage httpRequestMessage) 271public HttpRequestMessage HttpRequestMessage { get; private set; }
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpResponseMessageExtensionMethods.cs (1)
20HttpRequestMessage request = httpResponseMessage.RequestMessage;
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpResponseMessageHelper.cs (1)
20private readonly HttpRequestMessage _httpRequestMessage;
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\HttpsChannelFactory.cs (3)
23private Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> _remoteCertificateValidationCallback; 186private bool RemoteCertificateValidationCallback(HttpRequestMessage sender, X509Certificate2 certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors) 312internal override void OnHttpRequestCompleted(HttpRequestMessage request)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ServiceModelHttpMessageHandler.CoreClr.cs (1)
72public Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool>
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\TransportSecurityHelpers.cs (9)
339private static Dictionary<HttpRequestMessage, string> s_serverCertMap = new Dictionary<HttpRequestMessage, string>(); 341public static void AddServerCertMapping(HttpRequestMessage request, EndpointAddress to) 355private static void AddServerCertMapping(HttpRequestMessage request, string thumbprint) 373private static Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> ChainValidator(Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> previousValidator) 380Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> chained = 393private static bool OnValidateServerCertificate(HttpRequestMessage request, X509Certificate2 certificate, X509Chain chain, 419public static void RemoveServerCertMapping(HttpRequestMessage request)
GenerateDocumentationAndConfigFiles (1)
Program.cs (1)
855var request = new HttpRequestMessage(HttpMethod.Head, uri);
Keycloak.Web (1)
AuthorizationHandler.cs (1)
8protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Microsoft.Analyzers.Local.Tests (1)
ApiLifecycle\ApiLifecycleAnalyzerTest.cs (1)
91Assembly.GetAssembly(typeof(HttpRequestMessage))!,
Microsoft.Arcade.Common (3)
ArcadeHttpMessageHandler.cs (2)
15public Task<HttpResponseMessage> SendAsync(HttpRequestMessage request) => SendAsync(request, CancellationToken.None); 17protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
RequestResponseHelper.cs (1)
13public HttpRequestMessage RequestMessage { get; set; }
Microsoft.AspNetCore.Authentication.OAuth (1)
OAuthHandler.cs (1)
218var requestMessage = new HttpRequestMessage(HttpMethod.Post, Options.TokenEndpoint);
Microsoft.AspNetCore.Diagnostics.Middleware.Tests (2)
Logging\AcceptanceTests.cs (2)
378using var request = new HttpRequestMessage(HttpMethod.Post, "/") 442using var httpMessage = new HttpRequestMessage(HttpMethod.Get, "/");
Microsoft.AspNetCore.Testing.Tests (4)
FakeCertificateHttpClientHandlerTests.cs (1)
18private readonly HttpRequestMessage _request = new();
TestResources\ReturningHttpClientHandler.cs (2)
14protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 20protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
TestResources\TestHandler.cs (1)
13protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request,
Microsoft.Deployment.DotNet.Releases (1)
Utils.cs (1)
30var httpRequest = new HttpRequestMessage(HttpMethod.Head, address);
Microsoft.Extensions.AI.Evaluation.Safety (2)
ContentSafetyService.cs (2)
414using var request = new HttpRequestMessage(requestMethod, requestUrl); 424HttpRequestMessage httpRequestMessage,
Microsoft.Extensions.AI.Integration.Tests (2)
VerbatimHttpHandler.cs (1)
44protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
VerbatimMultiPartHttpHandler.cs (1)
45HttpRequestMessage request,
Microsoft.Extensions.AI.OpenAI.Tests (1)
ThrowUserAgentExceptionHandler.cs (1)
13protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) =>
Microsoft.Extensions.Http (27)
HttpMessageHandlerBuilder.cs (1)
73/// of sending an <see cref="HttpRequestMessage"/> and receiving an <see cref="HttpResponseMessage"/>.
Logging\HttpClientLoggerHandler.cs (2)
25protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 65protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\IHttpClientAsyncLogger.cs (5)
17/// <see cref="HttpClient.SendAsync(HttpRequestMessage, CancellationToken)"/>), and their 23/// However, the implementation should be mindful about potential adverse side effects of accessing some of the <see cref="HttpRequestMessage"/> or 40ValueTask<object?> LogRequestStartAsync(HttpRequestMessage request, CancellationToken cancellationToken = default); 51ValueTask LogRequestStopAsync(object? context, HttpRequestMessage request, HttpResponseMessage response, TimeSpan elapsed, CancellationToken cancellationToken = default); 63ValueTask LogRequestFailedAsync(object? context, HttpRequestMessage request, HttpResponseMessage? response, Exception exception, TimeSpan elapsed, CancellationToken cancellationToken = default);
Logging\IHttpClientLogger.cs (4)
15/// However, the implementation should be mindful about potential adverse side effects of accessing some of the <see cref="HttpRequestMessage"/> or 30object? LogRequestStart(HttpRequestMessage request); 39void LogRequestStop(object? context, HttpRequestMessage request, HttpResponseMessage response, TimeSpan elapsed); 49void LogRequestFailed(object? context, HttpRequestMessage request, HttpResponseMessage? response, Exception exception, TimeSpan elapsed);
Logging\LoggingHttpMessageHandler.cs (6)
49private Task<HttpResponseMessage> SendCoreAsync(HttpRequestMessage request, bool useAsync, CancellationToken cancellationToken) 54async Task<HttpResponseMessage> Core(HttpRequestMessage request, bool useAsync, CancellationToken cancellationToken) 85/// <remarks>Logs the request to and response from the sent <see cref="HttpRequestMessage"/>.</remarks> 86protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 91/// <remarks>Logs the request to and response from the sent <see cref="HttpRequestMessage"/>.</remarks> 92protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\LoggingScopeHttpMessageHandler.cs (6)
48private Task<HttpResponseMessage> SendCoreAsync(HttpRequestMessage request, bool useAsync, CancellationToken cancellationToken) 53async Task<HttpResponseMessage> Core(HttpRequestMessage request, bool useAsync, CancellationToken cancellationToken) 86/// <remarks>Logs the request to and response from the sent <see cref="HttpRequestMessage"/>.</remarks> 87protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 92/// <remarks>Logs the request to and response from the sent <see cref="HttpRequestMessage"/>.</remarks> 93protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\LogHelper.cs (3)
68public static void LogRequestStart(this ILogger logger, HttpRequestMessage request, Func<string, bool> shouldRedactHeaderValue) 105public static IDisposable? BeginRequestPipelineScope(this ILogger logger, HttpRequestMessage request, out string? formattedUri) 111public static void LogRequestPipelineStart(this ILogger logger, HttpRequestMessage request, string? formattedUri, Func<string, bool> shouldRedactHeaderValue)
Microsoft.Extensions.Http.Diagnostics (30)
Http\HttpDependencyMetadataResolver.cs (2)
58/// Gets request metadata for the specified instance of <see cref="HttpRequestMessage"/>. 62public virtual RequestMetadata? GetRequestMetadata(HttpRequestMessage requestMessage)
Http\HttpDiagnosticsHttpRequestMessageExtensions.cs (4)
20/// <param name="request"><see cref="HttpRequestMessage"/> object.</param> 22public static void SetRequestMetadata(this HttpRequestMessage request, RequestMetadata metadata) 37/// <param name="request"><see cref="HttpRequestMessage"/> object.</param> 39public static RequestMetadata? GetRequestMetadata(this HttpRequestMessage request)
Latency\Internal\HttpClientLatencyLogEnricher.cs (1)
39public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage? request, HttpResponseMessage? response, Exception? exception)
Latency\Internal\HttpLatencyTelemetryHandler.cs (1)
45protected async override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\IHttpClientLogEnricher.cs (2)
19/// <param name="request"><see cref="HttpRequestMessage"/> object associated with the outgoing HTTP request.</param> 26void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception);
Logging\Internal\HttpClientLogger.cs (8)
67public async ValueTask<object?> LogRequestStartAsync(HttpRequestMessage request, CancellationToken cancellationToken = default) 112HttpRequestMessage request, 120HttpRequestMessage request, 127public object? LogRequestStart(HttpRequestMessage request) 130public void LogRequestStop(object? context, HttpRequestMessage request, HttpResponseMessage response, TimeSpan elapsed) 133public void LogRequestFailed(object? context, HttpRequestMessage request, HttpResponseMessage? response, Exception exception, TimeSpan elapsed) 152HttpRequestMessage request, 219HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Logging\Internal\HttpHeadersReader.cs (1)
41public void ReadRequestHeaders(HttpRequestMessage request, List<KeyValuePair<string, string>>? destination)
Logging\Internal\HttpRequestBodyReader.cs (3)
37public ValueTask<string> ReadAsync(HttpRequestMessage request, CancellationToken cancellationToken) 58private static async ValueTask<string> ReadFromStreamWithTimeoutAsync(HttpRequestMessage request, 76private static async ValueTask<string> ReadFromStreamAsync(HttpRequestMessage request, int readSizeLimit,
Logging\Internal\HttpRequestReader.cs (2)
118public async Task ReadRequestAsync(LogRecord logRecord, HttpRequestMessage request, 219private void GetRedactedPathAndParameters(HttpRequestMessage request, LogRecord logRecord)
Logging\Internal\IHttpHeadersReader.cs (2)
18/// <param name="request">An instance of <see cref="HttpRequestMessage"/> to read headers from.</param> 20void ReadRequestHeaders(HttpRequestMessage request, List<KeyValuePair<string, string>>? destination);
Logging\Internal\IHttpRequestReader.cs (3)
12/// Methods to read <see cref="HttpResponseMessage"/> or <see cref="HttpRequestMessage"/>. 29/// Reads <see cref="HttpRequestMessage"/>. 36Task ReadRequestAsync(LogRecord record, HttpRequestMessage request,
Logging\Internal\Log.cs (1)
14/// Logs <see cref="HttpRequestMessage"/>, <see cref="HttpResponseMessage"/> and the exceptions due to errors of request/response.
Microsoft.Extensions.Http.Diagnostics.PerformanceTests (7)
BenchEnricher.cs (1)
15public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Benchmarks\HeadersReaderBenchmark.cs (1)
29public HttpRequestMessage? Request { get; set; }
Benchmarks\HugeHttpCLientLoggingBenchmark.cs (1)
17private static HttpRequestMessage Request => new(HttpMethod.Post, "https://www.microsoft.com");
Benchmarks\MediumHttpClientLoggingBenchmark.cs (1)
17private static HttpRequestMessage Request => new(HttpMethod.Post, "https://www.microsoft.com");
Benchmarks\SmallHttpClientLoggingBenchmark.cs (1)
17private static HttpRequestMessage Request => new(HttpMethod.Post, "https://www.microsoft.com");
NoRemoteCallHandler.cs (1)
35protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
NoRemoteCallNotSeekableHandler.cs (1)
38protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Microsoft.Extensions.Http.Diagnostics.Tests (89)
Latency\Internal\HttpLatencyTelemetryHandlerTest.cs (3)
58using var req = new HttpRequestMessage 68ItExpr.IsAny<HttpRequestMessage>(), 69ItExpr.IsAny<CancellationToken>()).Callback<HttpRequestMessage, CancellationToken>((req, _) =>
Logging\AcceptanceTests.cs (13)
107using var httpRequestMessage = new HttpRequestMessage 162using var httpRequestMessage = new HttpRequestMessage 178using var httpRequestMessage2 = new HttpRequestMessage 195private static async Task<string> SendRequest(HttpClient httpClient, HttpRequestMessage httpRequestMessage) 243using var httpRequestMessage = new HttpRequestMessage 265using var httpRequestMessage2 = new HttpRequestMessage 308using var httpRequestMessage = new HttpRequestMessage 355using var httpRequestMessage = new HttpRequestMessage 420using var httpRequestMessage = new HttpRequestMessage 591using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, _unreachableRequestUri); 617using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, _unreachableRequestUri); 640using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, _unreachableRequestUri); 681using var httpRequestMessage = new HttpRequestMessage
Logging\HttpClientLoggerTest.cs (28)
83using var httpRequestMessage = new HttpRequestMessage 121using var httpRequestMessage = new HttpRequestMessage 131It.IsAny<HttpRequestMessage>(), 183using var httpRequestMessage = new HttpRequestMessage 280using var httpRequestMessage = new HttpRequestMessage 387using var httpRequestMessage = new HttpRequestMessage 484using var httpRequestMessage = new HttpRequestMessage 532It.IsAny<HttpRequestMessage>(), 535.Returns((LogRecord a, HttpRequestMessage b, List<KeyValuePair<string, string>> c, CancellationToken d) => 600using var httpRequestMessage = new HttpRequestMessage 693using var httpRequestMessage = new HttpRequestMessage 705enricher1.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 706enricher2.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 736using var httpRequestMessage = new HttpRequestMessage 748enricher1.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 749enricher2.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 758.Setup(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>())) 774using var httpRequestMessage = new HttpRequestMessage 791enricher1.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 792enricher2.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 801.Setup(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>())) 818using var httpRequestMessage = new HttpRequestMessage 837enricher1.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 838enricher2.Verify(e => e.Enrich(It.IsAny<IEnrichmentTagCollector>(), It.IsAny<HttpRequestMessage>(), It.IsAny<HttpResponseMessage>(), It.IsAny<Exception>()), Times.Exactly(1)); 868using var httpRequestMessage = new HttpRequestMessage 965using var httpRequestMessage = new HttpRequestMessage 990using var httpRequestMessage = new HttpRequestMessage(); 1009using var httpRequestMessage = new HttpRequestMessage();
Logging\HttpClientLoggingExtensionsTest.cs (3)
496private sealed class TestMessageHandler(Func<HttpRequestMessage, HttpResponseMessage> responseFactory) 499protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 509protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\HttpHeadersReaderTest.cs (4)
23using var httpRequest = new HttpRequestMessage(); 41using var httpRequest = new HttpRequestMessage(); 136using var httpRequest = new HttpRequestMessage { Content = requestContent }; 177using var httpRequest = new HttpRequestMessage();
Logging\HttpRequestBodyReaderTest.cs (9)
39using var httpRequest = new HttpRequestMessage 59using var httpRequest = new HttpRequestMessage 83using var httpRequest = new HttpRequestMessage 104using var httpRequest = new HttpRequestMessage 132using var httpRequest = new HttpRequestMessage 156using var httpRequest = new HttpRequestMessage 183using var httpRequest = new HttpRequestMessage 209using var httpRequest = new HttpRequestMessage 230using var httpRequest = new HttpRequestMessage
Logging\HttpRequestReaderTest.cs (15)
83using var httpRequestMessage = new HttpRequestMessage 148using var httpRequestMessage = new HttpRequestMessage 213using var httpRequestMessage = new HttpRequestMessage 289using var httpRequestMessage = new HttpRequestMessage 362using var httpRequestMessage = new HttpRequestMessage 422using var httpRequestMessage = new HttpRequestMessage 495using var httpRequestMessage = new HttpRequestMessage 564using var httpRequestMessage = new HttpRequestMessage 626using var httpRequestMessage = new HttpRequestMessage 660using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 690using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 726using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 774using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 815using var httpRequestMessage = new HttpRequestMessage(HttpMethod.Get, uri); 862using var httpRequestMessage = new HttpRequestMessage();
Logging\Internal\EmptyEnricher.cs (1)
12public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Logging\Internal\EnricherWithCounter.cs (1)
14public void Enrich(IEnrichmentTagCollector collector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Logging\Internal\ITestHttpClient1.cs (1)
11Task<HttpResponseMessage> SendRequest(HttpRequestMessage httpRequestMessage);
Logging\Internal\ITestHttpClient2.cs (1)
11Task<HttpResponseMessage> SendRequest(HttpRequestMessage httpRequestMessage);
Logging\Internal\MockedRequestReader.cs (1)
28HttpRequestMessage request,
Logging\Internal\NoRemoteCallHandler.cs (1)
29protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Logging\Internal\TestEnricher.cs (1)
29public void Enrich(IEnrichmentTagCollector tagCollector, HttpRequestMessage request, HttpResponseMessage? response, Exception? exception)
Logging\Internal\TestHttpClient1.cs (1)
18public Task<HttpResponseMessage> SendRequest(HttpRequestMessage httpRequestMessage)
Logging\Internal\TestHttpClient2.cs (1)
18public Task<HttpResponseMessage> SendRequest(HttpRequestMessage httpRequestMessage)
Logging\Internal\TestingHandlerStub.cs (3)
13private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _handlerFunc; 15public TestingHandlerStub(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> handlerFunc) 20protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) => _handlerFunc(request, cancellationToken);
Telemetry\HttpDependencyMetadataResolverTests.cs (2)
48using var requestMessage = new HttpRequestMessage 68using var requestMessage = new HttpRequestMessage
Microsoft.Extensions.Http.Resilience (38)
Hedging\HttpStandardHedgingResilienceOptions.cs (1)
32/// <see cref="StandardHedgingHandlerBuilderExtensions.SelectPipelineBy(IStandardHedgingHandlerBuilder, Func{IServiceProvider, Func{System.Net.Http.HttpRequestMessage, string}})"/> extensions.
Hedging\Internals\RequestMessageSnapshotStrategy.cs (2)
13/// This strategy creates a snapshot of <see cref="HttpRequestMessage"/> before executing the hedging to prevent race conditions when cloning and modifying the message at the same time. 23HttpRequestMessage? request = context.GetRequestMessage();
Hedging\ResilienceHttpClientBuilderExtensions.Hedging.cs (1)
90var requestMessage = snapshot.CreateRequestMessage();
Hedging\StandardHedgingHandlerBuilderExtensions.cs (1)
96public static IStandardHedgingHandlerBuilder SelectPipelineBy(this IStandardHedgingHandlerBuilder builder, Func<IServiceProvider, Func<HttpRequestMessage, string>> selectorFactory)
Internal\RequestMessageSnapshot.cs (4)
25public static RequestMessageSnapshot Create(HttpRequestMessage request) 32public HttpRequestMessage CreateRequestMessage() 34var clone = new HttpRequestMessage(_method!, _requestUri) 74private void Initialize(HttpRequestMessage request)
Internal\ResilienceKeys.cs (1)
13public static readonly ResiliencePropertyKey<HttpRequestMessage?> RequestMessage = new("Resilience.Http.RequestMessage");
Polly\HttpRetryStrategyOptionsExtensions.cs (2)
55if (result && GetRequestMessage(args) is HttpRequestMessage request) 64private static HttpRequestMessage? GetRequestMessage(RetryPredicateArguments<HttpResponseMessage> args) =>
Resilience\HttpResilienceContextExtensions.cs (2)
28public static HttpRequestMessage? GetRequestMessage(this ResilienceContext context) 40public static void SetRequestMessage(this ResilienceContext context, HttpRequestMessage? requestMessage)
Resilience\HttpResilienceHttpRequestMessageExtensions.cs (3)
10/// The resilience extensions for <see cref="HttpRequestMessage"/>. 25public static ResilienceContext? GetResilienceContext(this HttpRequestMessage requestMessage) 49public static void SetResilienceContext(this HttpRequestMessage requestMessage, ResilienceContext? resilienceContext)
Resilience\HttpResiliencePipelineBuilderExtensions.cs (1)
37public static IHttpResiliencePipelineBuilder SelectPipelineBy(this IHttpResiliencePipelineBuilder builder, Func<IServiceProvider, Func<HttpRequestMessage, string>> selectorFactory)
Resilience\HttpStandardResiliencePipelineBuilderExtensions.cs (1)
98public static IHttpStandardResiliencePipelineBuilder SelectPipelineBy(this IHttpStandardResiliencePipelineBuilder builder, Func<IServiceProvider, Func<HttpRequestMessage, string>> selectorFactory)
Resilience\Internal\ByAuthorityPipelineKeyProvider.cs (1)
14public string GetPipelineKey(HttpRequestMessage requestMessage)
Resilience\Internal\PipelineKeyOptions.cs (1)
14public Func<HttpRequestMessage, string>? KeyProvider { get; set; }
Resilience\Internal\PipelineKeyProviderHelper.cs (3)
21public static void SelectPipelineBy(IServiceCollection services, string pipelineName, Func<IServiceProvider, Func<HttpRequestMessage, string>> selectorFactory) 26public static Func<HttpRequestMessage, string>? GetPipelineKeyProvider(this IServiceProvider provider, string pipelineName) 31private static void UsePipelineKeyProvider(IServiceCollection services, string pipelineName, Func<IServiceProvider, Func<HttpRequestMessage, string>> factory)
Resilience\ResilienceHandler.cs (10)
20private readonly Func<HttpRequestMessage, ResiliencePipeline<HttpResponseMessage>> _pipelineProvider; 27public ResilienceHandler(Func<HttpRequestMessage, ResiliencePipeline<HttpResponseMessage>> pipelineProvider) 50protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 65HttpRequestMessage request = GetRequestMessage(context, state.request); 141private static ResilienceContext GetOrSetResilienceContext(HttpRequestMessage request, CancellationToken cancellationToken, out bool created) 155private static void TrySetRequestMetadata(ResilienceContext context, HttpRequestMessage request) 163private static HttpRequestMessage GetRequestMessage(ResilienceContext context, HttpRequestMessage request) 166private static void RestoreResilienceContext(ResilienceContext context, HttpRequestMessage request, bool created) 180private Task<HttpResponseMessage> SendCoreAsync(HttpRequestMessage requestMessage, CancellationToken cancellationToken)
Resilience\ResilienceHttpClientBuilderExtensions.Resilience.cs (3)
101private static Func<HttpRequestMessage, ResiliencePipeline<HttpResponseMessage>> CreatePipelineSelector(IServiceProvider serviceProvider, string pipelineName) 123private static void TouchPipelineKey(Func<HttpRequestMessage, string> provider) 128using var request = new HttpRequestMessage(HttpMethod.Get, "https://localhost:123");
Routing\Internal\RoutingResilienceStrategy.cs (1)
30HttpRequestMessage? request = context.GetRequestMessage();
Microsoft.Extensions.Http.Resilience.PerformanceTests (8)
EmptyHandler.cs (1)
12protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
HedgingBenchmark.cs (1)
16private static HttpRequestMessage Request => new(HttpMethod.Post, _uri);
HttpResilienceBenchmark.cs (2)
23private static HttpRequestMessage Request 27var request = new HttpRequestMessage(HttpMethod.Post, _uri);
NoRemoteCallHandler.cs (2)
26protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 33protected override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken)
RetryBenchmark.cs (1)
25private static HttpRequestMessage Request => new(HttpMethod.Post, _uri);
StandardResilienceBenchmark.cs (1)
25private static HttpRequestMessage Request => new(HttpMethod.Post, _uri);
Microsoft.Extensions.Http.Resilience.Tests (53)
Hedging\HedgingTests.cs (11)
83using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 123using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 142using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 164using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 189using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 213using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 237using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 265using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 289using var request = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 309HttpClient client, HttpRequestMessage request, bool asynchronous, CancellationToken cancellationToken = default) 348private Task<HttpResponseMessage> InnerHandlerFunction(HttpRequestMessage request, CancellationToken cancellationToken)
Hedging\StandardHedgingTests.cs (8)
121using var request = new HttpRequestMessage(); 223using var request = new HttpRequestMessage(HttpMethod.Get, "https://key:80/discarded"); 240var requests = new List<HttpRequestMessage>(); 256using var firstRequest = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 263using var secondRequest = new HttpRequestMessage(HttpMethod.Get, "https://to-be-replaced:1234/some-path?query"); 291using var request = new HttpRequestMessage(HttpMethod.Get, "https://some-endpoint:1234/some-path?query"); 338using var request = new HttpRequestMessage(HttpMethod.Get, $"https://{FailingEndpoint}:3000"); 352protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Helpers\TestHandlerStub.cs (3)
14private readonly Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> _handlerFunc; 21public TestHandlerStub(Func<HttpRequestMessage, CancellationToken, Task<HttpResponseMessage>> handlerFunc) 26protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Internal\RequestMessageSnapshotStrategyTests.cs (1)
22using var request = new HttpRequestMessage();
Polly\HttpRetryStrategyOptionsExtensionsTests.cs (4)
49using var request = new HttpRequestMessage { Method = new HttpMethod(httpMethod) }; 61using var request = new HttpRequestMessage { Method = HttpMethod.Get }; 73using var request = new HttpRequestMessage { Method = HttpMethod.Post }; 108using var request = new HttpRequestMessage { Method = new HttpMethod(httpMethod) };
Resilience\HttpClientBuilderExtensionsTests.BySelector.cs (3)
38using var request = new HttpRequestMessage(HttpMethod.Head, url); 53using var request = new HttpRequestMessage(); 84using var request = new HttpRequestMessage(HttpMethod.Head, url);
Resilience\HttpClientBuilderExtensionsTests.Standard.cs (2)
41using var request = new HttpRequestMessage(HttpMethod.Get, url); 228var requests = new List<HttpRequestMessage>();
Resilience\HttpResilienceContextExtensionsTests.cs (5)
42using var request = new HttpRequestMessage(); 52using var request = new HttpRequestMessage(); 63Assert.True(context.Properties.TryGetValue(ResilienceKeys.RequestMessage, out HttpRequestMessage? request)); 71using var request = new HttpRequestMessage(); 74Assert.True(context.Properties.TryGetValue(ResilienceKeys.RequestMessage, out HttpRequestMessage? actualRequest));
Resilience\RequestMessageSnapshotTests.cs (9)
21var initialRequest = new HttpRequestMessage 36using var request = CreateRequest(); 38var cloned = snapshot.CreateRequestMessage(); 45using var request = CreateRequest(); 49var cloned = snapshot.CreateRequestMessage(); 53private static HttpRequestMessage CreateRequest() 55var initialRequest = new HttpRequestMessage 76private static void AssertClonedMessage(HttpRequestMessage initialRequest, HttpRequestMessage cloned)
Resilience\ResilienceHandlerTest.cs (6)
30using var request = new HttpRequestMessage(); 68using var request = new HttpRequestMessage(); 100using var request = new HttpRequestMessage(); 131using var request = new HttpRequestMessage(); 155using var request = new HttpRequestMessage(); 164HttpRequestMessage request,
Routing\RoutingResilienceStrategyTests.cs (1)
37using var request = new HttpRequestMessage();
Microsoft.Extensions.ML (1)
ModelLoaders\UriModelLoader.cs (1)
109var headRequest = new HttpRequestMessage(HttpMethod.Head, uri);
Microsoft.Extensions.ServiceDiscovery (4)
Http\HttpServiceEndpointResolver.cs (2)
31/// <exception cref="InvalidOperationException">The request had no <see cref="HttpRequestMessage.RequestUri"/> set or a suitable endpoint could not be found.</exception> 32public async ValueTask<ServiceEndpoint> GetEndpointAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Http\ResolvingHttpClientHandler.cs (1)
17protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Http\ResolvingHttpDelegatingHandler.cs (1)
41protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
Microsoft.Extensions.ServiceDiscovery.Tests (1)
ServiceEndpointResolverTests.cs (1)
200var httpRequest = new HttpRequestMessage(HttpMethod.Get, "http://basket");
Microsoft.NET.Build.Containers (13)
AmazonECRMessageHandler.cs (1)
20protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
AuthHandshakeMessageHandler.cs (3)
483HttpRequestMessage postMessage = new(HttpMethod.Post, realmUri) 529var message = new HttpRequestMessage(HttpMethod.Get, builder.ToString()); 572protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
FallbackToHttpMessageHandler.cs (2)
30protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 88private static void FallbackToHttp(string registryName, HttpRequestMessage request)
Registry\DefaultBlobOperations.cs (1)
65using HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, new Uri(_baseUri, $"/v2/{repositoryName}/blobs/{digest}")).AcceptManifestFormats();
Registry\DefaultBlobUploadOperations.cs (3)
94private HttpRequestMessage GetPatchHttpRequest(Uri uploadUri, HttpContent httpContent) 97HttpRequestMessage patchMessage = new(HttpMethod.Patch, finalUri) 109HttpRequestMessage patchMessage = GetPatchHttpRequest(uploadUri, content);
Registry\DefaultManifestOperations.cs (1)
30using HttpRequestMessage request = new HttpRequestMessage(HttpMethod.Get, new Uri(_baseUri, $"/v2/{repositoryName}/manifests/{reference}")).AcceptManifestFormats();
Registry\HttpExtensions.cs (2)
21internal static HttpRequestMessage AcceptManifestFormats(this HttpRequestMessage request)
Microsoft.NET.Sdk.Publish.Tasks (2)
Kudu\KuduVfsDeploy.cs (1)
66using (var req = new HttpRequestMessage(HttpMethod.Put, apiUrl))
Kudu\KuduZipDeploy.cs (1)
57using (var req = new HttpRequestMessage(HttpMethod.Put, DestinationUrl))
netstandard (1)
netstandard.cs (1)
1131[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Net.Http.HttpRequestMessage))]
NuGet.Protocol (43)
HttpSource\HttpRequestMessageExtensions.cs (7)
21/// Clones an <see cref="HttpRequestMessage" /> request. 23internal static HttpRequestMessage Clone(this HttpRequestMessage request) 25var clone = new HttpRequestMessage(request.Method, request.RequestUri) 93public static HttpRequestMessageConfiguration GetOrCreateConfiguration(this HttpRequestMessage request) 112public static void SetConfiguration(this HttpRequestMessage request, HttpRequestMessageConfiguration configuration) 131private static T? GetProperty<T>(this HttpRequestMessage request, string key)
HttpSource\HttpRequestMessageFactory.cs (15)
11/// Factory class containing methods facilitating creation of <see cref="HttpRequestMessage"/> 18/// Creates an instance of <see cref="HttpRequestMessage"/>. 23/// <returns>Instance of <see cref="HttpRequestMessage"/></returns> 24public static HttpRequestMessage Create(HttpMethod method, string requestUri, ILogger log) 35/// Creates an instance of <see cref="HttpRequestMessage"/>. 40/// <returns>Instance of <see cref="HttpRequestMessage"/></returns> 41public static HttpRequestMessage Create(HttpMethod method, Uri requestUri, ILogger log) 52/// Creates an instance of <see cref="HttpRequestMessage"/>. 57/// <returns>Instance of <see cref="HttpRequestMessage"/></returns> 58public static HttpRequestMessage Create( 73var request = new HttpRequestMessage(method, requestUri); 80/// Creates an instance of <see cref="HttpRequestMessage"/>. 85/// <returns>Instance of <see cref="HttpRequestMessage"/></returns> 86public static HttpRequestMessage Create( 101var request = new HttpRequestMessage(method, requestUri);
HttpSource\HttpRetryHandler.cs (3)
37/// This method accepts a factory to create instances of the <see cref="HttpRequestMessage"/> because 53/// This method accepts a factory to create instances of the <see cref="HttpRequestMessage"/> because 97using (var requestMessage = request.RequestFactory())
HttpSource\HttpRetryHandlerRequest.cs (2)
19public HttpRetryHandlerRequest(HttpClient httpClient, Func<HttpRequestMessage> requestFactory) 46public Func<HttpRequestMessage> RequestFactory { get; }
HttpSource\HttpSource.cs (3)
118Func<HttpRequestMessage> requestFactory = () => 120var requestMessage = HttpRequestMessageFactory.Create(HttpMethod.Get, request.Uri, log); 327Func<HttpRequestMessage> requestFactory,
HttpSource\HttpSourceAuthenticationHandler.cs (2)
68protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 93using (var req = request.Clone())
HttpSource\HttpSourceCachedRequest.cs (1)
58/// The header values to apply when building the <see cref="HttpRequestMessage"/>.
HttpSource\HttpSourceRequest.cs (2)
27public HttpSourceRequest(Func<HttpRequestMessage> requestFactory) 40public Func<HttpRequestMessage> RequestFactory { get; }
HttpSource\ProxyAuthenticationHandler.cs (2)
57protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, 77using (var req = request.Clone())
HttpSource\ServerWarningLogHandler.cs (1)
19protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
LegacyFeed\V2FeedParser.cs (1)
587var request = HttpRequestMessageFactory.Create(HttpMethod.Get, uri, log);
Resources\PackageUpdateResource.cs (4)
641private HttpRequestMessage CreateRequest( 649var request = HttpRequestMessageFactory.Create( 768var request = HttpRequestMessageFactory.Create( 929var request = HttpRequestMessageFactory.Create(
System.Net.Http (190)
System\Net\Http\DelegatingHandler.cs (2)
45protected internal override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 53protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
System\Net\Http\DiagnosticsHandler.cs (25)
58private static Activity? StartActivity(HttpRequestMessage request) 76internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 90private async ValueTask<HttpResponseMessage> SendAsyncCore(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 264[DynamicDependency(nameof(HttpRequestMessage.RequestUri), typeof(HttpRequestMessage))] 265[DynamicDependency(nameof(HttpRequestMessage.Method), typeof(HttpRequestMessage))] 268internal ActivityStartData(HttpRequestMessage request) 273public HttpRequestMessage Request { get; } 280internal ActivityStopData(HttpResponseMessage? response, HttpRequestMessage request, TaskStatus requestTaskStatus) 288public HttpRequestMessage Request { get; } 297[DynamicDependency(nameof(HttpRequestMessage.RequestUri), typeof(HttpRequestMessage))] 298[DynamicDependency(nameof(HttpRequestMessage.Method), typeof(HttpRequestMessage))] 303internal ExceptionData(Exception exception, HttpRequestMessage request) 310public HttpRequestMessage Request { get; } 318[DynamicDependency(nameof(HttpRequestMessage.RequestUri), typeof(HttpRequestMessage))] 319[DynamicDependency(nameof(HttpRequestMessage.Method), typeof(HttpRequestMessage))] 322internal RequestData(HttpRequestMessage request, Guid loggingRequestId, long timestamp) 329public HttpRequestMessage Request { get; } 355private void InjectHeaders(Activity currentActivity, HttpRequestMessage request) 359if (carrier is HttpRequestMessage request && key is not null)
System\Net\Http\DiagnosticsHelper.cs (1)
42public static string GetServerAddress(HttpRequestMessage request, IWebProxy? proxy)
System\Net\Http\HttpClient.cs (30)
29private Version _defaultRequestVersion = HttpRequestMessage.DefaultRequestVersion; 30private HttpVersionPolicy _defaultVersionPolicy = HttpRequestMessage.DefaultVersionPolicy; 64/// Gets or sets the default value of <see cref="HttpRequestMessage.VersionPolicy" /> for implicitly created requests in convenience methods, 68/// Note that this property has no effect on any of the <see cref="Send(HttpRequestMessage)" /> and <see cref="SendAsync(HttpRequestMessage)" /> overloads 69/// since they accept fully initialized <see cref="HttpRequestMessage" />. 170HttpRequestMessage request = CreateRequestMessage(HttpMethod.Get, requestUri); 178private async Task<string> GetStringAsyncCore(HttpRequestMessage request, CancellationToken cancellationToken) 244HttpRequestMessage request = CreateRequestMessage(HttpMethod.Get, requestUri); 252private async Task<byte[]> GetByteArrayAsyncCore(HttpRequestMessage request, CancellationToken cancellationToken) 321HttpRequestMessage request = CreateRequestMessage(HttpMethod.Get, requestUri); 329private async Task<Stream> GetStreamAsyncCore(HttpRequestMessage request, CancellationToken cancellationToken) 395HttpRequestMessage request = CreateRequestMessage(HttpMethod.Post, requestUri); 411HttpRequestMessage request = CreateRequestMessage(HttpMethod.Put, requestUri); 427HttpRequestMessage request = CreateRequestMessage(HttpMethod.Patch, requestUri); 452public HttpResponseMessage Send(HttpRequestMessage request) => 459public HttpResponseMessage Send(HttpRequestMessage request, HttpCompletionOption completionOption) => 466public override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) => 473public HttpResponseMessage Send(HttpRequestMessage request, HttpCompletionOption completionOption, CancellationToken cancellationToken) 512public Task<HttpResponseMessage> SendAsync(HttpRequestMessage request) => 515public override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) => 518public Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, HttpCompletionOption completionOption) => 521public Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, HttpCompletionOption completionOption, CancellationToken cancellationToken) 530HttpRequestMessage request, HttpCompletionOption completionOption, 568private void CheckRequestBeforeSend(HttpRequestMessage request) 589private static bool ShouldBufferResponse(HttpCompletionOption completionOption, HttpRequestMessage request) => 643private static bool StartSend(HttpRequestMessage request) 749private static void CheckRequestMessage(HttpRequestMessage request) 757private void PrepareRequestMessage(HttpRequestMessage request) 829private HttpRequestMessage CreateRequestMessage(HttpMethod method, Uri? uri) =>
System\Net\Http\HttpClientHandler.cs (4)
309public Func<HttpRequestMessage, X509Certificate2?, X509Chain?, SslPolicyErrors, bool>? ServerCertificateCustomValidationCallback 358protected internal override HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 368protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 376public static Func<HttpRequestMessage, X509Certificate2?, X509Chain?, SslPolicyErrors, bool> DangerousAcceptAnyServerCertificateValidator =>
System\Net\Http\HttpMessageHandler.cs (2)
22protected internal virtual HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 27protected internal abstract Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken);
System\Net\Http\HttpMessageInvoker.cs (4)
35public virtual HttpResponseMessage Send(HttpRequestMessage request, CancellationToken cancellationToken) 67public virtual Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 80static async Task<HttpResponseMessage> SendAsyncWithTelemetry(HttpMessageHandler handler, HttpRequestMessage request, CancellationToken cancellationToken) 102private static bool ShouldSendWithTelemetry(HttpRequestMessage request) =>
System\Net\Http\HttpResponseMessage.cs (2)
20private HttpRequestMessage? _requestMessage; 130public HttpRequestMessage? RequestMessage
System\Net\Http\HttpTelemetry.cs (1)
48public void RequestStart(HttpRequestMessage request)
System\Net\Http\HttpVersionPolicy.cs (2)
16/// as well as a secure connection is being requested, the result is the <see cref="HttpRequestMessage.Version" />. 29/// Otherwise, downgrades to the <see cref="HttpRequestMessage.Version" />.
System\Net\Http\MessageProcessingHandler.cs (6)
25protected abstract HttpRequestMessage ProcessRequest(HttpRequestMessage request, 30protected internal sealed override HttpResponseMessage Send(HttpRequestMessage request, 36HttpRequestMessage newRequestMessage = ProcessRequest(request, cancellationToken); 42protected internal sealed override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, 55HttpRequestMessage newRequestMessage = ProcessRequest(request, cancellationToken);
System\Net\Http\Metrics\HttpMetricsEnrichmentContext.cs (9)
14/// Enrichment is done on per-request basis by callbacks registered with <see cref="AddCallback(HttpRequestMessage, Action{HttpMetricsEnrichmentContext})"/>. 25private HttpRequestMessage? _request; 33/// Gets the <see cref="HttpRequestMessage"/> that has been sent. 38public HttpRequestMessage Request => _request!; 41/// Gets the <see cref="HttpRequestMessage"/> received from the server or <see langword="null"/> if the request failed. 69/// <param name="request">The <see cref="HttpRequestMessage"/> to apply enrichment to.</param> 71public static void AddCallback(HttpRequestMessage request, Action<HttpMetricsEnrichmentContext> callback) 88internal static List<Action<HttpMetricsEnrichmentContext>>? GetEnrichmentCallbacksForRequest(HttpRequestMessage request) 101HttpRequestMessage request,
System\Net\Http\Metrics\MetricsHandler.cs (5)
41internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 55private async ValueTask<HttpResponseMessage> SendAsyncWithMetrics(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 90private (long StartTimestamp, bool RecordCurrentRequests) RequestStart(HttpRequestMessage request) 104private void RequestStop(HttpRequestMessage request, HttpResponseMessage? response, Exception? exception, long startTimestamp, bool recordCurrentRequests) 142private TagList InitializeCommonTags(HttpRequestMessage request)
System\Net\Http\SocketsHttpHandler\AuthenticationHelper.cs (7)
164private static void SetRequestAuthenticationHeaderValue(HttpRequestMessage request, AuthenticationHeaderValue headerValue, bool isProxyAuth) 176private static void SetBasicAuthToken(HttpRequestMessage request, NetworkCredential credential, bool isProxyAuth) 187private static async ValueTask<bool> TrySetDigestAuthToken(HttpRequestMessage request, NetworkCredential credential, DigestResponse digestResponse, bool isProxyAuth) 206private static ValueTask<HttpResponseMessage> InnerSendAsync(HttpRequestMessage request, bool async, bool isProxyAuth, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 213private static async ValueTask<HttpResponseMessage> SendWithAuthAsync(HttpRequestMessage request, Uri authUri, bool async, ICredentials credentials, bool preAuthenticate, bool isProxyAuth, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 375public static ValueTask<HttpResponseMessage> SendWithProxyAuthAsync(HttpRequestMessage request, Uri proxyUri, bool async, ICredentials proxyCredentials, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 380public static ValueTask<HttpResponseMessage> SendWithRequestAuthAsync(HttpRequestMessage request, bool async, ICredentials credentials, bool preAuthenticate, HttpConnectionPool pool, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\AuthenticationHelper.Digest.cs (1)
39public static async Task<string?> GetDigestTokenForCredential(NetworkCredential credential, HttpRequestMessage request, DigestResponse digestResponse)
System\Net\Http\SocketsHttpHandler\AuthenticationHelper.NtAuth.cs (4)
21private static Task<HttpResponseMessage> InnerSendAsync(HttpRequestMessage request, bool async, bool isProxyAuth, HttpConnectionPool pool, HttpConnection connection, CancellationToken cancellationToken) 46private static async Task<HttpResponseMessage> SendWithNtAuthAsync(HttpRequestMessage request, Uri authUri, bool async, ICredentials credentials, TokenImpersonationLevel impersonationLevel, bool isProxyAuth, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken) 205public static Task<HttpResponseMessage> SendWithNtProxyAuthAsync(HttpRequestMessage request, Uri proxyUri, bool async, ICredentials proxyCredentials, TokenImpersonationLevel impersonationLevel, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken) 210public static Task<HttpResponseMessage> SendWithNtConnectionAuthAsync(HttpRequestMessage request, bool async, ICredentials credentials, TokenImpersonationLevel impersonationLevel, HttpConnection connection, HttpConnectionPool connectionPool, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectHelper.cs (8)
25public readonly Func<HttpRequestMessage, X509Certificate2?, X509Chain?, SslPolicyErrors, bool> FromHttpClientHandler; 28public CertificateCallbackMapper(Func<HttpRequestMessage, X509Certificate2?, X509Chain?, SslPolicyErrors, bool> fromHttpClientHandler) 32FromHttpClientHandler((HttpRequestMessage)sender, certificate as X509Certificate2, chain, sslPolicyErrors); 36private static SslClientAuthenticationOptions SetUpRemoteCertificateValidationCallback(SslClientAuthenticationOptions sslOptions, HttpRequestMessage request) 44Func<HttpRequestMessage, X509Certificate2?, X509Chain?, SslPolicyErrors, bool> localFromHttpClientHandler = mapper.FromHttpClientHandler; 45HttpRequestMessage localRequest = request; 58public static async ValueTask<SslStream> EstablishSslConnectionAsync(SslClientAuthenticationOptions sslOptions, HttpRequestMessage request, bool async, Stream stream, CancellationToken cancellationToken) 115public static async ValueTask<QuicConnection> ConnectQuicAsync(HttpRequestMessage request, DnsEndPoint endPoint, TimeSpan idleTimeout, SslClientAuthenticationOptions clientAuthenticationOptions, Action<QuicConnection, QuicStreamCapacityChangedArgs> streamCapacityCallback, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (15)
346public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 365public ValueTask<HttpResponseMessage> SendWithProxyAuthAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 375private Task<HttpResponseMessage> SendWithNtConnectionAuthAsync(HttpConnection connection, HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 385public Task<HttpResponseMessage> SendWithNtProxyAuthAsync(HttpConnection connection, HttpRequestMessage request, bool async, CancellationToken cancellationToken) 395public async ValueTask<HttpResponseMessage> SendWithVersionDetectionAndRetryAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 563private async ValueTask<(Stream, TransportContext?, Activity?, IPEndPoint?)> ConnectAsync(HttpRequestMessage request, bool async, bool isForHttp2, CancellationToken cancellationToken) 655private async ValueTask<Stream> ConnectToTcpHostAsync(string host, int port, HttpRequestMessage initialRequest, bool async, CancellationToken cancellationToken) 716private SslClientAuthenticationOptions GetSslOptionsForRequest(HttpRequestMessage request, bool isForHttp2) 735private async ValueTask<Stream> ApplyPlaintextFilterAsync(bool async, Stream stream, Version httpVersion, HttpRequestMessage request, CancellationToken cancellationToken) 781HttpRequestMessage tunnelRequest = new HttpRequestMessage(HttpMethod.Connect, _proxyUri); 808private async ValueTask<Stream> EstablishSocksTunnel(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 864private static void ThrowGetVersionException(HttpRequestMessage request, int desiredVersion, Exception? inner = null) 880/// <see cref="HttpRequestMessage.Version"/> is less than 2.0 or if its 881/// <see cref="HttpRequestMessage.VersionPolicy"/> is <see cref="HttpVersionPolicy.RequestVersionOrLower"/>. 883internal static bool CanFallBackToHttp11(HttpRequestMessage request) =>
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http1.cs (3)
35private bool TryGetPooledHttp11Connection(HttpRequestMessage request, bool async, [NotNullWhen(true)] out HttpConnection? connection, [NotNullWhen(false)] out HttpConnectionWaiter<HttpConnection>? waiter) 294internal async ValueTask<HttpConnection> CreateHttp11ConnectionAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 300private async ValueTask<HttpConnection> ConstructHttp11ConnectionAsync(bool async, Stream stream, TransportContext? transportContext, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http2.cs (4)
65private bool TryGetPooledHttp2Connection(HttpRequestMessage request, [NotNullWhen(true)] out Http2Connection? connection, out HttpConnectionWaiter<Http2Connection?>? waiter) 247private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken) 295/// with <see cref="HttpRequestMessage.Version"/> >= 2.0) continue to use HTTP/2 as before. 302private async Task HandleHttp11Downgrade(HttpRequestMessage request, Stream stream, TransportContext? transportContext, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (3)
63private async ValueTask<HttpResponseMessage?> TrySendUsingHttp3Async(HttpRequestMessage request, CancellationToken cancellationToken) 131private bool TryGetPooledHttp3Connection(HttpRequestMessage request, [NotNullWhen(true)] out Http3Connection? connection, [NotNullWhen(false)] out HttpConnectionWaiter<Http3Connection?>? waiter, out bool streamAvailable) 610private bool TryGetHttp3Authority(HttpRequestMessage request, [NotNullWhen(true)] out HttpAuthority? authority, out Exception? reasonException)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionWaiter.cs (2)
20public ValueTask<T> WaitForConnectionAsync(HttpRequestMessage request, HttpConnectionPool pool, bool async, CancellationToken requestCancellationToken) 30private async ValueTask<T> WaitForConnectionWithTelemetryAsync(HttpRequestMessage request, HttpConnectionPool pool, bool async, CancellationToken requestCancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectionPool\RequestQueue.cs (3)
14public HttpRequestMessage Request; 114public HttpConnectionWaiter<T> EnqueueRequest(HttpRequestMessage request) 122public void EnqueueRequest(HttpRequestMessage request, HttpConnectionWaiter<T> waiter)
System\Net\Http\SocketsHttpHandler\DecompressionHandler.cs (1)
66internal override async ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (5)
1428private int WriteHeaderCollection(HttpRequestMessage request, HttpHeaders headers, ref ArrayBuffer headerBuffer) 1432HeaderEncodingSelector<HttpRequestMessage>? encodingSelector = _pool.Settings._requestHeaderEncodingSelector; 1500private void WriteHeaders(HttpRequestMessage request, ref ArrayBuffer headerBuffer) 1637private async ValueTask<Http2Stream> SendHeadersAsync(HttpRequestMessage request, CancellationToken cancellationToken, bool mustFlush) 2000public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (2)
34private readonly HttpRequestMessage _request; 92public Http2Stream(HttpRequestMessage request, Http2Connection connection)
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)
264public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, WaitForHttp3ConnectionActivity waitForConnectionActivity, bool streamAvailable, CancellationToken cancellationToken) 962public void Stop(HttpRequestMessage request, HttpConnectionPool pool, Exception? exception)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (4)
25private readonly HttpRequestMessage _request; 70public Http3RequestStream(HttpRequestMessage request, Http3Connection connection, QuicStream stream) 660private void BufferHeaders(HttpRequestMessage request) 773HeaderEncodingSelector<HttpRequestMessage>? encodingSelector = _connection.Pool.Settings._requestHeaderEncodingSelector;
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (7)
48private HttpRequestMessage? _currentRequest; 309private void WriteHeaders(HttpRequestMessage request) 421HeaderEncodingSelector<HttpRequestMessage>? encodingSelector = _pool.Settings._requestHeaderEncodingSelector; 532public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 944private HttpContentWriteStream CreateRequestContentStream(HttpRequestMessage request) 970private async ValueTask SendRequestContentAsync(HttpRequestMessage request, HttpContentWriteStream stream, bool async, CancellationToken cancellationToken) 997HttpRequestMessage request, Task<bool> allowExpect100ToContinueTask,
System\Net\Http\SocketsHttpHandler\HttpConnectionHandler.cs (1)
20internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\HttpConnectionPoolManager.cs (6)
230private HttpConnectionKey GetConnectionKey(HttpRequestMessage request, Uri? proxyUri, bool isProxyConnect) 307private static string? GetTelemetryServerAddress(HttpRequestMessage request, HttpConnectionKey key) 332public ValueTask<HttpResponseMessage> SendAsyncCore(HttpRequestMessage request, Uri? proxyUri, bool async, bool doRequestAuth, bool isProxyConnect, CancellationToken cancellationToken) 371public ValueTask<HttpResponseMessage> SendProxyConnectAsync(HttpRequestMessage request, Uri proxyUri, bool async, CancellationToken cancellationToken) 376public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 429private async ValueTask<HttpResponseMessage> SendAsyncMultiProxy(HttpRequestMessage request, bool async, bool doRequestAuth, MultiProxy multiProxy, Uri? firstProxy, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\HttpConnectionSettings.cs (2)
53internal HeaderEncodingSelector<HttpRequestMessage>? _requestHeaderEncodingSelector; 54internal HeaderEncodingSelector<HttpRequestMessage>? _responseHeaderEncodingSelector;
System\Net\Http\SocketsHttpHandler\HttpMessageHandlerStage.cs (3)
11protected internal sealed override HttpResponseMessage Send(HttpRequestMessage request, 20protected internal sealed override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) => 23internal abstract ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken);
System\Net\Http\SocketsHttpHandler\Metrics\SocketsHttpHandlerMetrics.cs (1)
32public void RequestLeftQueue(HttpRequestMessage request, HttpConnectionPool pool, TimeSpan duration, int versionMajor)
System\Net\Http\SocketsHttpHandler\RedirectHandler.cs (1)
27internal override async ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\SocketsHttpConnectionContext.cs (3)
12private readonly HttpRequestMessage _initialRequestMessage; 14internal SocketsHttpConnectionContext(DnsEndPoint dnsEndPoint, HttpRequestMessage initialRequestMessage) 28public HttpRequestMessage InitialRequestMessage => _initialRequestMessage;
System\Net\Http\SocketsHttpHandler\SocketsHttpHandler.cs (6)
439public HeaderEncodingSelector<HttpRequestMessage>? RequestHeaderEncodingSelector 453public HeaderEncodingSelector<HttpRequestMessage>? ResponseHeaderEncodingSelector 574protected internal override HttpResponseMessage Send(HttpRequestMessage request, 605protected internal override Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 629async Task<HttpResponseMessage> CreateHandlerAndSendAsync(HttpRequestMessage request, CancellationToken cancellationToken) 637private static Exception? ValidateAndNormalizeRequest(HttpRequestMessage request)
System\Net\Http\SocketsHttpHandler\SocketsHttpPlaintextStreamFilterContext.cs (3)
15private readonly HttpRequestMessage _initialRequestMessage; 17internal SocketsHttpPlaintextStreamFilterContext(Stream plaintextStream, Version negotiatedHttpVersion, HttpRequestMessage initialRequestMessage) 37public HttpRequestMessage InitialRequestMessage => _initialRequestMessage;
System.Net.Http.WinHttpHandler (10)
System\Net\Http\CachedCertificateValue.cs (1)
25public CachedCertificateKey(IPAddress address, HttpRequestMessage message)
System\Net\Http\WinHttpCookieContainerAdapter.cs (1)
18HttpRequestMessage? request = state.RequestMessage;
System\Net\Http\WinHttpHandler.cs (5)
68HttpRequestMessage, 240HttpRequestMessage, 592HttpRequestMessage request, 658private static WinHttpChunkMode GetChunkedModeForSend(HttpRequestMessage requestMessage) 715HttpRequestMessage requestMessage,
System\Net\Http\WinHttpRequestState.cs (2)
100public HttpRequestMessage? RequestMessage { get; set; } 128public Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool>? ServerCertificateValidationCallback { get; set; }
System\Net\Http\WinHttpResponseParser.cs (1)
20HttpRequestMessage? request = state.RequestMessage;
System.Net.Requests (2)
System\Net\HttpWebRequest.cs (2)
49private HttpRequestMessage? _sendRequestMessage; 1311private void AddCacheControlHeaders(HttpRequestMessage request)
System.ServiceModel.Http (21)
System\ServiceModel\Channels\HttpChannelFactory.cs (9)
686internal HttpRequestMessage GetHttpRequestMessage(Uri via) 690var requestMessage = new HttpRequestMessage(HttpMethod.Post, httpRequestUri); 948internal HttpRequestMessage GetHttpRequestMessage(Uri via) 953internal virtual void OnHttpRequestCompleted(HttpRequestMessage request) 976private HttpRequestMessage _httpRequestMessage; 1006HttpRequestMessage httpRequestMessage = _channel.GetHttpRequestMessage(_via); 1111var httpRequestMessageSnapshot = _httpRequestMessage; 1326private void TryCompleteHttpRequest(HttpRequestMessage request) 1350HttpRequestMessage headHttpRequestMessage = new HttpRequestMessage()
System\ServiceModel\Channels\HttpChannelHelpers.cs (2)
103public static HttpResponseMessage ProcessGetResponseWebException(HttpRequestException requestException, HttpRequestMessage request, HttpAbortReason abortReason) 117public static Exception ConvertHttpRequestException(HttpRequestException exception, HttpRequestMessage request, HttpAbortReason abortReason)
System\ServiceModel\Channels\HttpResponseMessageHelper.cs (1)
22private readonly HttpRequestMessage _httpRequestMessage;
System\ServiceModel\Channels\HttpsChannelFactory.cs (3)
23private Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> _remoteCertificateValidationCallback; 212private bool RemoteCertificateValidationCallback(HttpRequestMessage sender, X509Certificate2 certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors) 387internal override void OnHttpRequestCompleted(HttpRequestMessage request)
System\ServiceModel\Channels\HttpTransportSecurityHelpers.cs (6)
68bool identityValidator(HttpRequestMessage requestMessage, X509Certificate2 cert, X509Chain chain, SslPolicyErrors policyErrors) 87public static void SetServerCertificateValidationCallback(HttpClientHandler handler, Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> validator) 93private static Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> ChainValidator( 94Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> previousValidator, 95Func<HttpRequestMessage, X509Certificate2, X509Chain, SslPolicyErrors, bool> validator) 102bool chained(HttpRequestMessage request, X509Certificate2 certificate, X509Chain chain, SslPolicyErrors sslPolicyErrors)