Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

ActorGraphInterpreter Box Caching #7116

Draft
wants to merge 5 commits into
base: dev
Choose a base branch
from

Make ObjectPool less specific

cec7572
Select commit
Loading
Failed to load commit list.
Draft

ActorGraphInterpreter Box Caching #7116

Make ObjectPool less specific
cec7572
Select commit
Loading
Failed to load commit list.
Azure Pipelines / PR Validation failed Mar 17, 2024 in 16m 23s

Build #2024.3.17.1 had test failures

7 errors / 6 warnings

Details

Tests

  • Failed: 4 (0.19%)
  • Passed: 1,972 (94.76%)
  • Other: 105 (5.05%)
  • Total: 2,081

Annotations

Check failure on line 11538 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L11538 

Process completed with exit code 42.

Check failure on line 11820 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L11820 

Process completed with exit code 42.

Check failure on line 9019 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L9019 

Bash exited with code '42'.

Check failure on line 14 in Build log

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Build log #L14 

ECHO is off.

Check failure on line 1 in Akka.API.Tests.CoreAPISpec.ApproveStreams

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.API.Tests.CoreAPISpec.ApproveStreams 

VerifyException : Directory: D:\a\1\s\src\core\Akka.API.Tests\verify
NotEqual:
  - Received: CoreAPISpec.ApproveStreams.Net4_6.received.txt
    Verified: CoreAPISpec.ApproveStreams.Net.verified.txt

FileContent:

NotEqual:

