[main] Source code updates from dotnet/dotnet (#64365)

dotnet-maestro[bot] · web-flow · commit 4abe082fdf69 · 2025-11-14T15:10:29.000Z
[main] Source code updates from dotnet/dotnet
diff --git a/eng/Version.Details.props b/eng/Version.Details.props
diff --git a/eng/Version.Details.xml b/eng/Version.Details.xml
diff --git a/eng/common/core-templates/job/publish-build-assets.yml b/eng/common/core-templates/job/publish-build-assets.yml
@@ -140,7 +140,7 @@ jobs:
           /p:MaestroApiEndpoint=https://maestro.dot.net
           /p:OfficialBuildId=$(OfficialBuildId)
           -runtimeSourceFeed https://ci.dot.net/internal
-          -runtimeSourceFeedKey $(dotnetbuilds-internal-container-read-token-base64)
+          -runtimeSourceFeedKey '$(dotnetbuilds-internal-container-read-token-base64)'
 
       condition: ${{ parameters.condition }}
       continueOnError: ${{ parameters.continueOnError }}
@@ -210,8 +210,8 @@ jobs:
             -ArtifactsPublishingAdditionalParameters '${{ parameters.artifactsPublishingAdditionalParameters }}'
             -SymbolPublishingAdditionalParameters '${{ parameters.symbolPublishingAdditionalParameters }}'
             -SkipAssetsPublishing '${{ parameters.isAssetlessBuild }}'
-            -runtimeSourceFeed https://ci.dot.net/internal 
-            -runtimeSourceFeedKey $(dotnetbuilds-internal-container-read-token-base64)
+            -runtimeSourceFeed https://ci.dot.net/internal
+            -runtimeSourceFeedKey '$(dotnetbuilds-internal-container-read-token-base64)'
 
     - ${{ if eq(parameters.enablePublishBuildArtifacts, 'true') }}:
       - template: /eng/common/core-templates/steps/publish-logs.yml
diff --git a/eng/common/core-templates/post-build/post-build.yml b/eng/common/core-templates/post-build/post-build.yml
@@ -334,4 +334,4 @@ stages:
               -SymbolPublishingAdditionalParameters '${{ parameters.symbolPublishingAdditionalParameters }}'
               -SkipAssetsPublishing '${{ parameters.isAssetlessBuild }}'
               -runtimeSourceFeed https://ci.dot.net/internal 
-              -runtimeSourceFeedKey $(dotnetbuilds-internal-container-read-token-base64)
+              -runtimeSourceFeedKey '$(dotnetbuilds-internal-container-read-token-base64)'
diff --git a/eng/common/core-templates/steps/publish-logs.yml b/eng/common/core-templates/steps/publish-logs.yml
@@ -26,10 +26,10 @@ steps:
     #  If the file exists - sensitive data for redaction will be sourced from it
     #  (single entry per line, lines starting with '# ' are considered comments and skipped)
     arguments: -InputPath '$(System.DefaultWorkingDirectory)/PostBuildLogs' 
-      -BinlogToolVersion ${{parameters.BinlogToolVersion}}
+      -BinlogToolVersion '${{parameters.BinlogToolVersion}}'
       -TokensFilePath '$(System.DefaultWorkingDirectory)/eng/BinlogSecretsRedactionFile.txt'
       -runtimeSourceFeed https://ci.dot.net/internal 
-      -runtimeSourceFeedKey $(dotnetbuilds-internal-container-read-token-base64)
+      -runtimeSourceFeedKey '$(dotnetbuilds-internal-container-read-token-base64)'
       '$(publishing-dnceng-devdiv-code-r-build-re)'
       '$(MaestroAccessToken)'
       '$(dn-bot-all-orgs-artifact-feeds-rw)'
diff --git a/eng/common/core-templates/steps/source-index-stage1-publish.yml b/eng/common/core-templates/steps/source-index-stage1-publish.yml
@@ -14,8 +14,8 @@ steps:
     workingDirectory: $(Agent.TempDirectory)
 
 - script: |
-    $(Agent.TempDirectory)/dotnet/dotnet tool install BinLogToSln --version ${{parameters.sourceIndexProcessBinlogPackageVersion}} --add-source ${{parameters.SourceIndexPackageSource}} --tool-path $(Agent.TempDirectory)/.source-index/tools
-    $(Agent.TempDirectory)/dotnet/dotnet tool install UploadIndexStage1 --version ${{parameters.sourceIndexUploadPackageVersion}} --add-source ${{parameters.SourceIndexPackageSource}} --tool-path $(Agent.TempDirectory)/.source-index/tools
+    $(Agent.TempDirectory)/dotnet/dotnet tool install BinLogToSln --version ${{parameters.sourceIndexProcessBinlogPackageVersion}} --source ${{parameters.SourceIndexPackageSource}} --tool-path $(Agent.TempDirectory)/.source-index/tools
+    $(Agent.TempDirectory)/dotnet/dotnet tool install UploadIndexStage1 --version ${{parameters.sourceIndexUploadPackageVersion}} --source ${{parameters.SourceIndexPackageSource}} --tool-path $(Agent.TempDirectory)/.source-index/tools
   displayName: "Source Index: Download netsourceindex Tools"
   # Set working directory to temp directory so 'dotnet' doesn't try to use global.json and use the repo's sdk.
   workingDirectory: $(Agent.TempDirectory)
diff --git a/eng/common/native/install-dependencies.sh b/eng/common/native/install-dependencies.sh
@@ -27,7 +27,7 @@ case "$os" in
                 libssl-dev libkrb5-dev pigz cpio
 
             localedef -i en_US -c -f UTF-8 -A /usr/share/locale/locale.alias en_US.UTF-8
-        elif [ "$ID" = "fedora" ] || [ "$ID" = "rhel" ] || [ "$ID" = "azurelinux" ]; then
+        elif [ "$ID" = "fedora" ] || [ "$ID" = "rhel" ] || [ "$ID" = "azurelinux" ] || [ "$ID" = "centos"]; then
             pkg_mgr="$(command -v tdnf 2>/dev/null || command -v dnf)"
             $pkg_mgr install -y cmake llvm lld lldb clang python curl libicu-devel openssl-devel krb5-devel lttng-ust-devel pigz cpio
         elif [ "$ID" = "amzn" ]; then
diff --git a/global.json b/global.json
@@ -32,9 +32,9 @@
     "jdk": "latest"
   },
   "msbuild-sdks": {
-    "Microsoft.DotNet.Arcade.Sdk": "11.0.0-beta.25556.111",
-    "Microsoft.DotNet.Helix.Sdk": "11.0.0-beta.25556.111",
-    "Microsoft.DotNet.SharedFramework.Sdk": "11.0.0-beta.25556.111",
+    "Microsoft.DotNet.Arcade.Sdk": "11.0.0-beta.25563.103",
+    "Microsoft.DotNet.Helix.Sdk": "11.0.0-beta.25563.103",
+    "Microsoft.DotNet.SharedFramework.Sdk": "11.0.0-beta.25563.103",
     "Microsoft.Build.NoTargets": "3.7.0",
     "Microsoft.Build.Traversal": "3.4.0",
     "Microsoft.WixToolset.Sdk": "5.0.2-dotnet.2811440"
diff --git a/src/Servers/Kestrel/Core/src/Internal/Http3/Http3ControlStream.cs b/src/Servers/Kestrel/Core/src/Internal/Http3/Http3ControlStream.cs
@@ -65,6 +65,12 @@ public Http3ControlStream(Http3StreamContext context, long? headerType)
             context.ClientPeerSettings,
             this);
         _frameWriter.Reset(context.Transport.Output, context.ConnectionId);
