Fix serialization verification problem with Akka.IO messages

src/core/Akka.Tests/IO/TcpIntegrationSpec.cs

@@ -45,6 +45,8 @@ class AckWithValue : Tcp.Event
 
         public TcpIntegrationSpec(ITestOutputHelper output)
             : base($@"akka.loglevel = DEBUG
+                     akka.actor.serialize-creators = on
+                     akka.actor.serialize-messages = on
                      akka.io.tcp.trace-logging = true
                      akka.io.tcp.write-commands-queue-max-size = {InternalConnectionActorMaxQueueSize}", output: output)
         { }
@@ -190,7 +192,7 @@ public void The_TCP_transport_implementation_should_properly_support_connecting_
             var targetAddress = new DnsEndPoint("localhost", boundMsg.LocalAddress.AsInstanceOf<IPEndPoint>().Port);
             var clientHandler = CreateTestProbe();
             Sys.Tcp().Tell(new Tcp.Connect(targetAddress), clientHandler);
-            clientHandler.ExpectMsg<Tcp.Connected>(TimeSpan.FromMinutes(10));
+            clientHandler.ExpectMsg<Tcp.Connected>(TimeSpan.FromSeconds(3));
             var clientEp = clientHandler.Sender;
             clientEp.Tell(new Tcp.Register(clientHandler));
             serverHandler.ExpectMsg<Tcp.Connected>();

src/core/Akka.Tests/IO/TcpListenerSpec.cs

@@ -19,12 +19,14 @@ namespace Akka.Tests.IO
     public class TcpListenerSpec : AkkaSpec
     {
         public TcpListenerSpec()
-            : base(@"akka.io.tcp.register-timeout = 500ms
+            : base(@"
+                     akka.actor.serialize-creators = on
+                     akka.actor.serialize-messages = on
+                     akka.io.tcp.register-timeout = 500ms
                      akka.io.tcp.max-received-message-size = 1024
                      akka.io.tcp.direct-buffer-size = 512
                      akka.actor.serialize-creators = on
-                     akka.io.tcp.batch-accept-limit = 2
-                    ")
+                     akka.io.tcp.batch-accept-limit = 2")
         { }
 
         [Fact]

src/core/Akka.Tests/IO/UdpConnectedIntegrationSpec.cs

@@ -24,6 +24,8 @@ public class UdpConnectedIntegrationSpec : AkkaSpec
 
         public UdpConnectedIntegrationSpec(ITestOutputHelper output)
             : base(@"
+                    akka.actor.serialize-creators = on
+                    akka.actor.serialize-messages = on
                     akka.io.udp-connected.nr-of-selectors = 1
                     akka.io.udp-connected.direct-buffer-pool-limit = 100
                     akka.io.udp-connected.direct-buffer-size = 1024

src/core/Akka.Tests/IO/UdpIntegrationSpec.cs

@@ -27,6 +27,8 @@ public class UdpIntegrationSpec : AkkaSpec
 
         public UdpIntegrationSpec(ITestOutputHelper output)
             : base(@"
+                    akka.actor.serialize-creators = on
+                    akka.actor.serialize-messages = on
                     akka.io.udp.max-channels = unlimited
                     akka.io.udp.nr-of-selectors = 1
                     akka.io.udp.direct-buffer-pool-limit = 100

src/core/Akka.Tests/IO/UdpListenerSpec.cs

@@ -13,17 +13,21 @@
 using Akka.IO;
 using Akka.TestKit;
 using Xunit;
+using Xunit.Abstractions;
 using UdpListener = Akka.IO.UdpListener;
 
 namespace Akka.Tests.IO
 {
     public class UdpListenerSpec : AkkaSpec
     {
-        public UdpListenerSpec()
-            : base(@"akka.io.udp.max-channels = unlimited
+        public UdpListenerSpec(ITestOutputHelper output)
+            : base(@"
+                    akka.actor.serialize-creators = on
+                    akka.actor.serialize-messages = on
+                    akka.io.udp.max-channels = unlimited
                     akka.io.udp.nr-of-selectors = 1
                     akka.io.udp.direct-buffer-pool-limit = 100
-                    akka.io.udp.direct-buffer-size = 1024")
+                    akka.io.udp.direct-buffer-size = 1024", output)
         { }
 
         [Fact]

src/core/Akka/Actor/ActorCell.Children.cs

@@ -10,8 +10,10 @@
 using System.Collections.Immutable;
 using System.Text;
 using System.Runtime.CompilerServices;
+using System.Runtime.Serialization;
 using System.Threading;
 using Akka.Actor.Internal;
+using Akka.Dispatch.SysMsg;
 using Akka.Serialization;
 using Akka.Util;
 using Akka.Util.Internal;
@@ -452,6 +454,7 @@ private IInternalActorRef MakeChild(Props props, string name, bool async, bool s
             if (_systemImpl.Settings.SerializeAllCreators && !systemService && !(props.Deploy.Scope is LocalScope))
             {
                 var oldInfo = Serialization.Serialization.CurrentTransportInformation;
+                object propArgument = null;
                 try
                 {
                     if (oldInfo == null)
@@ -465,17 +468,24 @@ private IInternalActorRef MakeChild(Props props, string name, bool async, bool s
                         {
                             if (argument != null && !(argument is INoSerializationVerificationNeeded))
                             {
+                                propArgument = argument;
                                 var serializer = ser.FindSerializerFor(argument);
                                 var bytes = serializer.ToBinary(argument);
                                 var ms = Serialization.Serialization.ManifestFor(serializer, argument);
-                                if(ser.Deserialize(bytes, serializer.Identifier, ms) == null)
+                                if (ser.Deserialize(bytes, serializer.Identifier, ms) == null)
                                     throw new ArgumentException(
-                                            $"Pre-creation serialization check failed at [${_self.Path}/{name}]",
-                                            nameof(name));
+                                        $"Pre-creation serialization check failed at [${_self.Path}/{name}]",
+                                        nameof(name));
                             }
                         }
                     }
                 }
+                catch (Exception e)
+                {
+                    throw new SerializationException(
+                        $"Failed to serialize and deserialize actor props argument of type {propArgument?.GetType()}",
+                        e);
+                }
                 finally
                 {
                     Serialization.Serialization.CurrentTransportInformation = oldInfo;

src/core/Akka/Actor/ActorCell.cs

@@ -13,6 +13,7 @@
 using Akka.Dispatch.SysMsg;
 using Akka.Event;
 using System.Reflection;
+using System.Runtime.Serialization;
 using Akka.Serialization;
 using Akka.Util;
 using Assert = System.Diagnostics.Debug;
@@ -518,6 +519,9 @@ private Envelope SerializeAndDeserialize(Envelope envelope)
             if (unwrapped is INoSerializationVerificationNeeded)
                 return envelope;
 
+            if(unwrapped.GetType().Namespace?.StartsWith("System.Net.Sockets") ?? false)
+                return envelope;
+
             var deserializedMsg = SerializeAndDeserializePayload(unwrapped);
             if (deadLetter != null)
                 return new Envelope(new DeadLetter(deserializedMsg, deadLetter.Sender, deadLetter.Recipient), envelope.Sender);
@@ -540,6 +544,10 @@ private object SerializeAndDeserializePayload(object obj)
                 var manifest = Serialization.Serialization.ManifestFor(serializer, obj);
                 return _systemImpl.Serialization.Deserialize(bytes, serializer.Identifier, manifest);
             }
+            catch (Exception e)
+            {
+                throw new SerializationException($"Failed to serialize and deserialize payload object {obj.GetType()}", e);
+            }
             finally
             {
                 Serialization.Serialization.CurrentTransportInformation = oldInfo;

src/core/Akka/IO/Dns.cs

@@ -59,7 +59,7 @@ public class Dns : ExtensionIdProvider<DnsExt>
         /// <summary>
         /// TBD
         /// </summary>
-        public abstract class Command
+        public abstract class Command : INoSerializationVerificationNeeded
         { }
 
         /// <summary>

src/core/Akka/IO/Tcp.cs

@@ -53,7 +53,7 @@ public override TcpExt CreateExtension(ExtendedActorSystem system)
 
         #region internal connection messages
 
-        internal abstract class SocketCompleted { }
+        internal abstract class SocketCompleted : INoSerializationVerificationNeeded { }
 
         internal sealed class SocketSent : SocketCompleted
         {

src/core/Akka/IO/Udp.cs

@@ -34,7 +34,7 @@ public class Udp : ExtensionIdProvider<UdpExt>
     {
         #region internal connection messages
 
-        internal abstract class SocketCompleted { }
+        internal abstract class SocketCompleted : INoSerializationVerificationNeeded { }
 
         internal sealed class SocketSent : SocketCompleted
         {
@@ -104,7 +104,7 @@ public override UdpExt CreateExtension(ExtendedActorSystem system)
         }
 
         /// <summary>The common interface for <see cref="Command"/> and <see cref="Event"/>.</summary>
-        public abstract class Message { }
+        public abstract class Message : INoSerializationVerificationNeeded { }
 
         /// <summary>The common type of all commands supported by the UDP implementation.</summary>
         public abstract class Command : Message

src/core/Akka/IO/UdpConnected.cs

@@ -34,7 +34,7 @@ public class UdpConnected : ExtensionIdProvider<UdpConnectedExt>
     {
         #region internal connection messages
 
-        internal abstract class SocketCompleted
+        internal abstract class SocketCompleted : INoSerializationVerificationNeeded
         {
             public readonly SocketAsyncEventArgs EventArgs;
 
@@ -92,7 +92,7 @@ public override UdpConnectedExt CreateExtension(ExtendedActorSystem system)
         /// <summary>
         /// The common interface for <see cref="Command"/> and <see cref="Event"/>.
         /// </summary>
-        public abstract class Message { }
+        public abstract class Message : INoSerializationVerificationNeeded { }
 
         /// <summary>
         /// The common type of all commands supported by the UDP implementation.
@@ -372,7 +372,7 @@ private Disconnected()
     /// <summary>
     /// TBD
     /// </summary>
-    public class UdpConnectedExt : IOExtension
+    public class UdpConnectedExt : IOExtension, INoSerializationVerificationNeeded
     {
         public UdpConnectedExt(ExtendedActorSystem system)
             : this(system, UdpSettings.Create(system.Settings.Config.GetConfig("akka.io.udp-connected")))