[Release/6.0-rc2] Fix and test HttpSys delegation (#36698)

Tratcher · web-flow · commit a43284c9cf76 · 2021-09-18T14:11:32.000-07:00
* Out of proc delegation tests
* Troubleshoot IsFeatureSupported
* Fix test
* Fix formatting
* Seperate tests
* Cleanup
* Fix SLN
diff --git a/AspNetCore.sln b/AspNetCore.sln
@@ -1656,6 +1656,10 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Microsoft.AspNetCore.App.Co
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Microsoft.AspNetCore.App.Analyzers.Test", "src\Framework\AspNetCoreAnalyzers\test\Microsoft.AspNetCore.App.Analyzers.Test.csproj", "{B739B8B6-94F5-4F05-9497-28A7C6EBBC03}"
 EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Microsoft.AspNetCore.Server.HttpSys.NonHelixTests", "src\Servers\HttpSys\test\NonHelixTests\Microsoft.AspNetCore.Server.HttpSys.NonHelixTests.csproj", "{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DelegationSite", "src\Servers\HttpSys\test\testassets\DelegationSite\DelegationSite.csproj", "{14217994-9F24-4E14-87B6-58367ED0413B}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -7907,6 +7911,30 @@ Global
 		{B739B8B6-94F5-4F05-9497-28A7C6EBBC03}.Release|x64.Build.0 = Release|Any CPU
 		{B739B8B6-94F5-4F05-9497-28A7C6EBBC03}.Release|x86.ActiveCfg = Release|Any CPU
 		{B739B8B6-94F5-4F05-9497-28A7C6EBBC03}.Release|x86.Build.0 = Release|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Debug|x64.Build.0 = Debug|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Debug|x86.Build.0 = Debug|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Release|Any CPU.Build.0 = Release|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Release|x64.ActiveCfg = Release|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Release|x64.Build.0 = Release|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Release|x86.ActiveCfg = Release|Any CPU
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1}.Release|x86.Build.0 = Release|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Debug|x64.ActiveCfg = Debug|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Debug|x64.Build.0 = Debug|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Debug|x86.Build.0 = Debug|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Release|Any CPU.Build.0 = Release|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Release|x64.ActiveCfg = Release|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Release|x64.Build.0 = Release|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Release|x86.ActiveCfg = Release|Any CPU
+		{14217994-9F24-4E14-87B6-58367ED0413B}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -8727,6 +8755,8 @@ Global
 		{636B73F6-9EED-435D-9DA8-EB3C7FDFAB1C} = {23C56C5B-9D3F-4069-88C4-87ACCFE05DBC}
 		{78D9A5AF-6089-44F4-93AB-F7E96925E4FD} = {23C56C5B-9D3F-4069-88C4-87ACCFE05DBC}
 		{B739B8B6-94F5-4F05-9497-28A7C6EBBC03} = {12541C41-58FB-46F4-BA0F-0D56B5B45A18}
+		{37BDB2D5-EEEC-48C9-A7AD-5A2A73BD31B1} = {C3722C5D-E159-4AB3-AF60-769185B31B47}
+		{14217994-9F24-4E14-87B6-58367ED0413B} = {C3722C5D-E159-4AB3-AF60-769185B31B47}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {3E8720B3-DBDD-498C-B383-2CC32A054E8F}
diff --git a/src/Hosting/Server.IntegrationTesting/src/Deployers/SelfHostDeployer.cs b/src/Hosting/Server.IntegrationTesting/src/Deployers/SelfHostDeployer.cs
@@ -150,7 +150,7 @@ public override async Task<DeploymentResult> DeployAsync()
                 HostProcess.EnableRaisingEvents = true;
                 HostProcess.OutputDataReceived += (sender, dataArgs) =>
                 {
-                    if (string.Equals(dataArgs.Data, ApplicationStartedMessage))
+                    if (!string.IsNullOrEmpty(dataArgs.Data) && dataArgs.Data.Contains(ApplicationStartedMessage))
                     {
                         started.TrySetResult();
                     }
diff --git a/src/Servers/HttpSys/HttpSysServer.slnf b/src/Servers/HttpSys/HttpSysServer.slnf
@@ -31,7 +31,9 @@
       "src\\Servers\\HttpSys\\samples\\TestClient\\TestClient.csproj",
       "src\\Servers\\HttpSys\\src\\Microsoft.AspNetCore.Server.HttpSys.csproj",
       "src\\Servers\\HttpSys\\test\\FunctionalTests\\Microsoft.AspNetCore.Server.HttpSys.FunctionalTests.csproj",
+      "src\\Servers\\HttpSys\\test\\NonHelixTests\\Microsoft.AspNetCore.Server.HttpSys.NonHelixTests.csproj",
       "src\\Servers\\HttpSys\\test\\Tests\\Microsoft.AspNetCore.Server.HttpSys.Tests.csproj",
+      "src\\Servers\\HttpSys\\test\\testassets\\DelegationSite\\DelegationSite.csproj",
       "src\\Servers\\IIS\\IISIntegration\\src\\Microsoft.AspNetCore.Server.IISIntegration.csproj",
       "src\\Servers\\IIS\\IIS\\src\\Microsoft.AspNetCore.Server.IIS.csproj",
       "src\\Servers\\Kestrel\\Core\\src\\Microsoft.AspNetCore.Server.Kestrel.Core.csproj",
diff --git a/src/Servers/HttpSys/src/MessagePump.cs b/src/Servers/HttpSys/src/MessagePump.cs
@@ -55,7 +55,7 @@ public MessagePump(IOptions<HttpSysOptions> options, ILoggerFactory loggerFactor
             _serverAddresses = new ServerAddressesFeature();
             Features.Set<IServerAddressesFeature>(_serverAddresses);
 
-            if (HttpApi.IsFeatureSupported(HttpApiTypes.HTTP_FEATURE_ID.HttpFeatureDelegateEx))
+            if (HttpApi.SupportsDelegation)
             {
                 var delegationProperty = new ServerDelegationPropertyFeature(Listener.RequestQueue, _logger);
                 Features.Set<IServerDelegationFeature>(delegationProperty);
diff --git a/src/Servers/HttpSys/src/Microsoft.AspNetCore.Server.HttpSys.csproj b/src/Servers/HttpSys/src/Microsoft.AspNetCore.Server.HttpSys.csproj
@@ -28,4 +28,9 @@
     <Reference Include="Microsoft.Net.Http.Headers" />
   </ItemGroup>
 
+  <ItemGroup>
+    <InternalsVisibleTo Include="Microsoft.AspNetCore.Server.HttpSys.FunctionalTests" />
+    <InternalsVisibleTo Include="Microsoft.AspNetCore.Server.HttpSys.NonHelixTests" />
+  </ItemGroup>
+
 </Project>
diff --git a/src/Servers/HttpSys/src/NativeInterop/HttpApi.cs b/src/Servers/HttpSys/src/NativeInterop/HttpApi.cs
@@ -125,6 +125,7 @@ internal static HTTP_API_VERSION ApiVersion
         internal static bool SupportsTrailers { get; private set; }
         [MemberNotNullWhen(true, nameof(HttpSetRequestProperty))]
         internal static bool SupportsReset { get; private set; }
+        internal static bool SupportsDelegation { get; private set; }
 
         static HttpApi()
         {
@@ -136,18 +137,17 @@ private static void InitHttpApi(ushort majorVersion, ushort minorVersion)
             version.HttpApiMajorVersion = majorVersion;
             version.HttpApiMinorVersion = minorVersion;
 
-            var statusCode = HttpInitialize(version, (uint)HTTP_FLAGS.HTTP_INITIALIZE_SERVER, null);
+            var statusCode = HttpInitialize(version, (uint)(HTTP_FLAGS.HTTP_INITIALIZE_SERVER | HTTP_FLAGS.HTTP_INITIALIZE_CONFIG), null);
 
             supported = statusCode == UnsafeNclNativeMethods.ErrorCodes.ERROR_SUCCESS;
 
             if (supported)
             {
                 HttpApiModule = SafeLibraryHandle.Open(HTTPAPI);
                 HttpSetRequestProperty = HttpApiModule.GetProcAddress<HttpSetRequestPropertyInvoker>("HttpSetRequestProperty", throwIfNotFound: false);
-
                 SupportsReset = HttpSetRequestProperty != null;
-                // Trailers support was added in the same release as Reset, but there's no method we can export to check it directly.
-                SupportsTrailers = SupportsReset;
+                SupportsTrailers = IsFeatureSupported(HTTP_FEATURE_ID.HttpFeatureResponseTrailers);
+                SupportsDelegation = IsFeatureSupported(HTTP_FEATURE_ID.HttpFeatureDelegateEx);
             }
         }
 
@@ -160,7 +160,7 @@ internal static bool Supported
             }
         }
 
-        internal static bool IsFeatureSupported(HTTP_FEATURE_ID feature)
+        private static bool IsFeatureSupported(HTTP_FEATURE_ID feature)
         {
             try
             {
diff --git a/src/Servers/HttpSys/src/Properties/AssemblyInfo.cs b/src/Servers/HttpSys/src/Properties/AssemblyInfo.cs
diff --git a/src/Servers/HttpSys/src/StandardFeatureCollection.cs b/src/Servers/HttpSys/src/StandardFeatureCollection.cs
@@ -48,7 +48,7 @@ static StandardFeatureCollection()
                 _featureFuncLookup[typeof(ITlsHandshakeFeature)] = ctx => ctx.GetTlsHandshakeFeature();
             }
 
-            if (HttpApi.IsFeatureSupported(HttpApiTypes.HTTP_FEATURE_ID.HttpFeatureDelegateEx))
+            if (HttpApi.SupportsDelegation)
             {
                 _featureFuncLookup[typeof(IHttpSysRequestDelegationFeature)] = _identityFunc;
             }
diff --git a/src/Servers/HttpSys/test/FunctionalTests/DelegateSupportedConditionAttribute.cs b/src/Servers/HttpSys/test/FunctionalTests/DelegateSupportedConditionAttribute.cs
@@ -1,13 +1,7 @@
 // Licensed to the .NET Foundation under one or more agreements.
 // The .NET Foundation licenses this file to you under the MIT license.
 
-using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
-using System.Threading.Tasks;
 using Microsoft.AspNetCore.Testing;
-using static Microsoft.AspNetCore.HttpSys.Internal.HttpApiTypes;
 
 namespace Microsoft.AspNetCore.Server.HttpSys.FunctionalTests
 {
@@ -17,14 +11,8 @@ public class DelegateSupportedConditionAttribute : Attribute, ITestCondition
         private readonly bool _isSupported;
         public DelegateSupportedConditionAttribute(bool isSupported) => _isSupported = isSupported;
 
-        private readonly Lazy<bool> _isDelegateSupported = new Lazy<bool>(CanDelegate);
-        public bool IsMet => (_isDelegateSupported.Value == _isSupported);
+        public bool IsMet => HttpApi.SupportsDelegation == _isSupported;
 
         public string SkipReason => $"Http.Sys does {(_isSupported ? "not" : "")} support delegating requests";
-
-        private static bool CanDelegate()
-        {
-            return HttpApi.IsFeatureSupported(HTTP_FEATURE_ID.HttpFeatureDelegateEx);
-        }
     }
 }
diff --git a/src/Servers/HttpSys/test/FunctionalTests/DelegateTests.cs b/src/Servers/HttpSys/test/FunctionalTests/DelegateTests.cs
@@ -148,6 +148,9 @@ public async Task DelegateAfterRequestBodyReadShouldThrow()
         [DelegateSupportedCondition(false)]
         public async Task DelegationFeaturesAreNull()
         {
+            // Testing the DelegateSupportedCondition
+            Assert.True(Environment.OSVersion.Version < new Version(10, 0, 22000), "This should be supported on Win 11.");
+
             using var delegator = Utilities.CreateHttpServer(out var delegatorAddress, httpContext =>
             {
                 var delegateFeature = httpContext.Features.Get<IHttpSysRequestDelegationFeature>();
diff --git a/src/Servers/HttpSys/test/NonHelixTests/DelegateOutOfProcTests.cs b/src/Servers/HttpSys/test/NonHelixTests/DelegateOutOfProcTests.cs
@@ -0,0 +1,70 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using System.Net.Http;
+using Microsoft.AspNetCore.Server.IntegrationTesting;
+using Microsoft.AspNetCore.Testing;
+using Xunit.Abstractions;
+
+namespace Microsoft.AspNetCore.Server.HttpSys.NonHelixTests
+{
+    public class DelegateOutOfProcTests : LoggedTest
+    {
+        public DelegateOutOfProcTests(ITestOutputHelper output) : base(output) { }
+
+        [ConditionalFact]
+        [DelegateSupportedCondition(true)]
+        public async Task CanDelegateOutOfProcess()
+        {
+            using var _ = StartLog(out var loggerFactory);
+
+            var logger = loggerFactory.CreateLogger("CanDelegateOutOfProcess");
+
+            // https://github.com/dotnet/aspnetcore/issues/8247
+#pragma warning disable 0618
+            var applicationPath = Path.Combine(TestPathUtilities.GetSolutionRootDirectory("HttpSysServer"), "test", "testassets",
+                "DelegationSite");
+#pragma warning restore 0618
+
+            var deploymentParameters = new DeploymentParameters(
+                applicationPath,
+                ServerType.HttpSys,
+                RuntimeFlavor.CoreClr,
+                RuntimeArchitecture.x64)
+            {
+                EnvironmentName = "Testing",
+                TargetFramework = Tfm.Default,
+                ApplicationType = ApplicationType.Portable,
+                PublishApplicationBeforeDeployment = true,
+                StatusMessagesEnabled = true
+            };
+
+            var queueName = Guid.NewGuid().ToString();
+            deploymentParameters.EnvironmentVariables["queue"] = queueName;
+
+            using var deployer = new SelfHostDeployer(deploymentParameters, loggerFactory);
+            var deploymentResult = await deployer.DeployAsync().DefaultTimeout();
+
+            // Make sure the deployment really worked
+            var responseString = await deploymentResult.HttpClient.GetStringAsync("").DefaultTimeout();
+            Assert.Equal("Hello from delegatee", responseString);
+
+            DelegationRule destination = default;
+            using var delegator = Utilities.CreateHttpServer(out var delegatorAddress, httpContext =>
+            {
+                var delegateFeature = httpContext.Features.Get<IHttpSysRequestDelegationFeature>();
+                delegateFeature.DelegateRequest(destination);
+                return Task.CompletedTask;
+            });
+
+            var delegationProperty = delegator.Features.Get<IServerDelegationFeature>();
+            using (destination = delegationProperty.CreateDelegationRule(queueName, deploymentResult.ApplicationBaseUri))
+            {
+                // Send a request to the delegator that gets transfered to the delegatee in the other process.
+                using var client = new HttpClient();
+                responseString = await client.GetStringAsync(delegatorAddress).DefaultTimeout();
+                Assert.Equal("Hello from delegatee", responseString);
+            }
+        }
+    }
+}
diff --git a/src/Servers/HttpSys/test/NonHelixTests/DelegateSupportedConditionAttribute.cs b/src/Servers/HttpSys/test/NonHelixTests/DelegateSupportedConditionAttribute.cs
@@ -0,0 +1,18 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using Microsoft.AspNetCore.Testing;
+
+namespace Microsoft.AspNetCore.Server.HttpSys.NonHelixTests
+{
+    [AttributeUsage(AttributeTargets.Method, AllowMultiple = false)]
+    public class DelegateSupportedConditionAttribute : Attribute, ITestCondition
+    {
+        private readonly bool _isSupported;
+        public DelegateSupportedConditionAttribute(bool isSupported) => _isSupported = isSupported;
+
+        public bool IsMet => HttpApi.SupportsDelegation == _isSupported;
+
+        public string SkipReason => $"Http.Sys does {(_isSupported ? "not" : "")} support delegating requests";
+    }
+}
diff --git a/src/Servers/HttpSys/test/NonHelixTests/DummyApplication.cs b/src/Servers/HttpSys/test/NonHelixTests/DummyApplication.cs
@@ -0,0 +1,36 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using Microsoft.AspNetCore.Hosting.Server;
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Http.Features;
+
+namespace Microsoft.AspNetCore.Server.HttpSys
+{
+    internal class DummyApplication : IHttpApplication<HttpContext>
+    {
+        private readonly RequestDelegate _requestDelegate;
+
+        public DummyApplication() : this(context => Task.CompletedTask) { }
+
+        public DummyApplication(RequestDelegate requestDelegate)
+        {
+            _requestDelegate = requestDelegate;
+        }
+
+        public HttpContext CreateContext(IFeatureCollection contextFeatures)
+        {
+            return new DefaultHttpContext(contextFeatures);
+        }
+
+        public void DisposeContext(HttpContext httpContext, Exception exception)
+        {
+
+        }
+
+        public async Task ProcessRequestAsync(HttpContext httpContext)
+        {
+            await _requestDelegate(httpContext);
+        }
+    }
+}
diff --git a/src/Servers/HttpSys/test/NonHelixTests/Microsoft.AspNetCore.Server.HttpSys.NonHelixTests.csproj b/src/Servers/HttpSys/test/NonHelixTests/Microsoft.AspNetCore.Server.HttpSys.NonHelixTests.csproj
@@ -0,0 +1,30 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>$(DefaultNetCoreTargetFramework)</TargetFramework>
+    <TestGroupName>HttpSys.NonHelixTests</TestGroupName>
+    <AllowUnsafeBlocks>true</AllowUnsafeBlocks>
+
+    <!-- Tests do not work on Helix or when bin/ directory is not in project directory due to undeclared dependency on test content. -->
+    <!-- https://github.com/dotnet/aspnetcore/issues/8247 -->
+    <BuildHelixPayload>false</BuildHelixPayload>
+    <BaseOutputPath />
+    <OutputPath />
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Reference Include="Microsoft.AspNetCore.Server.HttpSys" />
+    <Reference Include="Microsoft.Extensions.Hosting" />
+  </ItemGroup>
+
+  <PropertyGroup>
+    <!--Imitate IIS Express so we can use it's cert bindings-->
+    <PackageTags>214124cd-d05b-4309-9af9-9caa44b2b74a</PackageTags>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Content Include="testroot\**\*" CopyToOutputDirectory="PreserveNewest" CopyToPublishDirectory="PreserveNewest" />
+    <ProjectReference Include="$(RepoRoot)src\Hosting\Server.IntegrationTesting\src\Microsoft.AspNetCore.Server.IntegrationTesting.csproj" />
+  </ItemGroup>
+
+</Project>
diff --git a/src/Servers/HttpSys/test/NonHelixTests/Properties/AssemblyInfo.cs b/src/Servers/HttpSys/test/NonHelixTests/Properties/AssemblyInfo.cs
@@ -0,0 +1,9 @@
+﻿// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using Microsoft.AspNetCore.Testing;
+using Xunit;
+
+[assembly: OSSkipCondition(OperatingSystems.MacOSX)]
+[assembly: OSSkipCondition(OperatingSystems.Linux)]
+[assembly: CollectionBehavior(DisableTestParallelization = true)]
diff --git a/src/Servers/HttpSys/test/NonHelixTests/Utilities.cs b/src/Servers/HttpSys/test/NonHelixTests/Utilities.cs
diff --git a/src/Servers/HttpSys/test/testassets/DelegationSite/DelegationSite.csproj b/src/Servers/HttpSys/test/testassets/DelegationSite/DelegationSite.csproj
diff --git a/src/Servers/HttpSys/test/testassets/DelegationSite/Program.cs b/src/Servers/HttpSys/test/testassets/DelegationSite/Program.cs
diff --git a/src/Servers/HttpSys/test/testassets/DelegationSite/Properties/launchSettings.json b/src/Servers/HttpSys/test/testassets/DelegationSite/Properties/launchSettings.json
diff --git a/src/Servers/HttpSys/test/testassets/Directory.Build.props b/src/Servers/HttpSys/test/testassets/Directory.Build.props
diff --git a/src/Shared/HttpSys/NativeInterop/HttpApiTypes.cs b/src/Shared/HttpSys/NativeInterop/HttpApiTypes.cs

Original file line number	Diff line number	Diff line change
`@@ -150,7 +150,7 @@ public override async Task<DeploymentResult> DeployAsync()`
`150`	`150`	`HostProcess.EnableRaisingEvents = true;`
`151`	`151`	`HostProcess.OutputDataReceived += (sender, dataArgs) =>`
`152`	`152`	`{`
`153`		`- if (string.Equals(dataArgs.Data, ApplicationStartedMessage))`
	`153`	`+ if (!string.IsNullOrEmpty(dataArgs.Data) && dataArgs.Data.Contains(ApplicationStartedMessage))`
`154`	`154`	`{`
`155`	`155`	`started.TrySetResult();`
`156`	`156`	`}`
Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ public MessagePump(IOptions<HttpSysOptions> options, ILoggerFactory loggerFactor`
`55`	`55`	`_serverAddresses = new ServerAddressesFeature();`
`56`	`56`	`Features.Set<IServerAddressesFeature>(_serverAddresses);`
`57`	`57`
`58`		`- if (HttpApi.IsFeatureSupported(HttpApiTypes.HTTP_FEATURE_ID.HttpFeatureDelegateEx))`
	`58`	`+ if (HttpApi.SupportsDelegation)`
`59`	`59`	`{`
`60`	`60`	`var delegationProperty = new ServerDelegationPropertyFeature(Listener.RequestQueue, _logger);`
`61`	`61`	`Features.Set<IServerDelegationFeature>(delegationProperty);`
Original file line number	Diff line number	Diff line change
`@@ -125,6 +125,7 @@ internal static HTTP_API_VERSION ApiVersion`
`125`	`125`	`internal static bool SupportsTrailers { get; private set; }`
`126`	`126`	`[MemberNotNullWhen(true, nameof(HttpSetRequestProperty))]`
`127`	`127`	`internal static bool SupportsReset { get; private set; }`
	`128`	`+ internal static bool SupportsDelegation { get; private set; }`
`128`	`129`
`129`	`130`	`static HttpApi()`
`130`	`131`	`{`
`@@ -136,18 +137,17 @@ private static void InitHttpApi(ushort majorVersion, ushort minorVersion)`
`136`	`137`	`version.HttpApiMajorVersion = majorVersion;`
`137`	`138`	`version.HttpApiMinorVersion = minorVersion;`
`138`	`139`
`139`		`- var statusCode = HttpInitialize(version, (uint)HTTP_FLAGS.HTTP_INITIALIZE_SERVER, null);`
	`140`	`+ var statusCode = HttpInitialize(version, (uint)(HTTP_FLAGS.HTTP_INITIALIZE_SERVER \| HTTP_FLAGS.HTTP_INITIALIZE_CONFIG), null);`
`140`	`141`
`141`	`142`	`supported = statusCode == UnsafeNclNativeMethods.ErrorCodes.ERROR_SUCCESS;`
`142`	`143`
`143`	`144`	`if (supported)`
`144`	`145`	`{`
`145`	`146`	`HttpApiModule = SafeLibraryHandle.Open(HTTPAPI);`
`146`	`147`	`HttpSetRequestProperty = HttpApiModule.GetProcAddress<HttpSetRequestPropertyInvoker>("HttpSetRequestProperty", throwIfNotFound: false);`
`147`		`-`
`148`	`148`	`SupportsReset = HttpSetRequestProperty != null;`
`149`		`- // Trailers support was added in the same release as Reset, but there's no method we can export to check it directly.`
`150`		`- SupportsTrailers = SupportsReset;`
	`149`	`+ SupportsTrailers = IsFeatureSupported(HTTP_FEATURE_ID.HttpFeatureResponseTrailers);`
	`150`	`+ SupportsDelegation = IsFeatureSupported(HTTP_FEATURE_ID.HttpFeatureDelegateEx);`
`151`	`151`	`}`
`152`	`152`	`}`
`153`	`153`
`@@ -160,7 +160,7 @@ internal static bool Supported`
`160`	`160`	`}`
`161`	`161`	`}`
`162`	`162`
`163`		`- internal static bool IsFeatureSupported(HTTP_FEATURE_ID feature)`
	`163`	`+ private static bool IsFeatureSupported(HTTP_FEATURE_ID feature)`
`164`	`164`	`{`
`165`	`165`	`try`
`166`	`166`	`{`
Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ static StandardFeatureCollection()`
`48`	`48`	`_featureFuncLookup[typeof(ITlsHandshakeFeature)] = ctx => ctx.GetTlsHandshakeFeature();`
`49`	`49`	`}`
`50`	`50`
`51`		`- if (HttpApi.IsFeatureSupported(HttpApiTypes.HTTP_FEATURE_ID.HttpFeatureDelegateEx))`
	`51`	`+ if (HttpApi.SupportsDelegation)`
`52`	`52`	`{`
`53`	`53`	`_featureFuncLookup[typeof(IHttpSysRequestDelegationFeature)] = _identityFunc;`
`54`	`54`	`}`
Original file line number	Diff line number	Diff line change
`@@ -148,6 +148,9 @@ public async Task DelegateAfterRequestBodyReadShouldThrow()`
`148`	`148`	`[DelegateSupportedCondition(false)]`
`149`	`149`	`public async Task DelegationFeaturesAreNull()`
`150`	`150`	`{`
	`151`	`+ // Testing the DelegateSupportedCondition`
	`152`	`+ Assert.True(Environment.OSVersion.Version < new Version(10, 0, 22000), "This should be supported on Win 11.");`
	`153`	`+`
`151`	`154`	`using var delegator = Utilities.CreateHttpServer(out var delegatorAddress, httpContext =>`
`152`	`155`	`{`
`153`	`156`	`var delegateFeature = httpContext.Features.Get<IHttpSysRequestDelegationFeature>();`