diff --git a/CloudKit/Docker/Commands.vb b/CloudKit/Docker/Commands.vb
index d0b6331..25cf5d9 100644
--- a/CloudKit/Docker/Commands.vb
+++ b/CloudKit/Docker/Commands.vb
@@ -1,43 +1,43 @@
-#Region "Microsoft.VisualBasic::8ea53b995fa2693902323f5b89829565, CloudKit\Docker\Commands.vb"
-
-' Author:
-'
-' asuka (amethyst.asuka@gcmodeller.org)
-' xie (genetics@smrucc.org)
-' xieguigang (xie.guigang@live.com)
-'
-' Copyright (c) 2018 GPL3 Licensed
-'
-'
-' GNU GENERAL PUBLIC LICENSE (GPL3)
-'
-'
-' This program is free software: you can redistribute it and/or modify
-' it under the terms of the GNU General Public License as published by
-' the Free Software Foundation, either version 3 of the License, or
-' (at your option) any later version.
-'
-' This program is distributed in the hope that it will be useful,
-' but WITHOUT ANY WARRANTY; without even the implied warranty of
-' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-' GNU General Public License for more details.
-'
-' You should have received a copy of the GNU General Public License
-' along with this program. If not, see .
-
-
-
-' /********************************************************************************/
-
-' Summaries:
-
-' Module Commands
-'
-' Function: CommandHistory, PS, Run, Search
-'
-' Sub: [Stop]
-'
-' /********************************************************************************/
+#Region "Microsoft.VisualBasic::ffc19cddc95f25b000eaefc28a5f74a7, CloudKit\Docker\Commands.vb"
+
+ ' Author:
+ '
+ ' asuka (amethyst.asuka@gcmodeller.org)
+ ' xie (genetics@smrucc.org)
+ ' xieguigang (xie.guigang@live.com)
+ '
+ ' Copyright (c) 2018 GPL3 Licensed
+ '
+ '
+ ' GNU GENERAL PUBLIC LICENSE (GPL3)
+ '
+ '
+ ' This program is free software: you can redistribute it and/or modify
+ ' it under the terms of the GNU General Public License as published by
+ ' the Free Software Foundation, either version 3 of the License, or
+ ' (at your option) any later version.
+ '
+ ' This program is distributed in the hope that it will be useful,
+ ' but WITHOUT ANY WARRANTY; without even the implied warranty of
+ ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ ' GNU General Public License for more details.
+ '
+ ' You should have received a copy of the GNU General Public License
+ ' along with this program. If not, see .
+
+
+
+ ' /********************************************************************************/
+
+ ' Summaries:
+
+ ' Module Commands
+ '
+ ' Function: CommandHistory, PS, rmi, Run, Search
+ '
+ ' Sub: [Stop]
+ '
+ ' /********************************************************************************/
#End Region
diff --git a/Parallel/Extensions.vb b/Parallel/Extensions.vb
index 64edc2e..0a03a41 100644
--- a/Parallel/Extensions.vb
+++ b/Parallel/Extensions.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::97ba65c8233cda19188f383166f0b14b, Parallel\Extensions.vb"
+#Region "Microsoft.VisualBasic::6899da998f0554355d5fe6b72ae3dc0c, Parallel\Extensions.vb"
' Author:
'
@@ -43,4 +43,3 @@
Public Module Extensions
End Module
-
diff --git a/Parallel/IpcParallel/IPCSocket.vb b/Parallel/IpcParallel/IPCSocket.vb
index 6ff53e3..46fa7d3 100644
--- a/Parallel/IpcParallel/IPCSocket.vb
+++ b/Parallel/IpcParallel/IPCSocket.vb
@@ -1,54 +1,55 @@
-#Region "Microsoft.VisualBasic::3cd47c9347dfb0bebb90110fe2139a7c, Parallel\IpcParallel\IPCSocket.vb"
-
-' Author:
-'
-' asuka (amethyst.asuka@gcmodeller.org)
-' xie (genetics@smrucc.org)
-' xieguigang (xie.guigang@live.com)
-'
-' Copyright (c) 2018 GPL3 Licensed
-'
-'
-' GNU GENERAL PUBLIC LICENSE (GPL3)
-'
-'
-' This program is free software: you can redistribute it and/or modify
-' it under the terms of the GNU General Public License as published by
-' the Free Software Foundation, either version 3 of the License, or
-' (at your option) any later version.
-'
-' This program is distributed in the hope that it will be useful,
-' but WITHOUT ANY WARRANTY; without even the implied warranty of
-' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-' GNU General Public License for more details.
-'
-' You should have received a copy of the GNU General Public License
-' along with this program. If not, see .
-
-
-
-' /********************************************************************************/
-
-' Summaries:
-
-' Class IPCSocket
-'
-' Properties: handleError, handleGetArgument, handlePOSTResult, host, HostPort
-' nargs, Protocol
-'
-' Constructor: (+1 Overloads) Sub New
-'
-' Function: GetArgumentByIndex, GetArgumentNumber, GetFirstAvailablePort, GetTask, PostError
-' PostResult, PostStart, Run
-'
-' Sub: [Stop]
-'
-' /********************************************************************************/
+#Region "Microsoft.VisualBasic::762bc5a2ac7fdb45934a6d6d89b2ab09, Parallel\IpcParallel\IPCSocket.vb"
+
+ ' Author:
+ '
+ ' asuka (amethyst.asuka@gcmodeller.org)
+ ' xie (genetics@smrucc.org)
+ ' xieguigang (xie.guigang@live.com)
+ '
+ ' Copyright (c) 2018 GPL3 Licensed
+ '
+ '
+ ' GNU GENERAL PUBLIC LICENSE (GPL3)
+ '
+ '
+ ' This program is free software: you can redistribute it and/or modify
+ ' it under the terms of the GNU General Public License as published by
+ ' the Free Software Foundation, either version 3 of the License, or
+ ' (at your option) any later version.
+ '
+ ' This program is distributed in the hope that it will be useful,
+ ' but WITHOUT ANY WARRANTY; without even the implied warranty of
+ ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ ' GNU General Public License for more details.
+ '
+ ' You should have received a copy of the GNU General Public License
+ ' along with this program. If not, see .
+
+
+
+ ' /********************************************************************************/
+
+ ' Summaries:
+
+ ' Class IPCSocket
+ '
+ ' Properties: handleGetArgument, handlePOSTResult, handleSetResult, host, HostPort
+ ' nargs, Protocol, result, socketExitCode
+ '
+ ' Constructor: (+1 Overloads) Sub New
+ '
+ ' Function: GetArgumentByIndex, GetArgumentNumber, GetFirstAvailablePort, GetTask, PostError
+ ' PostResult, PostStart, Run
+ '
+ ' Sub: [Stop]
+ '
+ ' /********************************************************************************/
#End Region
Imports System.IO
Imports System.Text
+Imports System.Threading
Imports Microsoft.VisualBasic.ComponentModel
#If netcore5 = 1 Then
Imports Microsoft.VisualBasic.ComponentModel.Collection
@@ -57,13 +58,8 @@ Imports Microsoft.VisualBasic.Net.Protocols.Reflection
Imports Microsoft.VisualBasic.Net.Tcp
Imports Microsoft.VisualBasic.Parallel
Imports Microsoft.VisualBasic.Serialization.JSON
-Imports Microsoft.VisualBasic.Linq
Imports Parallel.IpcStream
-
-#If netcore5 = 1 Then
Imports randf = Microsoft.VisualBasic.Math.RandomExtensions
-Imports System.Threading
-#End If
Public Class IPCSocket : Implements ITaskDriver
diff --git a/Parallel/IpcParallel/SlaveTask.vb b/Parallel/IpcParallel/SlaveTask.vb
index c9c0e5e..3b63ac0 100644
--- a/Parallel/IpcParallel/SlaveTask.vb
+++ b/Parallel/IpcParallel/SlaveTask.vb
@@ -1,47 +1,48 @@
-#Region "Microsoft.VisualBasic::c7901ef38489164efc1ff25498efb52f, Parallel\IpcParallel\SlaveTask.vb"
-
-' Author:
-'
-' asuka (amethyst.asuka@gcmodeller.org)
-' xie (genetics@smrucc.org)
-' xieguigang (xie.guigang@live.com)
-'
-' Copyright (c) 2018 GPL3 Licensed
-'
-'
-' GNU GENERAL PUBLIC LICENSE (GPL3)
-'
-'
-' This program is free software: you can redistribute it and/or modify
-' it under the terms of the GNU General Public License as published by
-' the Free Software Foundation, either version 3 of the License, or
-' (at your option) any later version.
-'
-' This program is distributed in the hope that it will be useful,
-' but WITHOUT ANY WARRANTY; without even the implied warranty of
-' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-' GNU General Public License for more details.
-'
-' You should have received a copy of the GNU General Public License
-' along with this program. If not, see .
-
-
-
-' /********************************************************************************/
-
-' Summaries:
-
-' Delegate Function
-'
-'
-' Class SlaveTask
-'
-' Constructor: (+1 Overloads) Sub New
-' Function: (+2 Overloads) Emit, GetValueFromStream, handleGET, handlePOST, RunTask
-'
-'
-'
-' /********************************************************************************/
+#Region "Microsoft.VisualBasic::f9dda941b56efa826aa6b892738040c4, Parallel\IpcParallel\SlaveTask.vb"
+
+ ' Author:
+ '
+ ' asuka (amethyst.asuka@gcmodeller.org)
+ ' xie (genetics@smrucc.org)
+ ' xieguigang (xie.guigang@live.com)
+ '
+ ' Copyright (c) 2018 GPL3 Licensed
+ '
+ '
+ ' GNU GENERAL PUBLIC LICENSE (GPL3)
+ '
+ '
+ ' This program is free software: you can redistribute it and/or modify
+ ' it under the terms of the GNU General Public License as published by
+ ' the Free Software Foundation, either version 3 of the License, or
+ ' (at your option) any later version.
+ '
+ ' This program is distributed in the hope that it will be useful,
+ ' but WITHOUT ANY WARRANTY; without even the implied warranty of
+ ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ ' GNU General Public License for more details.
+ '
+ ' You should have received a copy of the GNU General Public License
+ ' along with this program. If not, see .
+
+
+
+ ' /********************************************************************************/
+
+ ' Summaries:
+
+ ' Delegate Function
+ '
+ '
+ ' Class SlaveTask
+ '
+ ' Constructor: (+1 Overloads) Sub New
+ ' Function: (+2 Overloads) Emit, GetValueFromStream, handleGET, handlePOST, RunTask
+ ' startSocket
+ '
+ '
+ '
+ ' /********************************************************************************/
#End Region
diff --git a/Parallel/IpcParallel/SocketBuffer/SocketRef.vb b/Parallel/IpcParallel/SocketBuffer/SocketRef.vb
index 3591754..20e6d1e 100644
--- a/Parallel/IpcParallel/SocketBuffer/SocketRef.vb
+++ b/Parallel/IpcParallel/SocketBuffer/SocketRef.vb
@@ -1,44 +1,44 @@
-#Region "Microsoft.VisualBasic::11d09a76aa25b30fc9f2f80cf0f60145, Parallel\IpcParallel\SocketBuffer\SocketRef.vb"
-
-' Author:
-'
-' asuka (amethyst.asuka@gcmodeller.org)
-' xie (genetics@smrucc.org)
-' xieguigang (xie.guigang@live.com)
-'
-' Copyright (c) 2018 GPL3 Licensed
-'
-'
-' GNU GENERAL PUBLIC LICENSE (GPL3)
-'
-'
-' This program is free software: you can redistribute it and/or modify
-' it under the terms of the GNU General Public License as published by
-' the Free Software Foundation, either version 3 of the License, or
-' (at your option) any later version.
-'
-' This program is distributed in the hope that it will be useful,
-' but WITHOUT ANY WARRANTY; without even the implied warranty of
-' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-' GNU General Public License for more details.
-'
-' You should have received a copy of the GNU General Public License
-' along with this program. If not, see .
-
-
-
-' /********************************************************************************/
-
-' Summaries:
-
-' Class SocketRef
-'
-' Properties: address
-'
-' Function: CreateReference, GetSocket, Open, ToString, WriteBuffer
-'
-'
-' /********************************************************************************/
+#Region "Microsoft.VisualBasic::feb839fe206c8518a09ae7577064ddbf, Parallel\IpcParallel\SocketBuffer\SocketRef.vb"
+
+ ' Author:
+ '
+ ' asuka (amethyst.asuka@gcmodeller.org)
+ ' xie (genetics@smrucc.org)
+ ' xieguigang (xie.guigang@live.com)
+ '
+ ' Copyright (c) 2018 GPL3 Licensed
+ '
+ '
+ ' GNU GENERAL PUBLIC LICENSE (GPL3)
+ '
+ '
+ ' This program is free software: you can redistribute it and/or modify
+ ' it under the terms of the GNU General Public License as published by
+ ' the Free Software Foundation, either version 3 of the License, or
+ ' (at your option) any later version.
+ '
+ ' This program is distributed in the hope that it will be useful,
+ ' but WITHOUT ANY WARRANTY; without even the implied warranty of
+ ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ ' GNU General Public License for more details.
+ '
+ ' You should have received a copy of the GNU General Public License
+ ' along with this program. If not, see .
+
+
+
+ ' /********************************************************************************/
+
+ ' Summaries:
+
+ ' Class SocketRef
+ '
+ ' Properties: address
+ '
+ ' Function: CreateReference, GetSocket, Open, ToString, WriteBuffer
+ '
+ '
+ ' /********************************************************************************/
#End Region
diff --git a/Parallel/IpcParallel/Stream/EmitStreamAttribute.vb b/Parallel/IpcParallel/Stream/EmitStreamAttribute.vb
new file mode 100644
index 0000000..44bf7c4
--- /dev/null
+++ b/Parallel/IpcParallel/Stream/EmitStreamAttribute.vb
@@ -0,0 +1,73 @@
+#Region "Microsoft.VisualBasic::649d6beaad89002ea8a513be53a3967f, Parallel\IpcParallel\Stream\EmitStreamAttribute.vb"
+
+ ' Author:
+ '
+ ' asuka (amethyst.asuka@gcmodeller.org)
+ ' xie (genetics@smrucc.org)
+ ' xieguigang (xie.guigang@live.com)
+ '
+ ' Copyright (c) 2018 GPL3 Licensed
+ '
+ '
+ ' GNU GENERAL PUBLIC LICENSE (GPL3)
+ '
+ '
+ ' This program is free software: you can redistribute it and/or modify
+ ' it under the terms of the GNU General Public License as published by
+ ' the Free Software Foundation, either version 3 of the License, or
+ ' (at your option) any later version.
+ '
+ ' This program is distributed in the hope that it will be useful,
+ ' but WITHOUT ANY WARRANTY; without even the implied warranty of
+ ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ ' GNU General Public License for more details.
+ '
+ ' You should have received a copy of the GNU General Public License
+ ' along with this program. If not, see .
+
+
+
+ ' /********************************************************************************/
+
+ ' Summaries:
+
+ ' Class EmitStreamAttribute
+ '
+ ' Properties: Handler
+ '
+ ' Constructor: (+1 Overloads) Sub New
+ '
+ ' Interface IEmitStream
+ '
+ ' Function: BufferInMemory, ReadBuffer, (+2 Overloads) WriteBuffer
+ '
+ ' /********************************************************************************/
+
+#End Region
+
+Imports System.IO
+
+
+Public Class EmitStreamAttribute : Inherits Attribute
+
+ Public ReadOnly Property Handler As Type
+
+ Sub New(handler As Type)
+ Me.Handler = handler
+ End Sub
+
+End Class
+
+Public Interface IEmitStream
+
+ '''
+ ''' serialize into a memory stream buffer?
+ '''
+ '''
+ '''
+ Function BufferInMemory(obj As Object) As Boolean
+ Function WriteBuffer(obj As Object, file As Stream) As Boolean
+ Function WriteBuffer(obj As Object) As Stream
+ Function ReadBuffer(file As Stream) As Object
+
+End Interface
diff --git a/Parallel/IpcParallel/Stream/StreamEmit.vb b/Parallel/IpcParallel/Stream/StreamEmit.vb
index ee1d316..2b418f7 100644
--- a/Parallel/IpcParallel/Stream/StreamEmit.vb
+++ b/Parallel/IpcParallel/Stream/StreamEmit.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::e147992baf842713336a08ed275e0487, Parallel\IpcParallel\Stream\StreamEmit.vb"
+#Region "Microsoft.VisualBasic::fd22cd7fc0597f451c12b76376ad5261, Parallel\IpcParallel\Stream\StreamEmit.vb"
' Author:
'
@@ -34,7 +34,7 @@
' Class StreamEmit
'
' Constructor: (+1 Overloads) Sub New
- ' Function: (+2 Overloads) Emit, (+2 Overloads) handleCreate, handleSerialize
+ ' Function: (+2 Overloads) Emit, getHandler, (+2 Overloads) handleCreate, handleSerialize
'
'
' /********************************************************************************/
@@ -42,9 +42,12 @@
#End Region
Imports System.IO
+Imports System.Reflection
+Imports Microsoft.VisualBasic.Emit.Delegates
+Imports Microsoft.VisualBasic.Linq
Imports Microsoft.VisualBasic.MIME.application.json
Imports Microsoft.VisualBasic.MIME.application.json.BSON
-Imports Microsoft.VisualBasic.Scripting.MetaData
+Imports TypeInfo = Microsoft.VisualBasic.Scripting.MetaData.TypeInfo
Namespace IpcStream
@@ -52,6 +55,7 @@ Namespace IpcStream
ReadOnly toBuffers As New Dictionary(Of Type, toBuffer)
ReadOnly loadBuffers As New Dictionary(Of Type, loadBuffer)
+ ReadOnly emitCache As New Dictionary(Of Type, IEmitStream)
Sub New()
For Each [handle] In EmitHandler.PopulatePrimitiveHandles
@@ -82,8 +86,17 @@ Namespace IpcStream
If emit = StreamMethods.Auto Then
If loadBuffers.ContainsKey(type) Then
Return loadBuffers(type)(buf)
+ ElseIf emitCache.ContainsKey(type) Then
+ Return emitCache(type).ReadBuffer(buf)
Else
- Return BSONFormat.Load(buf).CreateObject(type)
+ Dim handler As IEmitStream = getHandler(type)
+
+ If Not handler Is Nothing Then
+ emitCache.Add(type, handler)
+ Return emitCache(type).ReadBuffer(buf)
+ Else
+ Return BSONFormat.Load(buf).CreateObject(type)
+ End If
End If
ElseIf emit = StreamMethods.BSON Then
Return BSONFormat.Load(buf).CreateObject(type)
@@ -94,17 +107,50 @@ Namespace IpcStream
End If
End Function
+ Private Function getHandler(type As Type) As IEmitStream
+ Dim attr As EmitStreamAttribute = CType(type, System.Reflection.TypeInfo).GetCustomAttributes(Of EmitStreamAttribute).FirstOrDefault
+
+ If attr Is Nothing Then
+ Return Nothing
+ End If
+
+ type = attr.Handler
+
+ If Not type.ImplementInterface(Of IEmitStream) Then
+ Return Nothing
+ Else
+ Return Activator.CreateInstance(type)
+ End If
+ End Function
+
Public Function handleSerialize(param As Object) As ObjectStream
Dim type As Type = param.GetType
+ Dim method As StreamMethods
+ Dim typeinfo As New TypeInfo(type, fullpath:=True)
+ Dim buf As Stream
If toBuffers.ContainsKey(type) Then
- Return New ObjectStream(New TypeInfo(type, fullpath:=True), StreamMethods.Emit, toBuffers(type)(param))
+ method = StreamMethods.Emit
+ buf = toBuffers(type)(param)
+ ElseIf emitCache.ContainsKey(type) Then
+ method = StreamMethods.Auto
+ buf = emitCache(type).WriteBuffer(param)
Else
- Dim element = type.GetJsonElement(param, New JSONSerializerOptions)
- Dim buf As Stream = BSONFormat.SafeGetBuffer(element)
+ Dim handler As IEmitStream = getHandler(type)
- Return New ObjectStream(New TypeInfo(type, fullpath:=True), StreamMethods.BSON, buf)
+ If Not handler Is Nothing Then
+ emitCache.Add(type, handler)
+ method = StreamMethods.Auto
+ buf = handler.WriteBuffer(param)
+ Else
+ buf = type _
+ .GetJsonElement(param, New JSONSerializerOptions) _
+ .DoCall(AddressOf BSONFormat.SafeGetBuffer)
+ method = StreamMethods.BSON
+ End If
End If
+
+ Return New ObjectStream(typeinfo, method, buf)
End Function
End Class
End Namespace
diff --git a/Parallel/Parallel.vbproj b/Parallel/Parallel.vbproj
index b5fc2f5..924bb7f 100644
--- a/Parallel/Parallel.vbproj
+++ b/Parallel/Parallel.vbproj
@@ -244,6 +244,7 @@
+
diff --git a/Parallel/ThreadTask/ThreadTask.vb b/Parallel/ThreadTask/ThreadTask.vb
index e3a87e2..e5b3af3 100644
--- a/Parallel/ThreadTask/ThreadTask.vb
+++ b/Parallel/ThreadTask/ThreadTask.vb
@@ -1,44 +1,44 @@
-#Region "Microsoft.VisualBasic::ab043b5d85d49c6a5816812cec0a2a9e, Parallel\ThreadTask\ThreadTask.vb"
-
-' Author:
-'
-' asuka (amethyst.asuka@gcmodeller.org)
-' xie (genetics@smrucc.org)
-' xieguigang (xie.guigang@live.com)
-'
-' Copyright (c) 2018 GPL3 Licensed
-'
-'
-' GNU GENERAL PUBLIC LICENSE (GPL3)
-'
-'
-' This program is free software: you can redistribute it and/or modify
-' it under the terms of the GNU General Public License as published by
-' the Free Software Foundation, either version 3 of the License, or
-' (at your option) any later version.
-'
-' This program is distributed in the hope that it will be useful,
-' but WITHOUT ANY WARRANTY; without even the implied warranty of
-' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
-' GNU General Public License for more details.
-'
-' You should have received a copy of the GNU General Public License
-' along with this program. If not, see .
-
-
-
-' /********************************************************************************/
-
-' Summaries:
-
-' Class ThreadTask
-'
-' Constructor: (+1 Overloads) Sub New
-' Function: (+2 Overloads) CreateThreads, GetCompleteThread, GetEmptyThread, RunParallel, ToString
-' WithDegreeOfParallelism
-'
-'
-' /********************************************************************************/
+#Region "Microsoft.VisualBasic::7cd6d6a4e9253d42d69cae2e21b60f99, Parallel\ThreadTask\ThreadTask.vb"
+
+ ' Author:
+ '
+ ' asuka (amethyst.asuka@gcmodeller.org)
+ ' xie (genetics@smrucc.org)
+ ' xieguigang (xie.guigang@live.com)
+ '
+ ' Copyright (c) 2018 GPL3 Licensed
+ '
+ '
+ ' GNU GENERAL PUBLIC LICENSE (GPL3)
+ '
+ '
+ ' This program is free software: you can redistribute it and/or modify
+ ' it under the terms of the GNU General Public License as published by
+ ' the Free Software Foundation, either version 3 of the License, or
+ ' (at your option) any later version.
+ '
+ ' This program is distributed in the hope that it will be useful,
+ ' but WITHOUT ANY WARRANTY; without even the implied warranty of
+ ' MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ ' GNU General Public License for more details.
+ '
+ ' You should have received a copy of the GNU General Public License
+ ' along with this program. If not, see .
+
+
+
+ ' /********************************************************************************/
+
+ ' Summaries:
+
+ ' Class ThreadTask
+ '
+ ' Constructor: (+1 Overloads) Sub New
+ ' Function: (+2 Overloads) CreateThreads, GetCompleteThread, GetEmptyThread, ParallelTask, RunParallel
+ ' SequenceTask, ToString, WithDegreeOfParallelism
+ '
+ '
+ ' /********************************************************************************/
#End Region
diff --git a/Rpc/BindingProtocols/ConnectorExtensions.vb b/Rpc/BindingProtocols/ConnectorExtensions.vb
index c591ef1..d2d06ab 100644
--- a/Rpc/BindingProtocols/ConnectorExtensions.vb
+++ b/Rpc/BindingProtocols/ConnectorExtensions.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::90c2c118cd42290ae3951ed1ae567db7, Rpc\BindingProtocols\ConnectorExtensions.vb"
+#Region "Microsoft.VisualBasic::e5588b71b9715e18e2f44f39c77e042d, Rpc\BindingProtocols\ConnectorExtensions.vb"
' Author:
'
@@ -118,4 +118,3 @@ Namespace Rpc.BindingProtocols
End Function
End Module
End Namespace
-
diff --git a/Rpc/BindingProtocols/Protocol.vb b/Rpc/BindingProtocols/Protocol.vb
index dbe483a..60b18ee 100644
--- a/Rpc/BindingProtocols/Protocol.vb
+++ b/Rpc/BindingProtocols/Protocol.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::3c8e2339b4bd3e052a423136336f7d94, Rpc\BindingProtocols\Protocol.vb"
+#Region "Microsoft.VisualBasic::3fd0c1078a5c1616f65bdb2d1c57de97, Rpc\BindingProtocols\Protocol.vb"
' Author:
'
@@ -43,7 +43,6 @@
#End Region
-
Namespace Rpc.BindingProtocols
'''
''' constants of port mapper protocol
@@ -60,4 +59,3 @@ Namespace Rpc.BindingProtocols
UDP = 17
End Enum
End Namespace
-
diff --git a/Rpc/BindingProtocols/ProtocolFamily.vb b/Rpc/BindingProtocols/ProtocolFamily.vb
index 2846e61..0167e9a 100644
--- a/Rpc/BindingProtocols/ProtocolFamily.vb
+++ b/Rpc/BindingProtocols/ProtocolFamily.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::a0a77eb7c747563c67b59e9b92fb53bb, Rpc\BindingProtocols\ProtocolFamily.vb"
+#Region "Microsoft.VisualBasic::c45b7b8efa66bdc94277dc10e6efce06, Rpc\BindingProtocols\ProtocolFamily.vb"
' Author:
'
@@ -40,7 +40,6 @@
#End Region
-
Namespace Rpc.BindingProtocols
'''
''' Protocol family (rpcb_entry.r_nc_protofmly): This identifies the family to which the protocol belongs.
@@ -142,4 +141,3 @@ Namespace Rpc.BindingProtocols
Public Const NC_GOSIP As String = "gosip"
End Module
End Namespace
-
diff --git a/Rpc/BindingProtocols/ProtocolName.vb b/Rpc/BindingProtocols/ProtocolName.vb
index 50521d5..ded00c7 100644
--- a/Rpc/BindingProtocols/ProtocolName.vb
+++ b/Rpc/BindingProtocols/ProtocolName.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::4194e470c8ec3f98103175893a3bcfc4, Rpc\BindingProtocols\ProtocolName.vb"
+#Region "Microsoft.VisualBasic::d3c271bd4d7e47931e9d56ae2c6003a4, Rpc\BindingProtocols\ProtocolName.vb"
' Author:
'
@@ -40,7 +40,6 @@
#End Region
-
Namespace Rpc.BindingProtocols
'''
''' Protocol name (rpcb_entry.r_nc_proto): This identifies a protocol within a family.
@@ -65,4 +64,3 @@ Namespace Rpc.BindingProtocols
Public Const NC_ICMP As String = "icmp"
End Module
End Namespace
-
diff --git a/Rpc/BindingProtocols/TaskBuilders/BaseRpcBind.vb b/Rpc/BindingProtocols/TaskBuilders/BaseRpcBind.vb
index 96c6474..8020763 100644
--- a/Rpc/BindingProtocols/TaskBuilders/BaseRpcBind.vb
+++ b/Rpc/BindingProtocols/TaskBuilders/BaseRpcBind.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::eb26db07836d0ba66d2c9e96d0277915, Rpc\BindingProtocols\TaskBuilders\BaseRpcBind.vb"
+#Region "Microsoft.VisualBasic::f1b3521b15d77b06df943a11d2d828cc, Rpc\BindingProtocols\TaskBuilders\BaseRpcBind.vb"
' Author:
'
@@ -122,4 +122,3 @@ Namespace Rpc.BindingProtocols.TaskBuilders
End Function
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/TaskBuilders/BaseTaskBuilder.vb b/Rpc/BindingProtocols/TaskBuilders/BaseTaskBuilder.vb
index a947a7c..5c2f655 100644
--- a/Rpc/BindingProtocols/TaskBuilders/BaseTaskBuilder.vb
+++ b/Rpc/BindingProtocols/TaskBuilders/BaseTaskBuilder.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::5b38f1431837ca95783f3aa7b059070c, Rpc\BindingProtocols\TaskBuilders\BaseTaskBuilder.vb"
+#Region "Microsoft.VisualBasic::1e9d6c6c0c23218b8562f5d016091a90, Rpc\BindingProtocols\TaskBuilders\BaseTaskBuilder.vb"
' Author:
'
@@ -100,4 +100,3 @@ Namespace Rpc.BindingProtocols.TaskBuilders
End Function
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/TaskBuilders/PortMapper.vb b/Rpc/BindingProtocols/TaskBuilders/PortMapper.vb
index 72e7841..1e85bc1 100644
--- a/Rpc/BindingProtocols/TaskBuilders/PortMapper.vb
+++ b/Rpc/BindingProtocols/TaskBuilders/PortMapper.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::29666658658663add6ba9dc83d448c79, Rpc\BindingProtocols\TaskBuilders\PortMapper.vb"
+#Region "Microsoft.VisualBasic::b9ee3eee7ba86ac3d3dc7da89443fc04, Rpc\BindingProtocols\TaskBuilders\PortMapper.vb"
' Author:
'
@@ -137,4 +137,3 @@ Namespace Rpc.BindingProtocols.TaskBuilders
End Function
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/TaskBuilders/RpcBindV3.vb b/Rpc/BindingProtocols/TaskBuilders/RpcBindV3.vb
index f0e073c..53b4428 100644
--- a/Rpc/BindingProtocols/TaskBuilders/RpcBindV3.vb
+++ b/Rpc/BindingProtocols/TaskBuilders/RpcBindV3.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::ec87a30153cb0fede9ce1daba57828b2, Rpc\BindingProtocols\TaskBuilders\RpcBindV3.vb"
+#Region "Microsoft.VisualBasic::260d607f3869f6875a6192de18fed731, Rpc\BindingProtocols\TaskBuilders\RpcBindV3.vb"
' Author:
'
@@ -91,4 +91,3 @@ Namespace Rpc.BindingProtocols.TaskBuilders
End Function
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/TaskBuilders/RpcBindV4.vb b/Rpc/BindingProtocols/TaskBuilders/RpcBindV4.vb
index d85fbfc..0abc8ff 100644
--- a/Rpc/BindingProtocols/TaskBuilders/RpcBindV4.vb
+++ b/Rpc/BindingProtocols/TaskBuilders/RpcBindV4.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::8a0a38428b215a5424c73b8470a8281d, Rpc\BindingProtocols\TaskBuilders\RpcBindV4.vb"
+#Region "Microsoft.VisualBasic::2ab1aea23a36baaa9ad03c3c0ba788ab, Rpc\BindingProtocols\TaskBuilders\RpcBindV4.vb"
' Author:
'
@@ -126,4 +126,3 @@ Namespace Rpc.BindingProtocols.TaskBuilders
End Function
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/TransportSemantics.vb b/Rpc/BindingProtocols/TransportSemantics.vb
index a1e48e2..884793c 100644
--- a/Rpc/BindingProtocols/TransportSemantics.vb
+++ b/Rpc/BindingProtocols/TransportSemantics.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::f74e13a226a5afa9b873abd8be02b82d, Rpc\BindingProtocols\TransportSemantics.vb"
+#Region "Microsoft.VisualBasic::8abd96f6c0ef44b08c8cb28884b15e68, Rpc\BindingProtocols\TransportSemantics.vb"
' Author:
'
@@ -40,7 +40,6 @@
#End Region
-
Namespace Rpc.BindingProtocols
'''
''' Transport semantics (rpcb_entry.r_nc_semantics): This represents the type of transport.
@@ -65,4 +64,3 @@ Namespace Rpc.BindingProtocols
Public Const NC_TPI_RAW As ULong = 4
End Module
End Namespace
-
diff --git a/Rpc/BindingProtocols/call_args.vb b/Rpc/BindingProtocols/call_args.vb
index f44a0c8..e00475d 100644
--- a/Rpc/BindingProtocols/call_args.vb
+++ b/Rpc/BindingProtocols/call_args.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::91035abf1c2a72e43487e5535e1d26f5, Rpc\BindingProtocols\call_args.vb"
+#Region "Microsoft.VisualBasic::8308f7e1795515441aaf357dbae81c2a, Rpc\BindingProtocols\call_args.vb"
' Author:
'
@@ -73,4 +73,3 @@ Namespace Rpc.BindingProtocols
Public args As Byte()
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/call_result.vb b/Rpc/BindingProtocols/call_result.vb
index 0023eac..75419c9 100644
--- a/Rpc/BindingProtocols/call_result.vb
+++ b/Rpc/BindingProtocols/call_result.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::3c808964aaddb4e382ea67deae5b910d, Rpc\BindingProtocols\call_result.vb"
+#Region "Microsoft.VisualBasic::03ff050c7d69ea60b7a7204035fd718d, Rpc\BindingProtocols\call_result.vb"
' Author:
'
@@ -61,4 +61,3 @@ Namespace Rpc.BindingProtocols
Public res As Byte()
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/mapping.vb b/Rpc/BindingProtocols/mapping.vb
index e15861d..7e2adf2 100644
--- a/Rpc/BindingProtocols/mapping.vb
+++ b/Rpc/BindingProtocols/mapping.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::0fe15f75d20e135d78954f95827c63fa, Rpc\BindingProtocols\mapping.vb"
+#Region "Microsoft.VisualBasic::0c0f35a4b3b9cc9c8acdc27061b76a71, Rpc\BindingProtocols\mapping.vb"
' Author:
'
@@ -80,4 +80,3 @@ Namespace Rpc.BindingProtocols
End Function
End Structure
End Namespace
-
diff --git a/Rpc/BindingProtocols/netbuf.vb b/Rpc/BindingProtocols/netbuf.vb
index 60e5a44..80d5385 100644
--- a/Rpc/BindingProtocols/netbuf.vb
+++ b/Rpc/BindingProtocols/netbuf.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::5fcc84acd31b708738eda919e966568e, Rpc\BindingProtocols\netbuf.vb"
+#Region "Microsoft.VisualBasic::ffdbfff314cbbd439f5d9605be7da648, Rpc\BindingProtocols\netbuf.vb"
' Author:
'
@@ -60,4 +60,3 @@ Namespace Rpc.BindingProtocols
Public buf As Byte()
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/rpcb.vb b/Rpc/BindingProtocols/rpcb.vb
index 40889f7..840ac9b 100644
--- a/Rpc/BindingProtocols/rpcb.vb
+++ b/Rpc/BindingProtocols/rpcb.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::cde1ec0bd9b296bc5dfddcfa66ab1f45, Rpc\BindingProtocols\rpcb.vb"
+#Region "Microsoft.VisualBasic::6497e581883477f797cd1dcde4296a11, Rpc\BindingProtocols\rpcb.vb"
' Author:
'
@@ -78,4 +78,3 @@ Namespace Rpc.BindingProtocols
Public r_owner As String
End Structure
End Namespace
-
diff --git a/Rpc/BindingProtocols/rpcb_entry.vb b/Rpc/BindingProtocols/rpcb_entry.vb
index 9b70972..a55afb8 100644
--- a/Rpc/BindingProtocols/rpcb_entry.vb
+++ b/Rpc/BindingProtocols/rpcb_entry.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::2c52b326297aef05747b2e47e27c279d, Rpc\BindingProtocols\rpcb_entry.vb"
+#Region "Microsoft.VisualBasic::c8445eafe71d16b729cff7dc680113ac, Rpc\BindingProtocols\rpcb_entry.vb"
' Author:
'
@@ -76,4 +76,3 @@ Namespace Rpc.BindingProtocols
Public r_nc_proto As String
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/rpcb_rmtcallargs.vb b/Rpc/BindingProtocols/rpcb_rmtcallargs.vb
index c8cad57..9ee3d60 100644
--- a/Rpc/BindingProtocols/rpcb_rmtcallargs.vb
+++ b/Rpc/BindingProtocols/rpcb_rmtcallargs.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::cb29fa988f436f2366c3dbc089fa7344, Rpc\BindingProtocols\rpcb_rmtcallargs.vb"
+#Region "Microsoft.VisualBasic::4083fbf912c7f2085145f8c3f8e8ab25, Rpc\BindingProtocols\rpcb_rmtcallargs.vb"
' Author:
'
@@ -70,4 +70,3 @@ Namespace Rpc.BindingProtocols
Public args As Byte()
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/rpcb_rmtcallres.vb b/Rpc/BindingProtocols/rpcb_rmtcallres.vb
index 61bb1d3..7daad8f 100644
--- a/Rpc/BindingProtocols/rpcb_rmtcallres.vb
+++ b/Rpc/BindingProtocols/rpcb_rmtcallres.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::735309b40d3dc1ccced1be27b77bf28c, Rpc\BindingProtocols\rpcb_rmtcallres.vb"
+#Region "Microsoft.VisualBasic::b278b2261794db401e057ca389168fae, Rpc\BindingProtocols\rpcb_rmtcallres.vb"
' Author:
'
@@ -60,4 +60,3 @@ Namespace Rpc.BindingProtocols
Public results As Byte()
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/rpcb_stat.vb b/Rpc/BindingProtocols/rpcb_stat.vb
index bff667d..e1ef159 100644
--- a/Rpc/BindingProtocols/rpcb_stat.vb
+++ b/Rpc/BindingProtocols/rpcb_stat.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::d50394e31b3ef3ad248cbe7f2570aee8, Rpc\BindingProtocols\rpcb_stat.vb"
+#Region "Microsoft.VisualBasic::4d1e0b765a4526667133f55c9cab334e, Rpc\BindingProtocols\rpcb_stat.vb"
' Author:
'
@@ -81,4 +81,3 @@ Namespace Rpc.BindingProtocols
Public rmtinfo As List(Of rpcbs_rmtcall)
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/rpcb_stat_byvers.vb b/Rpc/BindingProtocols/rpcb_stat_byvers.vb
index d4ee73f..0eecb39 100644
--- a/Rpc/BindingProtocols/rpcb_stat_byvers.vb
+++ b/Rpc/BindingProtocols/rpcb_stat_byvers.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::653b688dc0ed36b0b77d72d90e39c159, Rpc\BindingProtocols\rpcb_stat_byvers.vb"
+#Region "Microsoft.VisualBasic::db624fd5fcb3954855677818410712d3, Rpc\BindingProtocols\rpcb_stat_byvers.vb"
' Author:
'
@@ -67,4 +67,3 @@ Namespace Rpc.BindingProtocols
Public V4 As rpcb_stat
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/rpcbs_addr.vb b/Rpc/BindingProtocols/rpcbs_addr.vb
index 955f0c2..66b1999 100644
--- a/Rpc/BindingProtocols/rpcbs_addr.vb
+++ b/Rpc/BindingProtocols/rpcbs_addr.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::76ccd68197ecb13e4206b4aeb7478c08, Rpc\BindingProtocols\rpcbs_addr.vb"
+#Region "Microsoft.VisualBasic::103f104940d83e83099ba35c69655f86, Rpc\BindingProtocols\rpcbs_addr.vb"
' Author:
'
@@ -75,4 +75,3 @@ Namespace Rpc.BindingProtocols
Public netid As String
End Class
End Namespace
-
diff --git a/Rpc/BindingProtocols/rpcbs_rmtcall.vb b/Rpc/BindingProtocols/rpcbs_rmtcall.vb
index 0694ee7..eb6ce37 100644
--- a/Rpc/BindingProtocols/rpcbs_rmtcall.vb
+++ b/Rpc/BindingProtocols/rpcbs_rmtcall.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::3ffa0485f2edfa2616ff7248e96649d4, Rpc\BindingProtocols\rpcbs_rmtcall.vb"
+#Region "Microsoft.VisualBasic::4c0d0aa5a6ac02fc9576e0bb604ba151, Rpc\BindingProtocols\rpcbs_rmtcall.vb"
' Author:
'
@@ -85,4 +85,3 @@ Namespace Rpc.BindingProtocols
Public netid As String
End Class
End Namespace
-
diff --git a/Rpc/Connectors/IRpcSession.vb b/Rpc/Connectors/IRpcSession.vb
index a96cc5f..220a834 100644
--- a/Rpc/Connectors/IRpcSession.vb
+++ b/Rpc/Connectors/IRpcSession.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::7704e207ae0ce5c71aa683fccd1ff0a8, Rpc\Connectors\IRpcSession.vb"
+#Region "Microsoft.VisualBasic::1ddd41e1bc96cbf4b6e78395ca71bc7a, Rpc\Connectors\IRpcSession.vb"
' Author:
'
@@ -52,4 +52,3 @@ Namespace Rpc.Connectors
Event OnSended As Action(Of IRpcSession)
End Interface
End Namespace
-
diff --git a/Rpc/Connectors/ITicket.vb b/Rpc/Connectors/ITicket.vb
index e14ba9c..a0acac8 100644
--- a/Rpc/Connectors/ITicket.vb
+++ b/Rpc/Connectors/ITicket.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::16498068f3f11e71d3e79060915c9c87, Rpc\Connectors\ITicket.vb"
+#Region "Microsoft.VisualBasic::8e8b5228e79a36c05c718af1ac98d87f, Rpc\Connectors\ITicket.vb"
' Author:
'
@@ -54,4 +54,3 @@ Namespace Rpc.Connectors
Sub BuildRpcMessage(ByVal bw As IByteWriter)
End Interface
End Namespace
-
diff --git a/Rpc/Connectors/ITicketOwner.vb b/Rpc/Connectors/ITicketOwner.vb
index 53f96a3..a690a80 100644
--- a/Rpc/Connectors/ITicketOwner.vb
+++ b/Rpc/Connectors/ITicketOwner.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::633b0d110b6fd7992529570eb786c9ba, Rpc\Connectors\ITicketOwner.vb"
+#Region "Microsoft.VisualBasic::26363800d6f6d11caf4ca25908b4081b, Rpc\Connectors\ITicketOwner.vb"
' Author:
'
@@ -45,4 +45,3 @@ Namespace Rpc.Connectors
Sub RemoveTicket(ByVal ticket As ITicket)
End Interface
End Namespace
-
diff --git a/Rpc/Connectors/TcpClientWrapper.vb b/Rpc/Connectors/TcpClientWrapper.vb
index 2a3f574..cb43d1b 100644
--- a/Rpc/Connectors/TcpClientWrapper.vb
+++ b/Rpc/Connectors/TcpClientWrapper.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::2f3cb0d1c9bf2c4a90e1d3d3c59d406f, Rpc\Connectors\TcpClientWrapper.vb"
+#Region "Microsoft.VisualBasic::56816b31e3ebe28240fdc458329a2a7c, Rpc\Connectors\TcpClientWrapper.vb"
' Author:
'
@@ -305,4 +305,3 @@ Namespace Rpc.Connectors
End Sub
End Class
End Namespace
-
diff --git a/Rpc/Connectors/TcpSession.vb b/Rpc/Connectors/TcpSession.vb
index a5df0ef..c06caac 100644
--- a/Rpc/Connectors/TcpSession.vb
+++ b/Rpc/Connectors/TcpSession.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::4d4a345d63b3483d4d827ac6e9ee4e9d, Rpc\Connectors\TcpSession.vb"
+#Region "Microsoft.VisualBasic::9375bac9bafcd3331749001949b27a3d, Rpc\Connectors\TcpSession.vb"
' Author:
'
@@ -228,4 +228,3 @@ Namespace Rpc.Connectors
End Sub
End Class
End Namespace
-
diff --git a/Rpc/Connectors/Ticket.vb b/Rpc/Connectors/Ticket.vb
index 94e51a4..005944e 100644
--- a/Rpc/Connectors/Ticket.vb
+++ b/Rpc/Connectors/Ticket.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::8f2646d0a1f0e20fc35f82ef36a437ce, Rpc\Connectors\Ticket.vb"
+#Region "Microsoft.VisualBasic::20a4f53dbbf2bdf65ad3d3dfccf0297b, Rpc\Connectors\Ticket.vb"
' Author:
'
@@ -117,4 +117,3 @@ Namespace Rpc.Connectors
End Sub
End Class
End Namespace
-
diff --git a/Rpc/Connectors/UdpClientWrapper.vb b/Rpc/Connectors/UdpClientWrapper.vb
index 087603a..389d5b0 100644
--- a/Rpc/Connectors/UdpClientWrapper.vb
+++ b/Rpc/Connectors/UdpClientWrapper.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::ae83e80bfb5a8df8c6cbf3cca890d88f, Rpc\Connectors\UdpClientWrapper.vb"
+#Region "Microsoft.VisualBasic::0e46a4a5d2e6d4c63440cb8ae8c4dd62, Rpc\Connectors\UdpClientWrapper.vb"
' Author:
'
@@ -146,4 +146,3 @@ Namespace Rpc.Connectors
End Sub
End Class
End Namespace
-
diff --git a/Rpc/Connectors/UdpSession.vb b/Rpc/Connectors/UdpSession.vb
index 7680030..dc9976f 100644
--- a/Rpc/Connectors/UdpSession.vb
+++ b/Rpc/Connectors/UdpSession.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::9241b9d4021c483ccbda7a02cb6a4650, Rpc\Connectors\UdpSession.vb"
+#Region "Microsoft.VisualBasic::14f21439dc2d2a8324d44249cffbd635, Rpc\Connectors\UdpSession.vb"
' Author:
'
@@ -212,4 +212,3 @@ Namespace Rpc.Connectors
End Sub
End Class
End Namespace
-
diff --git a/Rpc/Exceptions/AuthenticateException.vb b/Rpc/Exceptions/AuthenticateException.vb
index ef0e7d4..f4f8abd 100644
--- a/Rpc/Exceptions/AuthenticateException.vb
+++ b/Rpc/Exceptions/AuthenticateException.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::5f9c5b374ef55a3be24c64965a97017b, Rpc\Exceptions\AuthenticateException.vb"
+#Region "Microsoft.VisualBasic::48c2bdf3c92b618bdcde81c3d468fb1d, Rpc\Exceptions\AuthenticateException.vb"
' Author:
'
@@ -77,4 +77,3 @@ Namespace Rpc
End Sub
End Class
End Namespace
-
diff --git a/Rpc/Exceptions/Exceptions.vb b/Rpc/Exceptions/Exceptions.vb
index be46c68..c60c476 100644
--- a/Rpc/Exceptions/Exceptions.vb
+++ b/Rpc/Exceptions/Exceptions.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::fdf4faa92a0c5721ec165b75f6ddc8af, Rpc\Exceptions\Exceptions.vb"
+#Region "Microsoft.VisualBasic::090bf2b892725ca9852057d30c262620, Rpc\Exceptions\Exceptions.vb"
' Author:
'
@@ -115,4 +115,3 @@ Namespace Rpc
End Function
End Module
End Namespace
-
diff --git a/Rpc/Exceptions/ReplyException.vb b/Rpc/Exceptions/ReplyException.vb
index 2250f70..211df2b 100644
--- a/Rpc/Exceptions/ReplyException.vb
+++ b/Rpc/Exceptions/ReplyException.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::457b53e16b4b468ec6e7c09322a8d467, Rpc\Exceptions\ReplyException.vb"
+#Region "Microsoft.VisualBasic::4f25adfd73df3b72fcc481dadc2ceaa1, Rpc\Exceptions\ReplyException.vb"
' Author:
'
@@ -95,4 +95,3 @@ Namespace Rpc
End Sub
End Class
End Namespace
-
diff --git a/Rpc/Exceptions/RpcException.vb b/Rpc/Exceptions/RpcException.vb
index 6a455e7..003fc5d 100644
--- a/Rpc/Exceptions/RpcException.vb
+++ b/Rpc/Exceptions/RpcException.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::7c85e6230709bf64ec1bf2777d221f43, Rpc\Exceptions\RpcException.vb"
+#Region "Microsoft.VisualBasic::0e95a10b7eeef55c1a5e09a64b449186, Rpc\Exceptions\RpcException.vb"
' Author:
'
@@ -72,4 +72,3 @@ Namespace Rpc
End Sub
End Class
End Namespace
-
diff --git a/Rpc/IMsgReader.vb b/Rpc/IMsgReader.vb
index 16aef65..498db10 100644
--- a/Rpc/IMsgReader.vb
+++ b/Rpc/IMsgReader.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::63bc1bbc685da2884db70965d158ee95, Rpc\IMsgReader.vb"
+#Region "Microsoft.VisualBasic::f2ca360f71398e2a829f9e49d5585a1f, Rpc\IMsgReader.vb"
' Author:
'
@@ -40,10 +40,8 @@
#End Region
-
Namespace Rpc
Friend Interface IMsgReader
Sub CheckEmpty()
End Interface
End Namespace
-
diff --git a/Rpc/IRpcClient.vb b/Rpc/IRpcClient.vb
index 067f88f..9fc18b1 100644
--- a/Rpc/IRpcClient.vb
+++ b/Rpc/IRpcClient.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::a38f8679e95b45f67426755b831a515c, Rpc\IRpcClient.vb"
+#Region "Microsoft.VisualBasic::669a88225bdf5b200a70b0664ce5bda1, Rpc\IRpcClient.vb"
' Author:
'
@@ -70,4 +70,3 @@ Namespace Rpc
Sub Close()
End Interface
End Namespace
-
diff --git a/Rpc/MessageProtocol/accept_stat.vb b/Rpc/MessageProtocol/accept_stat.vb
index 29ebdf1..675f72e 100644
--- a/Rpc/MessageProtocol/accept_stat.vb
+++ b/Rpc/MessageProtocol/accept_stat.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::cab73729bbb9b74d42df93cc021ef94e, Rpc\MessageProtocol\accept_stat.vb"
+#Region "Microsoft.VisualBasic::f85895fb3aed997dfe2b73a573816101, Rpc\MessageProtocol\accept_stat.vb"
' Author:
'
@@ -43,7 +43,6 @@
#End Region
-
Namespace Rpc.MessageProtocol
'''
''' Given that a call message was accepted, the following is the status of an attempt to call a remote procedure.
@@ -81,4 +80,3 @@ Namespace Rpc.MessageProtocol
SYSTEM_ERR = 5
End Enum
End Namespace
-
diff --git a/Rpc/MessageProtocol/accepted_reply.vb b/Rpc/MessageProtocol/accepted_reply.vb
index e3656d1..8f363ca 100644
--- a/Rpc/MessageProtocol/accepted_reply.vb
+++ b/Rpc/MessageProtocol/accepted_reply.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::ca46e903429fd589f431c9b903916103, Rpc\MessageProtocol\accepted_reply.vb"
+#Region "Microsoft.VisualBasic::e01a4d61633bd5d6b1e005f89c152c05, Rpc\MessageProtocol\accepted_reply.vb"
' Author:
'
@@ -85,4 +85,3 @@ Namespace Rpc.MessageProtocol
End Class
End Class
End Namespace
-
diff --git a/Rpc/MessageProtocol/auth_flavor.vb b/Rpc/MessageProtocol/auth_flavor.vb
index af125f0..3be4e09 100644
--- a/Rpc/MessageProtocol/auth_flavor.vb
+++ b/Rpc/MessageProtocol/auth_flavor.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::4563d59528ebf1bfdce192c729f47610, Rpc\MessageProtocol\auth_flavor.vb"
+#Region "Microsoft.VisualBasic::8ca02b98ec4cda01bbeb49377ba9de20, Rpc\MessageProtocol\auth_flavor.vb"
' Author:
'
@@ -43,7 +43,6 @@
#End Region
-
Namespace Rpc.MessageProtocol
'''
''' Authentication flavor
@@ -76,4 +75,3 @@ Namespace Rpc.MessageProtocol
RPCSEC_GSS = 6
End Enum
End Namespace
-
diff --git a/Rpc/MessageProtocol/auth_stat.vb b/Rpc/MessageProtocol/auth_stat.vb
index a5b539e..e40de71 100644
--- a/Rpc/MessageProtocol/auth_stat.vb
+++ b/Rpc/MessageProtocol/auth_stat.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::0d3a878e5351e64a7151237182d91458, Rpc\MessageProtocol\auth_stat.vb"
+#Region "Microsoft.VisualBasic::7b7a6d0f37de156391c6a901fbf48847, Rpc\MessageProtocol\auth_stat.vb"
' Author:
'
@@ -132,4 +132,3 @@ Namespace Rpc.MessageProtocol
RPCSEC_GSS_CTXPROBLEM = 14
End Enum
End Namespace
-
diff --git a/Rpc/MessageProtocol/body.vb b/Rpc/MessageProtocol/body.vb
index c2e682b..d78f7b7 100644
--- a/Rpc/MessageProtocol/body.vb
+++ b/Rpc/MessageProtocol/body.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::3fd3f8dbe1913a55417ffeb6d0f73a2a, Rpc\MessageProtocol\body.vb"
+#Region "Microsoft.VisualBasic::bd99e53c687276780aa4fb106404cec7, Rpc\MessageProtocol\body.vb"
' Author:
'
@@ -65,4 +65,3 @@ Namespace Rpc.MessageProtocol
Public rbody As reply_body
End Class
End Namespace
-
diff --git a/Rpc/MessageProtocol/call_body.vb b/Rpc/MessageProtocol/call_body.vb
index dcfbd4b..0a62fb2 100644
--- a/Rpc/MessageProtocol/call_body.vb
+++ b/Rpc/MessageProtocol/call_body.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::40e713d87003ae50324d5047ecf242a9, Rpc\MessageProtocol\call_body.vb"
+#Region "Microsoft.VisualBasic::1fde0edb903700a2434d2a359f6875d1, Rpc\MessageProtocol\call_body.vb"
' Author:
'
@@ -85,4 +85,3 @@ Namespace Rpc.MessageProtocol
Public verf As opaque_auth
End Class
End Namespace
-
diff --git a/Rpc/MessageProtocol/mismatch_info.vb b/Rpc/MessageProtocol/mismatch_info.vb
index 8906347..c9e05ad 100644
--- a/Rpc/MessageProtocol/mismatch_info.vb
+++ b/Rpc/MessageProtocol/mismatch_info.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::a0aaefb69597acd71048a10ac6547da1, Rpc\MessageProtocol\mismatch_info.vb"
+#Region "Microsoft.VisualBasic::84d2797e504b3b24da51cc30e29b226a, Rpc\MessageProtocol\mismatch_info.vb"
' Author:
'
@@ -61,4 +61,3 @@ Namespace Rpc.MessageProtocol
Public high As UInteger
End Class
End Namespace
-
diff --git a/Rpc/MessageProtocol/msg_type.vb b/Rpc/MessageProtocol/msg_type.vb
index 5767e24..20200e5 100644
--- a/Rpc/MessageProtocol/msg_type.vb
+++ b/Rpc/MessageProtocol/msg_type.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::83ef946e184dbad5a96930778c907b05, Rpc\MessageProtocol\msg_type.vb"
+#Region "Microsoft.VisualBasic::0f50fb6c9812d218fb61a417db9f1a23, Rpc\MessageProtocol\msg_type.vb"
' Author:
'
@@ -43,7 +43,6 @@
#End Region
-
Namespace Rpc.MessageProtocol
'''
''' message type
@@ -60,4 +59,3 @@ Namespace Rpc.MessageProtocol
REPLY = 1
End Enum
End Namespace
-
diff --git a/Rpc/MessageProtocol/opaque_auth.vb b/Rpc/MessageProtocol/opaque_auth.vb
index 49b2bc8..f19c751 100644
--- a/Rpc/MessageProtocol/opaque_auth.vb
+++ b/Rpc/MessageProtocol/opaque_auth.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::18e6426cd429f1800568feab377d4a0b, Rpc\MessageProtocol\opaque_auth.vb"
+#Region "Microsoft.VisualBasic::a8778148a4e31d9bbc52dae0df6c0976, Rpc\MessageProtocol\opaque_auth.vb"
' Author:
'
@@ -72,4 +72,3 @@ Namespace Rpc.MessageProtocol
Public body As Byte()
End Structure
End Namespace
-
diff --git a/Rpc/MessageProtocol/reject_stat.vb b/Rpc/MessageProtocol/reject_stat.vb
index c45d7c3..862154b 100644
--- a/Rpc/MessageProtocol/reject_stat.vb
+++ b/Rpc/MessageProtocol/reject_stat.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::ada6af6ba575f1531a9879513ac3764c, Rpc\MessageProtocol\reject_stat.vb"
+#Region "Microsoft.VisualBasic::cb4b4952e0eafdafc056b31e09294801, Rpc\MessageProtocol\reject_stat.vb"
' Author:
'
@@ -43,7 +43,6 @@
#End Region
-
Namespace Rpc.MessageProtocol
'''
''' Reasons why a call message was rejected
@@ -60,4 +59,3 @@ Namespace Rpc.MessageProtocol
AUTH_ERROR = 1
End Enum
End Namespace
-
diff --git a/Rpc/MessageProtocol/rejected_reply.vb b/Rpc/MessageProtocol/rejected_reply.vb
index f5e7a00..40bc03e 100644
--- a/Rpc/MessageProtocol/rejected_reply.vb
+++ b/Rpc/MessageProtocol/rejected_reply.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::91fb29d3a9316ef2d51063e5cdcf81b7, Rpc\MessageProtocol\rejected_reply.vb"
+#Region "Microsoft.VisualBasic::63a7b7513a469a29ada2ddc97a7ae21d, Rpc\MessageProtocol\rejected_reply.vb"
' Author:
'
@@ -67,4 +67,3 @@ Namespace Rpc.MessageProtocol
Public astat As auth_stat
End Class
End Namespace
-
diff --git a/Rpc/MessageProtocol/reply_body.vb b/Rpc/MessageProtocol/reply_body.vb
index 53ef168..91a3599 100644
--- a/Rpc/MessageProtocol/reply_body.vb
+++ b/Rpc/MessageProtocol/reply_body.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::7bd7750f00177f0799029703b6194810, Rpc\MessageProtocol\reply_body.vb"
+#Region "Microsoft.VisualBasic::4fbae78d156727bb507c8f4bd3319cb3, Rpc\MessageProtocol\reply_body.vb"
' Author:
'
@@ -67,4 +67,3 @@ Namespace Rpc.MessageProtocol
Public rreply As rejected_reply
End Class
End Namespace
-
diff --git a/Rpc/MessageProtocol/reply_stat.vb b/Rpc/MessageProtocol/reply_stat.vb
index d21dafd..1b9da32 100644
--- a/Rpc/MessageProtocol/reply_stat.vb
+++ b/Rpc/MessageProtocol/reply_stat.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::27db7c8e9e48f67ab1be006a2cf35a0d, Rpc\MessageProtocol\reply_stat.vb"
+#Region "Microsoft.VisualBasic::9fa5af60ab54598988899af92298a6c4, Rpc\MessageProtocol\reply_stat.vb"
' Author:
'
@@ -43,7 +43,6 @@
#End Region
-
Namespace Rpc.MessageProtocol
'''
''' A reply to a call message can take on two forms: the message was either accepted or rejected.
@@ -60,4 +59,3 @@ Namespace Rpc.MessageProtocol
MSG_DENIED = 1
End Enum
End Namespace
-
diff --git a/Rpc/MessageProtocol/rpc_msg.vb b/Rpc/MessageProtocol/rpc_msg.vb
index cd5a87b..aeff52e 100644
--- a/Rpc/MessageProtocol/rpc_msg.vb
+++ b/Rpc/MessageProtocol/rpc_msg.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::1417e64a905bc81363ca8d3c4a998ef6, Rpc\MessageProtocol\rpc_msg.vb"
+#Region "Microsoft.VisualBasic::27ce1cd71eca7c0ca19ccfb903b62ae8, Rpc\MessageProtocol\rpc_msg.vb"
' Author:
'
@@ -60,4 +60,3 @@ Namespace Rpc.MessageProtocol
Public body As body
End Class
End Namespace
-
diff --git a/Rpc/RpcClient.vb b/Rpc/RpcClient.vb
index 75e5b81..068bac9 100644
--- a/Rpc/RpcClient.vb
+++ b/Rpc/RpcClient.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::90eeddbc890118720072c91002474e3b, Rpc\RpcClient.vb"
+#Region "Microsoft.VisualBasic::d7312dbb05793bd8941454dd896c4334, Rpc\RpcClient.vb"
' Author:
'
@@ -208,4 +208,3 @@ Namespace Rpc
End Sub
End Class
End Namespace
-
diff --git a/Rpc/TcpStreaming/TcpReader.vb b/Rpc/TcpStreaming/TcpReader.vb
index b040b73..8eb775f 100644
--- a/Rpc/TcpStreaming/TcpReader.vb
+++ b/Rpc/TcpStreaming/TcpReader.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::5dff12a599ab6006cfb82ed0299e05fe, Rpc\TcpStreaming\TcpReader.vb"
+#Region "Microsoft.VisualBasic::b43a3952755b4a3c1792e6daecb89e40, Rpc\TcpStreaming\TcpReader.vb"
' Author:
'
@@ -145,4 +145,3 @@ Namespace Rpc.TcpStreaming
End Sub
End Class
End Namespace
-
diff --git a/Rpc/TcpStreaming/TcpWriter.vb b/Rpc/TcpStreaming/TcpWriter.vb
index 8bee335..3525308 100644
--- a/Rpc/TcpStreaming/TcpWriter.vb
+++ b/Rpc/TcpStreaming/TcpWriter.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::f46feb0257e6cbe942519e39c1c57801, Rpc\TcpStreaming\TcpWriter.vb"
+#Region "Microsoft.VisualBasic::8700ec6d626b51d311a84dbf67bf7178, Rpc\TcpStreaming\TcpWriter.vb"
' Author:
'
@@ -148,4 +148,3 @@ Namespace Rpc.TcpStreaming
End Function
End Class
End Namespace
-
diff --git a/Rpc/Toolkit.vb b/Rpc/Toolkit.vb
index 8ebecf3..288eaa5 100644
--- a/Rpc/Toolkit.vb
+++ b/Rpc/Toolkit.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::b0bc29541e517958c49a008a0ec35cab, Rpc\Toolkit.vb"
+#Region "Microsoft.VisualBasic::d9fc60e97f8ac77fdc9bf9e8bdec53c4, Rpc\Toolkit.vb"
' Author:
'
@@ -164,4 +164,3 @@ Namespace Rpc
End Sub
End Module
End Namespace
-
diff --git a/Rpc/UdpDatagrams/UdpReader.vb b/Rpc/UdpDatagrams/UdpReader.vb
index 1480fbf..34d3bec 100644
--- a/Rpc/UdpDatagrams/UdpReader.vb
+++ b/Rpc/UdpDatagrams/UdpReader.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::5a923928be3e05696690ddeb8e1cce5c, Rpc\UdpDatagrams\UdpReader.vb"
+#Region "Microsoft.VisualBasic::fefc384bbb2422b477c4270de9234f57, Rpc\UdpDatagrams\UdpReader.vb"
' Author:
'
@@ -108,4 +108,3 @@ Namespace Rpc.UdpDatagrams
End Sub
End Class
End Namespace
-
diff --git a/Rpc/UdpDatagrams/UdpWriter.vb b/Rpc/UdpDatagrams/UdpWriter.vb
index 3b23018..8e7c630 100644
--- a/Rpc/UdpDatagrams/UdpWriter.vb
+++ b/Rpc/UdpDatagrams/UdpWriter.vb
@@ -1,4 +1,4 @@
-#Region "Microsoft.VisualBasic::604605c1d68e2d09e7ae73df0fda9f0e, Rpc\UdpDatagrams\UdpWriter.vb"
+#Region "Microsoft.VisualBasic::97b31e1a2228390af824b8d7ec289a55, Rpc\UdpDatagrams\UdpWriter.vb"
' Author:
'
@@ -139,4 +139,3 @@ Namespace Rpc.UdpDatagrams
End Function
End Class
End Namespace
-