"An asynchronous socket operation is already in progress using this s… · StudyWithJeffrey/NetCoreServer@7b73bb8 · GitHub

1. StudyWithJeffrey
2. NetCoreServer

Repository navigation

• Code
• Pull requests
• Actions
• Projects
• Security and quality
• Insights

Commit 7b73bb8

Browse filesBrowse the repository at this point in the historyBrowse files

chronoxor

committed

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

1 parent e61e019 commit 7b73bb8
Copy full SHA for 7b73bb8

4 files changed

+26-6Lines changed: 26 additions & 6 deletions

File tree

Expand file treeCollapse file tree

Open diff view settings

Filter options

• .appveyor.yml
• source/NetCoreServer
  • NetCoreServer.csproj
  • TcpClient.cs
  • TcpSession.cs

Expand file treeCollapse file tree

Open diff view settings

Collapse file

‎.appveyor.yml‎

Copy file name to clipboardExpand all lines: .appveyor.yml

+1-1Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
@@ -1,5 +1,5 @@
1	1	# Specify version format
2		- version: "3.0.5.{build}"
	2	+ version: "3.0.6.{build}"
3	3
4	4	# Image to use
5	5	image: Visual Studio 2019

Collapse file

‎source/NetCoreServer/NetCoreServer.csproj‎

Copy file name to clipboardExpand all lines: source/NetCoreServer/NetCoreServer.csproj

+1-1Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
@@ -2,7 +2,7 @@
2	2
3	3	<PropertyGroup>
4	4	<TargetFramework>netstandard2.1</TargetFramework>
5		- <Version>3.0.5</Version>
	5	+ <Version>3.0.6</Version>
6	6	<Authors>Ivan Shynkarenka</Authors>
7	7	<Copyright>Copyright (c) 2019-2020 Ivan Shynkarenka</Copyright>
8	8	<RepositoryUrl>https://github.com/chronoxor/NetCoreServer</RepositoryUrl>

Collapse file

‎source/NetCoreServer/TcpClient.cs‎

Copy file name to clipboardExpand all lines: source/NetCoreServer/TcpClient.cs

+12-2Lines changed: 12 additions & 2 deletions

Original file line number	Diff line number	Diff line change
@@ -718,7 +718,12 @@ private void ProcessReceive(SocketAsyncEventArgs e)
718	718	{
719	719	// If zero is returned from a read operation, the remote end has closed the connection
720	720	if (size > 0)
721		- TryReceive();
	721	+ {
	722	+ if (Thread.CurrentThread.ManagedThreadId == _sendThreadId)
	723	+ ThreadPool.QueueUserWorkItem(_ => TryReceive());
	724	+ else
	725	+ TryReceive();
	726	+ }
722	727	else
723	728	DisconnectAsync();
724	729	}
@@ -768,7 +773,12 @@ private void ProcessSend(SocketAsyncEventArgs e)
768	773
769	774	// Try to send again if the client is valid
770	775	if (e.SocketError == SocketError.Success)
771		- TrySend();
	776	+ {
	777	+ if (Thread.CurrentThread.ManagedThreadId == _sendThreadId)
	778	+ ThreadPool.QueueUserWorkItem(_ => TrySend());
	779	+ else
	780	+ TrySend();
	781	+ }
772	782	else
773	783	{
774	784	SendError(e.SocketError);

Collapse file

‎source/NetCoreServer/TcpSession.cs‎

Copy file name to clipboardExpand all lines: source/NetCoreServer/TcpSession.cs

+12-2Lines changed: 12 additions & 2 deletions

Original file line number	Diff line number	Diff line change
@@ -551,7 +551,12 @@ private void ProcessReceive(SocketAsyncEventArgs e)
551	551	{
552	552	// If zero is returned from a read operation, the remote end has closed the connection
553	553	if (size > 0)
554		- TryReceive();
	554	+ {
	555	+ if (Thread.CurrentThread.ManagedThreadId == _sendThreadId)
	556	+ ThreadPool.QueueUserWorkItem(_ => TryReceive());
	557	+ else
	558	+ TryReceive();
	559	+ }
555	560	else
556	561	Disconnect();
557	562	}
@@ -602,7 +607,12 @@ private void ProcessSend(SocketAsyncEventArgs e)
602	607
603	608	// Try to send again if the session is valid
604	609	if (e.SocketError == SocketError.Success)
605		- TrySend();
	610	+ {
	611	+ if (Thread.CurrentThread.ManagedThreadId == _sendThreadId)
	612	+ ThreadPool.QueueUserWorkItem(_ => TrySend());
	613	+ else
	614	+ TrySend();
	615	+ }
606	616	else
607	617	{
608	618	SendError(e.SocketError);

0 commit comments

Comments

0 (0)