From 790bfcbd1f44d8671dc246e007ceec755307ff59 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=AC=9D=E6=A1=82=E7=B6=B1?= <xie.guigang@gmail.com>
Date: Tue, 2 Feb 2016 09:58:07 +0800
Subject: [PATCH] init add protocols

---
 .../Taskhost.d/LinqProvider.vb                | 28 +++++++++++++++++--
 .../ComputingServices/Taskhost.d/Protocols.vb |  7 +++++
 2 files changed, 33 insertions(+), 2 deletions(-)

diff --git a/ComputingServices/ComputingServices/Taskhost.d/LinqProvider.vb b/ComputingServices/ComputingServices/Taskhost.d/LinqProvider.vb
index 3d41e00..64f9daa 100644
--- a/ComputingServices/ComputingServices/Taskhost.d/LinqProvider.vb
+++ b/ComputingServices/ComputingServices/Taskhost.d/LinqProvider.vb
@@ -1,3 +1,27 @@
-Public Class LinqProvider
+Imports System.Reflection
+Imports Microsoft.VisualBasic.Net
+Imports Microsoft.VisualBasic.Net.Protocol
+Imports Microsoft.VisualBasic.Net.Protocol.Reflection
+Imports Microsoft.VisualBasic.Serialization
 
-End Class
+Namespace TaskHost
+
+    ''' <summary>
+    ''' 执行得到数据集合然后分独传输数据元素
+    ''' </summary>
+    ''' 
+    <Protocol(GetType(TaskProtocols))>
+    Public Class LinqProvider
+
+        ReadOnly __host As TcpSynchronizationServicesSocket = New TcpSynchronizationServicesSocket(GetFirstAvailablePort)
+
+        Sub New()
+            __host.Responsehandler = AddressOf New ProtocolHandler(Me).HandleRequest
+        End Sub
+
+        <Protocol(TaskProtocols.MoveNext)>
+        Private Function __moveNext(CA As Long, args As RequestStream, remote As System.Net.IPEndPoint) As RequestStream
+
+        End Function
+    End Class
+End Namespace
\ No newline at end of file
diff --git a/ComputingServices/ComputingServices/Taskhost.d/Protocols.vb b/ComputingServices/ComputingServices/Taskhost.d/Protocols.vb
index 592b4e3..b9c1c34 100644
--- a/ComputingServices/ComputingServices/Taskhost.d/Protocols.vb
+++ b/ComputingServices/ComputingServices/Taskhost.d/Protocols.vb
@@ -5,5 +5,12 @@
     ''' </summary>
     Public Module Protocols
 
+        Public Enum TaskProtocols
+
+#Region "LINQ supports"
+            MoveNext
+#End Region
+        End Enum
+
     End Module
 End Namespace
\ No newline at end of file