+
+        _streamClosedFeature.OnClosed(static state =>
+        {
+            var stream = (Http3ControlStream)state!;
+            stream.OnStreamClosed();
+        }, this);
     }
 
     private void OnStreamClosed()
@@ -135,12 +141,6 @@ private bool TryClose()
 
     internal async ValueTask ProcessOutboundSendsAsync(long id)
     {
-        _streamClosedFeature.OnClosed(static state =>
-        {
-            var stream = (Http3ControlStream)state!;
-            stream.OnStreamClosed();
-        }, this);
-
         await _frameWriter.WriteStreamIdAsync(id);
         await _frameWriter.WriteSettingsAsync(_serverPeerSettings.GetNonProtocolDefaults());
     }
@@ -311,18 +311,13 @@ private async Task HandleControlStream()
         }
     }
 
-    private async ValueTask HandleEncodingDecodingTask()
+    private Task HandleEncodingDecodingTask()
     {
         // Noop encoding and decoding task. Settings make it so we don't need to read content of encoder and decoder.
         // An endpoint MUST allow its peer to create an encoder stream and a
         // decoder stream even if the connection's settings prevent their use.
 
-        while (_isClosed == 0)
-        {
-            var result = await Input.ReadAsync();
-            var readableBuffer = result.Buffer;
-            Input.AdvanceTo(readableBuffer.End);
-        }
+        return Input.CopyToAsync(Stream.Null);
     }
 
     private ValueTask ProcessHttp3ControlStream(Http3RawFrame incomingFrame, bool isContinuedFrame, in ReadOnlySequence<byte> payload, out SequencePosition consumed)
