diff --git a/src/core/Akka.Remote.Tests/Transport/Bug3370DotNettyLinuxBufferPoolSpec.cs b/src/core/Akka.Remote.Tests/Transport/Bug3370DotNettyLinuxBufferPoolSpec.cs deleted file mode 100644 index 0d12256a75f..00000000000 --- a/src/core/Akka.Remote.Tests/Transport/Bug3370DotNettyLinuxBufferPoolSpec.cs +++ /dev/null @@ -1,93 +0,0 @@ -//----------------------------------------------------------------------- -// -// Copyright (C) 2009-2019 Lightbend Inc. -// Copyright (C) 2013-2019 .NET Foundation -// -//----------------------------------------------------------------------- - -using System.Threading.Tasks; -using Akka.Actor; -using Akka.Actor.Dsl; -using Hocon; using Akka.Configuration; -using Akka.Remote.Transport.DotNetty; -using Akka.TestKit; -using DotNetty.Buffers; -using FluentAssertions; -using Xunit; - -namespace Akka.Remote.Tests.Transport -{ - /// - /// Spec designed to verify that https://github.com/akkadotnet/akka.net/issues/3370 - /// - public class Bug3370DotNettyLinuxBufferPoolSpec : AkkaSpec - { - private static readonly Config Config = ConfigurationFactory.ParseString(@" - akka { - loglevel = DEBUG - actor.provider = ""Akka.Remote.RemoteActorRefProvider,Akka.Remote"" - remote { - dot-netty.tcp { - port = 0 - hostname = ""127.0.0.1"" - log-transport = true - enable-pooling = false - } - } - }"); - - public Bug3370DotNettyLinuxBufferPoolSpec() : base(Config) - { - - } - - [Fact] - public async Task DotNettyTcpTransport_should_start_without_pooling() - { - var config = Sys.Settings.Config.GetConfig("akka.remote.dot-netty.tcp"); - Assert.False(config.IsNullOrEmpty()); - - var t1 = new TcpTransport(Sys, config); - try - { - // bind - await t1.Listen(); - - // verify that ServerChannel is active and open - var sc = t1.ServerChannel; - sc.Should().NotBeNull(); - sc.Active.Should().BeTrue(); - sc.Open.Should().BeTrue(); - sc.Allocator.Should().NotBeOfType(); // verify we are not using pooling - sc.Allocator.Should().BeOfType(); - } - finally - { - await t1.Shutdown(); - } - } - - [Fact] - public void DotNettyTcpTransport_should_communicate_without_pooling() - { - var sys2 = ActorSystem.Create(Sys.Name, Sys.Settings.Config); - - InitializeLogger(sys2); - try - { - var echo = sys2.ActorOf(act => { act.ReceiveAny((o, context) => context.Sender.Tell(o)); }, "echo"); - - var address1 = RARP.For(Sys).Provider.DefaultAddress; - var address2 = RARP.For(sys2).Provider.DefaultAddress; - var echoPath = new RootActorPath(address2) / "user" / "echo"; - var probe = CreateTestProbe(); - Sys.ActorSelection(echoPath).Tell("hello", probe.Ref); - probe.ExpectMsg("hello"); - } - finally - { - Shutdown(sys2); - } - } - } -}