R
Robert A. van Ginkel
Hello Fellow Developer,
This looks like a long mail, but at the end of this post is my socket
wrapper attached.
I want to make a timeout procedure that starts counting down after the
socketbuffer is empty.
This connection is being used to transmit data following a RFC so I cann't
create a control protocol that tells me the data was received.
(And even if I could, I want the timeout procedure to start after I send all
data, because that makes for me the most sense. (say I am sending 128mb the
socket will take longer sending then the timeout interval))
Any questions/remarks, NOT related to my question, pls ask directly via
email, dont post on the news server because It toke me alot of effort to
create this post.
Sample case:
if u send 1 byte from a client in Canada to a server in Australia with a 28k
modem thats being shared by an office of 30 people connected to the slowest
profider. (etc.)
What I want to say is that 1 byte may take a couple of minutes, and I use 1
byte as an
example because I don't want to make a question more complicated.
TCP/IP is a async protocol, but due to the Berkley Connection engine it
keeps track of what was send and received and what was not, so when there is
a packet loss it will send again.
So a socket keeps the data sequential, and if we are optimistic, the only
thing that can go wrong is a socket error.
There are three stadiums(simplified):
(A) My object sends to the Winsock, (buffer is being fed, no data on the
network, no data on the remote point)
(B) Winsock processes his buffer and sends on the network and waits for a
confirment that the package is succesfull transmitted(buffer is 'empty',
data on the network, no data on the remote point)
(C) All data is correctly processed and transported (buffer is truely empty,
no data on the network,data on the remote point)
Relative to the Sample case:
I achieve (A) ofcourse, I would really want to know (C), but I would be
satisfied with (B). I know (B) can be achieved, I hope (C) is too.
VB.NET FrameWork 2003(all patched and updated):
I use the System.Net.Sockets to send/receive data (no
tcpclient/tcplistener), I made a receivethread in my wrapper, the
receivethread loops/sleeps while waiting for data and then fires a
datareceived event.
Within the waitingloop there is a timeout function but this doesn't work
properly (It will never timeout).
When I send by System.Net.Sockets.Socket.Send(buffer()) (<--this can be
10Mb) then it imitially returns to my thread, so the (internal) Send method
buffers it.
The System.Net.Sockets.Socket is a wrapper around the Win32 Socket 2 API's,
it makes internal calls to those api's, so I started reading if they forgot
implementing some functions, but they are all implemented.
I tried:
- The beginSend/EndSend (Async way with callback when command is finished)
This calls within the async object the Socket.Send method, so its no
help, I can better do Socket.Send myself.
- The Socket.Blocking Property, it only blocks the Receive method,
Socket.Send goes directly in the buffer and then it returns immitially.
- Socket.Poll Method, returns the accessrights of the socket, "may I use
this socket to write?"
-
getSocketOption(Socket/TCP/IP,SendBuffer/ReceiveBuffer/SendLowWater/ReceiveL
owWater/SendTimeout/ReceiveTimeout) Method
Throws an Exception
MyWrapper.vb:
Imports System
Imports System.Net
Imports System.Net.Sockets
Imports System.IO
Imports System.Collections
Imports System.Threading
Imports System.Diagnostics
Public Class SmartConnection
Public Event ConnectionOpened(ByVal pMe As SmartConnection)
Public Event DataReceived(ByVal pMe As SmartConnection, ByVal Data As
Message)
Public Event CouldntConnect(ByVal pMe As SmartConnection)
Public Event ConnectionClosed(ByVal pMe As SmartConnection)
Public Event [Error](ByVal pMe As SmartConnection, ByVal pErr As
Exception)
Public Event TimeOut(ByVal pme As SmartConnection)
Private _Socket As Socket
Private _ReadThread As Thread
Private _StopThread As Thread 'Lookup threadingpool
Private _Closing As Boolean = False
Private _InError As Boolean = False
Private _lport As Long
Private lasttimeout As Long
Private pHost As String
Private pPort As Long
Private pRead As Boolean
Private pTimeout As Long
Private _Iswriting As Boolean = False
Protected Overrides Sub Finalize()
_ReadThread = Nothing
_StopThread = Nothing
_Socket = Nothing
MyBase.Finalize()
End Sub
#Region " Properties"
Public ReadOnly Property IsClosing() As Boolean
Get
IsClosing = (_Closing Or _Socket Is Nothing)
End Get
End Property
Public ReadOnly Property Connected() As Boolean
Get
Try
Connected = ((Not IsClosing) AndAlso _Socket.Connected =
True)
Catch e As Exception
OnError(e)
End Try
End Get
End Property
Protected ReadOnly Property Receiving() As Boolean
Get
Try
If Not Connected Then Throw New Exception("Socket is not
connected")
Receiving = ((Not _ReadThread Is Nothing) AndAlso
_ReadThread.IsAlive)
Catch e As Exception
OnError(e)
End Try
End Get
End Property
Public ReadOnly Property IPlocal() As String
Get
Try
If Connected Then IPlocal = EP2IPS(_Socket.LocalEndPoint)
Catch e As Exception
OnError(e)
End Try
End Get
End Property
Public ReadOnly Property IPremote() As String
Get
Try
If Connected Then IPremote = EP2IPS(_Socket.RemoteEndPoint)
Catch e As Exception
OnError(e)
End Try
End Get
End Property
#End Region
#Region " Connect"
Public Overridable Sub ConnectTo(ByRef hostName As String, ByRef port As
Long, Optional ByVal timeout As Long = 0)
Try
StartConnect(hostName, port, timeout, True)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub ConnectToWithoutReading(ByRef hostName As String, ByRef
port As Long, Optional ByVal timeout As Long = 0)
Try
StartConnect(hostName, port, timeout, False)
Catch e As Exception
OnError(e)
End Try
End Sub
Private Sub StartConnect(ByRef hostName As String, ByRef port As Long,
ByRef timeout As Long, ByRef read As Boolean)
Try
If Not _ReadThread Is Nothing Then Throw New Exception("Already
trying to connect")
_ReadThread = New Thread(AddressOf ConnectThread)
pHost = hostName : pPort = port : pRead = read : pTimeout =
timeout
_ReadThread.Start()
Catch e As Exception
OnError(e)
End Try
End Sub
Private Sub ConnectThread()
Try
If pHost = "" Then Throw New ArgumentNullException("hostname")
If pPort < IPEndPoint.MinPort Or pPort > IPEndPoint.MaxPort Then
Throw New ArgumentOutOfRangeException("port", "ArgRange_Port")
_Socket = New Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp)
Try
_Socket.Blocking = True
_Socket.Connect(New
IPEndPoint(Dns.Resolve(pHost).AddressList(0), pPort))
_lport = CType(_Socket.LocalEndPoint, IPEndPoint).Port
If Not pRead Then
SetReadName("SC.Read[PreConnect]")
_ReadThread = Nothing
Else
SetReadName("SC.EarlyRead[" & _lport & "]")
End If
OnConnectionOpened()
If pRead Then Receive()
Catch e As SocketException 'e.ErrorCode = 10061
SetReadName("SC.Read[NoConnect]")
_ReadThread = Nothing
OnCouldntConnect()
Close()
End Try
Catch e As Exception
SetReadName("SC.Read[Error]")
_ReadThread = Nothing
OnError(e)
End Try
End Sub
#End Region
#Region " Receive"
Protected Sub StartReceive()
Try
If Receiving Then Throw New Exception("Receiving was already
started")
_ReadThread = New Thread(AddressOf Receive)
SetReadName("SC.LateRead[" & _lport & "]")
_ReadThread.Start()
Catch e As Exception
OnError(e)
End Try
End Sub
Private Sub Receive()
Dim i As Long
Dim b() As Byte
'Dim ds As String, dt As String
Try
Do While Connected
If pTimeout > 0 Then lasttimeout = CurrTick() + pTimeout
Do While _Socket.Available = 0
'dt = ds
'ds = "@" & _lport & ","
'ds += _Socket.GetSocketOption(SocketOptionLevel.Socket,
SocketOptionName.SendBuffer) & ","
'ds += _Socket.GetSocketOption(SocketOptionLevel.Socket,
SocketOptionName.SendLowWater) & ","
'ds += _Socket.GetSocketOption(SocketOptionLevel.Socket,
SocketOptionName.SendTimeout)
'Debug.WriteLineIf(dt <> ds, ds)
_ReadThread.Sleep(ReceiveWait)
If IsClosing Then Exit Sub
If _Socket.Poll(0, SelectMode.SelectError) Then
'System.Runtime.InteropServices.Marshal.GetLastWin32Error())
'_Socket.GetSocketOption(SocketOptionLevel.IP,
SocketOptionName.Error)
OnError(New Exception("Socket Error"))
End If
If pTimeout > 0 Then
'If _Socket.Poll(0, SelectMode.SelectWrite) Then
'lasttimeout = CurrTick() + pTimeout
'Else
If lasttimeout <= CurrTick() Then
OnTimeOut()
Close()
Exit Sub
End If
'Endif
End If
Loop
ReDim b(_Socket.Available - 1)
'SyncLock _Socket
i = _Socket.Receive(b, SocketFlags.None)
'End SyncLock
If i < b.Length Then ReDim b(i - 1)
OnMessageReceived(New Message(b))
b = Nothing
Loop
Catch e As ThreadAbortException
Exit Sub
Catch e As Exception
OnError(e)
End Try
End Sub
#End Region
#Region " Send"
Public Overridable Overloads Sub Send(ByRef data As String)
Try
Send(getbytes(data))
Catch e As Exception
OnError(e)
End Try
End Sub
Public Overridable Overloads Sub Send(ByRef data() As Byte)
Try
If Not Connected Then Throw New Exception("Socket isn't
connected")
_Iswriting = True
'SyncLock _Socket
_Socket.Send(data)
'End SyncLock
_Iswriting = False
Catch e As Exception
_Iswriting = False
OnError(e)
End Try
End Sub
#End Region
#Region " Close"
Public Overridable Sub Close() 'OR QUEE IT?
Try
If IsClosing Then Throw New Exception("Already is closing")
_Closing = True
_StopThread = New Thread(AddressOf DoClose)
_StopThread.Name = "SC.Stop[" & _lport & "]"
_StopThread.Start()
Catch e As Exception
OnError(e)
End Try
End Sub
Private Sub DoClose()
Try
_StopThread.Sleep(CloseWait)
Try
If Not _ReadThread Is Nothing Then
SetReadName("SC.Read[Close]")
If _ReadThread.IsAlive Then _ReadThread.Abort()
End If
Catch e As Exception
End Try
Try
If Not _Socket Is Nothing AndAlso _Socket.Connected Then
_Socket.Close()
Catch e As Exception
End Try
_ReadThread = Nothing
_Socket = Nothing
_Closing = False
_StopThread = Nothing
OnConnectionClosed()
Catch e As Exception
OnError(e)
End Try
End Sub
#End Region
#Region " OnEvent"
Protected Overridable Sub OnError(ByRef pErr As Exception) 'If 2 errors
in diff threads?
Try
If Not _InError Then
_InError = True
Close()
_InError = False
End If
RaiseEvent Error(Me, pErr)
Catch e As Exception
Throw e
End Try
End Sub
Protected Sub OnTimeOut()
Try
RaiseEvent TimeOut(Me)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub OnCouldntConnect()
Try
RaiseEvent CouldntConnect(Me)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub OnConnectionClosed()
Try
RaiseEvent ConnectionClosed(Me)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub OnConnectionOpened()
Try
RaiseEvent ConnectionOpened(Me)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub OnMessageReceived(ByRef data As Message)
Try
RaiseEvent DataReceived(Me, data)
Catch e As Exception
OnError(e)
End Try
End Sub
#End Region
Private Sub SetReadName(ByRef pName As String)
If Not _ReadThread Is Nothing AndAlso _ReadThread.Name Is Nothing
Then _ReadThread.Name = pName
End Sub
End Class
This looks like a long mail, but at the end of this post is my socket
wrapper attached.
I want to make a timeout procedure that starts counting down after the
socketbuffer is empty.
This connection is being used to transmit data following a RFC so I cann't
create a control protocol that tells me the data was received.
(And even if I could, I want the timeout procedure to start after I send all
data, because that makes for me the most sense. (say I am sending 128mb the
socket will take longer sending then the timeout interval))
Any questions/remarks, NOT related to my question, pls ask directly via
email, dont post on the news server because It toke me alot of effort to
create this post.
Sample case:
if u send 1 byte from a client in Canada to a server in Australia with a 28k
modem thats being shared by an office of 30 people connected to the slowest
profider. (etc.)
What I want to say is that 1 byte may take a couple of minutes, and I use 1
byte as an
example because I don't want to make a question more complicated.
TCP/IP is a async protocol, but due to the Berkley Connection engine it
keeps track of what was send and received and what was not, so when there is
a packet loss it will send again.
So a socket keeps the data sequential, and if we are optimistic, the only
thing that can go wrong is a socket error.
There are three stadiums(simplified):
(A) My object sends to the Winsock, (buffer is being fed, no data on the
network, no data on the remote point)
(B) Winsock processes his buffer and sends on the network and waits for a
confirment that the package is succesfull transmitted(buffer is 'empty',
data on the network, no data on the remote point)
(C) All data is correctly processed and transported (buffer is truely empty,
no data on the network,data on the remote point)
Relative to the Sample case:
I achieve (A) ofcourse, I would really want to know (C), but I would be
satisfied with (B). I know (B) can be achieved, I hope (C) is too.
VB.NET FrameWork 2003(all patched and updated):
I use the System.Net.Sockets to send/receive data (no
tcpclient/tcplistener), I made a receivethread in my wrapper, the
receivethread loops/sleeps while waiting for data and then fires a
datareceived event.
Within the waitingloop there is a timeout function but this doesn't work
properly (It will never timeout).
When I send by System.Net.Sockets.Socket.Send(buffer()) (<--this can be
10Mb) then it imitially returns to my thread, so the (internal) Send method
buffers it.
The System.Net.Sockets.Socket is a wrapper around the Win32 Socket 2 API's,
it makes internal calls to those api's, so I started reading if they forgot
implementing some functions, but they are all implemented.
I tried:
- The beginSend/EndSend (Async way with callback when command is finished)
This calls within the async object the Socket.Send method, so its no
help, I can better do Socket.Send myself.
- The Socket.Blocking Property, it only blocks the Receive method,
Socket.Send goes directly in the buffer and then it returns immitially.
- Socket.Poll Method, returns the accessrights of the socket, "may I use
this socket to write?"
-
getSocketOption(Socket/TCP/IP,SendBuffer/ReceiveBuffer/SendLowWater/ReceiveL
owWater/SendTimeout/ReceiveTimeout) Method
Throws an Exception
MyWrapper.vb:
Imports System
Imports System.Net
Imports System.Net.Sockets
Imports System.IO
Imports System.Collections
Imports System.Threading
Imports System.Diagnostics
Public Class SmartConnection
Public Event ConnectionOpened(ByVal pMe As SmartConnection)
Public Event DataReceived(ByVal pMe As SmartConnection, ByVal Data As
Message)
Public Event CouldntConnect(ByVal pMe As SmartConnection)
Public Event ConnectionClosed(ByVal pMe As SmartConnection)
Public Event [Error](ByVal pMe As SmartConnection, ByVal pErr As
Exception)
Public Event TimeOut(ByVal pme As SmartConnection)
Private _Socket As Socket
Private _ReadThread As Thread
Private _StopThread As Thread 'Lookup threadingpool
Private _Closing As Boolean = False
Private _InError As Boolean = False
Private _lport As Long
Private lasttimeout As Long
Private pHost As String
Private pPort As Long
Private pRead As Boolean
Private pTimeout As Long
Private _Iswriting As Boolean = False
Protected Overrides Sub Finalize()
_ReadThread = Nothing
_StopThread = Nothing
_Socket = Nothing
MyBase.Finalize()
End Sub
#Region " Properties"
Public ReadOnly Property IsClosing() As Boolean
Get
IsClosing = (_Closing Or _Socket Is Nothing)
End Get
End Property
Public ReadOnly Property Connected() As Boolean
Get
Try
Connected = ((Not IsClosing) AndAlso _Socket.Connected =
True)
Catch e As Exception
OnError(e)
End Try
End Get
End Property
Protected ReadOnly Property Receiving() As Boolean
Get
Try
If Not Connected Then Throw New Exception("Socket is not
connected")
Receiving = ((Not _ReadThread Is Nothing) AndAlso
_ReadThread.IsAlive)
Catch e As Exception
OnError(e)
End Try
End Get
End Property
Public ReadOnly Property IPlocal() As String
Get
Try
If Connected Then IPlocal = EP2IPS(_Socket.LocalEndPoint)
Catch e As Exception
OnError(e)
End Try
End Get
End Property
Public ReadOnly Property IPremote() As String
Get
Try
If Connected Then IPremote = EP2IPS(_Socket.RemoteEndPoint)
Catch e As Exception
OnError(e)
End Try
End Get
End Property
#End Region
#Region " Connect"
Public Overridable Sub ConnectTo(ByRef hostName As String, ByRef port As
Long, Optional ByVal timeout As Long = 0)
Try
StartConnect(hostName, port, timeout, True)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub ConnectToWithoutReading(ByRef hostName As String, ByRef
port As Long, Optional ByVal timeout As Long = 0)
Try
StartConnect(hostName, port, timeout, False)
Catch e As Exception
OnError(e)
End Try
End Sub
Private Sub StartConnect(ByRef hostName As String, ByRef port As Long,
ByRef timeout As Long, ByRef read As Boolean)
Try
If Not _ReadThread Is Nothing Then Throw New Exception("Already
trying to connect")
_ReadThread = New Thread(AddressOf ConnectThread)
pHost = hostName : pPort = port : pRead = read : pTimeout =
timeout
_ReadThread.Start()
Catch e As Exception
OnError(e)
End Try
End Sub
Private Sub ConnectThread()
Try
If pHost = "" Then Throw New ArgumentNullException("hostname")
If pPort < IPEndPoint.MinPort Or pPort > IPEndPoint.MaxPort Then
Throw New ArgumentOutOfRangeException("port", "ArgRange_Port")
_Socket = New Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp)
Try
_Socket.Blocking = True
_Socket.Connect(New
IPEndPoint(Dns.Resolve(pHost).AddressList(0), pPort))
_lport = CType(_Socket.LocalEndPoint, IPEndPoint).Port
If Not pRead Then
SetReadName("SC.Read[PreConnect]")
_ReadThread = Nothing
Else
SetReadName("SC.EarlyRead[" & _lport & "]")
End If
OnConnectionOpened()
If pRead Then Receive()
Catch e As SocketException 'e.ErrorCode = 10061
SetReadName("SC.Read[NoConnect]")
_ReadThread = Nothing
OnCouldntConnect()
Close()
End Try
Catch e As Exception
SetReadName("SC.Read[Error]")
_ReadThread = Nothing
OnError(e)
End Try
End Sub
#End Region
#Region " Receive"
Protected Sub StartReceive()
Try
If Receiving Then Throw New Exception("Receiving was already
started")
_ReadThread = New Thread(AddressOf Receive)
SetReadName("SC.LateRead[" & _lport & "]")
_ReadThread.Start()
Catch e As Exception
OnError(e)
End Try
End Sub
Private Sub Receive()
Dim i As Long
Dim b() As Byte
'Dim ds As String, dt As String
Try
Do While Connected
If pTimeout > 0 Then lasttimeout = CurrTick() + pTimeout
Do While _Socket.Available = 0
'dt = ds
'ds = "@" & _lport & ","
'ds += _Socket.GetSocketOption(SocketOptionLevel.Socket,
SocketOptionName.SendBuffer) & ","
'ds += _Socket.GetSocketOption(SocketOptionLevel.Socket,
SocketOptionName.SendLowWater) & ","
'ds += _Socket.GetSocketOption(SocketOptionLevel.Socket,
SocketOptionName.SendTimeout)
'Debug.WriteLineIf(dt <> ds, ds)
_ReadThread.Sleep(ReceiveWait)
If IsClosing Then Exit Sub
If _Socket.Poll(0, SelectMode.SelectError) Then
'System.Runtime.InteropServices.Marshal.GetLastWin32Error())
'_Socket.GetSocketOption(SocketOptionLevel.IP,
SocketOptionName.Error)
OnError(New Exception("Socket Error"))
End If
If pTimeout > 0 Then
'If _Socket.Poll(0, SelectMode.SelectWrite) Then
'lasttimeout = CurrTick() + pTimeout
'Else
If lasttimeout <= CurrTick() Then
OnTimeOut()
Close()
Exit Sub
End If
'Endif
End If
Loop
ReDim b(_Socket.Available - 1)
'SyncLock _Socket
i = _Socket.Receive(b, SocketFlags.None)
'End SyncLock
If i < b.Length Then ReDim b(i - 1)
OnMessageReceived(New Message(b))
b = Nothing
Loop
Catch e As ThreadAbortException
Exit Sub
Catch e As Exception
OnError(e)
End Try
End Sub
#End Region
#Region " Send"
Public Overridable Overloads Sub Send(ByRef data As String)
Try
Send(getbytes(data))
Catch e As Exception
OnError(e)
End Try
End Sub
Public Overridable Overloads Sub Send(ByRef data() As Byte)
Try
If Not Connected Then Throw New Exception("Socket isn't
connected")
_Iswriting = True
'SyncLock _Socket
_Socket.Send(data)
'End SyncLock
_Iswriting = False
Catch e As Exception
_Iswriting = False
OnError(e)
End Try
End Sub
#End Region
#Region " Close"
Public Overridable Sub Close() 'OR QUEE IT?
Try
If IsClosing Then Throw New Exception("Already is closing")
_Closing = True
_StopThread = New Thread(AddressOf DoClose)
_StopThread.Name = "SC.Stop[" & _lport & "]"
_StopThread.Start()
Catch e As Exception
OnError(e)
End Try
End Sub
Private Sub DoClose()
Try
_StopThread.Sleep(CloseWait)
Try
If Not _ReadThread Is Nothing Then
SetReadName("SC.Read[Close]")
If _ReadThread.IsAlive Then _ReadThread.Abort()
End If
Catch e As Exception
End Try
Try
If Not _Socket Is Nothing AndAlso _Socket.Connected Then
_Socket.Close()
Catch e As Exception
End Try
_ReadThread = Nothing
_Socket = Nothing
_Closing = False
_StopThread = Nothing
OnConnectionClosed()
Catch e As Exception
OnError(e)
End Try
End Sub
#End Region
#Region " OnEvent"
Protected Overridable Sub OnError(ByRef pErr As Exception) 'If 2 errors
in diff threads?
Try
If Not _InError Then
_InError = True
Close()
_InError = False
End If
RaiseEvent Error(Me, pErr)
Catch e As Exception
Throw e
End Try
End Sub
Protected Sub OnTimeOut()
Try
RaiseEvent TimeOut(Me)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub OnCouldntConnect()
Try
RaiseEvent CouldntConnect(Me)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub OnConnectionClosed()
Try
RaiseEvent ConnectionClosed(Me)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub OnConnectionOpened()
Try
RaiseEvent ConnectionOpened(Me)
Catch e As Exception
OnError(e)
End Try
End Sub
Protected Sub OnMessageReceived(ByRef data As Message)
Try
RaiseEvent DataReceived(Me, data)
Catch e As Exception
OnError(e)
End Try
End Sub
#End Region
Private Sub SetReadName(ByRef pName As String)
If Not _ReadThread Is Nothing AndAlso _ReadThread.Name Is Nothing
Then _ReadThread.Name = pName
End Sub
End Class