Changeset 1939
- Timestamp:
- 05/28/09 18:38:46 (15 years ago)
- Location:
- trunk/sources
- Files:
-
- 4 added
- 32 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/sources/HeuristicLab.DataAccess/3.2/PersistableObject.cs
r1720 r1939 28 28 namespace HeuristicLab.DataAccess { 29 29 [DataContract] 30 [Serializable] 30 31 public class PersistableObject: IPersistableObject { 31 32 [DataMember] -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/HeuristicLab.Hive.Client.Communication-3.2.csproj
r1635 r1939 145 145 <None Include="Service References\ServerService\HeuristicLab.Hive.Contracts1.xsd" /> 146 146 <None Include="Service References\ServerService\HeuristicLab.PluginInfrastructure.xsd" /> 147 <None Include="Service References\ServerService\HeuristicLab.PluginInfrastructure2.xsd" /> 148 <None Include="Service References\ServerService\Message.xsd" /> 147 149 <None Include="Service References\ServerService\Reference.svcmap"> 148 150 <Generator>WCF Proxy Generator</Generator> -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/HeuristicLab.Hive.Contracts.BusinessObjects1.xsd
r1594 r1939 51 51 <xs:enumeration value="abort" /> 52 52 <xs:enumeration value="requestSnapshot" /> 53 <xs:enumeration value="requestSnapshotSent" /> 53 54 </xs:restriction> 54 55 </xs:simpleType> -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/HeuristicLab.Hive.Contracts1.xsd
r1594 r1939 44 44 <xs:enumeration value="SnapshotReady" /> 45 45 <xs:enumeration value="Shutdown" /> 46 <xs:enumeration value="JobFailed" /> 46 47 </xs:restriction> 47 48 </xs:simpleType> -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/Reference.cs
r1594 r1939 2 2 // <auto-generated> 3 3 // This code was generated by a tool. 4 // Runtime Version:2.0.50727.30 534 // Runtime Version:2.0.50727.3082 5 5 // 6 6 // Changes to this file may cause incorrect behavior and will be lost if … … 13 13 14 14 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")] 15 [System.ServiceModel.ServiceContractAttribute(ConfigurationName="ServerService.IClient Communicator")]16 public interface IClient Communicator{15 [System.ServiceModel.ServiceContractAttribute(ConfigurationName="ServerService.IClientFacade")] 16 public interface IClientFacade { 17 17 18 18 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/IClientCommunicator/Login", ReplyAction="http://tempuri.org/IClientCommunicator/LoginResponse")] … … 91 91 92 92 HeuristicLab.Hive.Contracts.ResponsePlugin EndSendPlugins(System.IAsyncResult result); 93 } 94 95 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")] 96 public interface IClientCommunicatorChannel : HeuristicLab.Hive.Client.Communication.ServerService.IClientCommunicator, System.ServiceModel.IClientChannel { 93 94 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/IClientFacade/SendStreamedJob", ReplyAction="http://tempuri.org/IClientFacade/SendStreamedJobResponse")] 95 System.IO.Stream SendStreamedJob(System.Guid clientId); 96 97 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/IClientFacade/SendStreamedJob", ReplyAction="http://tempuri.org/IClientFacade/SendStreamedJobResponse")] 98 System.IAsyncResult BeginSendStreamedJob(System.Guid clientId, System.AsyncCallback callback, object asyncState); 99 100 System.IO.Stream EndSendStreamedJob(System.IAsyncResult result); 101 102 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/IClientFacade/SendStreamedPlugins", ReplyAction="http://tempuri.org/IClientFacade/SendStreamedPluginsResponse")] 103 System.IO.Stream SendStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfo[] pluginList); 104 105 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/IClientFacade/SendStreamedPlugins", ReplyAction="http://tempuri.org/IClientFacade/SendStreamedPluginsResponse")] 106 System.IAsyncResult BeginSendStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfo[] pluginList, System.AsyncCallback callback, object asyncState); 107 108 System.IO.Stream EndSendStreamedPlugins(System.IAsyncResult result); 109 110 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/IClientFacade/StoreFinishedJobResultStreamed", ReplyAction="http://tempuri.org/IClientFacade/StoreFinishedJobResultStreamedResponse")] 111 HeuristicLab.Hive.Contracts.ResponseResultReceived StoreFinishedJobResultStreamed(System.IO.Stream stream); 112 113 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/IClientFacade/StoreFinishedJobResultStreamed", ReplyAction="http://tempuri.org/IClientFacade/StoreFinishedJobResultStreamedResponse")] 114 System.IAsyncResult BeginStoreFinishedJobResultStreamed(System.IO.Stream stream, System.AsyncCallback callback, object asyncState); 115 116 HeuristicLab.Hive.Contracts.ResponseResultReceived EndStoreFinishedJobResultStreamed(System.IAsyncResult result); 117 118 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/IClientFacade/ProcessSnapshotStreamed", ReplyAction="http://tempuri.org/IClientFacade/ProcessSnapshotStreamedResponse")] 119 HeuristicLab.Hive.Contracts.ResponseResultReceived ProcessSnapshotStreamed(System.IO.Stream stream); 120 121 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/IClientFacade/ProcessSnapshotStreamed", ReplyAction="http://tempuri.org/IClientFacade/ProcessSnapshotStreamedResponse")] 122 System.IAsyncResult BeginProcessSnapshotStreamed(System.IO.Stream stream, System.AsyncCallback callback, object asyncState); 123 124 HeuristicLab.Hive.Contracts.ResponseResultReceived EndProcessSnapshotStreamed(System.IAsyncResult result); 125 } 126 127 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")] 128 public interface IClientFacadeChannel : HeuristicLab.Hive.Client.Communication.ServerService.IClientFacade, System.ServiceModel.IClientChannel { 97 129 } 98 130 … … 251 283 [System.Diagnostics.DebuggerStepThroughAttribute()] 252 284 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")] 253 public partial class ClientCommunicatorClient : System.ServiceModel.ClientBase<HeuristicLab.Hive.Client.Communication.ServerService.IClientCommunicator>, HeuristicLab.Hive.Client.Communication.ServerService.IClientCommunicator { 285 public partial class SendStreamedJobCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs { 286 287 private object[] results; 288 289 public SendStreamedJobCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) : 290 base(exception, cancelled, userState) { 291 this.results = results; 292 } 293 294 public System.IO.Stream Result { 295 get { 296 base.RaiseExceptionIfNecessary(); 297 return ((System.IO.Stream)(this.results[0])); 298 } 299 } 300 } 301 302 [System.Diagnostics.DebuggerStepThroughAttribute()] 303 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")] 304 public partial class SendStreamedPluginsCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs { 305 306 private object[] results; 307 308 public SendStreamedPluginsCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) : 309 base(exception, cancelled, userState) { 310 this.results = results; 311 } 312 313 public System.IO.Stream Result { 314 get { 315 base.RaiseExceptionIfNecessary(); 316 return ((System.IO.Stream)(this.results[0])); 317 } 318 } 319 } 320 321 [System.Diagnostics.DebuggerStepThroughAttribute()] 322 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")] 323 public partial class StoreFinishedJobResultStreamedCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs { 324 325 private object[] results; 326 327 public StoreFinishedJobResultStreamedCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) : 328 base(exception, cancelled, userState) { 329 this.results = results; 330 } 331 332 public HeuristicLab.Hive.Contracts.ResponseResultReceived Result { 333 get { 334 base.RaiseExceptionIfNecessary(); 335 return ((HeuristicLab.Hive.Contracts.ResponseResultReceived)(this.results[0])); 336 } 337 } 338 } 339 340 [System.Diagnostics.DebuggerStepThroughAttribute()] 341 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")] 342 public partial class ProcessSnapshotStreamedCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs { 343 344 private object[] results; 345 346 public ProcessSnapshotStreamedCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) : 347 base(exception, cancelled, userState) { 348 this.results = results; 349 } 350 351 public HeuristicLab.Hive.Contracts.ResponseResultReceived Result { 352 get { 353 base.RaiseExceptionIfNecessary(); 354 return ((HeuristicLab.Hive.Contracts.ResponseResultReceived)(this.results[0])); 355 } 356 } 357 } 358 359 [System.Diagnostics.DebuggerStepThroughAttribute()] 360 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")] 361 public partial class ClientFacadeClient : System.ServiceModel.ClientBase<HeuristicLab.Hive.Client.Communication.ServerService.IClientFacade>, HeuristicLab.Hive.Client.Communication.ServerService.IClientFacade { 254 362 255 363 private BeginOperationDelegate onBeginLoginDelegate; … … 301 409 private System.Threading.SendOrPostCallback onSendPluginsCompletedDelegate; 302 410 303 public ClientCommunicatorClient() { 304 } 305 306 public ClientCommunicatorClient(string endpointConfigurationName) : 411 private BeginOperationDelegate onBeginSendStreamedJobDelegate; 412 413 private EndOperationDelegate onEndSendStreamedJobDelegate; 414 415 private System.Threading.SendOrPostCallback onSendStreamedJobCompletedDelegate; 416 417 private BeginOperationDelegate onBeginSendStreamedPluginsDelegate; 418 419 private EndOperationDelegate onEndSendStreamedPluginsDelegate; 420 421 private System.Threading.SendOrPostCallback onSendStreamedPluginsCompletedDelegate; 422 423 private BeginOperationDelegate onBeginStoreFinishedJobResultStreamedDelegate; 424 425 private EndOperationDelegate onEndStoreFinishedJobResultStreamedDelegate; 426 427 private System.Threading.SendOrPostCallback onStoreFinishedJobResultStreamedCompletedDelegate; 428 429 private BeginOperationDelegate onBeginProcessSnapshotStreamedDelegate; 430 431 private EndOperationDelegate onEndProcessSnapshotStreamedDelegate; 432 433 private System.Threading.SendOrPostCallback onProcessSnapshotStreamedCompletedDelegate; 434 435 public ClientFacadeClient() { 436 } 437 438 public ClientFacadeClient(string endpointConfigurationName) : 307 439 base(endpointConfigurationName) { 308 440 } 309 441 310 public Client CommunicatorClient(string endpointConfigurationName, string remoteAddress) :442 public ClientFacadeClient(string endpointConfigurationName, string remoteAddress) : 311 443 base(endpointConfigurationName, remoteAddress) { 312 444 } 313 445 314 public Client CommunicatorClient(string endpointConfigurationName, System.ServiceModel.EndpointAddress remoteAddress) :446 public ClientFacadeClient(string endpointConfigurationName, System.ServiceModel.EndpointAddress remoteAddress) : 315 447 base(endpointConfigurationName, remoteAddress) { 316 448 } 317 449 318 public Client CommunicatorClient(System.ServiceModel.Channels.Binding binding, System.ServiceModel.EndpointAddress remoteAddress) :450 public ClientFacadeClient(System.ServiceModel.Channels.Binding binding, System.ServiceModel.EndpointAddress remoteAddress) : 319 451 base(binding, remoteAddress) { 320 452 } … … 335 467 336 468 public event System.EventHandler<SendPluginsCompletedEventArgs> SendPluginsCompleted; 469 470 public event System.EventHandler<SendStreamedJobCompletedEventArgs> SendStreamedJobCompleted; 471 472 public event System.EventHandler<SendStreamedPluginsCompletedEventArgs> SendStreamedPluginsCompleted; 473 474 public event System.EventHandler<StoreFinishedJobResultStreamedCompletedEventArgs> StoreFinishedJobResultStreamedCompleted; 475 476 public event System.EventHandler<ProcessSnapshotStreamedCompletedEventArgs> ProcessSnapshotStreamedCompleted; 337 477 338 478 public HeuristicLab.Hive.Contracts.Response Login(HeuristicLab.Hive.Contracts.BusinessObjects.ClientInfo clientInfo) { … … 751 891 pluginList}, this.onEndSendPluginsDelegate, this.onSendPluginsCompletedDelegate, userState); 752 892 } 893 894 public System.IO.Stream SendStreamedJob(System.Guid clientId) { 895 return base.Channel.SendStreamedJob(clientId); 896 } 897 898 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 899 public System.IAsyncResult BeginSendStreamedJob(System.Guid clientId, System.AsyncCallback callback, object asyncState) { 900 return base.Channel.BeginSendStreamedJob(clientId, callback, asyncState); 901 } 902 903 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 904 public System.IO.Stream EndSendStreamedJob(System.IAsyncResult result) { 905 return base.Channel.EndSendStreamedJob(result); 906 } 907 908 private System.IAsyncResult OnBeginSendStreamedJob(object[] inValues, System.AsyncCallback callback, object asyncState) { 909 System.Guid clientId = ((System.Guid)(inValues[0])); 910 return this.BeginSendStreamedJob(clientId, callback, asyncState); 911 } 912 913 private object[] OnEndSendStreamedJob(System.IAsyncResult result) { 914 System.IO.Stream retVal = this.EndSendStreamedJob(result); 915 return new object[] { 916 retVal}; 917 } 918 919 private void OnSendStreamedJobCompleted(object state) { 920 if ((this.SendStreamedJobCompleted != null)) { 921 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 922 this.SendStreamedJobCompleted(this, new SendStreamedJobCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState)); 923 } 924 } 925 926 public void SendStreamedJobAsync(System.Guid clientId) { 927 this.SendStreamedJobAsync(clientId, null); 928 } 929 930 public void SendStreamedJobAsync(System.Guid clientId, object userState) { 931 if ((this.onBeginSendStreamedJobDelegate == null)) { 932 this.onBeginSendStreamedJobDelegate = new BeginOperationDelegate(this.OnBeginSendStreamedJob); 933 } 934 if ((this.onEndSendStreamedJobDelegate == null)) { 935 this.onEndSendStreamedJobDelegate = new EndOperationDelegate(this.OnEndSendStreamedJob); 936 } 937 if ((this.onSendStreamedJobCompletedDelegate == null)) { 938 this.onSendStreamedJobCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnSendStreamedJobCompleted); 939 } 940 base.InvokeAsync(this.onBeginSendStreamedJobDelegate, new object[] { 941 clientId}, this.onEndSendStreamedJobDelegate, this.onSendStreamedJobCompletedDelegate, userState); 942 } 943 944 public System.IO.Stream SendStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfo[] pluginList) { 945 return base.Channel.SendStreamedPlugins(pluginList); 946 } 947 948 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 949 public System.IAsyncResult BeginSendStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfo[] pluginList, System.AsyncCallback callback, object asyncState) { 950 return base.Channel.BeginSendStreamedPlugins(pluginList, callback, asyncState); 951 } 952 953 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 954 public System.IO.Stream EndSendStreamedPlugins(System.IAsyncResult result) { 955 return base.Channel.EndSendStreamedPlugins(result); 956 } 957 958 private System.IAsyncResult OnBeginSendStreamedPlugins(object[] inValues, System.AsyncCallback callback, object asyncState) { 959 HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfo[] pluginList = ((HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfo[])(inValues[0])); 960 return this.BeginSendStreamedPlugins(pluginList, callback, asyncState); 961 } 962 963 private object[] OnEndSendStreamedPlugins(System.IAsyncResult result) { 964 System.IO.Stream retVal = this.EndSendStreamedPlugins(result); 965 return new object[] { 966 retVal}; 967 } 968 969 private void OnSendStreamedPluginsCompleted(object state) { 970 if ((this.SendStreamedPluginsCompleted != null)) { 971 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 972 this.SendStreamedPluginsCompleted(this, new SendStreamedPluginsCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState)); 973 } 974 } 975 976 public void SendStreamedPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfo[] pluginList) { 977 this.SendStreamedPluginsAsync(pluginList, null); 978 } 979 980 public void SendStreamedPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfo[] pluginList, object userState) { 981 if ((this.onBeginSendStreamedPluginsDelegate == null)) { 982 this.onBeginSendStreamedPluginsDelegate = new BeginOperationDelegate(this.OnBeginSendStreamedPlugins); 983 } 984 if ((this.onEndSendStreamedPluginsDelegate == null)) { 985 this.onEndSendStreamedPluginsDelegate = new EndOperationDelegate(this.OnEndSendStreamedPlugins); 986 } 987 if ((this.onSendStreamedPluginsCompletedDelegate == null)) { 988 this.onSendStreamedPluginsCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnSendStreamedPluginsCompleted); 989 } 990 base.InvokeAsync(this.onBeginSendStreamedPluginsDelegate, new object[] { 991 pluginList}, this.onEndSendStreamedPluginsDelegate, this.onSendStreamedPluginsCompletedDelegate, userState); 992 } 993 994 public HeuristicLab.Hive.Contracts.ResponseResultReceived StoreFinishedJobResultStreamed(System.IO.Stream stream) { 995 return base.Channel.StoreFinishedJobResultStreamed(stream); 996 } 997 998 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 999 public System.IAsyncResult BeginStoreFinishedJobResultStreamed(System.IO.Stream stream, System.AsyncCallback callback, object asyncState) { 1000 return base.Channel.BeginStoreFinishedJobResultStreamed(stream, callback, asyncState); 1001 } 1002 1003 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1004 public HeuristicLab.Hive.Contracts.ResponseResultReceived EndStoreFinishedJobResultStreamed(System.IAsyncResult result) { 1005 return base.Channel.EndStoreFinishedJobResultStreamed(result); 1006 } 1007 1008 private System.IAsyncResult OnBeginStoreFinishedJobResultStreamed(object[] inValues, System.AsyncCallback callback, object asyncState) { 1009 System.IO.Stream stream = ((System.IO.Stream)(inValues[0])); 1010 return this.BeginStoreFinishedJobResultStreamed(stream, callback, asyncState); 1011 } 1012 1013 private object[] OnEndStoreFinishedJobResultStreamed(System.IAsyncResult result) { 1014 HeuristicLab.Hive.Contracts.ResponseResultReceived retVal = this.EndStoreFinishedJobResultStreamed(result); 1015 return new object[] { 1016 retVal}; 1017 } 1018 1019 private void OnStoreFinishedJobResultStreamedCompleted(object state) { 1020 if ((this.StoreFinishedJobResultStreamedCompleted != null)) { 1021 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 1022 this.StoreFinishedJobResultStreamedCompleted(this, new StoreFinishedJobResultStreamedCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState)); 1023 } 1024 } 1025 1026 public void StoreFinishedJobResultStreamedAsync(System.IO.Stream stream) { 1027 this.StoreFinishedJobResultStreamedAsync(stream, null); 1028 } 1029 1030 public void StoreFinishedJobResultStreamedAsync(System.IO.Stream stream, object userState) { 1031 if ((this.onBeginStoreFinishedJobResultStreamedDelegate == null)) { 1032 this.onBeginStoreFinishedJobResultStreamedDelegate = new BeginOperationDelegate(this.OnBeginStoreFinishedJobResultStreamed); 1033 } 1034 if ((this.onEndStoreFinishedJobResultStreamedDelegate == null)) { 1035 this.onEndStoreFinishedJobResultStreamedDelegate = new EndOperationDelegate(this.OnEndStoreFinishedJobResultStreamed); 1036 } 1037 if ((this.onStoreFinishedJobResultStreamedCompletedDelegate == null)) { 1038 this.onStoreFinishedJobResultStreamedCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnStoreFinishedJobResultStreamedCompleted); 1039 } 1040 base.InvokeAsync(this.onBeginStoreFinishedJobResultStreamedDelegate, new object[] { 1041 stream}, this.onEndStoreFinishedJobResultStreamedDelegate, this.onStoreFinishedJobResultStreamedCompletedDelegate, userState); 1042 } 1043 1044 public HeuristicLab.Hive.Contracts.ResponseResultReceived ProcessSnapshotStreamed(System.IO.Stream stream) { 1045 return base.Channel.ProcessSnapshotStreamed(stream); 1046 } 1047 1048 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1049 public System.IAsyncResult BeginProcessSnapshotStreamed(System.IO.Stream stream, System.AsyncCallback callback, object asyncState) { 1050 return base.Channel.BeginProcessSnapshotStreamed(stream, callback, asyncState); 1051 } 1052 1053 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1054 public HeuristicLab.Hive.Contracts.ResponseResultReceived EndProcessSnapshotStreamed(System.IAsyncResult result) { 1055 return base.Channel.EndProcessSnapshotStreamed(result); 1056 } 1057 1058 private System.IAsyncResult OnBeginProcessSnapshotStreamed(object[] inValues, System.AsyncCallback callback, object asyncState) { 1059 System.IO.Stream stream = ((System.IO.Stream)(inValues[0])); 1060 return this.BeginProcessSnapshotStreamed(stream, callback, asyncState); 1061 } 1062 1063 private object[] OnEndProcessSnapshotStreamed(System.IAsyncResult result) { 1064 HeuristicLab.Hive.Contracts.ResponseResultReceived retVal = this.EndProcessSnapshotStreamed(result); 1065 return new object[] { 1066 retVal}; 1067 } 1068 1069 private void OnProcessSnapshotStreamedCompleted(object state) { 1070 if ((this.ProcessSnapshotStreamedCompleted != null)) { 1071 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 1072 this.ProcessSnapshotStreamedCompleted(this, new ProcessSnapshotStreamedCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState)); 1073 } 1074 } 1075 1076 public void ProcessSnapshotStreamedAsync(System.IO.Stream stream) { 1077 this.ProcessSnapshotStreamedAsync(stream, null); 1078 } 1079 1080 public void ProcessSnapshotStreamedAsync(System.IO.Stream stream, object userState) { 1081 if ((this.onBeginProcessSnapshotStreamedDelegate == null)) { 1082 this.onBeginProcessSnapshotStreamedDelegate = new BeginOperationDelegate(this.OnBeginProcessSnapshotStreamed); 1083 } 1084 if ((this.onEndProcessSnapshotStreamedDelegate == null)) { 1085 this.onEndProcessSnapshotStreamedDelegate = new EndOperationDelegate(this.OnEndProcessSnapshotStreamed); 1086 } 1087 if ((this.onProcessSnapshotStreamedCompletedDelegate == null)) { 1088 this.onProcessSnapshotStreamedCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnProcessSnapshotStreamedCompleted); 1089 } 1090 base.InvokeAsync(this.onBeginProcessSnapshotStreamedDelegate, new object[] { 1091 stream}, this.onEndProcessSnapshotStreamedDelegate, this.onProcessSnapshotStreamedCompletedDelegate, userState); 1092 } 753 1093 } 754 1094 } -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/Reference.svcmap
r1635 r1939 18 18 </ClientOptions> 19 19 <MetadataSources> 20 <MetadataSource Address="net.tcp://10.20.53. 1:9000/HiveServer/mex" Protocol="mex" SourceId="1" />20 <MetadataSource Address="net.tcp://10.20.53.7:9000/HiveServer/mex" Protocol="mex" SourceId="1" /> 21 21 </MetadataSources> 22 22 <Metadata> 23 <MetadataFile FileName="service1.wsdl" MetadataType="Wsdl" ID="008f07c5-6214-48b2-be81-56a008f61361" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 24 <MetadataFile FileName="service2.xsd" MetadataType="Schema" ID="d50f72bd-5f1f-467b-a33c-cada777612ad" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 25 <MetadataFile FileName="service3.xsd" MetadataType="Schema" ID="f8645317-b60d-447b-b3be-dd9d61f39339" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 26 <MetadataFile FileName="HeuristicLab.Hive.Contracts.BusinessObjects1.xsd" MetadataType="Schema" ID="37e6fe8a-479c-4357-83c5-e953e5e9cf5d" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 27 <MetadataFile FileName="HeuristicLab.DataAccess1.xsd" MetadataType="Schema" ID="09df29d2-ed89-4555-9cc8-bc3096dbf165" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 28 <MetadataFile FileName="HeuristicLab.Hive.Contracts1.xsd" MetadataType="Schema" ID="4da8b2ab-d9e8-4a0d-8fb5-34b9c764e8d8" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 29 <MetadataFile FileName="Arrays1.xsd" MetadataType="Schema" ID="16f9cb76-243c-466b-ad58-cdde73fb3174" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 30 <MetadataFile FileName="System1.xsd" MetadataType="Schema" ID="917b5c33-2ff0-4d42-8a17-3cbe66a47f61" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 31 <MetadataFile FileName="HeuristicLab.PluginInfrastructure.xsd" MetadataType="Schema" ID="a4d05bc1-9273-40e8-8a04-a090c796d546" SourceId="1" SourceUrl="net.tcp://10.20.53.1:9000/HiveServer/mex" /> 23 <MetadataFile FileName="service1.wsdl" MetadataType="Wsdl" ID="d53938ec-48ba-418f-bb09-632f539cde8a" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 24 <MetadataFile FileName="service2.xsd" MetadataType="Schema" ID="a16a26be-18d5-4b62-a8d7-91b7bc268763" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 25 <MetadataFile FileName="service3.xsd" MetadataType="Schema" ID="4f67baa6-eb91-49e2-a96c-810e6d087176" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 26 <MetadataFile FileName="HeuristicLab.Hive.Contracts.BusinessObjects1.xsd" MetadataType="Schema" ID="cb3b3f0d-0600-4026-bcb3-79ce12ad35e8" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 27 <MetadataFile FileName="HeuristicLab.DataAccess1.xsd" MetadataType="Schema" ID="a242f5d6-43b5-432f-896a-9e3690c252ed" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 28 <MetadataFile FileName="HeuristicLab.Hive.Contracts1.xsd" MetadataType="Schema" ID="b3db33c3-5c13-42cc-a005-04e92465fe23" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 29 <MetadataFile FileName="Arrays1.xsd" MetadataType="Schema" ID="fefa8f39-1910-40e0-9ef1-e44ffc2f6345" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 30 <MetadataFile FileName="System1.xsd" MetadataType="Schema" ID="c92c72f7-5b07-4aa4-a719-1aabc2a53f18" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 31 <MetadataFile FileName="HeuristicLab.PluginInfrastructure2.xsd" MetadataType="Schema" ID="3a57272e-8914-4d62-b585-e69d27495bd4" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 32 <MetadataFile FileName="Message.xsd" MetadataType="Schema" ID="82cab27f-34e8-430c-be01-1d302547f342" SourceId="1" SourceUrl="net.tcp://10.20.53.7:9000/HiveServer/mex" /> 32 33 </Metadata> 33 34 <Extensions> -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/configuration.svcinfo
r1635 r1939 3 3 <behaviors /> 4 4 <bindings> 5 <binding digest="System.ServiceModel.Configuration.NetTcpBindingElement, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089:<?xml version="1.0" encoding="utf-16"?><Data hostNameComparisonMode="StrongWildcard" listenBacklog="10" maxBufferSize="65536" maxConnections="10" name="NetTcpBinding_IClient Communicator" transactionFlow="false" transactionProtocol="OleTransactions" transferMode="Buffered"><readerQuotas maxArrayLength="16384" maxBytesPerRead="4096" maxDepth="32" maxNameTableCharCount="16384" maxStringContentLength="8192" /><reliableSession enabled="false" inactivityTimeout="00:10:00" ordered="true" /><security mode="Transport"><message clientCredentialType="Windows" /><transport clientCredentialType="Windows" protectionLevel="EncryptAndSign" /></security></Data>" bindingType="netTcpBinding" name="NetTcpBinding_IClientCommunicator" />5 <binding digest="System.ServiceModel.Configuration.NetTcpBindingElement, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089:<?xml version="1.0" encoding="utf-16"?><Data hostNameComparisonMode="StrongWildcard" listenBacklog="10" maxBufferSize="65536" maxConnections="10" name="NetTcpBinding_IClientFacade" transactionFlow="false" transactionProtocol="OleTransactions" transferMode="Streamed"><readerQuotas maxArrayLength="16384" maxBytesPerRead="4096" maxDepth="32" maxNameTableCharCount="16384" maxStringContentLength="8192" /><reliableSession enabled="false" inactivityTimeout="00:10:00" ordered="true" /><security mode="Transport"><message clientCredentialType="Windows" /><transport clientCredentialType="Windows" protectionLevel="EncryptAndSign" /></security></Data>" bindingType="netTcpBinding" name="NetTcpBinding_IClientFacade" /> 6 6 </bindings> 7 7 <endpoints> 8 <endpoint normalizedDigest="<?xml version="1.0" encoding="utf-16"?><Data address="net.tcp://10.20.53. 1:9000/HiveServer/ClientCommunicator" binding="netTcpBinding" bindingConfiguration="NetTcpBinding_IClientCommunicator" contract="ServerService.IClientCommunicator" name="NetTcpBinding_IClientCommunicator"><identity><userPrincipalName value="mse08023@fhs-hagenberg.ac.at" /></identity></Data>" digest="<?xml version="1.0" encoding="utf-16"?><Data address="net.tcp://10.20.53.1:9000/HiveServer/ClientCommunicator" binding="netTcpBinding" bindingConfiguration="NetTcpBinding_IClientCommunicator" contract="ServerService.IClientCommunicator" name="NetTcpBinding_IClientCommunicator"><identity><userPrincipalName value="mse08023@fhs-hagenberg.ac.at" /></identity></Data>" contractName="ServerService.IClientCommunicator" name="NetTcpBinding_IClientCommunicator" />8 <endpoint normalizedDigest="<?xml version="1.0" encoding="utf-16"?><Data address="net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator" binding="netTcpBinding" bindingConfiguration="NetTcpBinding_IClientFacade" contract="ServerService.IClientFacade" name="NetTcpBinding_IClientFacade"><identity><userPrincipalName value="mse08026@fhs-hagenberg.ac.at" /></identity></Data>" digest="<?xml version="1.0" encoding="utf-16"?><Data address="net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator" binding="netTcpBinding" bindingConfiguration="NetTcpBinding_IClientFacade" contract="ServerService.IClientFacade" name="NetTcpBinding_IClientFacade"><identity><userPrincipalName value="mse08026@fhs-hagenberg.ac.at" /></identity></Data>" contractName="ServerService.IClientFacade" name="NetTcpBinding_IClientFacade" /> 9 9 </endpoints> 10 10 </configurationSnapshot> -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/configuration91.svcinfo
r1635 r1939 1 1 <?xml version="1.0" encoding="utf-8"?> 2 <SavedWcfConfigurationInformation xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" Version="9.1" CheckSum=" 7tyXa/aSUNO4WyJm94sZeOTEbBk=">2 <SavedWcfConfigurationInformation xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" Version="9.1" CheckSum="s00QQcc2/XY558TAo0TIgu0l4q4="> 3 3 <bindingConfigurations> 4 <bindingConfiguration bindingType="netTcpBinding" name="NetTcpBinding_IClient Communicator">4 <bindingConfiguration bindingType="netTcpBinding" name="NetTcpBinding_IClientFacade"> 5 5 <properties> 6 6 <property path="/name" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> 7 <serializedValue>NetTcpBinding_IClient Communicator</serializedValue>7 <serializedValue>NetTcpBinding_IClientFacade</serializedValue> 8 8 </property> 9 9 <property path="/closeTimeout" isComplexType="false" isExplicitlyDefined="true" clrType="System.TimeSpan, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> … … 23 23 </property> 24 24 <property path="/transferMode" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.TransferMode, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> 25 <serializedValue> Buffered</serializedValue>25 <serializedValue>Streamed</serializedValue> 26 26 </property> 27 27 <property path="/transactionProtocol" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.TransactionProtocol, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> … … 107 107 </bindingConfigurations> 108 108 <endpoints> 109 <endpoint name="NetTcpBinding_IClient Communicator" contract="ServerService.IClientCommunicator" bindingType="netTcpBinding" address="net.tcp://10.20.53.1:9000/HiveServer/ClientCommunicator" bindingConfiguration="NetTcpBinding_IClientCommunicator">109 <endpoint name="NetTcpBinding_IClientFacade" contract="ServerService.IClientFacade" bindingType="netTcpBinding" address="net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator" bindingConfiguration="NetTcpBinding_IClientFacade"> 110 110 <properties> 111 111 <property path="/address" isComplexType="false" isExplicitlyDefined="true" clrType="System.Uri, System, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> 112 <serializedValue>net.tcp://10.20.53. 1:9000/HiveServer/ClientCommunicator</serializedValue>112 <serializedValue>net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator</serializedValue> 113 113 </property> 114 114 <property path="/behaviorConfiguration" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> … … 119 119 </property> 120 120 <property path="/bindingConfiguration" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> 121 <serializedValue>NetTcpBinding_IClient Communicator</serializedValue>121 <serializedValue>NetTcpBinding_IClientFacade</serializedValue> 122 122 </property> 123 123 <property path="/contract" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> 124 <serializedValue>ServerService.IClient Communicator</serializedValue>124 <serializedValue>ServerService.IClientFacade</serializedValue> 125 125 </property> 126 126 <property path="/headers" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.AddressHeaderCollectionElement, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> … … 137 137 </property> 138 138 <property path="/identity/userPrincipalName/value" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> 139 <serializedValue>mse0802 3@fhs-hagenberg.ac.at</serializedValue>139 <serializedValue>mse08026@fhs-hagenberg.ac.at</serializedValue> 140 140 </property> 141 141 <property path="/identity/servicePrincipalName" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.ServicePrincipalNameElement, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> … … 182 182 </property> 183 183 <property path="/name" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089"> 184 <serializedValue>NetTcpBinding_IClient Communicator</serializedValue>184 <serializedValue>NetTcpBinding_IClientFacade</serializedValue> 185 185 </property> 186 186 </properties> -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/service1.wsdl
r1635 r1939 1 1 <?xml version="1.0" encoding="utf-8"?> 2 2 <wsdl:definitions xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/" xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/" xmlns:wsu="http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-utility-1.0.xsd" xmlns:wsa="http://schemas.xmlsoap.org/ws/2004/08/addressing" xmlns:wsap="http://schemas.xmlsoap.org/ws/2004/08/addressing/policy" xmlns:wsp="http://schemas.xmlsoap.org/ws/2004/09/policy" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:msc="http://schemas.microsoft.com/ws/2005/12/wsdl/contract" xmlns:tns="http://tempuri.org/" xmlns:wsaw="http://www.w3.org/2006/05/addressing/wsdl" xmlns:soap12="http://schemas.xmlsoap.org/wsdl/soap12/" xmlns:wsa10="http://www.w3.org/2005/08/addressing" xmlns:wsam="http://www.w3.org/2007/05/addressing/metadata" name="ClientFacade" targetNamespace="http://tempuri.org/" xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"> 3 <wsp:Policy wsu:Id="NetTcpBinding_IClient Communicator_policy">3 <wsp:Policy wsu:Id="NetTcpBinding_IClientFacade_policy"> 4 4 <wsp:ExactlyOne> 5 5 <wsp:All> … … 29 29 </wsp:Policy> 30 30 </sp:TransportBinding> 31 <msf:Streamed xmlns:msf="http://schemas.microsoft.com/ws/2006/05/framing/policy"> 32 </msf:Streamed> 31 33 <wsaw:UsingAddressing> 32 34 </wsaw:UsingAddressing> … … 44 46 <xsd:import namespace="http://schemas.datacontract.org/2004/07/System" /> 45 47 <xsd:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.PluginInfrastructure" /> 48 <xsd:import namespace="http://schemas.microsoft.com/Message" /> 46 49 </xsd:schema> 47 50 </wsdl:types> 48 <wsdl:message name="IClient Communicator_Login_InputMessage">51 <wsdl:message name="IClientFacade_Login_InputMessage"> 49 52 <wsdl:part name="parameters" element="tns:Login" /> 50 53 </wsdl:message> 51 <wsdl:message name="IClient Communicator_Login_OutputMessage">54 <wsdl:message name="IClientFacade_Login_OutputMessage"> 52 55 <wsdl:part name="parameters" element="tns:LoginResponse" /> 53 56 </wsdl:message> 54 <wsdl:message name="IClient Communicator_ProcessHeartBeat_InputMessage">57 <wsdl:message name="IClientFacade_ProcessHeartBeat_InputMessage"> 55 58 <wsdl:part name="parameters" element="tns:ProcessHeartBeat" /> 56 59 </wsdl:message> 57 <wsdl:message name="IClient Communicator_ProcessHeartBeat_OutputMessage">60 <wsdl:message name="IClientFacade_ProcessHeartBeat_OutputMessage"> 58 61 <wsdl:part name="parameters" element="tns:ProcessHeartBeatResponse" /> 59 62 </wsdl:message> 60 <wsdl:message name="IClient Communicator_SendJob_InputMessage">63 <wsdl:message name="IClientFacade_SendJob_InputMessage"> 61 64 <wsdl:part name="parameters" element="tns:SendJob" /> 62 65 </wsdl:message> 63 <wsdl:message name="IClient Communicator_SendJob_OutputMessage">66 <wsdl:message name="IClientFacade_SendJob_OutputMessage"> 64 67 <wsdl:part name="parameters" element="tns:SendJobResponse" /> 65 68 </wsdl:message> 66 <wsdl:message name="IClient Communicator_StoreFinishedJobResult_InputMessage">69 <wsdl:message name="IClientFacade_StoreFinishedJobResult_InputMessage"> 67 70 <wsdl:part name="parameters" element="tns:StoreFinishedJobResult" /> 68 71 </wsdl:message> 69 <wsdl:message name="IClient Communicator_StoreFinishedJobResult_OutputMessage">72 <wsdl:message name="IClientFacade_StoreFinishedJobResult_OutputMessage"> 70 73 <wsdl:part name="parameters" element="tns:StoreFinishedJobResultResponse" /> 71 74 </wsdl:message> 72 <wsdl:message name="IClient Communicator_ProcessSnapshot_InputMessage">75 <wsdl:message name="IClientFacade_ProcessSnapshot_InputMessage"> 73 76 <wsdl:part name="parameters" element="tns:ProcessSnapshot" /> 74 77 </wsdl:message> 75 <wsdl:message name="IClient Communicator_ProcessSnapshot_OutputMessage">78 <wsdl:message name="IClientFacade_ProcessSnapshot_OutputMessage"> 76 79 <wsdl:part name="parameters" element="tns:ProcessSnapshotResponse" /> 77 80 </wsdl:message> 78 <wsdl:message name="IClient Communicator_Logout_InputMessage">81 <wsdl:message name="IClientFacade_Logout_InputMessage"> 79 82 <wsdl:part name="parameters" element="tns:Logout" /> 80 83 </wsdl:message> 81 <wsdl:message name="IClient Communicator_Logout_OutputMessage">84 <wsdl:message name="IClientFacade_Logout_OutputMessage"> 82 85 <wsdl:part name="parameters" element="tns:LogoutResponse" /> 83 86 </wsdl:message> 84 <wsdl:message name="IClient Communicator_IsJobStillNeeded_InputMessage">87 <wsdl:message name="IClientFacade_IsJobStillNeeded_InputMessage"> 85 88 <wsdl:part name="parameters" element="tns:IsJobStillNeeded" /> 86 89 </wsdl:message> 87 <wsdl:message name="IClient Communicator_IsJobStillNeeded_OutputMessage">90 <wsdl:message name="IClientFacade_IsJobStillNeeded_OutputMessage"> 88 91 <wsdl:part name="parameters" element="tns:IsJobStillNeededResponse" /> 89 92 </wsdl:message> 90 <wsdl:message name="IClient Communicator_SendPlugins_InputMessage">93 <wsdl:message name="IClientFacade_SendPlugins_InputMessage"> 91 94 <wsdl:part name="parameters" element="tns:SendPlugins" /> 92 95 </wsdl:message> 93 <wsdl:message name="IClient Communicator_SendPlugins_OutputMessage">96 <wsdl:message name="IClientFacade_SendPlugins_OutputMessage"> 94 97 <wsdl:part name="parameters" element="tns:SendPluginsResponse" /> 95 98 </wsdl:message> 96 <wsdl:portType name="IClientCommunicator"> 99 <wsdl:message name="IClientFacade_SendStreamedJob_InputMessage"> 100 <wsdl:part name="parameters" element="tns:SendStreamedJob" /> 101 </wsdl:message> 102 <wsdl:message name="IClientFacade_SendStreamedJob_OutputMessage"> 103 <wsdl:part name="parameters" element="tns:SendStreamedJobResponse" /> 104 </wsdl:message> 105 <wsdl:message name="IClientFacade_SendStreamedPlugins_InputMessage"> 106 <wsdl:part name="parameters" element="tns:SendStreamedPlugins" /> 107 </wsdl:message> 108 <wsdl:message name="IClientFacade_SendStreamedPlugins_OutputMessage"> 109 <wsdl:part name="parameters" element="tns:SendStreamedPluginsResponse" /> 110 </wsdl:message> 111 <wsdl:message name="IClientFacade_StoreFinishedJobResultStreamed_InputMessage"> 112 <wsdl:part name="parameters" element="tns:StoreFinishedJobResultStreamed" /> 113 </wsdl:message> 114 <wsdl:message name="IClientFacade_StoreFinishedJobResultStreamed_OutputMessage"> 115 <wsdl:part name="parameters" element="tns:StoreFinishedJobResultStreamedResponse" /> 116 </wsdl:message> 117 <wsdl:message name="IClientFacade_ProcessSnapshotStreamed_InputMessage"> 118 <wsdl:part name="parameters" element="tns:ProcessSnapshotStreamed" /> 119 </wsdl:message> 120 <wsdl:message name="IClientFacade_ProcessSnapshotStreamed_OutputMessage"> 121 <wsdl:part name="parameters" element="tns:ProcessSnapshotStreamedResponse" /> 122 </wsdl:message> 123 <wsdl:portType name="IClientFacade"> 97 124 <wsdl:operation name="Login"> 98 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/Login" message="tns:IClient Communicator_Login_InputMessage" />99 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/LoginResponse" message="tns:IClient Communicator_Login_OutputMessage" />125 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/Login" message="tns:IClientFacade_Login_InputMessage" /> 126 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/LoginResponse" message="tns:IClientFacade_Login_OutputMessage" /> 100 127 </wsdl:operation> 101 128 <wsdl:operation name="ProcessHeartBeat"> 102 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessHeartBeat" message="tns:IClient Communicator_ProcessHeartBeat_InputMessage" />103 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessHeartBeatResponse" message="tns:IClient Communicator_ProcessHeartBeat_OutputMessage" />129 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessHeartBeat" message="tns:IClientFacade_ProcessHeartBeat_InputMessage" /> 130 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessHeartBeatResponse" message="tns:IClientFacade_ProcessHeartBeat_OutputMessage" /> 104 131 </wsdl:operation> 105 132 <wsdl:operation name="SendJob"> 106 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/SendJob" message="tns:IClient Communicator_SendJob_InputMessage" />107 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/SendJobResponse" message="tns:IClient Communicator_SendJob_OutputMessage" />133 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/SendJob" message="tns:IClientFacade_SendJob_InputMessage" /> 134 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/SendJobResponse" message="tns:IClientFacade_SendJob_OutputMessage" /> 108 135 </wsdl:operation> 109 136 <wsdl:operation name="StoreFinishedJobResult"> 110 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/StoreFinishedJobResult" message="tns:IClient Communicator_StoreFinishedJobResult_InputMessage" />111 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/StoreFinishedJobResultResponse" message="tns:IClient Communicator_StoreFinishedJobResult_OutputMessage" />137 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/StoreFinishedJobResult" message="tns:IClientFacade_StoreFinishedJobResult_InputMessage" /> 138 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/StoreFinishedJobResultResponse" message="tns:IClientFacade_StoreFinishedJobResult_OutputMessage" /> 112 139 </wsdl:operation> 113 140 <wsdl:operation name="ProcessSnapshot"> 114 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessSnapshot" message="tns:IClient Communicator_ProcessSnapshot_InputMessage" />115 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessSnapshotResponse" message="tns:IClient Communicator_ProcessSnapshot_OutputMessage" />141 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessSnapshot" message="tns:IClientFacade_ProcessSnapshot_InputMessage" /> 142 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessSnapshotResponse" message="tns:IClientFacade_ProcessSnapshot_OutputMessage" /> 116 143 </wsdl:operation> 117 144 <wsdl:operation name="Logout"> 118 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/Logout" message="tns:IClient Communicator_Logout_InputMessage" />119 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/LogoutResponse" message="tns:IClient Communicator_Logout_OutputMessage" />145 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/Logout" message="tns:IClientFacade_Logout_InputMessage" /> 146 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/LogoutResponse" message="tns:IClientFacade_Logout_OutputMessage" /> 120 147 </wsdl:operation> 121 148 <wsdl:operation name="IsJobStillNeeded"> 122 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/IsJobStillNeeded" message="tns:IClient Communicator_IsJobStillNeeded_InputMessage" />123 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/IsJobStillNeededResponse" message="tns:IClient Communicator_IsJobStillNeeded_OutputMessage" />149 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/IsJobStillNeeded" message="tns:IClientFacade_IsJobStillNeeded_InputMessage" /> 150 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/IsJobStillNeededResponse" message="tns:IClientFacade_IsJobStillNeeded_OutputMessage" /> 124 151 </wsdl:operation> 125 152 <wsdl:operation name="SendPlugins"> 126 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/SendPlugins" message="tns:IClientCommunicator_SendPlugins_InputMessage" /> 127 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/SendPluginsResponse" message="tns:IClientCommunicator_SendPlugins_OutputMessage" /> 153 <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/SendPlugins" message="tns:IClientFacade_SendPlugins_InputMessage" /> 154 <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/SendPluginsResponse" message="tns:IClientFacade_SendPlugins_OutputMessage" /> 155 </wsdl:operation> 156 <wsdl:operation name="SendStreamedJob"> 157 <wsdl:input wsaw:Action="http://tempuri.org/IClientFacade/SendStreamedJob" message="tns:IClientFacade_SendStreamedJob_InputMessage" /> 158 <wsdl:output wsaw:Action="http://tempuri.org/IClientFacade/SendStreamedJobResponse" message="tns:IClientFacade_SendStreamedJob_OutputMessage" /> 159 </wsdl:operation> 160 <wsdl:operation name="SendStreamedPlugins"> 161 <wsdl:input wsaw:Action="http://tempuri.org/IClientFacade/SendStreamedPlugins" message="tns:IClientFacade_SendStreamedPlugins_InputMessage" /> 162 <wsdl:output wsaw:Action="http://tempuri.org/IClientFacade/SendStreamedPluginsResponse" message="tns:IClientFacade_SendStreamedPlugins_OutputMessage" /> 163 </wsdl:operation> 164 <wsdl:operation name="StoreFinishedJobResultStreamed"> 165 <wsdl:input wsaw:Action="http://tempuri.org/IClientFacade/StoreFinishedJobResultStreamed" message="tns:IClientFacade_StoreFinishedJobResultStreamed_InputMessage" /> 166 <wsdl:output wsaw:Action="http://tempuri.org/IClientFacade/StoreFinishedJobResultStreamedResponse" message="tns:IClientFacade_StoreFinishedJobResultStreamed_OutputMessage" /> 167 </wsdl:operation> 168 <wsdl:operation name="ProcessSnapshotStreamed"> 169 <wsdl:input wsaw:Action="http://tempuri.org/IClientFacade/ProcessSnapshotStreamed" message="tns:IClientFacade_ProcessSnapshotStreamed_InputMessage" /> 170 <wsdl:output wsaw:Action="http://tempuri.org/IClientFacade/ProcessSnapshotStreamedResponse" message="tns:IClientFacade_ProcessSnapshotStreamed_OutputMessage" /> 128 171 </wsdl:operation> 129 172 </wsdl:portType> 130 <wsdl:binding name="NetTcpBinding_IClient Communicator" type="tns:IClientCommunicator">131 <wsp:PolicyReference URI="#NetTcpBinding_IClient Communicator_policy">173 <wsdl:binding name="NetTcpBinding_IClientFacade" type="tns:IClientFacade"> 174 <wsp:PolicyReference URI="#NetTcpBinding_IClientFacade_policy"> 132 175 </wsp:PolicyReference> 133 176 <soap12:binding transport="http://schemas.microsoft.com/soap/tcp" /> … … 204 247 </wsdl:output> 205 248 </wsdl:operation> 249 <wsdl:operation name="SendStreamedJob"> 250 <soap12:operation soapAction="http://tempuri.org/IClientFacade/SendStreamedJob" style="document" /> 251 <wsdl:input> 252 <soap12:body use="literal" /> 253 </wsdl:input> 254 <wsdl:output> 255 <soap12:body use="literal" /> 256 </wsdl:output> 257 </wsdl:operation> 258 <wsdl:operation name="SendStreamedPlugins"> 259 <soap12:operation soapAction="http://tempuri.org/IClientFacade/SendStreamedPlugins" style="document" /> 260 <wsdl:input> 261 <soap12:body use="literal" /> 262 </wsdl:input> 263 <wsdl:output> 264 <soap12:body use="literal" /> 265 </wsdl:output> 266 </wsdl:operation> 267 <wsdl:operation name="StoreFinishedJobResultStreamed"> 268 <soap12:operation soapAction="http://tempuri.org/IClientFacade/StoreFinishedJobResultStreamed" style="document" /> 269 <wsdl:input> 270 <soap12:body use="literal" /> 271 </wsdl:input> 272 <wsdl:output> 273 <soap12:body use="literal" /> 274 </wsdl:output> 275 </wsdl:operation> 276 <wsdl:operation name="ProcessSnapshotStreamed"> 277 <soap12:operation soapAction="http://tempuri.org/IClientFacade/ProcessSnapshotStreamed" style="document" /> 278 <wsdl:input> 279 <soap12:body use="literal" /> 280 </wsdl:input> 281 <wsdl:output> 282 <soap12:body use="literal" /> 283 </wsdl:output> 284 </wsdl:operation> 206 285 </wsdl:binding> 207 286 <wsdl:service name="ClientFacade"> 208 <wsdl:port name="NetTcpBinding_IClient Communicator" binding="tns:NetTcpBinding_IClientCommunicator">209 <soap12:address location="net.tcp://10.20.53. 1:9000/HiveServer/ClientCommunicator" />287 <wsdl:port name="NetTcpBinding_IClientFacade" binding="tns:NetTcpBinding_IClientFacade"> 288 <soap12:address location="net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator" /> 210 289 <wsa10:EndpointReference> 211 <wsa10:Address>net.tcp://10.20.53. 1:9000/HiveServer/ClientCommunicator</wsa10:Address>290 <wsa10:Address>net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator</wsa10:Address> 212 291 <Identity xmlns="http://schemas.xmlsoap.org/ws/2006/02/addressingidentity"> 213 <Upn>mse0802 3@fhs-hagenberg.ac.at</Upn>292 <Upn>mse08026@fhs-hagenberg.ac.at</Upn> 214 293 </Identity> 215 294 </wsa10:EndpointReference> -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/service2.xsd
r1594 r1939 5 5 <xs:import namespace="http://schemas.microsoft.com/2003/10/Serialization/" /> 6 6 <xs:import namespace="http://schemas.datacontract.org/2004/07/System" /> 7 <xs:import namespace="http://schemas.microsoft.com/Message" /> 7 8 <xs:element name="Login"> 8 9 <xs:complexType> … … 125 126 </xs:complexType> 126 127 </xs:element> 128 <xs:element name="SendStreamedJob"> 129 <xs:complexType> 130 <xs:sequence> 131 <xs:element xmlns:q21="http://schemas.microsoft.com/2003/10/Serialization/" minOccurs="0" name="clientId" type="q21:guid" /> 132 </xs:sequence> 133 </xs:complexType> 134 </xs:element> 135 <xs:element name="SendStreamedJobResponse"> 136 <xs:complexType> 137 <xs:sequence> 138 <xs:element xmlns:q22="http://schemas.microsoft.com/Message" name="SendStreamedJobResult" type="q22:StreamBody" /> 139 </xs:sequence> 140 </xs:complexType> 141 </xs:element> 142 <xs:element name="SendStreamedPlugins"> 143 <xs:complexType> 144 <xs:sequence> 145 <xs:element xmlns:q23="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.BusinessObjects" minOccurs="0" name="pluginList" nillable="true" type="q23:ArrayOfHivePluginInfo" /> 146 </xs:sequence> 147 </xs:complexType> 148 </xs:element> 149 <xs:element name="SendStreamedPluginsResponse"> 150 <xs:complexType> 151 <xs:sequence> 152 <xs:element xmlns:q24="http://schemas.microsoft.com/Message" name="SendStreamedPluginsResult" type="q24:StreamBody" /> 153 </xs:sequence> 154 </xs:complexType> 155 </xs:element> 156 <xs:element name="StoreFinishedJobResultStreamed"> 157 <xs:complexType> 158 <xs:sequence> 159 <xs:element xmlns:q25="http://schemas.microsoft.com/Message" name="stream" type="q25:StreamBody" /> 160 </xs:sequence> 161 </xs:complexType> 162 </xs:element> 163 <xs:element name="StoreFinishedJobResultStreamedResponse"> 164 <xs:complexType> 165 <xs:sequence> 166 <xs:element xmlns:q26="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts" minOccurs="0" name="StoreFinishedJobResultStreamedResult" nillable="true" type="q26:ResponseResultReceived" /> 167 </xs:sequence> 168 </xs:complexType> 169 </xs:element> 170 <xs:element name="ProcessSnapshotStreamed"> 171 <xs:complexType> 172 <xs:sequence> 173 <xs:element xmlns:q27="http://schemas.microsoft.com/Message" name="stream" type="q27:StreamBody" /> 174 </xs:sequence> 175 </xs:complexType> 176 </xs:element> 177 <xs:element name="ProcessSnapshotStreamedResponse"> 178 <xs:complexType> 179 <xs:sequence> 180 <xs:element xmlns:q28="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts" minOccurs="0" name="ProcessSnapshotStreamedResult" nillable="true" type="q28:ResponseResultReceived" /> 181 </xs:sequence> 182 </xs:complexType> 183 </xs:element> 127 184 </xs:schema> -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/WcfService.cs
r1936 r1939 31 31 using HeuristicLab.Hive.Client.Communication.ServerService; 32 32 using HeuristicLab.PluginInfrastructure; 33 using System.IO; 34 using System.Runtime.Serialization.Formatters.Binary; 33 35 34 36 namespace HeuristicLab.Hive.Client.Communication { … … 60 62 public event EventHandler Connected; 61 63 62 public Client CommunicatorClient proxy = null;64 public ClientFacadeClient proxy = null; 63 65 64 66 /// <summary> … … 74 76 public void Connect() { 75 77 try { 76 proxy = new Client CommunicatorClient(77 WcfSettings.Get Binding(),78 proxy = new ClientFacadeClient( 79 WcfSettings.GetStreamedBinding(), 78 80 new EndpointAddress("net.tcp://" + ServerIP + ":" + ServerPort + "/HiveServer/ClientCommunicator") 79 81 ); 80 82 81 83 proxy.LoginCompleted += new EventHandler<LoginCompletedEventArgs>(proxy_LoginCompleted); 82 proxy.Send JobCompleted += new EventHandler<SendJobCompletedEventArgs>(proxy_SendJobCompleted);83 proxy.StoreFinishedJobResult Completed += new EventHandler<StoreFinishedJobResultCompletedEventArgs>(proxy_StoreFinishedJobResultCompleted);84 proxy.ProcessSnapshot Completed += new EventHandler<ProcessSnapshotCompletedEventArgs>(proxy_ProcessSnapshotCompleted);84 proxy.SendStreamedJobCompleted += new EventHandler<SendStreamedJobCompletedEventArgs>(proxy_SendStreamedJobCompleted); 85 proxy.StoreFinishedJobResultStreamedCompleted += new EventHandler<StoreFinishedJobResultStreamedCompletedEventArgs>(proxy_StoreFinishedJobResultStreamedCompleted); 86 proxy.ProcessSnapshotStreamedCompleted += new EventHandler<ProcessSnapshotStreamedCompletedEventArgs>(proxy_ProcessSnapshotStreamedCompleted); 85 87 proxy.ProcessHeartBeatCompleted += new EventHandler<ProcessHeartBeatCompletedEventArgs>(proxy_ProcessHeartBeatCompleted); 86 88 proxy.Open(); … … 99 101 } 100 102 } 101 102 103 103 104 … … 174 175 public void SendJobAsync(Guid guid) { 175 176 if (ConnState == NetworkEnum.WcfConnState.Loggedin) 176 proxy.SendJobAsync(guid); 177 } 178 void proxy_SendJobCompleted(object sender, SendJobCompletedEventArgs e) { 179 if (e.Error == null) 180 SendJobCompleted(sender, e); 181 else 177 proxy.SendStreamedJobAsync(guid); 178 } 179 180 void proxy_SendStreamedJobCompleted(object sender, SendStreamedJobCompletedEventArgs e) { 181 if (e.Error == null) { 182 Stream stream = 183 (Stream)e.Result; 184 185 BinaryFormatter formatter = 186 new BinaryFormatter(); 187 ResponseJob response = (ResponseJob)formatter.Deserialize(stream); 188 189 SendJobCompletedEventArgs completedEventArgs = 190 new SendJobCompletedEventArgs(new object[] { response }, e.Error, e.Cancelled, e.UserState); 191 SendJobCompleted(sender, completedEventArgs); 192 } else 182 193 HandleNetworkError(e.Error); 183 194 } 195 184 196 #endregion 185 197 … … 191 203 public void StoreFinishedJobResultAsync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) { 192 204 if (ConnState == NetworkEnum.WcfConnState.Loggedin) 193 proxy.StoreFinishedJobResultAsync(clientId, jobId, result, percentage, exception, finished); 194 } 195 private void proxy_StoreFinishedJobResultCompleted(object sender, StoreFinishedJobResultCompletedEventArgs e) { 196 if (e.Error == null) 197 StoreFinishedJobResultCompleted(sender, e); 198 else 205 proxy.StoreFinishedJobResultStreamedAsync( 206 GetStreamedJobResult(clientId, jobId, result, percentage, exception)); 207 } 208 private void proxy_StoreFinishedJobResultStreamedCompleted(object sender, StoreFinishedJobResultStreamedCompletedEventArgs e) { 209 if (e.Error == null) { 210 StoreFinishedJobResultCompletedEventArgs args = 211 new StoreFinishedJobResultCompletedEventArgs( 212 new object[] { e.Result }, e.Error, e.Cancelled, e.UserState); 213 StoreFinishedJobResultCompleted(sender, args); 214 } else 199 215 HandleNetworkError(e.Error); 200 216 } … … 206 222 public void ProcessSnapshotAsync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) { 207 223 if(ConnState == NetworkEnum.WcfConnState.Loggedin) 208 proxy.ProcessSnapshotAsync(clientId, jobId, result, percentage, exception); 209 } 210 void proxy_ProcessSnapshotCompleted(object sender, ProcessSnapshotCompletedEventArgs e) { 211 if (e.Error == null) 212 ProcessSnapshotCompleted(sender, e); 213 else 224 proxy.ProcessSnapshotStreamedAsync( 225 GetStreamedJobResult( 226 clientId, jobId, result, percentage, exception)); 227 } 228 void proxy_ProcessSnapshotStreamedCompleted(object sender, ProcessSnapshotStreamedCompletedEventArgs e) { 229 if (e.Error == null) { 230 ProcessSnapshotCompletedEventArgs args = 231 new ProcessSnapshotCompletedEventArgs( 232 new object[] { e.Result }, e.Error, e.Cancelled, e.UserState); 233 234 ProcessSnapshotCompleted(sender, args); 235 } else 214 236 HandleNetworkError(e.Error); 215 237 } … … 249 271 #endregion */ 250 272 273 private Stream GetStreamedJobResult(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception) { 274 JobResult jobResult = 275 new JobResult(); 276 jobResult.ClientId = clientId; 277 jobResult.JobId = jobId; 278 jobResult.Result = result; 279 jobResult.Percentage = percentage; 280 jobResult.Exception = exception; 281 282 MemoryStream stream = 283 new MemoryStream(); 284 285 BinaryFormatter formatter = 286 new BinaryFormatter(); 287 288 formatter.Serialize(stream, jobResult); 289 stream.Seek(0, SeekOrigin.Begin); 290 291 return stream; 292 } 293 251 294 public ResponseResultReceived SendStoredJobResultsSync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) { 252 return proxy.StoreFinishedJobResult(clientId, jobId, result, percentage, exception); 295 return proxy.StoreFinishedJobResultStreamed( 296 GetStreamedJobResult(clientId, jobId, result, percentage, exception)); 253 297 } 254 298 255 299 public ResponseResultReceived ProcessSnapshotSync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception) { 256 300 try { 257 ResponseResultReceived res = proxy.ProcessSnapshot(clientId, jobId, result, percentage, null);258 301 Logging.Instance.Info(this.ToString(), "Snapshot for Job " + jobId + " submitted"); 259 return res; 302 return proxy.ProcessSnapshotStreamed( 303 GetStreamedJobResult(clientId, jobId, result, percentage, exception)); 260 304 } 261 305 catch (Exception e) { … … 267 311 public List<CachedHivePluginInfo> RequestPlugins(List<HivePluginInfo> requestedPlugins) { 268 312 try { 269 ResponsePlugin response = proxy.SendPlugins(requestedPlugins.ToArray()); 313 Stream stream = proxy.SendStreamedPlugins(requestedPlugins.ToArray()); 314 315 BinaryFormatter formatter = 316 new BinaryFormatter(); 317 ResponsePlugin response = (ResponsePlugin)formatter.Deserialize(stream); 270 318 return response.Plugins; 271 319 } -
trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/app.config
r1635 r1939 4 4 <bindings> 5 5 <netTcpBinding> 6 <binding name="NetTcpBinding_IClient Communicator" closeTimeout="00:01:00"6 <binding name="NetTcpBinding_IClientFacade" closeTimeout="00:01:00" 7 7 openTimeout="00:01:00" receiveTimeout="00:10:00" sendTimeout="00:01:00" 8 transactionFlow="false" transferMode=" Buffered" transactionProtocol="OleTransactions"8 transactionFlow="false" transferMode="Streamed" transactionProtocol="OleTransactions" 9 9 hostNameComparisonMode="StrongWildcard" listenBacklog="10" 10 10 maxBufferPoolSize="524288" maxBufferSize="65536" maxConnections="10" … … 22 22 </bindings> 23 23 <client> 24 <endpoint address="net.tcp://10.20.53. 1:9000/HiveServer/ClientCommunicator"25 binding="netTcpBinding" bindingConfiguration="NetTcpBinding_IClient Communicator"26 contract="ServerService.IClient Communicator" name="NetTcpBinding_IClientCommunicator">24 <endpoint address="net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator" 25 binding="netTcpBinding" bindingConfiguration="NetTcpBinding_IClientFacade" 26 contract="ServerService.IClientFacade" name="NetTcpBinding_IClientFacade"> 27 27 <identity> 28 <userPrincipalName value="mse0802 3@fhs-hagenberg.ac.at" />28 <userPrincipalName value="mse08026@fhs-hagenberg.ac.at" /> 29 29 </identity> 30 30 </endpoint> -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/CachedHivePluginInfo.cs
r1643 r1939 28 28 namespace HeuristicLab.PluginInfrastructure { 29 29 [DataContract] 30 [Serializable] 30 31 public class CachedHivePluginInfo : HivePluginInfo { 31 32 -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/Client.cs
r1772 r1939 31 31 32 32 [DataContract] 33 [Serializable] 33 34 public class ClientInfo : Resource { 34 35 [DataMember] -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/ClientConfig.cs
r1377 r1939 30 30 31 31 [DataContract] 32 [Serializable] 32 33 public class ClientConfig : PersistableObject { 33 34 [DataMember] -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/HivePluginInfo.cs
r1592 r1939 31 31 32 32 [DataContract] 33 [Serializable] 33 34 public class HivePluginInfo : PersistableObject { 34 35 [DataMember] -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/Job.cs
r1932 r1939 31 31 32 32 [DataContract] 33 [Serializable] 33 34 public class Job : PersistableObject { 34 35 [DataMember] -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/JobResult.cs
r1626 r1939 30 30 31 31 [DataContract] 32 [Serializable] 32 33 public class JobResult : PersistableObject { 33 34 [DataMember] 34 public Job Job{ get; set; }35 public Guid JobId { get; set; } 35 36 [DataMember] 36 37 public byte[] Result { get; set; } … … 40 41 public DateTime Timestamp { get; set; } 41 42 [DataMember] 42 public ClientInfo Client{ get; set; }43 public Guid ClientId { get; set; } 43 44 [DataMember] 44 45 public Exception Exception { get; set; } -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/Resource.cs
r1377 r1939 30 30 31 31 [DataContract] 32 [Serializable] 32 33 public class Resource : PersistableObject { 33 34 [DataMember] -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/HeuristicLab.Hive.Contracts-3.2.csproj
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> -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/Interfaces/IClientFacade.cs
r1101 r1939 24 24 using System.Linq; 25 25 using System.Text; 26 using System.ServiceModel; 27 using System.IO; 28 using HeuristicLab.Hive.Contracts.BusinessObjects; 26 29 27 30 namespace HeuristicLab.Hive.Contracts.Interfaces { 31 [ServiceContract] 28 32 public interface IClientFacade: IClientCommunicator { 33 [OperationContract] 34 Stream SendStreamedJob(Guid clientId); 35 36 [OperationContract] 37 Stream SendStreamedPlugins(List<HivePluginInfo> pluginList); 38 39 [OperationContract] 40 ResponseResultReceived StoreFinishedJobResultStreamed(Stream stream); 41 42 [OperationContract] 43 ResponseResultReceived ProcessSnapshotStreamed(Stream stream); 29 44 } 30 45 } -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/Response.cs
r1530 r1939 31 31 /// </summary> 32 32 [DataContract] 33 [Serializable] 33 34 public class Response { 34 35 [DataMember] -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/ResponseJob.cs
r1530 r1939 34 34 /// </summary> 35 35 [DataContract] 36 [Serializable] 36 37 public class ResponseJob : Response { 37 38 [DataMember] -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/ResponsePlugin.cs
r1596 r1939 9 9 10 10 [DataContract] 11 [Serializable] 11 12 public class ResponsePlugin : Response { 12 13 public ResponsePlugin() { -
trunk/sources/HeuristicLab.Hive.Contracts/3.2/WcfSettings.cs
r1809 r1939 25 25 NetTcpBinding binding = new NetTcpBinding(); 26 26 #endif 27 binding.MaxBufferSize = int.MaxValue; 27 /*binding.MaxBufferSize = int.MaxValue; 28 binding.MaxReceivedMessageSize = int.MaxValue; 29 binding.ReaderQuotas.MaxArrayLength = int.MaxValue; 30 binding.ReaderQuotas.MaxStringContentLength = int.MaxValue; */ 31 binding.CloseTimeout = new TimeSpan(0, 5, 0); 32 binding.ReceiveTimeout = new TimeSpan(0, 5, 0); 33 binding.SendTimeout = new TimeSpan(0, 5, 0); 34 return binding; 35 } 36 37 public static Binding GetStreamedBinding() { 38 #if USE_MSG_BINDING 39 NetTcpBinding binding = new NetTcpBinding(SecurityMode.Message); 40 #else 41 NetTcpBinding binding = new NetTcpBinding(); 42 #endif 43 binding.TransferMode = TransferMode.Streamed; 28 44 binding.MaxReceivedMessageSize = int.MaxValue; 29 45 binding.ReaderQuotas.MaxArrayLength = int.MaxValue; -
trunk/sources/HeuristicLab.Hive.Engine/3.2/ServiceLocator.cs
r1599 r1939 33 33 ChannelFactory<IExecutionEngineFacade> factory = 34 34 new ChannelFactory<IExecutionEngineFacade>( 35 WcfSettings.Get Binding(),35 WcfSettings.GetStreamedBinding(), 36 36 new EndpointAddress(url)); 37 37 -
trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/JobResultsAdapter.cs
r1716 r1939 50 50 dsHiveServer.JobResultRow row) { 51 51 if (row != null && result != null) { 52 if (result.Job != null)53 row.JobId = result.Job .Id;52 if (result.JobId != Guid.Empty) 53 row.JobId = result.JobId; 54 54 else 55 55 row.SetJobIdNull(); … … 60 60 row.SetJobResultNull(); 61 61 62 if (result.Client != null) {62 if (result.ClientId != Guid.Empty) { 63 63 ClientInfo client = 64 ClientAdapter.GetById(result.Client .Id);64 ClientAdapter.GetById(result.ClientId); 65 65 66 66 if (client != null) … … 95 95 96 96 if (!row.IsJobIdNull()) 97 result.Job = JobAdapter.GetById(row.JobId);97 result.JobId = row.JobId; 98 98 else 99 result.Job = null;99 result.JobId = Guid.Empty; 100 100 101 101 if (!row.IsJobResultNull()) … … 105 105 106 106 if (!row.IsResourceIdNull()) 107 result.Client = ClientAdapter.GetById(row.ResourceId);107 result.ClientId = row.ResourceId; 108 108 else 109 result.Client = null;109 result.ClientId = Guid.Empty; 110 110 111 111 if (!row.IsMessageNull()) … … 128 128 129 129 #region IJobResultsAdapter Members 130 protected override void doUpdate(JobResult result) {131 if (result != null) {132 ClientAdapter.Update(result.Client);133 JobAdapter.Update(result.Job);134 135 base.doUpdate(result);136 }137 }138 139 130 public ICollection<JobResult> GetResultsOf(Job job) { 140 131 if (job != null) { -
trunk/sources/HeuristicLab.Hive.Server.Console/3.2/HiveServerManagementConsole.cs
r1937 r1939 757 757 if (jobRes.List != null) { 758 758 foreach (JobResult jobresult in jobRes.List) { 759 ListViewItem curSnapshot = new ListViewItem(jobresult.Client .Name);759 ListViewItem curSnapshot = new ListViewItem(jobresult.ClientId.ToString()); 760 760 double percentage = jobresult.Percentage * 100; 761 761 curSnapshot.SubItems.Add(percentage.ToString() + " %"); -
trunk/sources/HeuristicLab.Hive.Server.Core/3.2/ClientCommunicator.cs
r1928 r1939 451 451 JobResult jobResult = 452 452 new JobResult(); 453 jobResult.Client = client;454 jobResult.Job = job;453 jobResult.ClientId = client.Id; 454 jobResult.JobId = job.Id; 455 455 jobResult.Result = result; 456 456 jobResult.Percentage = percentage; -
trunk/sources/HeuristicLab.Hive.Server.Core/3.2/ClientFacade.cs
r1600 r1939 28 28 using HeuristicLab.Hive.Contracts; 29 29 using HeuristicLab.PluginInfrastructure; 30 using System.IO; 31 using System.Runtime.Serialization.Formatters.Binary; 30 32 31 33 namespace HeuristicLab.Hive.Server.Core { … … 74 76 75 77 #endregion 78 79 #region IClientFacade Members 80 81 public Stream SendStreamedJob(Guid clientId) { 82 return 83 new StreamedObject<ResponseJob>( 84 this.SendJob(clientId)); 85 } 86 87 public Stream SendStreamedPlugins(List<HivePluginInfo> pluginList) { 88 return 89 new StreamedObject<ResponsePlugin>( 90 this.SendPlugins(pluginList)); 91 } 92 93 public ResponseResultReceived StoreFinishedJobResultStreamed(Stream stream) { 94 BinaryFormatter formatter = 95 new BinaryFormatter(); 96 JobResult result = (JobResult)formatter.Deserialize(stream); 97 98 return this.StoreFinishedJobResult( 99 result.ClientId, 100 result.JobId, 101 result.Result, 102 result.Percentage, 103 result.Exception); 104 } 105 106 public ResponseResultReceived ProcessSnapshotStreamed(Stream stream) { 107 BinaryFormatter formatter = 108 new BinaryFormatter(); 109 JobResult result = (JobResult)formatter.Deserialize(stream); 110 111 return this.ProcessSnapshot( 112 result.ClientId, 113 result.JobId, 114 result.Result, 115 result.Percentage, 116 result.Exception); 117 } 118 119 #endregion 76 120 } 77 121 } -
trunk/sources/HeuristicLab.Hive.Server/3.2/HiveServerApplication.cs
r1579 r1939 43 43 private Dictionary<string, ServiceHost> runningServices = new Dictionary<string, ServiceHost>(); 44 44 private NetTcpBinding binding = (NetTcpBinding)WcfSettings.GetBinding(); 45 private NetTcpBinding streamedBinding = (NetTcpBinding)WcfSettings.GetStreamedBinding(); 45 46 46 47 private enum Services { … … 76 77 uriTcp = new Uri("net.tcp://" + ipAddress + ":" + port + "/HiveServer/"); 77 78 serviceHost = new ServiceHost(clientCommunicatorInstances[0].GetType(), uriTcp); 78 serviceHost.AddServiceEndpoint(typeof(IClient Communicator), binding, STR_ClientCommunicator);79 serviceHost.AddServiceEndpoint(typeof(IClientFacade), streamedBinding, STR_ClientCommunicator); 79 80 curServiceHost = STR_ClientCommunicator; 80 81 } … … 92 93 uriTcp = new Uri("net.tcp://" + ipAddress + ":" + port + "/ExecutionEngine/"); 93 94 serviceHost = new ServiceHost(executionEngineInstances[0].GetType(), uriTcp); 94 serviceHost.AddServiceEndpoint(typeof(IExecutionEngineFacade), binding, STR_ExecutionEngineFacade);95 serviceHost.AddServiceEndpoint(typeof(IExecutionEngineFacade), streamedBinding, STR_ExecutionEngineFacade); 95 96 curServiceHost = STR_ExecutionEngineFacade; 96 97 }
Note: See TracChangeset
for help on using the changeset viewer.