@@ -372,11 +367,6 @@ private ValueTask ProcessSettingsFrameAsync(bool isContinuedFrame, ReadOnlySeque
             }
 
             _haveReceivedSettingsFrame = true;
-            _streamClosedFeature.OnClosed(static state =>
-            {
-                var stream = (Http3ControlStream)state!;
-                stream.OnStreamClosed();
-            }, this);
         }
 
         while (true)
diff --git a/src/Servers/Kestrel/shared/test/Http3/Http3InMemory.cs b/src/Servers/Kestrel/shared/test/Http3/Http3InMemory.cs
@@ -300,12 +300,26 @@ public void OnInboundControlStreamSetting(Http3SettingType type, long value)
 
         public bool OnInboundDecoderStream(Server.Kestrel.Core.Internal.Http3.Http3ControlStream stream)
         {
-            return _inner.OnInboundDecoderStream(stream);
+            var res = _inner.OnInboundDecoderStream(stream);
+
+            if (_http3TestBase._runningStreams.TryGetValue(stream.StreamId, out var testStream))
+            {
+                testStream.OnDecoderStreamCreatedTcs.TrySetResult();
+            }
+
+            return res;
         }
 
         public bool OnInboundEncoderStream(Server.Kestrel.Core.Internal.Http3.Http3ControlStream stream)
         {
-            return _inner.OnInboundEncoderStream(stream);
+            var res = _inner.OnInboundEncoderStream(stream);
+
+            if (_http3TestBase._runningStreams.TryGetValue(stream.StreamId, out var testStream))
+            {
+                testStream.OnEncoderStreamCreatedTcs.TrySetResult();
+            }
+
+            return res;
         }
 
         public void OnStreamCompleted(IHttp3Stream stream)
@@ -479,6 +493,8 @@ internal class Http3StreamBase
     internal TaskCompletionSource OnStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
     internal TaskCompletionSource OnStreamCompletedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
     internal TaskCompletionSource OnHeaderReceivedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
+    internal TaskCompletionSource OnDecoderStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
+    internal TaskCompletionSource OnEncoderStreamCreatedTcs { get; } = new TaskCompletionSource(TaskCreationOptions.RunContinuationsAsynchronously);
 
     internal TestStreamContext StreamContext { get; }
     internal DuplexPipe.DuplexPipePair Pair { get; }
@@ -495,6 +511,8 @@ public long Error
     public Task OnStreamCreatedTask => OnStreamCreatedTcs.Task;
     public Task OnStreamCompletedTask => OnStreamCompletedTcs.Task;
     public Task OnHeaderReceivedTask => OnHeaderReceivedTcs.Task;
+    public Task OnDecoderStreamCreatedTask => OnDecoderStreamCreatedTcs.Task;
+    public Task OnEncoderStreamCreatedTask => OnEncoderStreamCreatedTcs.Task;
 
     public ConnectionAbortedException AbortReadException => StreamContext.AbortReadException;
     public ConnectionAbortedException AbortWriteException => StreamContext.AbortWriteException;
diff --git a/src/Servers/Kestrel/test/InMemory.FunctionalTests/Http3/Http3ConnectionTests.cs b/src/Servers/Kestrel/test/InMemory.FunctionalTests/Http3/Http3ConnectionTests.cs
@@ -768,6 +768,59 @@ public async Task ErrorCodeIsValidOnConnectionTimeout()
         Assert.InRange(errorCodeFeature.Error, 0, (1L << 62) - 1); // Valid range for HTTP/3 error codes
     }
 
