Context Navigation

HeuristicLab.Hive.Contracts

Timestamp:

05/28/09 18:38:46 (16 years ago)

Author:

svonolfe

Message:

Large amounts of data are now transferred streamed (fixed ticket #660)

Location:

trunk/sources/HeuristicLab.Hive.Contracts/3.2

Files:

r1643	r1939
28	28	namespace HeuristicLab.PluginInfrastructure {
29	29	[DataContract]
	30	[Serializable]
30	31	public class CachedHivePluginInfo : HivePluginInfo {
31	32

r1772	r1939
31	31
32	32	[DataContract]
	33	[Serializable]
33	34	public class ClientInfo : Resource {
34	35	[DataMember]

r1377	r1939
30	30
31	31	[DataContract]
	32	[Serializable]
32	33	public class ClientConfig : PersistableObject {
33	34	[DataMember]

r1592	r1939
31	31
32	32	[DataContract]
	33	[Serializable]
33	34	public class HivePluginInfo : PersistableObject {
34	35	[DataMember]

r1932	r1939
31	31
32	32	[DataContract]
	33	[Serializable]
33	34	public class Job : PersistableObject {
34	35	[DataMember]

-                      r1626
+                      r1939
   [DataContract]
+  [Serializable]
   public class JobResult : PersistableObject {
     [DataMember]
     public Job Job { get; set; }
+    public Guid JobId { get; set; }
     [DataMember]
     public byte[] Result { get; set; }
 …
     public DateTime Timestamp { get; set; }
     [DataMember]
     public ClientInfo Client { get; set; }
+    public Guid ClientId { get; set; }
     [DataMember]
     public Exception Exception { get; set; }

r1377	r1939
30	30
31	31	[DataContract]
	32	[Serializable]
32	33	public class Resource : PersistableObject {
33	34	[DataMember]

r1932	r1939
115	115	<Compile Include="ResponsePlugin.cs" />
116	116	<Compile Include="ResponseResultReceived.cs" />
	117	<Compile Include="StreamedObject.cs" />
117	118	<Compile Include="WcfSettings.cs" />
118	119	</ItemGroup>

-                      r1101
+                      r1939
 using System.Linq;
 using System.Text;
+using System.ServiceModel;
+using System.IO;
+using HeuristicLab.Hive.Contracts.BusinessObjects;
 namespace HeuristicLab.Hive.Contracts.Interfaces {
+  [ServiceContract]
   public interface IClientFacade: IClientCommunicator {
+    [OperationContract]
+    Stream SendStreamedJob(Guid clientId);
+    [OperationContract]
+    Stream SendStreamedPlugins(List<HivePluginInfo> pluginList);
+    [OperationContract]
+    ResponseResultReceived StoreFinishedJobResultStreamed(Stream stream);
+    [OperationContract]
+    ResponseResultReceived ProcessSnapshotStreamed(Stream stream);
+  }
+}

r1530	r1939
34	34	/// </summary>
35	35	[DataContract]
	36	[Serializable]
36	37	public class ResponseJob : Response {
37	38	[DataMember]

r1596	r1939
9	9
10	10	[DataContract]
	11	[Serializable]
11	12	public class ResponsePlugin : Response {
12	13	public ResponsePlugin() {

-                      r1809
+                      r1939
       NetTcpBinding binding = new NetTcpBinding();
 #endif
+      binding.MaxBufferSize = int.MaxValue;
+      /*binding.MaxBufferSize = int.MaxValue;
+      binding.MaxReceivedMessageSize = int.MaxValue;
+      binding.ReaderQuotas.MaxArrayLength = int.MaxValue;
+      binding.ReaderQuotas.MaxStringContentLength = int.MaxValue;   */
+      binding.CloseTimeout = new TimeSpan(0, 5, 0);
+      binding.ReceiveTimeout = new TimeSpan(0, 5, 0);
+      binding.SendTimeout = new TimeSpan(0, 5, 0);
+      return binding;
+    }
+    public static Binding GetStreamedBinding() {
+#if USE_MSG_BINDING
+      NetTcpBinding binding = new NetTcpBinding(SecurityMode.Message);
+#else
+      NetTcpBinding binding = new NetTcpBinding();
+#endif
+      binding.TransferMode = TransferMode.Streamed;
       binding.MaxReceivedMessageSize = int.MaxValue;
       binding.ReaderQuotas.MaxArrayLength = int.MaxValue;

Note: See TracChangeset for help on using the changeset viewer.