[Backport v1.5] Fix: Akka.Remote should not shutdown on invalid TLS traffic - #7952
Merged
Aaronontheweb merged 1 commit intoNov 25, 2025
Merged
Azure Pipelines / PR Validation
failed
Nov 25, 2025 in 1h 2m 0s
Build #2025.11.25.15 had test failures
Details
- Failed: 13 (0.12%)
- Passed: 10,548 (96.51%)
- Other: 369 (3.38%)
- Total: 10,930
Annotations
Check failure on line 616 in Build log
azure-pipelines / PR Validation
Build log #L616
Cmd.exe exited with code '-1'.
Check failure on line 469 in Build log
azure-pipelines / PR Validation
Build log #L469
Bash exited with code '255'.
azure-pipelines / PR Validation
Akka.Streams.Tests.Dsl.HubSpec.BroadcastHub_must_properly_signal_error_to_consumers
System.Exception : [ExpectNextN] expected 8 next elements but received 4 elements before an exception occured. Received: [5, 6, 7, 8]
---- Failed: Timeout 00:00:03 while waiting for a message of type Akka.Streams.TestKit.TestSubscriber+OnNext`1[System.Int32]
Raw output
at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 222
at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+System.Threading.Tasks.Sources.IValueTaskSource<System.Boolean>.GetResult()
at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
at System.Linq.AsyncEnumerable.<ToListAsync>g__Core|424_0[TSource](IAsyncEnumerable`1 source, CancellationToken cancellationToken) in /_/Ix.NET/Source/System.Linq.Async/System/Linq/Operators/ToList.cs:line 36
at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextTask(ManualProbe`1 probe, Nullable`1 timeout, CancellationToken cancellationToken, T[] elems) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/TestSubscriber_Shared.cs:line 51
at Akka.Streams.TestKit.SubscriberFluentBuilder`1.ExecuteAsync(Func`1 asyncAction, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/SubscriberFluentBuilder.cs:line 334
at Akka.Streams.Tests.Dsl.HubSpec.<BroadcastHub_must_properly_signal_error_to_consumers>b__26_0() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/HubSpec.cs:line 574
at Akka.Streams.TestKit.Utils.<>c__DisplayClass5_0.<<AssertAllStagesStoppedAsync>b__0>d.MoveNext() in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 59
--- End of stack trace from previous location ---
at Akka.TestKit.Extensions.TaskExtensions.<>c__DisplayClass5_0`1.<<ShouldCompleteWithin>b__0>d.MoveNext()
--- End of stack trace from previous location ---
at FluentAssertions.Specialized.GenericAsyncFunctionAssertions`1.CompleteWithinAsync(TimeSpan timeSpan, String because, Object[] becauseArgs)
at Akka.TestKit.Extensions.TaskExtensions.ShouldCompleteWithin[T](Task`1 task, TimeSpan timeout, String because, Object[] becauseArgs)
at Akka.Streams.TestKit.Utils.AssertAllStagesStoppedAsync[T](TestKitBase spec, Func`1 block, IMaterializer materializer, Nullable`1 timeout, CancellationToken cancellationToken)
at Akka.Streams.TestKit.Utils.AssertAllStagesStoppedAsync(TestKitBase spec, Func`1 block, IMaterializer materializer, Nullable`1 timeout, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/Utils.cs:line 57
at Akka.Streams.Tests.Dsl.HubSpec.BroadcastHub_must_properly_signal_error_to_consumers() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/HubSpec.cs:line 553
--- End of stack trace from previous location ---
----- Inner Stack Trace -----
at Akka.TestKit.Xunit2.XunitAssertions.Fail(String format, Object[] args) in /home/vsts/work/1/s/src/contrib/testkits/Akka.TestKit.Xunit2/XunitAssertions.cs:line 26
at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`2 assert, String hint, CancellationToken cancellationToken, Boolean shouldLog) in /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 436
at Akka.TestKit.TestKitBase.InternalExpectMsgEnvelopeAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 411
at Akka.TestKit.TestKitBase.InternalExpectMsgAsync[T](Nullable`1 timeout, Action`1 msgAssert, Action`1 senderAssert, String hint, CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.TestKit/TestKitBase_Expect.cs:line 379
at Akka.Streams.TestKit.TestSubscriber.ManualProbe`1.ExpectNextNTask(TestProbe probe, Int64 n, Nullable`1 timeout, CancellationToken cancellationToken)+MoveNext() in /home/vsts/work/1/s/src/core/Akka.
azure-pipelines / PR Validation
Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_support_cancelling_the_master_stream
Expected task to complete within 3s.
Raw output
at FluentAssertions.Execution.XUnit2TestFramework.Throw(String message)
at FluentAssertions.Execution.TestFrameworkProvider.Throw(String message)
at FluentAssertions.Execution.DefaultAssertionStrategy.HandleFailure(String message)
at FluentAssertions.Execution.AssertionScope.FailWith(Func`1 failReasonFunc)
at FluentAssertions.Specialized.NonGenericAsyncFunctionAssertions.CompleteWithinAsync(TimeSpan timeSpan, String because, Object[] becauseArgs)
at Akka.TestKit.Extensions.TaskExtensions.ShouldCompleteWithin(Task task, TimeSpan timeout, String because, Object[] becauseArgs) in /home/vsts/work/1/s/src/core/Akka.TestKit/Extensions/TaskExtensions.cs:line 159
at Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_support_cancelling_the_master_stream() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/FlowSplitWhenSpec.cs:line 266
--- End of stack trace from previous location ---
azure-pipelines / PR Validation
Akka.Streams.Tests.Dsl.FlowLogSpec.A_Log_on_Flow_must_allow_disabling_elements_logging
System.InvalidCastException : Unable to cast object of type 'Akka.Event.SuppressedDeadLetter' to type 'Akka.Event.Debug'.
Raw output
at System.Linq.Enumerable.CastIterator[TResult](IEnumerable source)+MoveNext()
at System.Linq.Enumerable.SelectEnumerableIterator`2.ToArray()
at Akka.Streams.Tests.Dsl.FlowLogSpec.LogMessages(Int32 n) in D:\a\1\s\src\core\Akka.Streams.Tests\Dsl\FlowLogSpec.cs:line 38
at Akka.Streams.Tests.Dsl.FlowLogSpec.A_Log_on_Flow_must_allow_disabling_elements_logging() in D:\a\1\s\src\core\Akka.Streams.Tests\Dsl\FlowLogSpec.cs:line 65
at System.RuntimeMethodHandle.InvokeMethod(Object target, Void** arguments, Signature sig, Boolean isConstructor)
at System.Reflection.MethodBaseInvoker.InvokeWithNoArgs(Object obj, BindingFlags invokeAttr)
azure-pipelines / PR Validation
Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_support_cancelling_the_master_stream
Expected task to complete within 3s.
Raw output
at FluentAssertions.Execution.XUnit2TestFramework.Throw(String message)
at FluentAssertions.Execution.TestFrameworkProvider.Throw(String message)
at FluentAssertions.Execution.DefaultAssertionStrategy.HandleFailure(String message)
at FluentAssertions.Execution.AssertionScope.FailWith(Func`1 failReasonFunc)
at FluentAssertions.Specialized.NonGenericAsyncFunctionAssertions.CompleteWithinAsync(TimeSpan timeSpan, String because, Object[] becauseArgs)
at Akka.TestKit.Extensions.TaskExtensions.ShouldCompleteWithin(Task task, TimeSpan timeout, String because, Object[] becauseArgs) in D:\a\1\s\src\core\Akka.TestKit\Extensions\TaskExtensions.cs:line 159
at Akka.Streams.Tests.Dsl.FlowSplitWhenSpec.SplitWhen_must_support_cancelling_the_master_stream() in D:\a\1\s\src\core\Akka.Streams.Tests\Dsl\FlowSplitWhenSpec.cs:line 266
--- End of stack trace from previous location ---
Loading