close #4860 - use local deploy for TcpManager child actors. (#4862)

* close #4860 - use local deploy for TcpManager child actors. * Use local deploy for TcpIncomingConnection. * Use local deploy for Udp actors. Co-authored-by: Erik Folstad <[email protected]> Co-authored-by: Aaron Stannard <[email protected]>
akkadotnet · Mar 29, 2021 · b545365 · b545365
1 parent 21762b9
commit b545365
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/core/Akka/IO/TcpListener.cs b/src/core/Akka/IO/TcpListener.cs
@@ -89,7 +89,7 @@ protected override bool Receive(object message)
             {
                 var saea = message as SocketAsyncEventArgs;
                 if (saea.SocketError == SocketError.Success)
-                    Context.ActorOf(Props.Create<TcpIncomingConnection>(_tcp, saea.AcceptSocket, _bind.Handler, _bind.Options, _bind.PullMode));
+                    Context.ActorOf(Props.Create<TcpIncomingConnection>(_tcp, saea.AcceptSocket, _bind.Handler, _bind.Options, _bind.PullMode).WithDeploy(Deploy.Local));
                 saea.AcceptSocket = null;
 
                 if (!_socket.AcceptAsync(saea))

diff --git a/src/core/Akka/IO/TcpManager.cs b/src/core/Akka/IO/TcpManager.cs
@@ -76,14 +76,14 @@ protected override bool Receive(object message)
             if (c != null)
             {
                 var commander = Sender;
-                Context.ActorOf(Props.Create<TcpOutgoingConnection>(_tcp, commander, c));
+                Context.ActorOf(Props.Create<TcpOutgoingConnection>(_tcp, commander, c).WithDeploy(Deploy.Local));
                 return true;
             }
             var b = message as Bind;
             if (b != null)
             {
                 var commander = Sender;
-                Context.ActorOf(Props.Create<TcpListener>(_tcp, commander, b));
+                Context.ActorOf(Props.Create<TcpListener>(_tcp, commander, b).WithDeploy(Deploy.Local));
                 return true;
             }
             var dl = message as DeadLetter;

diff --git a/src/core/Akka/IO/UdpManager.cs b/src/core/Akka/IO/UdpManager.cs
@@ -65,14 +65,14 @@ protected override bool Receive(object message)
             if (b != null)
             {
                 var commander = Sender;
-                Context.ActorOf(Props.Create(() => new UdpListener(_udp, commander, b)));
+                Context.ActorOf(Props.Create(() => new UdpListener(_udp, commander, b)).WithDeploy(Deploy.Local));
                 return true;
             }
             var s = message as Udp.SimpleSender;
             if (s != null)
             {
                 var commander = Sender;
-                Context.ActorOf(Props.Create(() => new UdpSender(_udp, commander, s.Options)));
+                Context.ActorOf(Props.Create(() => new UdpSender(_udp, commander, s.Options)).WithDeploy(Deploy.Local));
                 return true;
             }
             throw new ArgumentException($"The supplied message of type {message.GetType().Name} is invalid. Only Connect and Bind messages are supported. " +