Received: CoreAPISpec.ApproveStreams.Net4_6.received.txt
Verified: CoreAPISpec.ApproveStreams.Net.verified.txt
Compare Result:
  [assembly: System.Reflection.AssemblyMetadataAttribute("RepositoryUrl", "https://github.com/akkadotnet/akka.net")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Benchmarks")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Persistence.Query.Sql")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Persistence.TCK")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Streams.TestKit")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Streams.Tests")]
  [assembly: System.Runtime.InteropServices.ComVisibleAttribute(false)]
  [assembly: System.Runtime.InteropServices.GuidAttribute("123b83e9-21f8-49a8-888a-3b1212ff21dc")]
  [assembly: System.Runtime.Versioning.TargetFrameworkAttribute(".NETStandard,Version=v2.0", FrameworkDisplayName=".NET Standard 2.0")]
  namespace Akka.Streams
  {
      public sealed class AbruptStageTerminationException : System.Exception
      {
          public AbruptStageTerminationException(Akka.Streams.Stage.GraphStageLogic logic) { }
          public AbruptStageTerminationException(System.Runtime.Serialization.SerializationInfo info, System.Runtime.Serialization.StreamingContext context) { }
      }
      public class AbruptTerminationException : System.Exception
      {
          public readonly Akka.Actor.IActorRef Actor;
          public AbruptTerminationException(Akka.Actor.IActorRef actor) { }
          protected AbruptTerminationException(System.Runtime.Serialization.SerializationInfo info, System.Runtime.Serialization.StreamingContext context) { }
      }
      public class static ActorAttributes
      {
          public static Akka.Streams.ActorAttributes.Dispatcher IODispatcher { get; }
          public static Akka.Streams.Attributes CreateDebugLogging(bool enabled) { }
          public static Akka.Streams.Attributes CreateDispatcher(string dispatcherName) { }
          public static Akka.Streams.Attributes CreateFuzzingMode(bool enabled) { }
          public static Akka.Streams.Attributes CreateMaxFixedBufferSize(int size) { }
          public static Akka.Streams.Attributes CreateOutputBurstLimit(int limit) { }
          public static Akka.Streams.Attributes CreateStreamSubscriptionTimeout(System.TimeSpan timeout, Akka.Streams.StreamSubscriptionTimeoutTerminationMode mode) { }
          public static Akka.Streams.Attributes CreateSupervisionStrategy(Akka.Streams.Supervision.Decider strategy) { }
          public static Akka.Streams.Attributes CreateSyncProcessingLimit(int limit) { }
          public sealed class DebugLogging : Akka.Streams.Attributes.IAttribute, Akka.Streams.Attributes.IMandatoryAttribute, System.IEquatable<Akka.Streams.ActorAttributes.DebugLogging>
          {
              public DebugLogging(bool enabled) { }
              public bool Enabled { get; }
              public bool Equals(Akka.Streams.ActorAttributes.DebugLogging other) { }
              public override bool Equals(object obj) { }
              public override int GetHashCode() { }
              public override string ToString() { }
          }
          public sealed class Dispatcher : Akka.Streams.Attributes.IAttribute, Akka.Streams.Attributes.IMandatoryAttribute, System.IEquatable<Akka.Streams.ActorAttributes.Dispatcher>
          {
              public readonly string Name;
              public Dispatcher(string name) { }
              public bool Equals(Akka.Streams.ActorAttributes.Dispatcher other) { }
              public override bool Equals(object obj) { }

Check failure on line 1 in Akka.API.Tests.CoreAPISpec.ApproveStreams

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.API.Tests.CoreAPISpec.ApproveStreams 

VerifyException : Directory: D:\a\1\s\src\core\Akka.API.Tests\verify
NotEqual:
  - Received: CoreAPISpec.ApproveStreams.DotNet8_0.received.txt
    Verified: CoreAPISpec.ApproveStreams.DotNet.verified.txt

FileContent:

NotEqual:

Received: CoreAPISpec.ApproveStreams.DotNet8_0.received.txt
Verified: CoreAPISpec.ApproveStreams.DotNet.verified.txt
Compare Result:
  [assembly: System.Reflection.AssemblyMetadataAttribute("RepositoryUrl", "https://github.com/akkadotnet/akka.net")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Benchmarks")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Persistence.Query.Sql")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Persistence.TCK")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Streams.TestKit")]
  [assembly: System.Runtime.CompilerServices.InternalsVisibleToAttribute("Akka.Streams.Tests")]
  [assembly: System.Runtime.InteropServices.ComVisibleAttribute(false)]
  [assembly: System.Runtime.InteropServices.GuidAttribute("123b83e9-21f8-49a8-888a-3b1212ff21dc")]
  [assembly: System.Runtime.Versioning.TargetFrameworkAttribute(".NETCoreApp,Version=v6.0", FrameworkDisplayName=".NET 6.0")]
  namespace Akka.Streams
  {
      public sealed class AbruptStageTerminationException : System.Exception
      {
          public AbruptStageTerminationException(Akka.Streams.Stage.GraphStageLogic logic) { }
          public AbruptStageTerminationException(System.Runtime.Serialization.SerializationInfo info, System.Runtime.Serialization.StreamingContext context) { }
      }
      public class AbruptTerminationException : System.Exception
      {
          public readonly Akka.Actor.IActorRef Actor;
          public AbruptTerminationException(Akka.Actor.IActorRef actor) { }
          protected AbruptTerminationException(System.Runtime.Serialization.SerializationInfo info, System.Runtime.Serialization.StreamingContext context) { }
      }
      public class static ActorAttributes
      {
          public static Akka.Streams.ActorAttributes.Dispatcher IODispatcher { get; }
          public static Akka.Streams.Attributes CreateDebugLogging(bool enabled) { }
          public static Akka.Streams.Attributes CreateDispatcher(string dispatcherName) { }
          public static Akka.Streams.Attributes CreateFuzzingMode(bool enabled) { }
          public static Akka.Streams.Attributes CreateMaxFixedBufferSize(int size) { }
          public static Akka.Streams.Attributes CreateOutputBurstLimit(int limit) { }
          public static Akka.Streams.Attributes CreateStreamSubscriptionTimeout(System.TimeSpan timeout, Akka.Streams.StreamSubscriptionTimeoutTerminationMode mode) { }
          public static Akka.Streams.Attributes CreateSupervisionStrategy(Akka.Streams.Supervision.Decider strategy) { }
          public static Akka.Streams.Attributes CreateSyncProcessingLimit(int limit) { }
          public sealed class DebugLogging : Akka.Streams.Attributes.IAttribute, Akka.Streams.Attributes.IMandatoryAttribute, System.IEquatable<Akka.Streams.ActorAttributes.DebugLogging>
          {
              public DebugLogging(bool enabled) { }
              public bool Enabled { get; }
              public bool Equals(Akka.Streams.ActorAttributes.DebugLogging other) { }
              public override bool Equals(object obj) { }
              public override int GetHashCode() { }
              public override string ToString() { }
          }
          public sealed class Dispatcher : Akka.Streams.Attributes.IAttribute, Akka.Streams.Attributes.IMandatoryAttribute, System.IEquatable<Akka.Streams.ActorAttributes.Dispatcher>
          {
              public readonly string Name;
              public Dispatcher(string name) { }
              public bool Equals(Akka.Streams.ActorAttributes.Dispatcher other) { }
              public override bool Equals(object obj) { }

Check failure on line 1 in Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_not_restart_on_completion_when_maxRestarts_is_reached

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.RestartSpec.A_restart_with_backoff_flow_should_not_restart_on_completion_when_maxRestarts_is_reached 

System.Exception : [ExpectNextN] expected 2 next elements but received 1 elements before an exception occured. Received: [out complete]
---- Failed: Timeout 00:00:03 while waiting for a message of type Akka.Streams.TestKit.TestSubscriber+OnNext`1[System.String]
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 214
   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.Tests.Dsl.RestartSpec.<A_restart_with_backoff_flow_should_not_restart_on_completion_when_maxRestarts_is_reached>b__40_0() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/RestartSpec.cs:line 1025
   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.RestartSpec.A_restart_with_backoff_flow_should_not_restart_on_completion_when_maxRestarts_is_reached() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/RestartSpec.cs:line 1016
--- 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()

Check failure on line 1 in Akka.Streams.Tests.Dsl.FlowSpec.A_broken_Flow_must_cancel_upstream_and_call_onError_on_current_and_future_downstream_subscribers_if_an_internal_error_occurs

See this annotation in the file changed.

@azure-pipelines azure-pipelines / PR Validation

Akka.Streams.Tests.Dsl.FlowSpec.A_broken_Flow_must_cancel_upstream_and_call_onError_on_current_and_future_downstream_subscribers_if_an_internal_error_occurs 

Timeout (00:00:03) during fishForMessage
Raw output 
   at Akka.TestKit.TestKitBase.FishForMessageAsync[T](Predicate`1 isMessage, ArrayList allMessages, Nullable`1 max, String hint, CancellationToken cancellationToken)
   at Akka.Streams.TestKit.StreamTestKit.PublisherProbeSubscription`1.ExpectCancellationAsync(CancellationToken cancellationToken) in /home/vsts/work/1/s/src/core/Akka.Streams.TestKit/StreamTestKit.cs:line 118
   at Akka.Streams.Tests.Dsl.FlowSpec.<A_broken_Flow_must_cancel_upstream_and_call_onError_on_current_and_future_downstream_subscribers_if_an_internal_error_occurs>b__34_0() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/FlowSpec.cs:line 736
   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.FlowSpec.A_broken_Flow_must_cancel_upstream_and_call_onError_on_current_and_future_downstream_subscribers_if_an_internal_error_occurs() in /home/vsts/work/1/s/src/core/Akka.Streams.Tests/Dsl/FlowSpec.cs:line 693
--- End of stack trace from previous location ---
View more details on Azure Pipelines