From a0f47057017312357d351e1e640912b4ab182f87 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Mon, 20 Dec 2021 12:09:53 -0600 Subject: [PATCH] remove the forced waiting on the underlying transport to start up (#5440) * remove the forced waiting on the underlying transport to start up * racy spec fix: `BackoffOnRestartSupervisor_must_respect_maxNrOfRetries_property_of_OneForOneStrategy` (#5442) issue was that using `AutoReset` could cause a race where if the scheduler could reset the count in-flight and throw off the estimates used by the tests. Using a `ManualReset` avoids this issue. * deleted commented out code * Make updates to `FishUntil` (#5433) * Make updates to `FishUntil` Implement nitpicks from https://github.com/akkadotnet/akka.net/pull/5430 * Nitpick * cleaned up `FishUntilMessage` * removed `FluentAssertions` reference * fixed bad `TestKit.ReceiveTests` * Custom frame size computation support in Framing (#5444) * Custom frame size computation support in Framing * Speed up of framing spec * optimize `Props` `NewExpression` allocations (#5428) per https://github.com/akkadotnet/akka.net/pull/5416#discussion_r768272397 Co-authored-by: Ismael Hamed <1279846+ismaelhamed@users.noreply.github.com> --- src/core/Akka/Actor/Internal/ActorSystemImpl.cs | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/src/core/Akka/Actor/Internal/ActorSystemImpl.cs b/src/core/Akka/Actor/Internal/ActorSystemImpl.cs index 34d329ecb4a..f7540c33f04 100644 --- a/src/core/Akka/Actor/Internal/ActorSystemImpl.cs +++ b/src/core/Akka/Actor/Internal/ActorSystemImpl.cs @@ -225,17 +225,6 @@ public void Start() { _log.Info(Settings.ToString()); } - - //HACK: ensure provider started - { - if (_provider.DefaultAddress is null) - Thread.Yield(); - var i = 1; - while(i < 10 && _provider.DefaultAddress is null) - Thread.Sleep(i++ * 16); - if (i == 10 && _provider.DefaultAddress is null) - throw new TimeoutException($"Provider '{_provider.GetType()}' startup timeout"); - } } catch (Exception) {