Free cookie consent management tool by TermsFeed Policy Generator

Changeset 1939 for trunk


Ignore:
Timestamp:
05/28/09 18:38:46 (15 years ago)
Author:
svonolfe
Message:

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

Location:
trunk/sources
Files:
4 added
32 edited

Legend:

Unmodified
Added
Removed

  • trunk/sources/HeuristicLab.DataAccess/3.2/PersistableObject.cs

    r1720 r1939  
    2828namespace HeuristicLab.DataAccess {
    2929  [DataContract]
     30  [Serializable]
    3031  public class PersistableObject: IPersistableObject {
    3132    [DataMember]

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/HeuristicLab.Hive.Client.Communication-3.2.csproj

    r1635 r1939  
    145145    <None Include="Service References\ServerService\HeuristicLab.Hive.Contracts1.xsd" />
    146146    <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" />
    147149    <None Include="Service References\ServerService\Reference.svcmap">
    148150      <Generator>WCF Proxy Generator</Generator>

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/HeuristicLab.Hive.Contracts.BusinessObjects1.xsd

    r1594 r1939  
    5151      <xs:enumeration value="abort" />
    5252      <xs:enumeration value="requestSnapshot" />
     53      <xs:enumeration value="requestSnapshotSent" />
    5354    </xs:restriction>
    5455  </xs:simpleType>

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/HeuristicLab.Hive.Contracts1.xsd

    r1594 r1939  
    4444      <xs:enumeration value="SnapshotReady" />
    4545      <xs:enumeration value="Shutdown" />
     46      <xs:enumeration value="JobFailed" />
    4647    </xs:restriction>
    4748  </xs:simpleType>

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/Reference.cs

    r1594 r1939  
    22// <auto-generated>
    33//     This code was generated by a tool.
    4 //     Runtime Version:2.0.50727.3053
     4//     Runtime Version:2.0.50727.3082
    55//
    66//     Changes to this file may cause incorrect behavior and will be lost if
    … …  
    1313   
    1414    [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "3.0.0.0")]
    15     [System.ServiceModel.ServiceContractAttribute(ConfigurationName="ServerService.IClientCommunicator")]
    16     public interface IClientCommunicator {
     15    [System.ServiceModel.ServiceContractAttribute(ConfigurationName="ServerService.IClientFacade")]
     16    public interface IClientFacade {
    1717       
    1818        [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/IClientCommunicator/Login", ReplyAction="http://tempuri.org/IClientCommunicator/LoginResponse")]
    … …  
    9191       
    9292        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 {
    97129    }
    98130   
    … …  
    251283    [System.Diagnostics.DebuggerStepThroughAttribute()]
    252284    [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 {
    254362       
    255363        private BeginOperationDelegate onBeginLoginDelegate;
    … …  
    301409        private System.Threading.SendOrPostCallback onSendPluginsCompletedDelegate;
    302410       
    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) :
    307439                base(endpointConfigurationName) {
    308440        }
    309441       
    310         public ClientCommunicatorClient(string endpointConfigurationName, string remoteAddress) :
     442        public ClientFacadeClient(string endpointConfigurationName, string remoteAddress) :
    311443                base(endpointConfigurationName, remoteAddress) {
    312444        }
    313445       
    314         public ClientCommunicatorClient(string endpointConfigurationName, System.ServiceModel.EndpointAddress remoteAddress) :
     446        public ClientFacadeClient(string endpointConfigurationName, System.ServiceModel.EndpointAddress remoteAddress) :
    315447                base(endpointConfigurationName, remoteAddress) {
    316448        }
    317449       
    318         public ClientCommunicatorClient(System.ServiceModel.Channels.Binding binding, System.ServiceModel.EndpointAddress remoteAddress) :
     450        public ClientFacadeClient(System.ServiceModel.Channels.Binding binding, System.ServiceModel.EndpointAddress remoteAddress) :
    319451                base(binding, remoteAddress) {
    320452        }
    … …  
    335467       
    336468        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;
    337477       
    338478        public HeuristicLab.Hive.Contracts.Response Login(HeuristicLab.Hive.Contracts.BusinessObjects.ClientInfo clientInfo) {
    … …  
    751891                        pluginList}, this.onEndSendPluginsDelegate, this.onSendPluginsCompletedDelegate, userState);
    752892        }
     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        }
    7531093    }
    7541094}

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/Reference.svcmap

    r1635 r1939  
    1818  </ClientOptions>
    1919  <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" />
    2121  </MetadataSources>
    2222  <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" />
    3233  </Metadata>
    3334  <Extensions>

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/configuration.svcinfo

    r1635 r1939  
    33  <behaviors />
    44  <bindings>
    5     <binding digest="System.ServiceModel.Configuration.NetTcpBindingElement, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089:&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data hostNameComparisonMode=&quot;StrongWildcard&quot; listenBacklog=&quot;10&quot; maxBufferSize=&quot;65536&quot; maxConnections=&quot;10&quot; name=&quot;NetTcpBinding_IClientCommunicator&quot; transactionFlow=&quot;false&quot; transactionProtocol=&quot;OleTransactions&quot; transferMode=&quot;Buffered&quot;&gt;&lt;readerQuotas maxArrayLength=&quot;16384&quot; maxBytesPerRead=&quot;4096&quot; maxDepth=&quot;32&quot; maxNameTableCharCount=&quot;16384&quot; maxStringContentLength=&quot;8192&quot; /&gt;&lt;reliableSession enabled=&quot;false&quot; inactivityTimeout=&quot;00:10:00&quot; ordered=&quot;true&quot; /&gt;&lt;security mode=&quot;Transport&quot;&gt;&lt;message clientCredentialType=&quot;Windows&quot; /&gt;&lt;transport clientCredentialType=&quot;Windows&quot; protectionLevel=&quot;EncryptAndSign&quot; /&gt;&lt;/security&gt;&lt;/Data&gt;" bindingType="netTcpBinding" name="NetTcpBinding_IClientCommunicator" />
     5    <binding digest="System.ServiceModel.Configuration.NetTcpBindingElement, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089:&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data hostNameComparisonMode=&quot;StrongWildcard&quot; listenBacklog=&quot;10&quot; maxBufferSize=&quot;65536&quot; maxConnections=&quot;10&quot; name=&quot;NetTcpBinding_IClientFacade&quot; transactionFlow=&quot;false&quot; transactionProtocol=&quot;OleTransactions&quot; transferMode=&quot;Streamed&quot;&gt;&lt;readerQuotas maxArrayLength=&quot;16384&quot; maxBytesPerRead=&quot;4096&quot; maxDepth=&quot;32&quot; maxNameTableCharCount=&quot;16384&quot; maxStringContentLength=&quot;8192&quot; /&gt;&lt;reliableSession enabled=&quot;false&quot; inactivityTimeout=&quot;00:10:00&quot; ordered=&quot;true&quot; /&gt;&lt;security mode=&quot;Transport&quot;&gt;&lt;message clientCredentialType=&quot;Windows&quot; /&gt;&lt;transport clientCredentialType=&quot;Windows&quot; protectionLevel=&quot;EncryptAndSign&quot; /&gt;&lt;/security&gt;&lt;/Data&gt;" bindingType="netTcpBinding" name="NetTcpBinding_IClientFacade" />
    66  </bindings>
    77  <endpoints>
    8     <endpoint normalizedDigest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;net.tcp://10.20.53.1:9000/HiveServer/ClientCommunicator&quot; binding=&quot;netTcpBinding&quot; bindingConfiguration=&quot;NetTcpBinding_IClientCommunicator&quot; contract=&quot;ServerService.IClientCommunicator&quot; name=&quot;NetTcpBinding_IClientCommunicator&quot;&gt;&lt;identity&gt;&lt;userPrincipalName value=&quot;mse08023@fhs-hagenberg.ac.at&quot; /&gt;&lt;/identity&gt;&lt;/Data&gt;" digest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;net.tcp://10.20.53.1:9000/HiveServer/ClientCommunicator&quot; binding=&quot;netTcpBinding&quot; bindingConfiguration=&quot;NetTcpBinding_IClientCommunicator&quot; contract=&quot;ServerService.IClientCommunicator&quot; name=&quot;NetTcpBinding_IClientCommunicator&quot;&gt;&lt;identity&gt;&lt;userPrincipalName value=&quot;mse08023@fhs-hagenberg.ac.at&quot; /&gt;&lt;/identity&gt;&lt;/Data&gt;" contractName="ServerService.IClientCommunicator" name="NetTcpBinding_IClientCommunicator" />
     8    <endpoint normalizedDigest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator&quot; binding=&quot;netTcpBinding&quot; bindingConfiguration=&quot;NetTcpBinding_IClientFacade&quot; contract=&quot;ServerService.IClientFacade&quot; name=&quot;NetTcpBinding_IClientFacade&quot;&gt;&lt;identity&gt;&lt;userPrincipalName value=&quot;mse08026@fhs-hagenberg.ac.at&quot; /&gt;&lt;/identity&gt;&lt;/Data&gt;" digest="&lt;?xml version=&quot;1.0&quot; encoding=&quot;utf-16&quot;?&gt;&lt;Data address=&quot;net.tcp://10.20.53.7:9000/HiveServer/ClientCommunicator&quot; binding=&quot;netTcpBinding&quot; bindingConfiguration=&quot;NetTcpBinding_IClientFacade&quot; contract=&quot;ServerService.IClientFacade&quot; name=&quot;NetTcpBinding_IClientFacade&quot;&gt;&lt;identity&gt;&lt;userPrincipalName value=&quot;mse08026@fhs-hagenberg.ac.at&quot; /&gt;&lt;/identity&gt;&lt;/Data&gt;" contractName="ServerService.IClientFacade" name="NetTcpBinding_IClientFacade" />
    99  </endpoints>
    1010</configurationSnapshot>

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/configuration91.svcinfo

    r1635 r1939  
    11<?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=">
    33  <bindingConfigurations>
    4     <bindingConfiguration bindingType="netTcpBinding" name="NetTcpBinding_IClientCommunicator">
     4    <bindingConfiguration bindingType="netTcpBinding" name="NetTcpBinding_IClientFacade">
    55      <properties>
    66        <property path="/name" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    7           <serializedValue>NetTcpBinding_IClientCommunicator</serializedValue>
     7          <serializedValue>NetTcpBinding_IClientFacade</serializedValue>
    88        </property>
    99        <property path="/closeTimeout" isComplexType="false" isExplicitlyDefined="true" clrType="System.TimeSpan, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    … …  
    2323        </property>
    2424        <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>
    2626        </property>
    2727        <property path="/transactionProtocol" isComplexType="false" isExplicitlyDefined="true" clrType="System.ServiceModel.TransactionProtocol, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    … …  
    107107  </bindingConfigurations>
    108108  <endpoints>
    109     <endpoint name="NetTcpBinding_IClientCommunicator" 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">
    110110      <properties>
    111111        <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>
    113113        </property>
    114114        <property path="/behaviorConfiguration" isComplexType="false" isExplicitlyDefined="false" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    … …  
    119119        </property>
    120120        <property path="/bindingConfiguration" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    121           <serializedValue>NetTcpBinding_IClientCommunicator</serializedValue>
     121          <serializedValue>NetTcpBinding_IClientFacade</serializedValue>
    122122        </property>
    123123        <property path="/contract" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    124           <serializedValue>ServerService.IClientCommunicator</serializedValue>
     124          <serializedValue>ServerService.IClientFacade</serializedValue>
    125125        </property>
    126126        <property path="/headers" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.AddressHeaderCollectionElement, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    … …  
    137137        </property>
    138138        <property path="/identity/userPrincipalName/value" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    139           <serializedValue>mse08023@fhs-hagenberg.ac.at</serializedValue>
     139          <serializedValue>mse08026@fhs-hagenberg.ac.at</serializedValue>
    140140        </property>
    141141        <property path="/identity/servicePrincipalName" isComplexType="true" isExplicitlyDefined="false" clrType="System.ServiceModel.Configuration.ServicePrincipalNameElement, System.ServiceModel, Version=3.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    … …  
    182182        </property>
    183183        <property path="/name" isComplexType="false" isExplicitlyDefined="true" clrType="System.String, mscorlib, Version=2.0.0.0, Culture=neutral, PublicKeyToken=b77a5c561934e089">
    184           <serializedValue>NetTcpBinding_IClientCommunicator</serializedValue>
     184          <serializedValue>NetTcpBinding_IClientFacade</serializedValue>
    185185        </property>
    186186      </properties>

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/service1.wsdl

    r1635 r1939  
    11<?xml version="1.0" encoding="utf-8"?>
    22<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_IClientCommunicator_policy">
     3  <wsp:Policy wsu:Id="NetTcpBinding_IClientFacade_policy">
    44    <wsp:ExactlyOne>
    55      <wsp:All>
    … …  
    2929          </wsp:Policy>
    3030        </sp:TransportBinding>
     31        <msf:Streamed xmlns:msf="http://schemas.microsoft.com/ws/2006/05/framing/policy">
     32        </msf:Streamed>
    3133        <wsaw:UsingAddressing>
    3234        </wsaw:UsingAddressing>
    … …  
    4446      <xsd:import namespace="http://schemas.datacontract.org/2004/07/System" />
    4547      <xsd:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.PluginInfrastructure" />
     48      <xsd:import namespace="http://schemas.microsoft.com/Message" />
    4649    </xsd:schema>
    4750  </wsdl:types>
    48   <wsdl:message name="IClientCommunicator_Login_InputMessage">
     51  <wsdl:message name="IClientFacade_Login_InputMessage">
    4952    <wsdl:part name="parameters" element="tns:Login" />
    5053  </wsdl:message>
    51   <wsdl:message name="IClientCommunicator_Login_OutputMessage">
     54  <wsdl:message name="IClientFacade_Login_OutputMessage">
    5255    <wsdl:part name="parameters" element="tns:LoginResponse" />
    5356  </wsdl:message>
    54   <wsdl:message name="IClientCommunicator_ProcessHeartBeat_InputMessage">
     57  <wsdl:message name="IClientFacade_ProcessHeartBeat_InputMessage">
    5558    <wsdl:part name="parameters" element="tns:ProcessHeartBeat" />
    5659  </wsdl:message>
    57   <wsdl:message name="IClientCommunicator_ProcessHeartBeat_OutputMessage">
     60  <wsdl:message name="IClientFacade_ProcessHeartBeat_OutputMessage">
    5861    <wsdl:part name="parameters" element="tns:ProcessHeartBeatResponse" />
    5962  </wsdl:message>
    60   <wsdl:message name="IClientCommunicator_SendJob_InputMessage">
     63  <wsdl:message name="IClientFacade_SendJob_InputMessage">
    6164    <wsdl:part name="parameters" element="tns:SendJob" />
    6265  </wsdl:message>
    63   <wsdl:message name="IClientCommunicator_SendJob_OutputMessage">
     66  <wsdl:message name="IClientFacade_SendJob_OutputMessage">
    6467    <wsdl:part name="parameters" element="tns:SendJobResponse" />
    6568  </wsdl:message>
    66   <wsdl:message name="IClientCommunicator_StoreFinishedJobResult_InputMessage">
     69  <wsdl:message name="IClientFacade_StoreFinishedJobResult_InputMessage">
    6770    <wsdl:part name="parameters" element="tns:StoreFinishedJobResult" />
    6871  </wsdl:message>
    69   <wsdl:message name="IClientCommunicator_StoreFinishedJobResult_OutputMessage">
     72  <wsdl:message name="IClientFacade_StoreFinishedJobResult_OutputMessage">
    7073    <wsdl:part name="parameters" element="tns:StoreFinishedJobResultResponse" />
    7174  </wsdl:message>
    72   <wsdl:message name="IClientCommunicator_ProcessSnapshot_InputMessage">
     75  <wsdl:message name="IClientFacade_ProcessSnapshot_InputMessage">
    7376    <wsdl:part name="parameters" element="tns:ProcessSnapshot" />
    7477  </wsdl:message>
    75   <wsdl:message name="IClientCommunicator_ProcessSnapshot_OutputMessage">
     78  <wsdl:message name="IClientFacade_ProcessSnapshot_OutputMessage">
    7679    <wsdl:part name="parameters" element="tns:ProcessSnapshotResponse" />
    7780  </wsdl:message>
    78   <wsdl:message name="IClientCommunicator_Logout_InputMessage">
     81  <wsdl:message name="IClientFacade_Logout_InputMessage">
    7982    <wsdl:part name="parameters" element="tns:Logout" />
    8083  </wsdl:message>
    81   <wsdl:message name="IClientCommunicator_Logout_OutputMessage">
     84  <wsdl:message name="IClientFacade_Logout_OutputMessage">
    8285    <wsdl:part name="parameters" element="tns:LogoutResponse" />
    8386  </wsdl:message>
    84   <wsdl:message name="IClientCommunicator_IsJobStillNeeded_InputMessage">
     87  <wsdl:message name="IClientFacade_IsJobStillNeeded_InputMessage">
    8588    <wsdl:part name="parameters" element="tns:IsJobStillNeeded" />
    8689  </wsdl:message>
    87   <wsdl:message name="IClientCommunicator_IsJobStillNeeded_OutputMessage">
     90  <wsdl:message name="IClientFacade_IsJobStillNeeded_OutputMessage">
    8891    <wsdl:part name="parameters" element="tns:IsJobStillNeededResponse" />
    8992  </wsdl:message>
    90   <wsdl:message name="IClientCommunicator_SendPlugins_InputMessage">
     93  <wsdl:message name="IClientFacade_SendPlugins_InputMessage">
    9194    <wsdl:part name="parameters" element="tns:SendPlugins" />
    9295  </wsdl:message>
    93   <wsdl:message name="IClientCommunicator_SendPlugins_OutputMessage">
     96  <wsdl:message name="IClientFacade_SendPlugins_OutputMessage">
    9497    <wsdl:part name="parameters" element="tns:SendPluginsResponse" />
    9598  </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">
    97124    <wsdl:operation name="Login">
    98       <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/Login" message="tns:IClientCommunicator_Login_InputMessage" />
    99       <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/LoginResponse" message="tns:IClientCommunicator_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" />
    100127    </wsdl:operation>
    101128    <wsdl:operation name="ProcessHeartBeat">
    102       <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessHeartBeat" message="tns:IClientCommunicator_ProcessHeartBeat_InputMessage" />
    103       <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessHeartBeatResponse" message="tns:IClientCommunicator_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" />
    104131    </wsdl:operation>
    105132    <wsdl:operation name="SendJob">
    106       <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/SendJob" message="tns:IClientCommunicator_SendJob_InputMessage" />
    107       <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/SendJobResponse" message="tns:IClientCommunicator_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" />
    108135    </wsdl:operation>
    109136    <wsdl:operation name="StoreFinishedJobResult">
    110       <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/StoreFinishedJobResult" message="tns:IClientCommunicator_StoreFinishedJobResult_InputMessage" />
    111       <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/StoreFinishedJobResultResponse" message="tns:IClientCommunicator_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" />
    112139    </wsdl:operation>
    113140    <wsdl:operation name="ProcessSnapshot">
    114       <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessSnapshot" message="tns:IClientCommunicator_ProcessSnapshot_InputMessage" />
    115       <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/ProcessSnapshotResponse" message="tns:IClientCommunicator_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" />
    116143    </wsdl:operation>
    117144    <wsdl:operation name="Logout">
    118       <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/Logout" message="tns:IClientCommunicator_Logout_InputMessage" />
    119       <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/LogoutResponse" message="tns:IClientCommunicator_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" />
    120147    </wsdl:operation>
    121148    <wsdl:operation name="IsJobStillNeeded">
    122       <wsdl:input wsaw:Action="http://tempuri.org/IClientCommunicator/IsJobStillNeeded" message="tns:IClientCommunicator_IsJobStillNeeded_InputMessage" />
    123       <wsdl:output wsaw:Action="http://tempuri.org/IClientCommunicator/IsJobStillNeededResponse" message="tns:IClientCommunicator_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" />
    124151    </wsdl:operation>
    125152    <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" />
    128171    </wsdl:operation>
    129172  </wsdl:portType>
    130   <wsdl:binding name="NetTcpBinding_IClientCommunicator" type="tns:IClientCommunicator">
    131     <wsp:PolicyReference URI="#NetTcpBinding_IClientCommunicator_policy">
     173  <wsdl:binding name="NetTcpBinding_IClientFacade" type="tns:IClientFacade">
     174    <wsp:PolicyReference URI="#NetTcpBinding_IClientFacade_policy">
    132175    </wsp:PolicyReference>
    133176    <soap12:binding transport="http://schemas.microsoft.com/soap/tcp" />
    … …  
    204247      </wsdl:output>
    205248    </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>
    206285  </wsdl:binding>
    207286  <wsdl:service name="ClientFacade">
    208     <wsdl:port name="NetTcpBinding_IClientCommunicator" 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" />
    210289      <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>
    212291        <Identity xmlns="http://schemas.xmlsoap.org/ws/2006/02/addressingidentity">
    213           <Upn>mse08023@fhs-hagenberg.ac.at</Upn>
     292          <Upn>mse08026@fhs-hagenberg.ac.at</Upn>
    214293        </Identity>
    215294      </wsa10:EndpointReference>

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/Service References/ServerService/service2.xsd

    r1594 r1939  
    55  <xs:import namespace="http://schemas.microsoft.com/2003/10/Serialization/" />
    66  <xs:import namespace="http://schemas.datacontract.org/2004/07/System" />
     7  <xs:import namespace="http://schemas.microsoft.com/Message" />
    78  <xs:element name="Login">
    89    <xs:complexType>
    … …  
    125126    </xs:complexType>
    126127  </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>
    127184</xs:schema>

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/WcfService.cs

    r1936 r1939  
    3131using HeuristicLab.Hive.Client.Communication.ServerService;
    3232using HeuristicLab.PluginInfrastructure;
     33using System.IO;
     34using System.Runtime.Serialization.Formatters.Binary;
    3335
    3436namespace HeuristicLab.Hive.Client.Communication {
    … …  
    6062    public event EventHandler Connected;   
    6163
    62     public ClientCommunicatorClient proxy = null;
     64    public ClientFacadeClient proxy = null;
    6365
    6466    /// <summary>
    … …  
    7476    public void Connect() {
    7577      try {
    76         proxy = new ClientCommunicatorClient(
    77           WcfSettings.GetBinding(),
     78        proxy = new ClientFacadeClient(
     79          WcfSettings.GetStreamedBinding(),
    7880          new EndpointAddress("net.tcp://" + ServerIP + ":" + ServerPort + "/HiveServer/ClientCommunicator")
    7981        );
    8082
    8183        proxy.LoginCompleted += new EventHandler<LoginCompletedEventArgs>(proxy_LoginCompleted);
    82         proxy.SendJobCompleted += new EventHandler<SendJobCompletedEventArgs>(proxy_SendJobCompleted);
    83         proxy.StoreFinishedJobResultCompleted += new EventHandler<StoreFinishedJobResultCompletedEventArgs>(proxy_StoreFinishedJobResultCompleted);
    84         proxy.ProcessSnapshotCompleted += 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);
    8587        proxy.ProcessHeartBeatCompleted += new EventHandler<ProcessHeartBeatCompletedEventArgs>(proxy_ProcessHeartBeatCompleted);
    8688        proxy.Open();
    … …  
    99101      }
    100102    }
    101 
    102103
    103104
    … …  
    174175    public void SendJobAsync(Guid guid) {
    175176      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
    182193        HandleNetworkError(e.Error);
    183194    }
     195
    184196    #endregion
    185197
    … …  
    191203    public void StoreFinishedJobResultAsync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) {
    192204      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
    199215        HandleNetworkError(e.Error);
    200216    }
    … …  
    206222    public void ProcessSnapshotAsync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) {
    207223      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
    214236        HandleNetworkError(e.Error);
    215237    }   
    … …  
    249271    #endregion  */
    250272
     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
    251294    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));
    253297    }
    254298
    255299    public ResponseResultReceived ProcessSnapshotSync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception) {
    256300      try {
    257         ResponseResultReceived res = proxy.ProcessSnapshot(clientId, jobId, result, percentage, null);
    258301        Logging.Instance.Info(this.ToString(), "Snapshot for Job " + jobId + " submitted");
    259         return res;
     302        return proxy.ProcessSnapshotStreamed(
     303          GetStreamedJobResult(clientId, jobId, result, percentage, exception));
    260304      }
    261305      catch (Exception e) {
    … …  
    267311    public List<CachedHivePluginInfo> RequestPlugins(List<HivePluginInfo> requestedPlugins) {
    268312      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);
    270318        return response.Plugins;       
    271319      }

  • trunk/sources/HeuristicLab.Hive.Client.Communication/3.2/app.config

    r1635 r1939  
    44        <bindings>
    55            <netTcpBinding>
    6                 <binding name="NetTcpBinding_IClientCommunicator" closeTimeout="00:01:00"
     6                <binding name="NetTcpBinding_IClientFacade" closeTimeout="00:01:00"
    77                    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"
    99                    hostNameComparisonMode="StrongWildcard" listenBacklog="10"
    1010                    maxBufferPoolSize="524288" maxBufferSize="65536" maxConnections="10"
    … …  
    2222        </bindings>
    2323        <client>
    24             <endpoint address="net.tcp://10.20.53.1:9000/HiveServer/ClientCommunicator"
    25                 binding="netTcpBinding" bindingConfiguration="NetTcpBinding_IClientCommunicator"
    26                 contract="ServerService.IClientCommunicator" 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">
    2727                <identity>
    28                     <userPrincipalName value="mse08023@fhs-hagenberg.ac.at" />
     28                    <userPrincipalName value="mse08026@fhs-hagenberg.ac.at" />
    2929                </identity>
    3030            </endpoint>

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/CachedHivePluginInfo.cs

    r1643 r1939  
    2828namespace HeuristicLab.PluginInfrastructure {
    2929  [DataContract]
     30  [Serializable]
    3031  public class CachedHivePluginInfo : HivePluginInfo {
    3132

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/Client.cs

    r1772 r1939  
    3131
    3232  [DataContract]
     33  [Serializable]
    3334  public class ClientInfo : Resource {
    3435    [DataMember]

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/ClientConfig.cs

    r1377 r1939  
    3030
    3131  [DataContract]
     32  [Serializable]
    3233  public class ClientConfig : PersistableObject {
    3334    [DataMember]

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/HivePluginInfo.cs

    r1592 r1939  
    3131
    3232  [DataContract]
     33  [Serializable]
    3334  public class HivePluginInfo : PersistableObject {
    3435    [DataMember]

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/Job.cs

    r1932 r1939  
    3131
    3232  [DataContract]
     33  [Serializable]
    3334  public class Job : PersistableObject {
    3435    [DataMember]

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/JobResult.cs

    r1626 r1939  
    3030
    3131  [DataContract]
     32  [Serializable]
    3233  public class JobResult : PersistableObject {
    3334    [DataMember]
    34     public Job Job { get; set; }
     35    public Guid JobId { get; set; }
    3536    [DataMember]
    3637    public byte[] Result { get; set; }
    … …  
    4041    public DateTime Timestamp { get; set; }
    4142    [DataMember]
    42     public ClientInfo Client { get; set; }
     43    public Guid ClientId { get; set; }
    4344    [DataMember]
    4445    public Exception Exception { get; set; }

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/BusinessObjects/Resource.cs

    r1377 r1939  
    3030
    3131  [DataContract]
     32  [Serializable]
    3233  public class Resource : PersistableObject {
    3334    [DataMember]

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/HeuristicLab.Hive.Contracts-3.2.csproj

    r1932 r1939  
    115115    <Compile Include="ResponsePlugin.cs" />
    116116    <Compile Include="ResponseResultReceived.cs" />
     117    <Compile Include="StreamedObject.cs" />
    117118    <Compile Include="WcfSettings.cs" />
    118119  </ItemGroup>

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/Interfaces/IClientFacade.cs

    r1101 r1939  
    2424using System.Linq;
    2525using System.Text;
     26using System.ServiceModel;
     27using System.IO;
     28using HeuristicLab.Hive.Contracts.BusinessObjects;
    2629
    2730namespace HeuristicLab.Hive.Contracts.Interfaces {
     31  [ServiceContract]
    2832  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);
    2944  }
    3045}

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/Response.cs

    r1530 r1939  
    3131  /// </summary>
    3232  [DataContract]
     33  [Serializable]
    3334  public class Response {
    3435    [DataMember]

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/ResponseJob.cs

    r1530 r1939  
    3434  /// </summary>
    3535  [DataContract]
     36  [Serializable]
    3637  public class ResponseJob : Response {
    3738    [DataMember]

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/ResponsePlugin.cs

    r1596 r1939  
    99
    1010  [DataContract]
     11  [Serializable]
    1112  public class ResponsePlugin : Response {
    1213    public ResponsePlugin() {

  • trunk/sources/HeuristicLab.Hive.Contracts/3.2/WcfSettings.cs

    r1809 r1939  
    2525      NetTcpBinding binding = new NetTcpBinding();
    2626#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;
    2844      binding.MaxReceivedMessageSize = int.MaxValue;
    2945      binding.ReaderQuotas.MaxArrayLength = int.MaxValue;

  • trunk/sources/HeuristicLab.Hive.Engine/3.2/ServiceLocator.cs

    r1599 r1939  
    3333      ChannelFactory<IExecutionEngineFacade> factory =
    3434        new ChannelFactory<IExecutionEngineFacade>(
    35           WcfSettings.GetBinding(),
     35          WcfSettings.GetStreamedBinding(),
    3636          new EndpointAddress(url));
    3737

  • trunk/sources/HeuristicLab.Hive.Server.ADODataAccess/3.2/JobResultsAdapter.cs

    r1716 r1939  
    5050      dsHiveServer.JobResultRow row) {
    5151      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;
    5454        else
    5555          row.SetJobIdNull();
    … …  
    6060          row.SetJobResultNull();
    6161
    62         if (result.Client != null)  {
     62        if (result.ClientId != Guid.Empty)  {
    6363          ClientInfo client =
    64                  ClientAdapter.GetById(result.Client.Id);
     64                 ClientAdapter.GetById(result.ClientId);
    6565
    6666          if (client != null)
    … …  
    9595
    9696        if (!row.IsJobIdNull())
    97           result.Job = JobAdapter.GetById(row.JobId);
     97          result.JobId = row.JobId;
    9898        else
    99           result.Job = null;
     99          result.JobId = Guid.Empty;
    100100
    101101        if (!row.IsJobResultNull())
    … …  
    105105
    106106        if (!row.IsResourceIdNull())
    107           result.Client = ClientAdapter.GetById(row.ResourceId);
     107          result.ClientId = row.ResourceId;
    108108        else
    109           result.Client = null;
     109          result.ClientId = Guid.Empty;
    110110
    111111        if (!row.IsMessageNull())
    … …  
    128128
    129129    #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 
    139130    public ICollection<JobResult> GetResultsOf(Job job) {
    140131      if (job != null) {

  • trunk/sources/HeuristicLab.Hive.Server.Console/3.2/HiveServerManagementConsole.cs

    r1937 r1939  
    757757      if (jobRes.List != null) {
    758758        foreach (JobResult jobresult in jobRes.List) {
    759           ListViewItem curSnapshot = new ListViewItem(jobresult.Client.Name);
     759          ListViewItem curSnapshot = new ListViewItem(jobresult.ClientId.ToString());
    760760          double percentage = jobresult.Percentage * 100;
    761761          curSnapshot.SubItems.Add(percentage.ToString() + " %");

  • trunk/sources/HeuristicLab.Hive.Server.Core/3.2/ClientCommunicator.cs

    r1928 r1939  
    451451        JobResult jobResult =
    452452          new JobResult();
    453         jobResult.Client = client;
    454         jobResult.Job = job;
     453        jobResult.ClientId = client.Id;
     454        jobResult.JobId = job.Id;
    455455        jobResult.Result = result;
    456456        jobResult.Percentage = percentage;

  • trunk/sources/HeuristicLab.Hive.Server.Core/3.2/ClientFacade.cs

    r1600 r1939  
    2828using HeuristicLab.Hive.Contracts;
    2929using HeuristicLab.PluginInfrastructure;
     30using System.IO;
     31using System.Runtime.Serialization.Formatters.Binary;
    3032
    3133namespace HeuristicLab.Hive.Server.Core {
    … …  
    7476
    7577    #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
    76120  }
    77121}

  • trunk/sources/HeuristicLab.Hive.Server/3.2/HiveServerApplication.cs

    r1579 r1939  
    4343    private Dictionary<string, ServiceHost> runningServices = new Dictionary<string, ServiceHost>();
    4444    private NetTcpBinding binding = (NetTcpBinding)WcfSettings.GetBinding();
     45    private NetTcpBinding streamedBinding = (NetTcpBinding)WcfSettings.GetStreamedBinding();
    4546
    4647    private enum Services {
    … …  
    7677            uriTcp = new Uri("net.tcp://" + ipAddress + ":" + port + "/HiveServer/");
    7778            serviceHost = new ServiceHost(clientCommunicatorInstances[0].GetType(), uriTcp);
    78             serviceHost.AddServiceEndpoint(typeof(IClientCommunicator), binding, STR_ClientCommunicator);
     79            serviceHost.AddServiceEndpoint(typeof(IClientFacade), streamedBinding, STR_ClientCommunicator);
    7980            curServiceHost = STR_ClientCommunicator;
    8081          }
    … …  
    9293            uriTcp = new Uri("net.tcp://" + ipAddress + ":" + port + "/ExecutionEngine/");
    9394            serviceHost = new ServiceHost(executionEngineInstances[0].GetType(), uriTcp);
    94             serviceHost.AddServiceEndpoint(typeof(IExecutionEngineFacade), binding, STR_ExecutionEngineFacade);
     95            serviceHost.AddServiceEndpoint(typeof(IExecutionEngineFacade), streamedBinding, STR_ExecutionEngineFacade);
    9596            curServiceHost = STR_ExecutionEngineFacade;
    9697          }
Note: See TracChangeset for help on using the changeset viewer.