"An asynchronous socket operation is already in progress using this socketasynceventargs instance" Exception #41

Author: chronoxor

.appveyor.yml

@@ -1,5 +1,5 @@
 # Specify version format
-version: "3.0.5.{build}"
+version: "3.0.6.{build}"
 
 # Image to use
 image: Visual Studio 2019

source/NetCoreServer/NetCoreServer.csproj

@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <TargetFramework>netstandard2.1</TargetFramework>
-    <Version>3.0.5</Version>
+    <Version>3.0.6</Version>
     <Authors>Ivan Shynkarenka</Authors>
     <Copyright>Copyright (c) 2019-2020 Ivan Shynkarenka</Copyright>
     <RepositoryUrl>https://github.com/chronoxor/NetCoreServer</RepositoryUrl>

source/NetCoreServer/TcpClient.cs

@@ -718,7 +718,12 @@ private void ProcessReceive(SocketAsyncEventArgs e)
             {
                 // If zero is returned from a read operation, the remote end has closed the connection
                 if (size > 0)
-                    TryReceive();
+                {
+                    if (Thread.CurrentThread.ManagedThreadId == _sendThreadId)
+                        ThreadPool.QueueUserWorkItem(_ => TryReceive());
+                    else
+                        TryReceive();
+                }
                 else
                     DisconnectAsync();
             }
@@ -768,7 +773,12 @@ private void ProcessSend(SocketAsyncEventArgs e)
 
             // Try to send again if the client is valid
             if (e.SocketError == SocketError.Success)
-                TrySend();
+            {
+                if (Thread.CurrentThread.ManagedThreadId == _sendThreadId)
+                    ThreadPool.QueueUserWorkItem(_ => TrySend());
+                else
+                    TrySend();
+            }
             else
             {
                 SendError(e.SocketError);

source/NetCoreServer/TcpSession.cs

@@ -551,7 +551,12 @@ private void ProcessReceive(SocketAsyncEventArgs e)
             {
                 // If zero is returned from a read operation, the remote end has closed the connection
                 if (size > 0)
-                    TryReceive();
+                {
+                    if (Thread.CurrentThread.ManagedThreadId == _sendThreadId)
+                        ThreadPool.QueueUserWorkItem(_ => TryReceive());
+                    else
+                        TryReceive();
+                }
                 else
                     Disconnect();
             }
@@ -602,7 +607,12 @@ private void ProcessSend(SocketAsyncEventArgs e)
 
             // Try to send again if the session is valid
             if (e.SocketError == SocketError.Success)
-                TrySend();
+            {
+                if (Thread.CurrentThread.ManagedThreadId == _sendThreadId)
+                    ThreadPool.QueueUserWorkItem(_ => TrySend());
+                else
+                    TrySend();
+            }
             else
             {
                 SendError(e.SocketError);