+    [Theory]
+    [InlineData(2)] // encoder
+    [InlineData(3)] // decoder
+    public async Task IgnoredControlStreams_CloseConnectionOnEndStream(int streamType)
+    {
+        await Http3Api.InitializeConnectionAsync(_noopApplication);
+
+        var stream = await Http3Api.CreateControlStream(streamType);
+
+        // PipeWriter will be completed when end of stream is received. Should exit read loop and close stream
+        // which will cause the connection to close with an error.
+        await stream.SendFrameAsync(Http3FrameType.Data, Memory<byte>.Empty, endStream: true);
+
+        await stream.OnStreamCompletedTask.DefaultTimeout();
+
+        Http3Api.TriggerTick();
+        Http3Api.TriggerTick(TimeSpan.FromSeconds(1));
+
+        await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>(
+            ignoreNonGoAwayFrames: true,
+            expectedLastStreamId: 0,
+            expectedErrorCode: Http3ErrorCode.ClosedCriticalStream,
+            matchExpectedErrorMessage: AssertExpectedErrorMessages,
+            expectedErrorMessage: CoreStrings.Http3ErrorControlStreamClosed);
+        MetricsAssert.Equal(ConnectionEndReason.ClosedCriticalStream, Http3Api.ConnectionTags);
+    }
+
+    [Theory]
+    [InlineData(2)] // encoder
+    [InlineData(3)] // decoder
+    public async Task IgnoredControlStreams_CloseConnectionOnStreamClose(int streamType)
+    {
+        await Http3Api.InitializeConnectionAsync(_noopApplication);
+
+        var stream = await Http3Api.CreateControlStream(streamType);
+
+        await (streamType == 2 ? stream.OnEncoderStreamCreatedTask : stream.OnDecoderStreamCreatedTask).DefaultTimeout();
+
+        // Simulate quic layer closing the stream
+        stream.StreamContext.Close();
+
+        Http3Api.TriggerTick();
+        Http3Api.TriggerTick(TimeSpan.FromSeconds(1));
+
+        await Http3Api.WaitForConnectionErrorAsync<Http3ConnectionErrorException>(
+            ignoreNonGoAwayFrames: true,
+            expectedLastStreamId: 0,
+            expectedErrorCode: Http3ErrorCode.ClosedCriticalStream,
+            matchExpectedErrorMessage: AssertExpectedErrorMessages,
+            expectedErrorMessage: CoreStrings.Http3ErrorControlStreamClosed);
+        MetricsAssert.Equal(ConnectionEndReason.ClosedCriticalStream, Http3Api.ConnectionTags);
+    }
+
     private sealed class ThrowingMultiplexedConnectionContext : TestMultiplexedConnectionContext
     {
         private int _skipCount;

Original file line number	Diff line number	Diff line change
`@@ -65,6 +65,12 @@ public Http3ControlStream(Http3StreamContext context, long? headerType)`
`65`	`65`	`context.ClientPeerSettings,`
`66`	`66`	`this);`
`67`	`67`	`_frameWriter.Reset(context.Transport.Output, context.ConnectionId);`
	`68`	`+`
	`69`	`+ _streamClosedFeature.OnClosed(static state =>`
	`70`	`+ {`
	`71`	`+ var stream = (Http3ControlStream)state!;`
	`72`	`+ stream.OnStreamClosed();`
	`73`	`+ }, this);`
`68`	`74`	`}`
`69`	`75`
`70`	`76`	`private void OnStreamClosed()`
`@@ -135,12 +141,6 @@ private bool TryClose()`
`135`	`141`
`136`	`142`	`internal async ValueTask ProcessOutboundSendsAsync(long id)`
`137`	`143`	`{`
`138`		`- _streamClosedFeature.OnClosed(static state =>`
`139`		`- {`
`140`		`- var stream = (Http3ControlStream)state!;`
`141`		`- stream.OnStreamClosed();`
`142`		`- }, this);`
`143`		`-`
`144`	`144`	`await _frameWriter.WriteStreamIdAsync(id);`
`145`	`145`	`await _frameWriter.WriteSettingsAsync(_serverPeerSettings.GetNonProtocolDefaults());`
`146`	`146`	`}`
`@@ -311,18 +311,13 @@ private async Task HandleControlStream()`
`311`	`311`	`}`
`312`	`312`	`}`
`313`	`313`
`314`		`- private async ValueTask HandleEncodingDecodingTask()`
	`314`	`+ private Task HandleEncodingDecodingTask()`
`315`	`315`	`{`
`316`	`316`	`// Noop encoding and decoding task. Settings make it so we don't need to read content of encoder and decoder.`
`317`	`317`	`// An endpoint MUST allow its peer to create an encoder stream and a`
`318`	`318`	`// decoder stream even if the connection's settings prevent their use.`
`319`	`319`
`320`		`- while (_isClosed == 0)`
`321`		`- {`
`322`		`- var result = await Input.ReadAsync();`
`323`		`- var readableBuffer = result.Buffer;`
`324`		`- Input.AdvanceTo(readableBuffer.End);`
`325`		`- }`
	`320`	`+ return Input.CopyToAsync(Stream.Null);`
`326`	`321`	`}`
`327`	`322`
`328`	`323`	`private ValueTask ProcessHttp3ControlStream(Http3RawFrame incomingFrame, bool isContinuedFrame, in ReadOnlySequence<byte> payload, out SequencePosition consumed)`
`@@ -372,11 +367,6 @@ private ValueTask ProcessSettingsFrameAsync(bool isContinuedFrame, ReadOnlySeque`
`372`	`367`	`}`
`373`	`368`
`374`	`369`	`_haveReceivedSettingsFrame = true;`
`375`		`- _streamClosedFeature.OnClosed(static state =>`
`376`		`- {`
`377`		`- var stream = (Http3ControlStream)state!;`
`378`		`- stream.OnStreamClosed();`
`379`		`- }, this);`
`380`	`370`	`}`
`381`	`371`
`382`	`372`	`while (true)`