1 #Region "Microsoft.VisualBasic::2a9fab9bd1de50bd10e8b19354d43b3a, Microsoft.VisualBasic.Core\ApplicationServices\Tools\Network\Tcp\Persistent\Socket\WorkSocket.vb"
2
3     ' Author:
4     
5     '       asuka (amethyst.asuka@gcmodeller.org)
6     '       xie (genetics@smrucc.org)
7     '       xieguigang (xie.guigang@live.com)
8     
9     ' Copyright (c) 2018 GPL3 Licensed
10     
11     
12     ' GNU GENERAL PUBLIC LICENSE (GPL3)
13     
14     
15     ' This program is free software: you can redistribute it and/or modify
16     ' it under the terms of the GNU General Public License as published by
17     ' the Free Software Foundation, either version 3 of the License, or
18     ' (at your option) any later version.
19     
20     ' This program is distributed in the hope that it will be useful,
21     ' but WITHOUT ANY WARRANTY; without even the implied warranty of
22     ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
23     ' GNU General Public License for more details.
24     
25     ' You should have received a copy of the GNU General Public License
26     ' along with this program. If not, see <http://www.gnu.org/licenses/>.
27
28
29
30     ' /********************************************************************************/
31
32     ' Summaries:
33
34     '     Class WorkSocket
35     
36     '         Constructor: (+1 OverloadsSub New
37     '         Sub: ReadCallback, SendMessage
38     
39     
40     ' /********************************************************************************/
41
42 #End Region
43
44 Imports System.Net.Sockets
45 Imports Microsoft.VisualBasic.Net.Abstract
46 Imports Microsoft.VisualBasic.Net.Protocols
47
48 Namespace Net.Persistent.Socket
49
50     ''' <summary>
51     ''' 长连接之中只是进行消息的发送处理,并不保证数据能够被接收到
52     ''' </summary>
53     Public Class WorkSocket : Inherits StateObject
54         Public ExceptionHandle As Abstract.ExceptionHandler
55         Public ForceCloseHandle As ForceCloseHandle
56         Public ReadOnly ConnectTime As Date = Now
57         Public TotalBytes As Double
58
59         Sub New(Socket As StateObject)
60             Me.ChunkBuffer = Socket.ChunkBuffer
61             Me.readBuffer = Socket.readBuffer
62             Me.workSocket = Socket.workSocket
63         End Sub
64
65         ''' <summary>
66         ''' DO_NOTHING
67         ''' </summary>
68         ''' <param name="ar"></param>
69         Public Sub ReadCallback(ar As IAsyncResult)
70             ' DO_NOTHING
71         End Sub 'ReadCallback
72
73         Public Sub SendMessage(request As RequestStream)
74             Dim byteData As Byte() = request.Serialize
75             Try
76                 Call Me.workSocket.Send(byteData, byteData.Length, SocketFlags.None)
77             Catch ex As Exception
78                 Call ForceCloseHandle(Me)
79             End Try
80         End Sub
81     End Class
82 End Namespace