Learning/s7netplus
0
0
Fork 0
mirror of https://github.com/S7NetPlus/s7netplus.git synced 2026-02-17 22:38:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

Handlers removed to avoid:

Browse Source 
An exception of type 'System.Net.Sockets.SocketException' occurred in S7.Net.Core.dll but was not handled in user code.
Additional information: A connection attempt failed because the connected party did not properly respond after a period of time, or established connection failed because connected host has failed to respond.
This commit is contained in:
Marcos Pereira
2016-02-18 19:02:16 +00:00
parent e51599cca6
commit ddbdec8473
1 changed files with 18 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
S7.Net.Core/SocketClient.cs
View File

@@ -21,7 +21,7 @@ namespace S7.Net
socketEventArg.RemoteEndPoint = server;
socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate (object s, SocketAsyncEventArgs e)
var completedEvent = new EventHandler<SocketAsyncEventArgs>(delegate (object s, SocketAsyncEventArgs e)
{
if (e.SocketError == SocketError.Success)
{
@@ -35,11 +35,15 @@ namespace S7.Net
_clientDone.Set();
});
socketEventArg.Completed += completedEvent;
_clientDone.Reset();
_socket.ConnectAsync(socketEventArg);
_clientDone.WaitOne(TIMEOUT_MILLISECONDS);
socketEventArg.Completed -= completedEvent;
}
public void SetReceiveTimeout(int milis)
@@ -63,7 +67,7 @@ namespace S7.Net
socketEventArg.RemoteEndPoint = _socket.RemoteEndPoint;
socketEventArg.UserToken = null;
socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate (object s, SocketAsyncEventArgs e)
var completedEvent = new EventHandler<SocketAsyncEventArgs>(delegate (object s, SocketAsyncEventArgs e)
{
if (e.SocketError == SocketError.Success)
{
@@ -77,6 +81,8 @@ namespace S7.Net
_clientDone.Set();
});
socketEventArg.Completed += completedEvent;
socketEventArg.SetBuffer(buffer, 0, size);
_clientDone.Reset();
@@ -84,6 +90,8 @@ namespace S7.Net
_socket.SendAsync(socketEventArg);
_clientDone.WaitOne(_sendTimeout);
socketEventArg.Completed -= completedEvent;
}
else
{
@@ -104,7 +112,7 @@ namespace S7.Net
socketEventArg.RemoteEndPoint = _socket.RemoteEndPoint;
socketEventArg.SetBuffer(buffer, 0, size);
socketEventArg.Completed += new EventHandler<SocketAsyncEventArgs>(delegate (object s, SocketAsyncEventArgs e)
var completedEvent = new EventHandler<SocketAsyncEventArgs>(delegate (object s, SocketAsyncEventArgs e)
{
if (e.SocketError == SocketError.Success)
{
@@ -118,11 +126,15 @@ namespace S7.Net
_clientDone.Set();
});
socketEventArg.Completed += completedEvent;
_clientDone.Reset();
_socket.ReceiveAsync(socketEventArg);
_clientDone.WaitOne(_receiveTimeout);
socketEventArg.Completed -= completedEvent;
}
else
{
@@ -139,6 +151,8 @@ namespace S7.Net
if (_socket != null)
{
_socket.Shutdown(SocketShutdown.Both);
_socket.Dispose();
_socket = null;
}
}
@@ -148,7 +162,7 @@ namespace S7.Net
private static ManualResetEvent _clientDone = new ManualResetEvent(false);
private const int TIMEOUT_MILLISECONDS = 5000;
private const int TIMEOUT_MILLISECONDS = 1000;
}
}