- Timestamp:
- 08/19/10 12:41:05 (14 years ago)
- Location:
- branches/3.3-HiveMigration/sources/HeuristicLab.Hive
- Files:
-
- 13 added
- 26 deleted
- 35 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/ApplicationConstants.cs
r4141 r4263 38 38 public static int JOB_TIME_TO_LIVE = 5; 39 39 40 public static string RESPONSE_SERVERCONSOLE_LOGIN_SUCCESS = "Logged in";41 public static string RESPONSE_SERVERCONSOLE_LOGIN_FAILED = "Login failed";40 //public static string RESPONSE_SERVERCONSOLE_LOGIN_SUCCESS = "Logged in"; 41 //public static string RESPONSE_SERVERCONSOLE_LOGIN_FAILED = "Login failed"; 42 42 43 public static string RESPONSE_USERROLE_GET_ALL_USERS = "UserRole.GetAllUsers";44 public static string RESPONSE_USERROLE_USER_EXISTS_ALLREADY = "UserRole.UserExistsAllready";45 public static string RESPONSE_USERROLE_USER_SUCCESSFULLY_ADDED = "UserRole.UserSuccessfullyAdded";46 public static string RESPONSE_USERROLE_USER_DOESNT_EXIST = "UserRole.UserDoesntExist";47 public static string RESPONSE_USERROLE_USER_REMOVED = "UserRole.UserRemoved";48 public static string RESPONSE_USERROLE_USERGROUP_EXISTS_ALLREADY = "UserRole.UsergroupExistsAllready";49 public static string RESPONSE_USERROLE_USERGROUP_ADDED = "UserRole.UserGroupAdded";50 public static string RESPONSE_USERROLE_USERGROUP_DOESNT_EXIST = "UserRole.UserGroupDoesntExist";51 public static string RESPONSE_USERROLE_PERMISSIONOWNER_DOESNT_EXIST = "UserRole.PermissionOwnerDoesntExist";52 public static string RESPONSE_USERROLE_PERMISSIONOWNER_REMOVED = "UserRole.PermissionOwnerRemoved";53 public static string RESPONSE_USERROLE_PERMISSIONOWNER_ADDED = "UserRole.PermissionOwnerAdded";54 public static string RESPONSE_USERROLE_GET_ALL_USERGROUPS = "UserRole.AllUserGroupsReturned";55 public static string RESPONSE_USERROLE_ID_MUST_NOT_BE_SET = "UserRole.IdMustNotBeSet";56 public static string RESPONSE_USERROLE_USERGROUP_ADDED_TO_USERGROUP = "UserRole.UserGroupAddedToUserGroup";57 public static string RESPONSE_USERROLE_USERNAME_EXISTS_ALLREADY = "UserRole.UsernameExistsAllready";43 //public static string RESPONSE_USERROLE_GET_ALL_USERS = "UserRole.GetAllUsers"; 44 //public static string RESPONSE_USERROLE_USER_EXISTS_ALLREADY = "UserRole.UserExistsAllready"; 45 //public static string RESPONSE_USERROLE_USER_SUCCESSFULLY_ADDED = "UserRole.UserSuccessfullyAdded"; 46 //public static string RESPONSE_USERROLE_USER_DOESNT_EXIST = "UserRole.UserDoesntExist"; 47 //public static string RESPONSE_USERROLE_USER_REMOVED = "UserRole.UserRemoved"; 48 //public static string RESPONSE_USERROLE_USERGROUP_EXISTS_ALLREADY = "UserRole.UsergroupExistsAllready"; 49 //public static string RESPONSE_USERROLE_USERGROUP_ADDED = "UserRole.UserGroupAdded"; 50 //public static string RESPONSE_USERROLE_USERGROUP_DOESNT_EXIST = "UserRole.UserGroupDoesntExist"; 51 //public static string RESPONSE_USERROLE_PERMISSIONOWNER_DOESNT_EXIST = "UserRole.PermissionOwnerDoesntExist"; 52 //public static string RESPONSE_USERROLE_PERMISSIONOWNER_REMOVED = "UserRole.PermissionOwnerRemoved"; 53 //public static string RESPONSE_USERROLE_PERMISSIONOWNER_ADDED = "UserRole.PermissionOwnerAdded"; 54 //public static string RESPONSE_USERROLE_GET_ALL_USERGROUPS = "UserRole.AllUserGroupsReturned"; 55 //public static string RESPONSE_USERROLE_ID_MUST_NOT_BE_SET = "UserRole.IdMustNotBeSet"; 56 //public static string RESPONSE_USERROLE_USERGROUP_ADDED_TO_USERGROUP = "UserRole.UserGroupAddedToUserGroup"; 57 //public static string RESPONSE_USERROLE_USERNAME_EXISTS_ALLREADY = "UserRole.UsernameExistsAllready"; 58 58 59 public static string RESPONSE_CLIENT_GET_ALL_CLIENTS = "Client.GetAllClients";60 public static string RESPONSE_CLIENT_GET_ALL_CLIENTGROUPS = "Client.GetAllClientGroups";61 public static string RESPONSE_CLIENT_ID_MUST_NOT_BE_SET = "Client.IdMustNotBeSet";62 public static string RESPONSE_CLIENT_CLIENTGROUP_ADDED = "Client.ClientGroupAdded";63 public static string RESPONSE_CLIENT_CLIENTGROUP_DOESNT_EXIST = "Client.ClientGroupDoesntExist";64 public static string RESPONSE_CLIENT_CLIENTGROUP_DELETED = "Client group sucessfully deleted";65 public static string RESPONSE_CLIENT_RESOURCE_ADDED_TO_GROUP = "Client.ResourceAddedToGroup";66 public static string RESPONSE_CLIENT_RESOURCE_REMOVED = "Client.ResourceRemoved";67 public static string RESPONSE_CLIENT_RESOURCE_NOT_FOUND = "Client.ResourceNotFound";68 public static string RESPONSE_CLIENT_PERMISSIONOWNER_DOESNT_EXIST = "Client.PermissionOwnerDoesntExist";69 public static string RESPONSE_CLIENT_GET_GROUPS_OF_CLIENT = "Get all groups of a client";59 //public static string RESPONSE_CLIENT_GET_ALL_CLIENTS = "Client.GetAllClients"; 60 //public static string RESPONSE_CLIENT_GET_ALL_CLIENTGROUPS = "Client.GetAllClientGroups"; 61 //public static string RESPONSE_CLIENT_ID_MUST_NOT_BE_SET = "Client.IdMustNotBeSet"; 62 //public static string RESPONSE_CLIENT_CLIENTGROUP_ADDED = "Client.ClientGroupAdded"; 63 //public static string RESPONSE_CLIENT_CLIENTGROUP_DOESNT_EXIST = "Client.ClientGroupDoesntExist"; 64 //public static string RESPONSE_CLIENT_CLIENTGROUP_DELETED = "Client group sucessfully deleted"; 65 //public static string RESPONSE_CLIENT_RESOURCE_ADDED_TO_GROUP = "Client.ResourceAddedToGroup"; 66 //public static string RESPONSE_CLIENT_RESOURCE_REMOVED = "Client.ResourceRemoved"; 67 //public static string RESPONSE_CLIENT_RESOURCE_NOT_FOUND = "Client.ResourceNotFound"; 68 //public static string RESPONSE_CLIENT_PERMISSIONOWNER_DOESNT_EXIST = "Client.PermissionOwnerDoesntExist"; 69 //public static string RESPONSE_CLIENT_GET_GROUPS_OF_CLIENT = "Get all groups of a client"; 70 70 71 public static string RESPONSE_COMMUNICATOR_HEARTBEAT_RECEIVED = "Communicator.HeardbeatReceived";72 public static string RESPONSE_COMMUNICATOR_JOB_PULLED = "Communicator.JobPulled";73 public static string RESPONSE_COMMUNICATOR_JOBRESULT_RECEIVED = "Communicator.JobResultReceived";74 public static string RESPONSE_COMMUNICATOR_LOGIN_USER_ALLREADY_ONLINE = "Communicator.LoginUserAllreadyOnline";75 public static string RESPONSE_COMMUNICATOR_LOGIN_SUCCESS = "Communicator.LoginSuccess";76 public static string RESPONSE_COMMUNICATOR_LOGOUT_CLIENT_NOT_REGISTERED = "Communicator.LogoutClientNotRegistered";77 public static string RESPONSE_COMMUNICATOR_LOGOUT_SUCCESS = "Communicator.LogoutSuccess";78 public static string RESPONSE_COMMUNICATOR_NO_JOBS_LEFT = "Communicator.NoJobsLeft";79 public static string RESPONSE_COMMUNICATOR_ID_MUST_NOT_BE_SET = "Communicator.IdMustNotBeSet";80 public static string RESPONSE_COMMUNICATOR_NO_JOB_WITH_THIS_ID = "Communicator.NoJobWithThisId";81 public static string RESPONSE_COMMUNICATOR_WRONG_JOB_STATE = "Communicator.WrongJobState";82 public static string RESPONSE_COMMUNICATOR_USER_NOT_LOGGED_IN = "Communicator.UserNotLoggedIn";83 public static string RESPONSE_COMMUNICATOR_JOB_IS_NOT_BEEING_CALCULATED = "Communicator.JobIsNotBeenigCalculated";84 public static string RESPONSE_COMMUNICATOR_WRONG_CLIENT_FOR_JOB = "Communicator.WrongClientForJob";85 public static string RESPONSE_COMMUNICATOR_JOB_ALLREADY_FINISHED = "Job allready finished. Not needed anymore";86 public static string RESPONSE_COMMUNICATOR_JOB_DOESNT_EXIST = "No job exists with this id";87 public static string RESPONSE_COMMUNICATOR_SEND_JOBRESULT = "Please send the Jobresult to the server";88 public static string RESPONSE_COMMUNICATOR_PLUGINS_SENT = "Communicator.PluginsSent";89 public static string RESPONSE_COMMUNICATOR_PLUGINS_NOT_AVAIL = "Communicator.PluginsNotAvail";90 public static string RESPONSE_COMMUNICATOR_JOB_WAS_ABORTED = "Job was aborted";71 //public static string RESPONSE_COMMUNICATOR_HEARTBEAT_RECEIVED = "Communicator.HeardbeatReceived"; 72 //public static string RESPONSE_COMMUNICATOR_JOB_PULLED = "Communicator.JobPulled"; 73 //public static string RESPONSE_COMMUNICATOR_JOBRESULT_RECEIVED = "Communicator.JobResultReceived"; 74 //public static string RESPONSE_COMMUNICATOR_LOGIN_USER_ALLREADY_ONLINE = "Communicator.LoginUserAllreadyOnline"; 75 //public static string RESPONSE_COMMUNICATOR_LOGIN_SUCCESS = "Communicator.LoginSuccess"; 76 //public static string RESPONSE_COMMUNICATOR_LOGOUT_CLIENT_NOT_REGISTERED = "Communicator.LogoutClientNotRegistered"; 77 //public static string RESPONSE_COMMUNICATOR_LOGOUT_SUCCESS = "Communicator.LogoutSuccess"; 78 //public static string RESPONSE_COMMUNICATOR_NO_JOBS_LEFT = "Communicator.NoJobsLeft"; 79 //public static string RESPONSE_COMMUNICATOR_ID_MUST_NOT_BE_SET = "Communicator.IdMustNotBeSet"; 80 //public static string RESPONSE_COMMUNICATOR_NO_JOB_WITH_THIS_ID = "Communicator.NoJobWithThisId"; 81 //public static string RESPONSE_COMMUNICATOR_WRONG_JOB_STATE = "Communicator.WrongJobState"; 82 //public static string RESPONSE_COMMUNICATOR_USER_NOT_LOGGED_IN = "Communicator.UserNotLoggedIn"; 83 //public static string RESPONSE_COMMUNICATOR_JOB_IS_NOT_BEEING_CALCULATED = "Communicator.JobIsNotBeenigCalculated"; 84 //public static string RESPONSE_COMMUNICATOR_WRONG_CLIENT_FOR_JOB = "Communicator.WrongClientForJob"; 85 //public static string RESPONSE_COMMUNICATOR_JOB_ALLREADY_FINISHED = "Job allready finished. Not needed anymore"; 86 //public static string RESPONSE_COMMUNICATOR_JOB_DOESNT_EXIST = "No job exists with this id"; 87 //public static string RESPONSE_COMMUNICATOR_SEND_JOBRESULT = "Please send the Jobresult to the server"; 88 //public static string RESPONSE_COMMUNICATOR_PLUGINS_SENT = "Communicator.PluginsSent"; 89 //public static string RESPONSE_COMMUNICATOR_PLUGINS_NOT_AVAIL = "Communicator.PluginsNotAvail"; 90 //public static string RESPONSE_COMMUNICATOR_JOB_WAS_ABORTED = "Job was aborted"; 91 91 92 public static string RESPONSE_COMMUNICATOR_FETCH_OR_FORCEFETCH_CALENDAR = "new Calendar must be fetched / force fetched";92 //public static string RESPONSE_COMMUNICATOR_FETCH_OR_FORCEFETCH_CALENDAR = "new Calendar must be fetched / force fetched"; 93 93 94 public static string RESPONSE_JOB_ALL_JOBS = "Job.AllJobs";95 public static string RESPONSE_JOB_GET_JOB_BY_ID = "Job.GetJobById";96 public static string RESPONSE_JOB_ID_MUST_NOT_BE_SET = "Job.IdMustNotBeSet";97 public static string RESPONSE_JOB_JOB_ADDED = "Job.JobAdded";98 public static string RESPONSE_JOB_JOB_NULL = "Job.JobNull";99 public static string RESPONSE_JOB_JOB_DOESNT_EXIST = "JobDoesntExist";100 public static string RESPONSE_JOB_JOB_REMOVED = "Job.JobRemoved";101 public static string RESPONSE_JOB_JOBSTATE_MUST_BE_OFFLINE = "Job.JobStateMustBeOffline";102 public static string RESPONSE_JOB_IS_NOT_BEEING_CALCULATED = "Job.IsNotBeeingCalculated";103 public static string RESPONSE_JOB_JOB_RESULT_SENT = "Job.JobResultSent";104 public static string RESPONSE_JOB_REQUEST_ALLREADY_SET = "Job.RequestAllreadySet";105 public static string RESPONSE_JOB_ABORT_REQUEST_ALLREADY_SET = "Job.AbortRequestAllreadySet";106 public static string RESPONSE_JOB_REQUEST_SET = "Job.RequestSet";107 public static string RESPONSE_JOB_ABORT_REQUEST_SET = "Job.AbortRequestSet";108 public static string RESPONSE_JOB_RESULT_NOT_YET_HERE = "Requested job result is not yet finished";109 public static string RESPONSE_JOB_PROJECT_NAME_EMPTY = "Please specifiy a project name";110 public static string RESPONSE_JOB_PROJECT_ADDED = "Project successfully added";111 public static string RESPONSE_JOB_PROJECT_DOESNT_EXIST = "The specified project doesn't exist";112 public static string RESPONSE_JOB_PROJECT_DELETED = "The project was sucessfully deleted";94 //public static string RESPONSE_JOB_ALL_JOBS = "Job.AllJobs"; 95 //public static string RESPONSE_JOB_GET_JOB_BY_ID = "Job.GetJobById"; 96 //public static string RESPONSE_JOB_ID_MUST_NOT_BE_SET = "Job.IdMustNotBeSet"; 97 //public static string RESPONSE_JOB_JOB_ADDED = "Job.JobAdded"; 98 //public static string RESPONSE_JOB_JOB_NULL = "Job.JobNull"; 99 //public static string RESPONSE_JOB_JOB_DOESNT_EXIST = "JobDoesntExist"; 100 //public static string RESPONSE_JOB_JOB_REMOVED = "Job.JobRemoved"; 101 //public static string RESPONSE_JOB_JOBSTATE_MUST_BE_OFFLINE = "Job.JobStateMustBeOffline"; 102 //public static string RESPONSE_JOB_IS_NOT_BEEING_CALCULATED = "Job.IsNotBeeingCalculated"; 103 //public static string RESPONSE_JOB_JOB_RESULT_SENT = "Job.JobResultSent"; 104 //public static string RESPONSE_JOB_REQUEST_ALLREADY_SET = "Job.RequestAllreadySet"; 105 //public static string RESPONSE_JOB_ABORT_REQUEST_ALLREADY_SET = "Job.AbortRequestAllreadySet"; 106 //public static string RESPONSE_JOB_REQUEST_SET = "Job.RequestSet"; 107 //public static string RESPONSE_JOB_ABORT_REQUEST_SET = "Job.AbortRequestSet"; 108 //public static string RESPONSE_JOB_RESULT_NOT_YET_HERE = "Requested job result is not yet finished"; 109 //public static string RESPONSE_JOB_PROJECT_NAME_EMPTY = "Please specifiy a project name"; 110 //public static string RESPONSE_JOB_PROJECT_ADDED = "Project successfully added"; 111 //public static string RESPONSE_JOB_PROJECT_DOESNT_EXIST = "The specified project doesn't exist"; 112 //public static string RESPONSE_JOB_PROJECT_DELETED = "The project was sucessfully deleted"; 113 113 114 public static string RESPONSE_UPTIMECALENDAR_NO_CALENDAR_FOUND = "No Calendar could be found anywhere in the tree";115 public static string RESPONSE_UPTIMECALENDAR_STATUS_UPDATED = "Calendar status has been updated";114 //public static string RESPONSE_UPTIMECALENDAR_NO_CALENDAR_FOUND = "No Calendar could be found anywhere in the tree"; 115 //public static string RESPONSE_UPTIMECALENDAR_STATUS_UPDATED = "Calendar status has been updated"; 116 116 } 117 117 } -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/HeuristicLab.Hive.Contracts-3.3.csproj
r4254 r4263 134 134 <Compile Include="BusinessObjects\ClientGroupDtoList.cs" /> 135 135 <Compile Include="RecurrentEvent.cs" /> 136 <Compile Include="Response Calendar.cs" />136 <Compile Include="ResponseObjects\ResponseCalendar.cs" /> 137 137 <Compile Include="MultiStream.cs" /> 138 138 <Compile Include="Interfaces\ISlaveFacade.cs" /> 139 139 <Compile Include="Interfaces\IExecutionEngineFacade.cs" /> 140 <Compile Include="ResponseObject .cs" />140 <Compile Include="ResponseObjects\ResponseObject.cs" /> 141 141 <Compile Include="Interfaces\ISlaveManager.cs" /> 142 142 <Compile Include="Interfaces\IJobManager.cs" /> … … 147 147 <Compile Include="Interfaces\ISlaveCommunicator.cs" /> 148 148 <Compile Include="Properties\AssemblyInfo.cs" /> 149 <Compile Include="Response.cs" /> 150 <Compile Include="ResponseHeartBeat.cs" /> 151 <Compile Include="ResponseList.cs" /> 152 <Compile Include="ResponseResultReceived.cs" /> 149 <Compile Include="ResponseObjects\Response.cs" /> 150 <Compile Include="ResponseObjects\ResponseHeartBeat.cs" /> 151 <Compile Include="ResponseObjects\ResponseList.cs" /> 152 <Compile Include="ResponseObjects\ResponseResultReceived.cs" /> 153 <Compile Include="ResponseStatus.cs" /> 153 154 <Compile Include="StreamedObject.cs" /> 154 155 <Compile Include="WcfSettings.cs" /> … … 157 158 <None Include="HeuristicLab.snk" /> 158 159 <None Include="Properties\AssemblyInfo.frame" /> 159 </ItemGroup>160 <ItemGroup>161 <EmbeddedResource Include="HiveServerMessages.resx">162 <SubType>Designer</SubType>163 </EmbeddedResource>164 160 </ItemGroup> 165 161 <ItemGroup> -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/Interfaces/IExecutionEngineFacade.cs
r4170 r4263 26 26 using System.ServiceModel; 27 27 using HeuristicLab.Hive.Contracts.BusinessObjects; 28 using HeuristicLab.Hive.Contracts.ResponseObjects; 28 29 29 30 namespace HeuristicLab.Hive.Contracts.Interfaces { … … 43 44 ResponseObject<JobDto> GetJobById(Guid jobId); 44 45 [OperationContract] 45 ResponseObject<JobResultList> Get AllJobResults(IEnumerable<Guid> jobIds);46 ResponseObject<JobResultList> GetJobResults(IEnumerable<Guid> jobIds); 46 47 } 47 48 } -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/Interfaces/IJobManager.cs
r4254 r4263 26 26 using System.ServiceModel; 27 27 using HeuristicLab.Hive.Contracts.BusinessObjects; 28 using HeuristicLab.Hive.Contracts.ResponseObjects; 28 29 29 30 namespace HeuristicLab.Hive.Contracts.Interfaces { … … 49 50 ResponseObject<JobDto> AddNewJob(SerializedJob job); 50 51 51 [OperationContract] 52 Response RemoveJob(Guid jobId); 52 //[OperationContract] 53 //Response RemoveJob(Guid jobId); 54 55 //[OperationContract] 56 //ResponseObject<JobDto> GetLastJobResultOf(Guid jobId); 53 57 54 58 [OperationContract] 55 ResponseObject< JobDto> GetLastJobResultOf(Guid jobId);59 ResponseObject<SerializedJob> GetLastSerializedResult(Guid jobId, bool requested, bool snapshot); 56 60 57 61 [OperationContract] 58 ResponseObject<SerializedJob> GetLastSerializedJobResultOf(Guid jobId, bool requested, bool snapshot); 59 60 [OperationContract] 61 ResponseObject<JobResultList> GetAllJobResults(IEnumerable<Guid> jobIds); 62 ResponseObject<JobResultList> GetJobResults(IEnumerable<Guid> jobIds); 62 63 63 64 [OperationContract] -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/Interfaces/IServerConsoleFacade.cs
r4253 r4263 26 26 using System.ServiceModel; 27 27 using System.Runtime.Serialization; 28 using HeuristicLab.Hive.Contracts.ResponseObjects; 28 29 29 30 namespace HeuristicLab.Hive.Contracts.Interfaces { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/Interfaces/ISlaveCommunicator.cs
r4254 r4263 27 27 using HeuristicLab.Hive.Contracts.BusinessObjects; 28 28 using HeuristicLab.PluginInfrastructure; 29 using HeuristicLab.Hive.Contracts.ResponseObjects; 29 30 30 31 namespace HeuristicLab.Hive.Contracts.Interfaces { … … 57 58 58 59 [OperationContract] 59 ResponseList<CachedHivePluginInfoDto> SendPlugins(List<HivePluginInfoDto> pluginList);60 ResponseList<CachedHivePluginInfoDto> GetPlugins(List<HivePluginInfoDto> pluginList); 60 61 61 62 [OperationContract] -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/Interfaces/ISlaveFacade.cs
r4253 r4263 27 27 using System.IO; 28 28 using HeuristicLab.Hive.Contracts.BusinessObjects; 29 using HeuristicLab.Hive.Contracts.ResponseObjects; 29 30 30 31 namespace HeuristicLab.Hive.Contracts.Interfaces { … … 32 33 public interface ISlaveFacade: ISlaveCommunicator { 33 34 [OperationContract] 34 Stream SendStreamedJob(Guid clientId);35 Stream GetStreamedJob(Guid clientId); 35 36 36 37 [OperationContract] 37 Stream SendStreamedPlugins(List<HivePluginInfoDto> pluginList);38 Stream GetStreamedPlugins(List<HivePluginInfoDto> pluginList); 38 39 39 40 [OperationContract] -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Contracts/3.3/Interfaces/ISlaveManager.cs
r4254 r4263 26 26 using System.ServiceModel; 27 27 using HeuristicLab.Hive.Contracts.BusinessObjects; 28 using HeuristicLab.Hive.Contracts.ResponseObjects; 28 29 29 30 namespace HeuristicLab.Hive.Contracts.Interfaces { … … 35 36 36 37 [OperationContract] 37 ResponseList<ClientDto> GetAll Clients();38 ResponseList<ClientDto> GetAllSlaves(); 38 39 39 40 [OperationContract] -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment.Views/3.3/JobItemView.cs
r4173 r4263 38 38 Content_JobStateChanged(this, EventArgs.Empty); 39 39 if (Content.LatestSnapshot != null) { 40 snapshotStatusText.InvokeIfRequired(c => c.Text = Content.LatestSnapshot.StatusMessage );40 snapshotStatusText.InvokeIfRequired(c => c.Text = Content.LatestSnapshot.StatusMessage.ToString()); 41 41 snapshotTimeText.InvokeIfRequired(c => { c.Text = Content.LatestSnapshotTime.ToString(); }); 42 42 } … … 91 91 } else { 92 92 if (Content.LatestSnapshot != null) { 93 snapshotStatusText.Text = Content.LatestSnapshot.StatusMessage ;93 snapshotStatusText.Text = Content.LatestSnapshot.StatusMessage.ToString(); 94 94 snapshotTimeText.Text = Content.LatestSnapshotTime.ToString(); 95 95 } else { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/HiveExperiment.cs
r4173 r4263 42 42 using System.Collections; 43 43 using System.ServiceModel; 44 using HeuristicLab.Hive.Contracts.ResponseObjects; 44 45 45 46 namespace HeuristicLab.Hive.Experiment { … … 561 562 LogMessage("Polling results for " + jobIdsToQuery.Count() + " jobs"); 562 563 try { 563 ResponseObject<JobResultList> response = executionEngineFacade.Get AllJobResults(jobIdsToQuery);564 if (response.S uccess) {564 ResponseObject<JobResultList> response = executionEngineFacade.GetJobResults(jobIdsToQuery); 565 if (response.StatusMessage == ResponseStatus.Ok) { 565 566 JobResultList jobItemList = response.Obj; 566 567 UpdateJobItems(jobItemList); 567 568 568 569 LogMessage("Polling successfully finished"); 570 } else { 571 throw new Exception(response.StatusMessage.ToString()); 569 572 } 570 573 } catch (Exception e) { … … 603 606 604 607 Response snapShotResponse = executionEngineFacade.RequestSnapshot(jobId); 605 if (snapShotResponse.StatusMessage == ApplicationConstants.RESPONSE_JOB_IS_NOT_BEEING_CALCULATED) {608 if (snapShotResponse.StatusMessage == ResponseStatus.RequestSnapshot_JobIsNotBeeingCalculated) { 606 609 // job already finished 607 610 Logger.Debug("HiveExperiment: Abort - GetLastResult(false)"); 608 611 response = executionEngineFacade.GetLastSerializedResult(jobId, false, false); 609 Logger.Debug("HiveExperiment: Abort - Server: " + response.StatusMessage + " success: " + response.Success);612 Logger.Debug("HiveExperiment: Abort - Server: " + response.StatusMessage); 610 613 } else { 611 614 // server sent snapshot request to client … … 615 618 Logger.Debug("HiveExperiment: Abort - GetLastResult(true)"); 616 619 response = executionEngineFacade.GetLastSerializedResult(jobId, false, true); 617 Logger.Debug("HiveExperiment: Abort - Server: " + response.StatusMessage + " success: " + response.Success);620 Logger.Debug("HiveExperiment: Abort - Server: " + response.StatusMessage); 618 621 retryCount++; 619 622 // loop while … … 622 625 } while ( 623 626 (retryCount < maxSnapshotRetries) && ( 624 !response.Success || 625 response.StatusMessage == ApplicationConstants.RESPONSE_JOB_RESULT_NOT_YET_HERE) 627 response.StatusMessage == ResponseStatus.GetLastSerializedResult_JobResultNotYetThere) 626 628 ); 627 629 } 628 if (response.S uccess) {630 if (response.StatusMessage == ResponseStatus.Ok) { 629 631 LogMessage(jobId, "Snapshot polling successfull for job " + jobId); 630 632 UpdateSnapshot(response); -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Experiment/3.3/JobItem.cs
r4173 r4263 11 11 using System.Diagnostics; 12 12 using HeuristicLab.Optimization; 13 using HeuristicLab.Hive.Contracts.ResponseObjects; 13 14 14 15 namespace HeuristicLab.Hive.Experiment { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Console/3.3/AddJobForm.cs
r4253 r4263 34 34 using HeuristicLab.Core; 35 35 using System.ServiceModel; 36 using HeuristicLab.Hive.Contracts.ResponseObjects; 36 37 37 38 namespace HeuristicLab.Hive.Server.ServerConsole { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Console/3.3/CgCalendar.cs
r4253 r4263 13 13 using HeuristicLab.Hive.Contracts; 14 14 using System.Collections; 15 using HeuristicLab.Hive.Contracts.ResponseObjects; 15 16 16 17 namespace HeuristicLab.Hive.Server.ServerConsole { … … 55 56 onlineTimes.Clear(); 56 57 ResponseList<AppointmentDto> response = ServiceLocator.GetClientManager().GetUptimeCalendarForResource(ResourceId); 57 if(response.S uccess) {58 if(response.StatusMessage == ResponseStatus.Ok) { 58 59 foreach (AppointmentDto appointmentDto in response.List) { 59 60 onlineTimes.Add(new Appointment { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Console/3.3/HiveServerConsole.cs
r2118 r4263 35 35 using System.Threading; 36 36 using System.ServiceModel; 37 using HeuristicLab.Hive.Contracts.ResponseObjects; 37 38 38 39 namespace HeuristicLab.Hive.Server.ServerConsole { … … 92 93 t.Abort(); 93 94 this.Cursor = Cursors.Default; 94 if (resp.S uccess == true) return true;95 lblError.Text = resp.StatusMessage ;95 if (resp.StatusMessage == ResponseStatus.Ok) return true; 96 lblError.Text = resp.StatusMessage.ToString(); 96 97 MessageBox.Show("Wrong username or password"); 97 98 } -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Console/3.3/HiveServerManagementConsole.cs
r4253 r4263 34 34 using System.ServiceModel; 35 35 using HeuristicLab.Tracing; 36 using HeuristicLab.Hive.Contracts.ResponseObjects; 36 37 37 38 namespace HeuristicLab.Hive.Server.ServerConsole { … … 280 281 281 282 private void updaterWoker_DoWork(object sender, DoWorkEventArgs e) { 282 283 283 changes.Clear(); 284 284 … … 412 412 ResponseObject<JobDto> response = ServiceLocator.GetJobManager().GetJobByIdWithDetails(currentJob.Id); 413 413 414 if(response.S uccess == false|| response.Obj == null)414 if(response.StatusMessage != ResponseStatus.Ok || response.Obj == null) 415 415 return; 416 416 … … 702 702 ResponseObject<ClientGroupDto> respcg = clientManager.AddClientGroup(cg); 703 703 Response res = clientManager.AddResourceToGroup(parentgroup, respcg.Obj); 704 if (res != null && !res.Success) {705 MessageBox.Show(res.StatusMessage , "Error adding Group", MessageBoxButtons.OK, MessageBoxIcon.Error);704 if (res != null && res.StatusMessage != ResponseStatus.Ok) { 705 MessageBox.Show(res.StatusMessage.ToString(), "Error adding Group", MessageBoxButtons.OK, MessageBoxIcon.Error); 706 706 } 707 707 } else { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Console/3.3/JobDataFetcher.cs
r4121 r4263 9 9 using System.Threading; 10 10 using HeuristicLab.Hive.Contracts.Interfaces; 11 using HeuristicLab.Hive.Contracts.ResponseObjects; 11 12 12 13 namespace HeuristicLab.Hive.Server.ServerConsole { … … 87 88 for (int i = 0; i < pollStatesCopy.Length; i++) { 88 89 ResponseList<JobDto> resList = jobManager.GetAllJobsWithFilter(pollStatesCopy[i], CurrentPage * NrOfEntriesOnPage, NrOfEntriesOnPage); 89 if (resList.S uccess) {90 if (resList.StatusMessage == ResponseStatus.Ok) { 90 91 if (resList.List.Count == 0) { 91 92 if (CurrentPage > 0) { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/Authorization/HivePermissionManager.cs
r4253 r4263 11 11 using HeuristicLab.Hive.Server.Core.InternalInterfaces; 12 12 using System.ServiceModel; 13 using HeuristicLab.Hive.Contracts.ResponseObjects; 13 14 14 15 namespace HeuristicLab.Hive.Server.Core { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/DefaultScheduler.cs
r4254 r4263 31 31 using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required, new TransactionOptions { IsolationLevel = ApplicationConstants.ISOLATION_LEVEL_SCOPE })) { 32 32 ClientDto slave = DaoLocator.ClientDao.FindById(slaveId); 33 LinkedList<JobDto> allOfflineJobsForSlave = 34 new LinkedList<JobDto>(DaoLocator.JobDao.FindFittingJobsForSlave(State.Offline, slave.NrOfFreeCores, slave.FreeMemory, slave.Id)); 33 LinkedList<JobDto> allOfflineJobsForSlave = new LinkedList<JobDto>(DaoLocator.JobDao.FindFittingJobsForSlave(State.Offline, slave.NrOfFreeCores, slave.FreeMemory, slave.Id)); 35 34 if (allOfflineJobsForSlave != null && allOfflineJobsForSlave.Count > 0) { 36 35 jobToCalculate = allOfflineJobsForSlave.First.Value; -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/Facades/ExecutionEngineFacade.cs
r4170 r4263 28 28 using HeuristicLab.Hive.Contracts.BusinessObjects; 29 29 using HeuristicLab.Hive.Server.DataAccess; 30 using HeuristicLab.Hive.Contracts.ResponseObjects; 30 31 31 32 namespace HeuristicLab.Hive.Server.Core { … … 60 61 public ResponseObject<SerializedJob> GetLastSerializedResult(Guid jobId, bool requested, bool snapshot) { 61 62 using (contextFactory.GetContext(false)) { 62 return jobManager.GetLastSerialized JobResultOf(jobId, requested, snapshot);63 return jobManager.GetLastSerializedResult(jobId, requested, snapshot); 63 64 } 64 65 } … … 77 78 78 79 79 public ResponseObject<JobResultList> Get AllJobResults(IEnumerable<Guid> jobIds) {80 public ResponseObject<JobResultList> GetJobResults(IEnumerable<Guid> jobIds) { 80 81 using (contextFactory.GetContext(false)) { 81 return jobManager.Get AllJobResults(jobIds);82 return jobManager.GetJobResults(jobIds); 82 83 } 83 84 } -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/Facades/ServerConsoleFacade.cs
r4253 r4263 31 31 using System.ServiceModel; 32 32 using HeuristicLab.Hive.Server.DataAccess; 33 using HeuristicLab.Hive.Contracts.ResponseObjects; 33 34 34 35 … … 53 54 sessionID = secMan.Login(username, password); 54 55 if (sessionID == Guid.Empty) { 55 resp.Success = false; 56 resp.StatusMessage = ApplicationConstants.RESPONSE_SERVERCONSOLE_LOGIN_FAILED; 57 } else { 58 resp.Success = true; 59 resp.StatusMessage = 60 ApplicationConstants.RESPONSE_SERVERCONSOLE_LOGIN_SUCCESS; 56 resp.StatusMessage = ResponseStatus.Login_LoginFaild; 61 57 } 62 58 return resp; … … 64 60 65 61 66 public ResponseList<ClientDto> GetAll Clients() {62 public ResponseList<ClientDto> GetAllSlaves() { 67 63 using (contextFactory.GetContext(false)) { 68 64 secMan.Authorize("AccessClients", sessionID, Guid.Empty); 69 return slaveManager.GetAll Clients();65 return slaveManager.GetAllSlaves(); 70 66 } 71 67 } … … 140 136 } 141 137 142 public ResponseObject<JobDto> GetLastJobResultOf(Guid jobId) { 138 //public ResponseObject<JobDto> GetLastJobResultOf(Guid jobId) { 139 // using (contextFactory.GetContext(false)) { 140 // secMan.Authorize("AccessJobResults", sessionID, jobId); 141 // return jobManager.GetLastJobResultOf(jobId); 142 // } 143 //} 144 145 public ResponseObject<SerializedJob> GetLastSerializedResult(Guid jobId, bool requested, bool snapshot) { 143 146 using (contextFactory.GetContext(false)) { 144 147 secMan.Authorize("AccessJobResults", sessionID, jobId); 145 return jobManager.GetLastJobResultOf(jobId); 146 } 147 } 148 149 public ResponseObject<SerializedJob> GetLastSerializedJobResultOf(Guid jobId, bool requested, bool snapshot) { 150 using (contextFactory.GetContext(false)) { 151 secMan.Authorize("AccessJobResults", sessionID, jobId); 152 return jobManager.GetLastSerializedJobResultOf(jobId, requested, snapshot); 153 } 154 } 155 156 public ResponseObject<JobResultList> GetAllJobResults(IEnumerable<Guid> jobIds) { 148 return jobManager.GetLastSerializedResult(jobId, requested, snapshot); 149 } 150 } 151 152 public ResponseObject<JobResultList> GetJobResults(IEnumerable<Guid> jobIds) { 157 153 using (contextFactory.GetContext(false)) { 158 154 //secMan.Authorize("AccessJobResults", sessionID, jobId); skip authorization 159 return jobManager.Get AllJobResults(jobIds);160 } 161 } 162 163 public Response RemoveJob(Guid jobId) {164 using (contextFactory.GetContext()) {165 secMan.Authorize("RemoveJob", sessionID, jobId);166 return jobManager.RemoveJob(jobId);167 }168 }155 return jobManager.GetJobResults(jobIds); 156 } 157 } 158 159 //public Response RemoveJob(Guid jobId) { 160 // using (contextFactory.GetContext()) { 161 // secMan.Authorize("RemoveJob", sessionID, jobId); 162 // return jobManager.RemoveJob(jobId); 163 // } 164 //} 169 165 170 166 public Response RequestSnapshot(Guid jobId) { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/Facades/SlaveFacade.cs
r4254 r4263 35 35 using HeuristicLab.Hive.Server.LINQDataAccess; 36 36 using HeuristicLab.Hive.Server.DataAccess; 37 using HeuristicLab.Hive.Contracts.ResponseObjects; 37 38 38 39 namespace HeuristicLab.Hive.Server.Core { … … 85 86 } 86 87 87 public ResponseList<CachedHivePluginInfoDto> SendPlugins(List<HivePluginInfoDto> pluginList) {88 return slaveCommunicator. SendPlugins(pluginList);88 public ResponseList<CachedHivePluginInfoDto> GetPlugins(List<HivePluginInfoDto> pluginList) { 89 return slaveCommunicator.GetPlugins(pluginList); 89 90 } 90 91 … … 94 95 } 95 96 } 96 97 97 98 98 public ResponseCalendar GetCalendar(Guid clientId) { … … 114 114 /// Do not use automatic transactions here 115 115 /// </summary> 116 public Stream SendStreamedJob(Guid clientId) {116 public Stream GetStreamedJob(Guid clientId) { 117 117 using (contextFactory.GetContext(false)) { 118 118 MultiStream stream = new MultiStream(); … … 125 125 stream.AddStream(new StreamedObject<ResponseObject<JobDto>>(job)); 126 126 127 IJobManager jobManager = ServiceLocator.GetJobManager(); 128 IInternalJobManager internalJobManager = (IInternalJobManager)jobManager; 127 IInternalJobManager internalJobManager = (IInternalJobManager)ServiceLocator.GetJobManager(); 129 128 130 129 //second stream the job binary data 131 130 MemoryStream memoryStream = new MemoryStream(); 132 if (job.Obj != null) 131 if (job.Obj != null) { 133 132 stream.AddStream(new MemoryStream(internalJobManager.GetSerializedJobDataById(job.Obj.Id))); 133 } 134 134 135 135 OperationContext clientContext = OperationContext.Current; … … 144 144 } 145 145 146 public Stream SendStreamedPlugins(List<HivePluginInfoDto> pluginList) {147 return new StreamedObject<ResponseList<CachedHivePluginInfoDto>>(this. SendPlugins(pluginList));146 public Stream GetStreamedPlugins(List<HivePluginInfoDto> pluginList) { 147 return new StreamedObject<ResponseList<CachedHivePluginInfoDto>>(this.GetPlugins(pluginList)); 148 148 } 149 149 -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/InternalInterfaces/IInternalSlaveCommunicator.cs
r4253 r4263 27 27 using HeuristicLab.Hive.Contracts; 28 28 using System.IO; 29 using HeuristicLab.Hive.Contracts.ResponseObjects; 29 30 30 31 namespace HeuristicLab.Hive.Server.Core.InternalInterfaces { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/JobManager.cs
r4254 r4263 38 38 using HeuristicLab.Hive.Server.LINQDataAccess; 39 39 using IsolationLevel = System.Transactions.IsolationLevel; 40 using HeuristicLab.Hive.Contracts.ResponseObjects; 40 41 41 42 namespace HeuristicLab.Hive.Server.Core { … … 50 51 lifecycleManager.RegisterStartup(new EventHandler(lifecycleManager_OnStartup)); 51 52 lifecycleManager.RegisterShutdown(new EventHandler(lifecycleManager_OnShutdown)); 52 }53 54 private JobDto GetLastJobResult(Guid jobId) {55 return DaoLocator.JobDao.FindById(jobId);56 53 } 57 54 … … 85 82 public ResponseList<JobDto> GetAllJobs() { 86 83 ResponseList<JobDto> response = new ResponseList<JobDto>(); 87 88 84 response.List = new List<JobDto>(DaoLocator.JobDao.FindAll()); 89 response.Success = true;90 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ALL_JOBS;91 92 85 return response; 93 86 } … … 96 89 ResponseList<JobDto> response = new ResponseList<JobDto>(); 97 90 response.List = new List<JobDto>(DaoLocator.JobDao.FindWithLimitations(jobState, offset, count)); 98 response.Success = true;99 91 return response; 100 92 } … … 118 110 response.Obj = DaoLocator.JobDao.FindById(jobId); 119 111 if (response.Obj != null) { 120 response.Success = true; 121 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_GET_JOB_BY_ID; 112 response.StatusMessage = ResponseStatus.Ok; 122 113 } else { 123 response.Success = false; 124 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_DOESNT_EXIST; 114 response.StatusMessage = ResponseStatus.GetJobById_JobDoesNotExist; 125 115 } 126 116 … … 135 125 job.Obj = DaoLocator.JobDao.FindById(jobId); 136 126 if (job.Obj != null) { 137 job.Success = true; 138 job.StatusMessage = ApplicationConstants.RESPONSE_JOB_GET_JOB_BY_ID; 127 job.StatusMessage = ResponseStatus.Ok; 139 128 140 129 job.Obj.Client = DaoLocator.ClientDao.GetClientForJob(jobId); 141 130 } else { 142 job.Success = false; 143 job.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_DOESNT_EXIST; 131 job.StatusMessage = ResponseStatus.GetJobByIdWithDetails_JobDoesNotExist; 144 132 } 145 133 return job; … … 166 154 if (job != null && job.JobInfo != null) { 167 155 if (job.JobInfo.State != State.Offline) { 168 response.Success = false; 169 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOBSTATE_MUST_BE_OFFLINE; 156 response.StatusMessage = ResponseStatus.AddNewJob_JobStateMustBeOffline; 170 157 return response; 171 158 } 172 159 if (job.JobInfo.Id != Guid.Empty) { 173 response.Success = false; 174 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ID_MUST_NOT_BE_SET; 160 response.StatusMessage = ResponseStatus.AddNewJob_JobIdMustNotBeSet; 175 161 return response; 176 162 } 177 163 if (job.SerializedJobData == null) { 178 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_NULL; 179 response.Success = false; 164 response.StatusMessage = ResponseStatus.AddNewJob_JobNull; 180 165 return response; 181 166 } … … 185 170 DaoLocator.PluginInfoDao.InsertPluginDependenciesForJob(job.JobInfo); 186 171 187 response.Success = true;188 172 response.Obj = job.JobInfo; 189 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_ADDED;190 173 } else { 191 response.Success = false; 192 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_NULL; 174 response.StatusMessage = ResponseStatus.AddNewJob_JobNull; 193 175 } 194 176 … … 198 180 /// <summary> 199 181 /// Removes a job from the database 182 /// 183 /// [chn] this is currently not used anywhere -> check redundancy with AbortJob 200 184 /// </summary> 201 185 /// <param name="jobId"></param> 202 186 /// <returns></returns> 203 public Response RemoveJob(Guid jobId) { 204 Response response = new Response(); 205 206 JobDto job = DaoLocator.JobDao.FindById(jobId); 207 if (job == null) { 208 response.Success = false; 209 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_DOESNT_EXIST; 210 return response; 211 } 212 DaoLocator.JobDao.Delete(job); 213 response.Success = false; 214 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_REMOVED; 215 216 return response; 217 } 218 219 public ResponseObject<JobDto> GetLastJobResultOf(Guid jobId) { 220 ResponseObject<JobDto> result = new ResponseObject<JobDto>(); 221 222 result.Obj = GetLastJobResult(jobId); 223 result.Success = result.Obj != null; 224 225 return result; 226 } 187 //public Response RemoveJob(Guid jobId) { 188 // Response response = new Response(); 189 190 // JobDto job = DaoLocator.JobDao.FindById(jobId); 191 // if (job == null) { 192 // response.StatusMessage = ResponseStatusMessage.RemoveJob_JobDoesNotExist; 193 // return response; 194 // } 195 // DaoLocator.JobDao.Delete(job); 196 197 // return response; 198 //} 199 200 /// 201 /// [chn] currently not used anywhere 202 /// 203 //public ResponseObject<JobDto> GetLastJobResultOf(Guid jobId) { 204 // ResponseObject<JobDto> result = new ResponseObject<JobDto>(); 205 206 // result.Obj = DaoLocator.JobDao.FindById(jobId); 207 // if (result.Obj == null) { 208 // result.StatusMessage = ResponseStatusMessage. 209 // } 210 211 // return result; 212 //} 227 213 228 214 // [chn] [refactor] why does this method handle 3 different cases? wouldn't 3 methods be easier? … … 230 216 // requested==true: resultat mit job 231 217 // requested==false: 232 public ResponseObject<SerializedJob> GetLastSerialized JobResultOf(Guid jobId, bool requested, bool snapshot) {218 public ResponseObject<SerializedJob> GetLastSerializedResult(Guid jobId, bool requested, bool snapshot) { 233 219 ResponseObject<SerializedJob> response = new ResponseObject<SerializedJob>(); 234 220 … … 237 223 //if it's a snapshot but the result hasn't reached the server yet... 238 224 if (snapshot && (job.State == State.RequestSnapshot || job.State == State.RequestSnapshotSent)) { 239 response.Success = true; 240 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_RESULT_NOT_YET_HERE; 225 response.StatusMessage = ResponseStatus.GetLastSerializedResult_JobResultNotYetThere; 241 226 242 227 return response; … … 245 230 //if it's NOT a snapshot, NEITHER request NOR is it finished 246 231 if (!requested && !snapshot && job.State != State.Finished) { 247 response.Success = true; 248 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_RESULT_NOT_YET_HERE; 232 response.StatusMessage = ResponseStatus.GetLastSerializedResult_JobResultNotYetThere; 249 233 250 234 return response; … … 252 236 253 237 //every other case - snapshot, job finished or it's requested 254 response.Success = true;255 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_RESULT_SENT;256 238 response.Obj = new SerializedJob(); 257 239 response.Obj.JobInfo = job; … … 267 249 JobDto job = DaoLocator.JobDao.FindById(jobId); 268 250 if (job.State == State.RequestSnapshot || job.State == State.RequestSnapshotSent) { 269 response.Success = true; 270 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_REQUEST_ALLREADY_SET; 251 response.StatusMessage = ResponseStatus.RequestSnapshot_SnapshotAlreadyRequested; 271 252 return response; 272 253 } 273 254 if (job.State != State.Calculating) { 274 response.Success = false; 275 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_IS_NOT_BEEING_CALCULATED; 255 response.StatusMessage = ResponseStatus.RequestSnapshot_JobIsNotBeeingCalculated; 276 256 return response; 277 257 } … … 280 260 DaoLocator.JobDao.Update(job); 281 261 282 re sponse.Success = true;283 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_REQUEST_SET;284 285 return response;286 }287 262 return response; 263 } 264 265 /// <summary> 266 /// [chn] rename to RequestAbortJob? 267 /// </summary> 288 268 public Response AbortJob(Guid jobId) { 289 269 Response response = new Response(); … … 291 271 JobDto job = DaoLocator.JobDao.FindById(jobId); 292 272 if (job == null) { 293 response.Success = false;294 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_JOB_DOESNT_EXIST;273 //response.Success = false; 274 response.StatusMessage = ResponseStatus.AbortJob_JobDoesNotExist; 295 275 return response; // no commit needed 296 276 } 297 277 if (job.State == State.Abort) { 298 response.Success = true;299 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ABORT_REQUEST_ALLREADY_SET;278 //response.Success = true; 279 response.StatusMessage = ResponseStatus.AbortJob_AbortAlreadyRequested; 300 280 return response; // no commit needed 301 281 } 302 282 if (job.State != State.Calculating && job.State != State.RequestSnapshot && job.State != State.RequestSnapshotSent) { 303 response.Success = false;304 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_IS_NOT_BEEING_CALCULATED;283 //response.Success = false; 284 response.StatusMessage = ResponseStatus.AbortJob_JobIsNotBeeingCalculated; 305 285 return response; // no commit needed 306 286 } … … 309 289 DaoLocator.JobDao.Update(job); 310 290 311 response.Success = true;312 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ABORT_REQUEST_SET;313 314 291 return response; 315 292 } … … 320 297 /// <param name="jobIds"></param> 321 298 /// <returns></returns> 322 public ResponseObject<JobResultList> Get AllJobResults(IEnumerable<Guid> jobIds) {299 public ResponseObject<JobResultList> GetJobResults(IEnumerable<Guid> jobIds) { 323 300 ResponseObject<JobResultList> response = new ResponseObject<JobResultList>(); 324 301 JobResultList jobResultList = new JobResultList(); … … 335 312 } 336 313 response.Obj = jobResultList; 337 response.Success = true;338 response.StatusMessage = ApplicationConstants.RESPONSE_JOB_ALL_JOBS;339 314 return response; 340 315 } -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/SlaveCommunicator.cs
r4254 r4263 33 33 using HeuristicLab.PluginInfrastructure; 34 34 using HeuristicLab.Tracing; 35 using HeuristicLab.Hive.Contracts.ResponseObjects; 35 36 36 37 namespace HeuristicLab.Hive.Server.Core { … … 168 169 /// A hearbeat entry is created as well (login is the first hearbeat) 169 170 /// </summary> 170 /// <param name=" clientInfo"></param>171 /// <param name="slaveInfo"></param> 171 172 /// <returns></returns> 172 public Response Login(ClientDto clientInfo) {173 public Response Login(ClientDto slaveInfo) { 173 174 Response response = new Response(); 174 175 175 176 heartbeatLock.EnterWriteLock(); 176 if (lastHeartbeats.ContainsKey( clientInfo.Id)) {177 lastHeartbeats[ clientInfo.Id] = DateTime.Now;177 if (lastHeartbeats.ContainsKey(slaveInfo.Id)) { 178 lastHeartbeats[slaveInfo.Id] = DateTime.Now; 178 179 } else { 179 lastHeartbeats.Add( clientInfo.Id, DateTime.Now);180 lastHeartbeats.Add(slaveInfo.Id, DateTime.Now); 180 181 } 181 182 heartbeatLock.ExitWriteLock(); 182 183 183 ClientDto dbClient = DaoLocator.ClientDao.FindById( clientInfo.Id);184 ClientDto dbClient = DaoLocator.ClientDao.FindById(slaveInfo.Id); 184 185 185 186 //Really set offline? 186 187 //Reconnect issues with the currently calculating jobs 187 clientInfo.State = State.Idle;188 clientInfo.CalendarSyncStatus = dbClient != null ? dbClient.CalendarSyncStatus : CalendarState.NotAllowedToFetch;188 slaveInfo.State = State.Idle; 189 slaveInfo.CalendarSyncStatus = dbClient != null ? dbClient.CalendarSyncStatus : CalendarState.NotAllowedToFetch; 189 190 190 191 if (dbClient == null) 191 DaoLocator.ClientDao.Insert( clientInfo);192 DaoLocator.ClientDao.Insert(slaveInfo); 192 193 else 193 DaoLocator.ClientDao.Update(clientInfo); 194 response.Success = true; 195 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_LOGIN_SUCCESS; 194 DaoLocator.ClientDao.Update(slaveInfo); 195 196 196 return response; 197 197 } … … 202 202 ClientDto client = DaoLocator.ClientDao.FindById(clientId); 203 203 if (client == null) { 204 response.Success = false;205 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_RESOURCE_NOT_FOUND;204 //response.Success = false; 205 response.StatusMessage = ResponseStatus.GetCalendar_ResourceNotFound; 206 206 return response; 207 207 } … … 211 211 IEnumerable<AppointmentDto> appointments = DaoLocator.UptimeCalendarDao.GetCalendarForClient(client); 212 212 if (appointments.Count() == 0) { 213 response.StatusMessage = ApplicationConstants.RESPONSE_UPTIMECALENDAR_NO_CALENDAR_FOUND;214 response.Success = false;213 response.StatusMessage = ResponseStatus.GetCalendar_NoCalendarFound; 214 //response.Success = false; 215 215 } else { 216 response.Success = true;216 //response.Success = true; 217 217 response.Appointments = appointments; 218 218 } … … 227 227 ClientDto client = DaoLocator.ClientDao.FindById(clientId); 228 228 if (client == null) { 229 response.Success = false;230 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_RESOURCE_NOT_FOUND;229 //response.Success = false; 230 response.StatusMessage = ResponseStatus.GetCalendar_ResourceNotFound; 231 231 return response; 232 232 } … … 234 234 client.CalendarSyncStatus = state; 235 235 DaoLocator.ClientDao.Update(client); 236 237 response.Success = true;238 response.StatusMessage = ApplicationConstants.RESPONSE_UPTIMECALENDAR_STATUS_UPDATED;239 236 240 237 return response; … … 259 256 // check if the client is logged in 260 257 if (client.State == State.Offline || client.State == State.NullState) { 261 response.Success = false;262 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_USER_NOT_LOGGED_IN;258 // response.Success = false; 259 response.StatusMessage = ResponseStatus.ProcessHeartBeat_UserNotLoggedIn; 263 260 response.ActionRequest.Add(new MessageContainer(MessageContainer.MessageType.NoMessage)); 264 261 … … 288 285 //check if new Cal must be loaded 289 286 if (client.CalendarSyncStatus == CalendarState.Fetch || client.CalendarSyncStatus == CalendarState.ForceFetch) { 290 response.Success = true;291 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_FETCH_OR_FORCEFETCH_CALENDAR;292 287 response.ActionRequest.Add(new MessageContainer(MessageContainer.MessageType.FetchOrForceFetchCalendar)); 293 288 … … 306 301 } 307 302 Logger.Debug(" END Looked for Client Jobs"); 308 response.Success = true;309 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_HEARTBEAT_RECEIVED;310 303 311 304 DaoLocator.ClientDao.Update(client); … … 347 340 if (hbData.JobProgress != null && hbData.JobProgress.Count > 0) { 348 341 if (jobsOfClient == null || jobsOfClient.Count == 0) { 349 response.Success = false;350 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_IS_NOT_BEEING_CALCULATED;342 //response.Success = false; 343 //response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_IS_NOT_BEEING_CALCULATED; 351 344 352 345 foreach (Guid jobId in hbData.JobProgress.Keys) { … … 362 355 curJob.Client = DaoLocator.ClientDao.GetClientForJob(curJob.Id); 363 356 if (curJob.Client == null || curJob.Client.Id != hbData.SlaveId) { 364 response.Success = false;365 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_IS_NOT_BEEING_CALCULATED;357 //response.Success = false; 358 //response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_IS_NOT_BEEING_CALCULATED; 366 359 response.ActionRequest.Add(new MessageContainer(MessageContainer.MessageType.AbortJob, curJob.Id)); 367 360 Logger.Error("There is no job calculated by this user " + hbData.SlaveId + " Job: " + curJob); … … 439 432 response.Obj = job2Calculate; 440 433 response.Obj.PluginsNeeded = DaoLocator.PluginInfoDao.GetPluginDependenciesForJob(response.Obj); 441 response.Success = true; 434 442 435 Logger.Info("Job pulled: " + job2Calculate + " for user " + clientId); 443 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_PULLED;444 436 lock (newAssignedJobs) { 445 437 if (!newAssignedJobs.ContainsKey(job2Calculate.Id)) … … 447 439 } 448 440 } else { 449 response.Success = false;441 //response.Success = false; 450 442 response.Obj = null; 451 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_NO_JOBS_LEFT;443 response.StatusMessage = ResponseStatus.GetJob_NoJobsAvailable; 452 444 Logger.Info("No more Jobs left for " + clientId); 453 445 } … … 473 465 ResponseResultReceived response = ProcessJobResult(result.ClientId, result.JobId, new byte[] { }, result.Percentage, result.Exception, finished); 474 466 475 if (response.S uccess) {467 if (response.StatusMessage == ResponseStatus.Ok) { 476 468 Logger.Debug("Trying to aquire WCF Job Stream"); 477 469 //jobStream = DaoLocator.JobDao.GetSerializedJobStream(result.JobId); … … 500 492 } 501 493 502 503 private ResponseResultReceived ProcessJobResult(Guid clientId, 504 Guid jobId, 505 byte[] result, 506 double? percentage, 507 string exception, 508 bool finished) { 509 494 private ResponseResultReceived ProcessJobResult(Guid clientId, Guid jobId, byte[] result, double? percentage, string exception, bool finished) { 510 495 Logger.Info("BEGIN Job received for Storage - SUB method: " + jobId); 511 496 … … 521 506 } 522 507 } 523 508 524 509 if (job != null && job.JobInfo == null) { 525 response.Success = false;526 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_NO_JOB_WITH_THIS_ID;510 //response.Success = false; 511 response.StatusMessage = ResponseStatus.ProcessJobResult_JobDoesNotExist; 527 512 response.JobId = jobId; 528 513 Logger.Error("No job with Id " + jobId); … … 532 517 } 533 518 if (job.JobInfo.State == State.Abort) { 534 response.Success = false;535 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_WAS_ABORTED;519 //response.Success = false; 520 response.StatusMessage = ResponseStatus.ProcessJobResult_JobAborted; 536 521 537 522 Logger.Error("Job was aborted! " + job.JobInfo); … … 541 526 } 542 527 if (job.JobInfo.Client == null) { 543 response.Success = false;544 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_IS_NOT_BEEING_CALCULATED;528 //response.Success = false; 529 response.StatusMessage = ResponseStatus.ProcessJobResult_JobIsNotBeeingCalculated; 545 530 response.JobId = jobId; 546 531 … … 551 536 } 552 537 if (job.JobInfo.Client.Id != clientId) { 553 response.Success = false;554 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_WRONG_CLIENT_FOR_JOB;538 //response.Success = false; 539 response.StatusMessage = ResponseStatus.ProcessJobResult_WrongClientForJob; 555 540 response.JobId = jobId; 556 541 … … 561 546 } 562 547 if (job.JobInfo.State == State.Finished) { 563 response.Success = true; 564 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOBRESULT_RECEIVED; 548 response.StatusMessage = ResponseStatus.Ok; 565 549 response.JobId = jobId; 566 550 … … 574 558 job.JobInfo.State = State.Calculating; 575 559 } 576 if (job.JobInfo.State != State.Calculating && 577 job.JobInfo.State != State.Pending) { 578 response.Success = false; 579 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_WRONG_JOB_STATE; 560 if (job.JobInfo.State != State.Calculating && job.JobInfo.State != State.Pending) { 561 //response.Success = false; 562 response.StatusMessage = ResponseStatus.ProcessJobResult_InvalidJobState; 580 563 response.JobId = jobId; 581 564 … … 600 583 DaoLocator.JobDao.Update(job.JobInfo); 601 584 602 response.Success = true; 603 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOBRESULT_RECEIVED; 585 response.StatusMessage = ResponseStatus.Ok; 604 586 response.JobId = jobId; 605 587 response.Finished = finished; … … 652 634 ClientDto client = DaoLocator.ClientDao.FindById(clientId); 653 635 if (client == null) { 654 response.Success = false;655 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_LOGOUT_CLIENT_NOT_REGISTERED;636 //response.Success = false; 637 response.StatusMessage = ResponseStatus.Logout_SlaveNotRegistered; 656 638 return response; 657 639 } … … 668 650 DaoLocator.ClientDao.Update(client); 669 651 670 response.Success = true;671 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_LOGOUT_SUCCESS;672 673 652 return response; 674 653 } … … 684 663 JobDto job = DaoLocator.JobDao.FindById(jobId); 685 664 if (job == null) { 686 response.Success = false;687 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_DOESNT_EXIST;665 //response.Success = false; 666 response.StatusMessage = ResponseStatus.IsJobStillNeeded_JobDoesNotExist; 688 667 Logger.Error("Job doesn't exist (anymore)! " + jobId); 689 668 return response; 690 669 } 691 670 if (job.State == State.Finished) { 692 response.Success = true;693 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_JOB_ALLREADY_FINISHED;671 //response.Success = true; 672 response.StatusMessage = ResponseStatus.IsJobStillNeeded_JobAlreadyFinished; 694 673 Logger.Error("already finished! " + job); 695 674 return response; … … 702 681 DaoLocator.JobDao.Update(job); 703 682 704 response.Success = true; 705 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_SEND_JOBRESULT; 706 return response; 707 } 708 709 public ResponseList<CachedHivePluginInfoDto> SendPlugins(List<HivePluginInfoDto> pluginList) { 683 return response; 684 } 685 686 public ResponseList<CachedHivePluginInfoDto> GetPlugins(List<HivePluginInfoDto> pluginList) { 710 687 ResponseList<CachedHivePluginInfoDto> response = new ResponseList<CachedHivePluginInfoDto>(); 688 response.List = new List<CachedHivePluginInfoDto>(); 711 689 foreach (HivePluginInfoDto pluginInfo in pluginList) { 712 690 if (pluginInfo.Update) { 713 691 //check if there is a newer version 714 IPluginDescription ipd = 715 ApplicationManager.Manager.Plugins.Where(pd => pd.Name == pluginInfo.Name && pd.Version.Major == pluginInfo.Version.Major && pd.Version.Minor == pluginInfo.Version.Minor && pd.Version.Revision > pluginInfo.Version.Revision).SingleOrDefault(); 692 IPluginDescription ipd = ApplicationManager.Manager.Plugins.Where(pd => pd.Name == pluginInfo.Name && pd.Version.Major == pluginInfo.Version.Major && pd.Version.Minor == pluginInfo.Version.Minor && pd.Version.Revision > pluginInfo.Version.Revision).SingleOrDefault(); 716 693 if (ipd != null) { 717 response.List.Add( convertPluginDescriptorToDto(ipd));694 response.List.Add(ConvertPluginDescriptorToDto(ipd)); 718 695 } 719 696 } else { 720 IPluginDescription ipd = 721 ApplicationManager.Manager.Plugins.Where(pd => pd.Name == pluginInfo.Name && pd.Version.Major == pluginInfo.Version.Major && pd.Version.Minor == pluginInfo.Version.Minor && pd.Version.Revision >= pluginInfo.Version.Revision).SingleOrDefault(); 697 IPluginDescription ipd = ApplicationManager.Manager.Plugins.Where(pd => pd.Name == pluginInfo.Name && pd.Version.Major == pluginInfo.Version.Major && pd.Version.Minor == pluginInfo.Version.Minor && pd.Version.Revision >= pluginInfo.Version.Revision).SingleOrDefault(); 722 698 if (ipd != null) { 723 response.List.Add( convertPluginDescriptorToDto(ipd));699 response.List.Add(ConvertPluginDescriptorToDto(ipd)); 724 700 } else { 725 response.Success = false;726 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_PLUGINS_NOT_AVAIL;701 //response.Success = false; 702 response.StatusMessage = ResponseStatus.GetPlugins_PluginsNotAvailable; 727 703 return response; 728 704 } 729 705 } 730 706 } 731 response.Success = true; 732 response.StatusMessage = ApplicationConstants.RESPONSE_COMMUNICATOR_PLUGINS_SENT; 733 734 return response; 735 } 736 737 private CachedHivePluginInfoDto convertPluginDescriptorToDto(IPluginDescription currPlugin) { 707 return response; 708 } 709 710 private CachedHivePluginInfoDto ConvertPluginDescriptorToDto(IPluginDescription currPlugin) { 738 711 CachedHivePluginInfoDto currCachedPlugin = new CachedHivePluginInfoDto { 739 712 Name = currPlugin.Name, -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/SlaveManager.cs
r4253 r4263 33 33 using HeuristicLab.Hive.Server.LINQDataAccess; 34 34 using ClientGroup=HeuristicLab.Hive.Contracts.BusinessObjects.ClientGroupDto; 35 using HeuristicLab.Hive.Contracts.ResponseObjects; 35 36 36 37 namespace HeuristicLab.Hive.Server.Core { … … 48 49 /// </summary> 49 50 /// <returns></returns> 50 public ResponseList<ClientDto> GetAll Clients() {51 public ResponseList<ClientDto> GetAllSlaves() { 51 52 ResponseList<ClientDto> response = new ResponseList<ClientDto>(); 52 53 53 response.List = new List<ClientDto>(DaoLocator.ClientDao.FindAll()); 54 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_GET_ALL_CLIENTS;55 response.Success = true;56 57 54 return response; 58 55 } … … 65 62 ResponseList<ClientGroup> response = new ResponseList<ClientGroup>(); 66 63 67 List<ClientGroup> allClientGroups = 68 new List<ClientGroup>(DaoLocator.ClientGroupDao.FindAllWithSubGroupsAndClients()); 64 List<ClientGroup> allClientGroups = new List<ClientGroup>(DaoLocator.ClientGroupDao.FindAllWithSubGroupsAndClients()); 69 65 ClientGroup emptyClientGroup = new ClientGroup(); 70 66 IEnumerable<ClientDto> groupLessClients = DaoLocator.ClientDao.FindAllClientsWithoutGroup(); … … 78 74 79 75 response.List = allClientGroups; 80 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_GET_ALL_CLIENTGROUPS;81 response.Success = true;82 76 83 77 return response; 84 78 } 85 79 80 /// <summary> 81 /// [chn] check usage 82 /// </summary> 86 83 public ResponseList<UpTimeStatisticsDto> GetAllUpTimeStatistics() { 87 ResponseList<UpTimeStatisticsDto> response = new ResponseList<UpTimeStatisticsDto>(); 88 response.Success = true; 89 return response; 84 return new ResponseList<UpTimeStatisticsDto>(); 90 85 } 91 86 … … 99 94 100 95 if (clientGroup.Id != Guid.Empty) { 101 response.Success = false;102 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_ID_MUST_NOT_BE_SET;96 //response.Success = false; 97 response.StatusMessage = ResponseStatus.AddClientGroup_SlaveIdMustNotBeSet; 103 98 } 104 99 else { … … 106 101 //clientGroupAdapter.Update(clientGroup); 107 102 response.Obj = clientGroup; 108 response.Success = true;109 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_CLIENTGROUP_ADDED;110 103 } 111 104 … … 124 117 ClientGroup clientGroup = DaoLocator.ClientGroupDao.FindById(clientGroupId); 125 118 if (clientGroup == null) { 126 response.Success = false;127 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_CLIENTGROUP_DOESNT_EXIST;119 //response.Success = false; 120 response.StatusMessage = ResponseStatus.AddResourceToGroup_SlaveGroupDoesNotExist; 128 121 return response; 129 122 } … … 138 131 DaoLocator.ClientDao.SetServerSideCalendar(dbr, clientGroup.Id); 139 132 } 140 141 response.Success = true;142 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_RESOURCE_ADDED_TO_GROUP;143 133 144 134 return response; … … 156 146 ClientGroup clientGroup = DaoLocator.ClientGroupDao.FindById(clientGroupId); 157 147 if (clientGroup == null) { 158 response.Success = false;159 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_CLIENTGROUP_DOESNT_EXIST;148 // response.Success = false; 149 response.StatusMessage = ResponseStatus.AddResourceToGroup_SlaveGroupDoesNotExist; 160 150 return response; 161 151 } 162 152 163 153 DaoLocator.ClientGroupDao.RemoveRessourceFromClientGroup(resourceId, clientGroup.Id); 164 165 response.Success = true;166 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_RESOURCE_REMOVED;167 154 return response; 168 155 } … … 175 162 ClientGroupDtoList groupsOfClient = new ClientGroupDtoList(DaoLocator.ClientGroupDao.MemberOf(client)); 176 163 response.Obj = groupsOfClient; 177 response.Success = true; 178 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_GET_GROUPS_OF_CLIENT; 179 } 180 else { 164 } else { 181 165 response.Obj = new ClientGroupDtoList(); 182 response.Success = false;183 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_RESOURCE_NOT_FOUND;166 //response.Success = false; 167 response.StatusMessage = ResponseStatus.GetAllGroupsOfResource_ResourceNotFound; 184 168 } 185 169 … … 192 176 ClientGroup clientGroup = DaoLocator.ClientGroupDao.FindById(clientGroupId); 193 177 if (clientGroup == null) { 194 response.Success = false; 195 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_CLIENTGROUP_DOESNT_EXIST; 178 response.StatusMessage = ResponseStatus.DeleteClientGroup_SlaveGroupDoesNotExist; 196 179 return response; 197 180 } 198 181 199 182 DaoLocator.ClientGroupDao.Delete(clientGroup); 200 201 response.Success = true;202 response.StatusMessage = ApplicationConstants.RESPONSE_CLIENT_CLIENTGROUP_DELETED;203 183 return response; 204 184 } … … 207 187 ResponseList<AppointmentDto> response = new ResponseList<AppointmentDto>(); 208 188 response.List = new List<AppointmentDto>(DaoLocator.UptimeCalendarDao.GetUptimeCalendarForResource(guid)); 209 response.Success = true;210 189 return response; 211 190 } … … 214 193 DaoLocator.UptimeCalendarDao.SetUptimeCalendarForResource(guid, appointments); 215 194 DaoLocator.UptimeCalendarDao.NotifyClientsOfNewCalendar(guid, isForced); 216 return new Response {Success = true};195 return new Response(); 217 196 } 218 197 #endregion -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/HeuristicLab.Hive.Slave.Communication-3.3.csproj
r4254 r4263 125 125 <None Include="Properties\DataSources\HeuristicLab.Hive.Contracts.BusinessObjects.JobDto.datasource" /> 126 126 <None Include="Properties\DataSources\HeuristicLab.Hive.Contracts.ResponseHeartBeat.datasource" /> 127 <None Include="Properties\DataSources\HeuristicLab.Hive.Contracts.ResponseObjects.Response.datasource" /> 128 <None Include="Properties\DataSources\HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar.datasource" /> 129 <None Include="Properties\DataSources\HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat.datasource" /> 130 <None Include="Properties\DataSources\HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived.datasource" /> 127 131 <None Include="Properties\DataSources\HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto.datasource" /> 128 132 <None Include="Service References\ServerService\Arrays1.xsd"> … … 133 137 </None> 134 138 <None Include="Service References\ServerService\HeuristicLab.Hive.Contracts.BusinessObjects1.xsd"> 139 <SubType>Designer</SubType> 140 </None> 141 <None Include="Service References\ServerService\HeuristicLab.Hive.Contracts.ResponseObjects.xsd"> 135 142 <SubType>Designer</SubType> 136 143 </None> -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/ServerService/HeuristicLab.Hive.Contracts1.xsd
r4254 r4263 2 2 <xs:schema xmlns:ser="http://schemas.microsoft.com/2003/10/Serialization/" xmlns:tns="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts" elementFormDefault="qualified" targetNamespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts" xmlns:xs="http://www.w3.org/2001/XMLSchema"> 3 3 <xs:import namespace="http://schemas.microsoft.com/2003/10/Serialization/" /> 4 <xs:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.BusinessObjects" /> 5 <xs:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.PluginInfrastructure" /> 6 <xs:complexType name="Response"> 7 <xs:sequence> 8 <xs:element minOccurs="0" name="StatusMessage" nillable="true" type="xs:string" /> 9 <xs:element minOccurs="0" name="Success" type="xs:boolean" /> 10 </xs:sequence> 11 </xs:complexType> 12 <xs:element name="Response" nillable="true" type="tns:Response" /> 13 <xs:complexType name="ResponseHeartBeat"> 14 <xs:complexContent mixed="false"> 15 <xs:extension base="tns:Response"> 16 <xs:sequence> 17 <xs:element minOccurs="0" name="ActionRequest" nillable="true" type="tns:ArrayOfMessageContainer" /> 18 </xs:sequence> 19 </xs:extension> 20 </xs:complexContent> 21 </xs:complexType> 22 <xs:element name="ResponseHeartBeat" nillable="true" type="tns:ResponseHeartBeat" /> 4 <xs:simpleType name="ResponseStatus"> 5 <xs:restriction base="xs:string"> 6 <xs:enumeration value="Ok" /> 7 <xs:enumeration value="RequestSnapshot_JobIsNotBeeingCalculated" /> 8 <xs:enumeration value="RequestSnapshot_SnapshotAlreadyRequested" /> 9 <xs:enumeration value="GetJobById_JobDoesNotExist" /> 10 <xs:enumeration value="GetJobByIdWithDetails_JobDoesNotExist" /> 11 <xs:enumeration value="AddNewJob_JobStateMustBeOffline" /> 12 <xs:enumeration value="AddNewJob_JobIdMustNotBeSet" /> 13 <xs:enumeration value="AddNewJob_JobNull" /> 14 <xs:enumeration value="RemoveJob_JobDoesNotExist" /> 15 <xs:enumeration value="GetLastSerializedResult_JobResultNotYetThere" /> 16 <xs:enumeration value="AbortJob_JobDoesNotExist" /> 17 <xs:enumeration value="AbortJob_AbortAlreadyRequested" /> 18 <xs:enumeration value="AbortJob_JobIsNotBeeingCalculated" /> 19 <xs:enumeration value="GetCalendar_ResourceNotFound" /> 20 <xs:enumeration value="GetCalendar_NoCalendarFound" /> 21 <xs:enumeration value="SetCalendarStatus_ResourceNotFound" /> 22 <xs:enumeration value="ProcessHeartBeat_UserNotLoggedIn" /> 23 <xs:enumeration value="GetJob_NoJobsAvailable" /> 24 <xs:enumeration value="ProcessJobResult_JobDoesNotExist" /> 25 <xs:enumeration value="ProcessJobResult_JobAborted" /> 26 <xs:enumeration value="ProcessJobResult_JobIsNotBeeingCalculated" /> 27 <xs:enumeration value="ProcessJobResult_WrongClientForJob" /> 28 <xs:enumeration value="ProcessJobResult_InvalidJobState" /> 29 <xs:enumeration value="Login_LoginFaild" /> 30 <xs:enumeration value="Logout_SlaveNotRegistered" /> 31 <xs:enumeration value="IsJobStillNeeded_JobDoesNotExist" /> 32 <xs:enumeration value="IsJobStillNeeded_JobAlreadyFinished" /> 33 <xs:enumeration value="GetPlugins_PluginsNotAvailable" /> 34 <xs:enumeration value="AddClientGroup_SlaveIdMustNotBeSet" /> 35 <xs:enumeration value="AddResourceToGroup_SlaveGroupDoesNotExist" /> 36 <xs:enumeration value="DeleteResourceFromGroup_SlaveGroupDoesNotExist" /> 37 <xs:enumeration value="GetAllGroupsOfResource_ResourceNotFound" /> 38 <xs:enumeration value="DeleteClientGroup_SlaveGroupDoesNotExist" /> 39 </xs:restriction> 40 </xs:simpleType> 41 <xs:element name="ResponseStatus" nillable="true" type="tns:ResponseStatus" /> 23 42 <xs:complexType name="ArrayOfMessageContainer"> 24 43 <xs:sequence> … … 50 69 </xs:simpleType> 51 70 <xs:element name="MessageContainer.MessageType" nillable="true" type="tns:MessageContainer.MessageType" /> 52 <xs:complexType name="ResponseObjectOfJobDtoZAa7YIsz">53 <xs:annotation>54 <xs:appinfo>55 <GenericType Name="ResponseObjectOf{0}{#}" Namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts" xmlns="http://schemas.microsoft.com/2003/10/Serialization/">56 <GenericParameter Name="JobDto" Namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.BusinessObjects">57 </GenericParameter>58 </GenericType>59 </xs:appinfo>60 </xs:annotation>61 <xs:complexContent mixed="false">62 <xs:extension base="tns:Response">63 <xs:sequence>64 <xs:element xmlns:q1="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.BusinessObjects" minOccurs="0" name="Obj" nillable="true" type="q1:JobDto" />65 </xs:sequence>66 </xs:extension>67 </xs:complexContent>68 </xs:complexType>69 <xs:element name="ResponseObjectOfJobDtoZAa7YIsz" nillable="true" type="tns:ResponseObjectOfJobDtoZAa7YIsz" />70 <xs:complexType name="ResponseResultReceived">71 <xs:complexContent mixed="false">72 <xs:extension base="tns:Response">73 <xs:sequence>74 <xs:element minOccurs="0" name="Finished" type="xs:boolean" />75 <xs:element minOccurs="0" name="JobId" type="ser:guid" />76 </xs:sequence>77 </xs:extension>78 </xs:complexContent>79 </xs:complexType>80 <xs:element name="ResponseResultReceived" nillable="true" type="tns:ResponseResultReceived" />81 <xs:complexType name="ResponseListOfCachedHivePluginInfoDtoZMwZop09">82 <xs:annotation>83 <xs:appinfo>84 <GenericType Name="ResponseListOf{0}{#}" Namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts" xmlns="http://schemas.microsoft.com/2003/10/Serialization/">85 <GenericParameter Name="CachedHivePluginInfoDto" Namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.PluginInfrastructure">86 </GenericParameter>87 </GenericType>88 </xs:appinfo>89 </xs:annotation>90 <xs:complexContent mixed="false">91 <xs:extension base="tns:Response">92 <xs:sequence>93 <xs:element xmlns:q2="http://schemas.datacontract.org/2004/07/HeuristicLab.PluginInfrastructure" minOccurs="0" name="List" nillable="true" type="q2:ArrayOfCachedHivePluginInfoDto" />94 </xs:sequence>95 </xs:extension>96 </xs:complexContent>97 </xs:complexType>98 <xs:element name="ResponseListOfCachedHivePluginInfoDtoZMwZop09" nillable="true" type="tns:ResponseListOfCachedHivePluginInfoDtoZMwZop09" />99 <xs:complexType name="ResponseCalendar">100 <xs:complexContent mixed="false">101 <xs:extension base="tns:Response">102 <xs:sequence>103 <xs:element xmlns:q3="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.BusinessObjects" minOccurs="0" name="Appointments" nillable="true" type="q3:ArrayOfAppointmentDto" />104 <xs:element minOccurs="0" name="ForceFetch" type="xs:boolean" />105 </xs:sequence>106 </xs:extension>107 </xs:complexContent>108 </xs:complexType>109 <xs:element name="ResponseCalendar" nillable="true" type="tns:ResponseCalendar" />110 71 </xs:schema> -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/ServerService/Reference.cs
r4254 r4263 17 17 18 18 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/Login", ReplyAction="http://tempuri.org/ISlaveCommunicator/LoginResponse")] 19 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response HeartBeat))]20 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>))]21 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response ResultReceived))]22 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>))]23 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response Calendar))]24 HeuristicLab.Hive.Contracts.Response Login(HeuristicLab.Hive.Contracts.BusinessObjects.ClientDto clientInfo);19 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat))] 20 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>))] 21 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived))] 22 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>))] 23 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar))] 24 HeuristicLab.Hive.Contracts.ResponseObjects.Response Login(HeuristicLab.Hive.Contracts.BusinessObjects.ClientDto clientInfo); 25 25 26 26 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/Login", ReplyAction="http://tempuri.org/ISlaveCommunicator/LoginResponse")] 27 27 System.IAsyncResult BeginLogin(HeuristicLab.Hive.Contracts.BusinessObjects.ClientDto clientInfo, System.AsyncCallback callback, object asyncState); 28 28 29 HeuristicLab.Hive.Contracts.Response EndLogin(System.IAsyncResult result);29 HeuristicLab.Hive.Contracts.ResponseObjects.Response EndLogin(System.IAsyncResult result); 30 30 31 31 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/ProcessHeartBeat", ReplyAction="http://tempuri.org/ISlaveCommunicator/ProcessHeartBeatResponse")] 32 HeuristicLab.Hive.Contracts.Response HeartBeat ProcessHeartBeat(HeuristicLab.Hive.Contracts.BusinessObjects.HeartBeatData hbData);32 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat ProcessHeartBeat(HeuristicLab.Hive.Contracts.BusinessObjects.HeartBeatData hbData); 33 33 34 34 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/ProcessHeartBeat", ReplyAction="http://tempuri.org/ISlaveCommunicator/ProcessHeartBeatResponse")] 35 35 System.IAsyncResult BeginProcessHeartBeat(HeuristicLab.Hive.Contracts.BusinessObjects.HeartBeatData hbData, System.AsyncCallback callback, object asyncState); 36 36 37 HeuristicLab.Hive.Contracts.Response HeartBeat EndProcessHeartBeat(System.IAsyncResult result);37 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat EndProcessHeartBeat(System.IAsyncResult result); 38 38 39 39 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/GetJob", ReplyAction="http://tempuri.org/ISlaveCommunicator/GetJobResponse")] 40 HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> GetJob(System.Guid clientId);40 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> GetJob(System.Guid clientId); 41 41 42 42 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/GetJob", ReplyAction="http://tempuri.org/ISlaveCommunicator/GetJobResponse")] 43 43 System.IAsyncResult BeginGetJob(System.Guid clientId, System.AsyncCallback callback, object asyncState); 44 44 45 HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> EndGetJob(System.IAsyncResult result);45 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> EndGetJob(System.IAsyncResult result); 46 46 47 47 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/StoreFinishedJobResult", ReplyAction="http://tempuri.org/ISlaveCommunicator/StoreFinishedJobResultResponse")] 48 HeuristicLab.Hive.Contracts.Response ResultReceived StoreFinishedJobResult(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception);48 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived StoreFinishedJobResult(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception); 49 49 50 50 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/StoreFinishedJobResult", ReplyAction="http://tempuri.org/ISlaveCommunicator/StoreFinishedJobResultResponse")] 51 51 System.IAsyncResult BeginStoreFinishedJobResult(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception, System.AsyncCallback callback, object asyncState); 52 52 53 HeuristicLab.Hive.Contracts.Response ResultReceived EndStoreFinishedJobResult(System.IAsyncResult result);53 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived EndStoreFinishedJobResult(System.IAsyncResult result); 54 54 55 55 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/ProcessSnapshot", ReplyAction="http://tempuri.org/ISlaveCommunicator/ProcessSnapshotResponse")] 56 HeuristicLab.Hive.Contracts.Response ResultReceived ProcessSnapshot(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception);56 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived ProcessSnapshot(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception); 57 57 58 58 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/ProcessSnapshot", ReplyAction="http://tempuri.org/ISlaveCommunicator/ProcessSnapshotResponse")] 59 59 System.IAsyncResult BeginProcessSnapshot(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception, System.AsyncCallback callback, object asyncState); 60 60 61 HeuristicLab.Hive.Contracts.Response ResultReceived EndProcessSnapshot(System.IAsyncResult result);61 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived EndProcessSnapshot(System.IAsyncResult result); 62 62 63 63 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/Logout", ReplyAction="http://tempuri.org/ISlaveCommunicator/LogoutResponse")] 64 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response HeartBeat))]65 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>))]66 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response ResultReceived))]67 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>))]68 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response Calendar))]69 HeuristicLab.Hive.Contracts.Response Logout(System.Guid clientId);64 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat))] 65 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>))] 66 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived))] 67 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>))] 68 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar))] 69 HeuristicLab.Hive.Contracts.ResponseObjects.Response Logout(System.Guid clientId); 70 70 71 71 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/Logout", ReplyAction="http://tempuri.org/ISlaveCommunicator/LogoutResponse")] 72 72 System.IAsyncResult BeginLogout(System.Guid clientId, System.AsyncCallback callback, object asyncState); 73 73 74 HeuristicLab.Hive.Contracts.Response EndLogout(System.IAsyncResult result);74 HeuristicLab.Hive.Contracts.ResponseObjects.Response EndLogout(System.IAsyncResult result); 75 75 76 76 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/IsJobStillNeeded", ReplyAction="http://tempuri.org/ISlaveCommunicator/IsJobStillNeededResponse")] 77 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response HeartBeat))]78 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>))]79 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response ResultReceived))]80 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>))]81 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response Calendar))]82 HeuristicLab.Hive.Contracts.Response IsJobStillNeeded(System.Guid jobId);77 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat))] 78 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>))] 79 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived))] 80 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>))] 81 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar))] 82 HeuristicLab.Hive.Contracts.ResponseObjects.Response IsJobStillNeeded(System.Guid jobId); 83 83 84 84 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/IsJobStillNeeded", ReplyAction="http://tempuri.org/ISlaveCommunicator/IsJobStillNeededResponse")] 85 85 System.IAsyncResult BeginIsJobStillNeeded(System.Guid jobId, System.AsyncCallback callback, object asyncState); 86 86 87 HeuristicLab.Hive.Contracts.Response EndIsJobStillNeeded(System.IAsyncResult result);88 89 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/ SendPlugins", ReplyAction="http://tempuri.org/ISlaveCommunicator/SendPluginsResponse")]90 HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> SendPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList);91 92 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/ SendPlugins", ReplyAction="http://tempuri.org/ISlaveCommunicator/SendPluginsResponse")]93 System.IAsyncResult Begin SendPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, System.AsyncCallback callback, object asyncState);94 95 HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> EndSendPlugins(System.IAsyncResult result);87 HeuristicLab.Hive.Contracts.ResponseObjects.Response EndIsJobStillNeeded(System.IAsyncResult result); 88 89 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/GetPlugins", ReplyAction="http://tempuri.org/ISlaveCommunicator/GetPluginsResponse")] 90 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> GetPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList); 91 92 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/GetPlugins", ReplyAction="http://tempuri.org/ISlaveCommunicator/GetPluginsResponse")] 93 System.IAsyncResult BeginGetPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, System.AsyncCallback callback, object asyncState); 94 95 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> EndGetPlugins(System.IAsyncResult result); 96 96 97 97 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/GetCalendar", ReplyAction="http://tempuri.org/ISlaveCommunicator/GetCalendarResponse")] 98 HeuristicLab.Hive.Contracts.Response Calendar GetCalendar(System.Guid clientId);98 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar GetCalendar(System.Guid clientId); 99 99 100 100 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/GetCalendar", ReplyAction="http://tempuri.org/ISlaveCommunicator/GetCalendarResponse")] 101 101 System.IAsyncResult BeginGetCalendar(System.Guid clientId, System.AsyncCallback callback, object asyncState); 102 102 103 HeuristicLab.Hive.Contracts.Response Calendar EndGetCalendar(System.IAsyncResult result);103 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar EndGetCalendar(System.IAsyncResult result); 104 104 105 105 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveCommunicator/SetCalendarStatus", ReplyAction="http://tempuri.org/ISlaveCommunicator/SetCalendarStatusResponse")] 106 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response HeartBeat))]107 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>))]108 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response ResultReceived))]109 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>))]110 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.Response Calendar))]111 HeuristicLab.Hive.Contracts.Response SetCalendarStatus(System.Guid clientId, HeuristicLab.Hive.Contracts.BusinessObjects.CalendarState state);106 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat))] 107 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>))] 108 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived))] 109 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>))] 110 [System.ServiceModel.ServiceKnownTypeAttribute(typeof(HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar))] 111 HeuristicLab.Hive.Contracts.ResponseObjects.Response SetCalendarStatus(System.Guid clientId, HeuristicLab.Hive.Contracts.BusinessObjects.CalendarState state); 112 112 113 113 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveCommunicator/SetCalendarStatus", ReplyAction="http://tempuri.org/ISlaveCommunicator/SetCalendarStatusResponse")] 114 114 System.IAsyncResult BeginSetCalendarStatus(System.Guid clientId, HeuristicLab.Hive.Contracts.BusinessObjects.CalendarState state, System.AsyncCallback callback, object asyncState); 115 115 116 HeuristicLab.Hive.Contracts.Response EndSetCalendarStatus(System.IAsyncResult result);117 118 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveFacade/ SendStreamedJob", ReplyAction="http://tempuri.org/ISlaveFacade/SendStreamedJobResponse")]119 System.IO.Stream SendStreamedJob(System.Guid clientId);120 121 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveFacade/ SendStreamedJob", ReplyAction="http://tempuri.org/ISlaveFacade/SendStreamedJobResponse")]122 System.IAsyncResult Begin SendStreamedJob(System.Guid clientId, System.AsyncCallback callback, object asyncState);123 124 System.IO.Stream End SendStreamedJob(System.IAsyncResult result);125 126 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveFacade/ SendStreamedPlugins", ReplyAction="http://tempuri.org/ISlaveFacade/SendStreamedPluginsResponse")]127 System.IO.Stream SendStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList);128 129 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveFacade/ SendStreamedPlugins", ReplyAction="http://tempuri.org/ISlaveFacade/SendStreamedPluginsResponse")]130 System.IAsyncResult Begin SendStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, System.AsyncCallback callback, object asyncState);131 132 System.IO.Stream End SendStreamedPlugins(System.IAsyncResult result);116 HeuristicLab.Hive.Contracts.ResponseObjects.Response EndSetCalendarStatus(System.IAsyncResult result); 117 118 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveFacade/GetStreamedJob", ReplyAction="http://tempuri.org/ISlaveFacade/GetStreamedJobResponse")] 119 System.IO.Stream GetStreamedJob(System.Guid clientId); 120 121 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveFacade/GetStreamedJob", ReplyAction="http://tempuri.org/ISlaveFacade/GetStreamedJobResponse")] 122 System.IAsyncResult BeginGetStreamedJob(System.Guid clientId, System.AsyncCallback callback, object asyncState); 123 124 System.IO.Stream EndGetStreamedJob(System.IAsyncResult result); 125 126 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveFacade/GetStreamedPlugins", ReplyAction="http://tempuri.org/ISlaveFacade/GetStreamedPluginsResponse")] 127 System.IO.Stream GetStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList); 128 129 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveFacade/GetStreamedPlugins", ReplyAction="http://tempuri.org/ISlaveFacade/GetStreamedPluginsResponse")] 130 System.IAsyncResult BeginGetStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, System.AsyncCallback callback, object asyncState); 131 132 System.IO.Stream EndGetStreamedPlugins(System.IAsyncResult result); 133 133 134 134 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveFacade/StoreFinishedJobResultStreamed", ReplyAction="http://tempuri.org/ISlaveFacade/StoreFinishedJobResultStreamedResponse")] 135 HeuristicLab.Hive.Contracts.Response ResultReceived StoreFinishedJobResultStreamed(System.IO.Stream stream);135 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived StoreFinishedJobResultStreamed(System.IO.Stream stream); 136 136 137 137 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveFacade/StoreFinishedJobResultStreamed", ReplyAction="http://tempuri.org/ISlaveFacade/StoreFinishedJobResultStreamedResponse")] 138 138 System.IAsyncResult BeginStoreFinishedJobResultStreamed(System.IO.Stream stream, System.AsyncCallback callback, object asyncState); 139 139 140 HeuristicLab.Hive.Contracts.Response ResultReceived EndStoreFinishedJobResultStreamed(System.IAsyncResult result);140 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived EndStoreFinishedJobResultStreamed(System.IAsyncResult result); 141 141 142 142 [System.ServiceModel.OperationContractAttribute(Action="http://tempuri.org/ISlaveFacade/ProcessSnapshotStreamed", ReplyAction="http://tempuri.org/ISlaveFacade/ProcessSnapshotStreamedResponse")] 143 HeuristicLab.Hive.Contracts.Response ResultReceived ProcessSnapshotStreamed(System.IO.Stream stream);143 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived ProcessSnapshotStreamed(System.IO.Stream stream); 144 144 145 145 [System.ServiceModel.OperationContractAttribute(AsyncPattern=true, Action="http://tempuri.org/ISlaveFacade/ProcessSnapshotStreamed", ReplyAction="http://tempuri.org/ISlaveFacade/ProcessSnapshotStreamedResponse")] 146 146 System.IAsyncResult BeginProcessSnapshotStreamed(System.IO.Stream stream, System.AsyncCallback callback, object asyncState); 147 147 148 HeuristicLab.Hive.Contracts.Response ResultReceived EndProcessSnapshotStreamed(System.IAsyncResult result);148 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived EndProcessSnapshotStreamed(System.IAsyncResult result); 149 149 } 150 150 … … 164 164 } 165 165 166 public HeuristicLab.Hive.Contracts.Response Result {167 get { 168 base.RaiseExceptionIfNecessary(); 169 return ((HeuristicLab.Hive.Contracts.Response )(this.results[0]));166 public HeuristicLab.Hive.Contracts.ResponseObjects.Response Result { 167 get { 168 base.RaiseExceptionIfNecessary(); 169 return ((HeuristicLab.Hive.Contracts.ResponseObjects.Response)(this.results[0])); 170 170 } 171 171 } … … 183 183 } 184 184 185 public HeuristicLab.Hive.Contracts.Response HeartBeat Result {186 get { 187 base.RaiseExceptionIfNecessary(); 188 return ((HeuristicLab.Hive.Contracts.Response HeartBeat)(this.results[0]));185 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat Result { 186 get { 187 base.RaiseExceptionIfNecessary(); 188 return ((HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat)(this.results[0])); 189 189 } 190 190 } … … 202 202 } 203 203 204 public HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> Result {205 get { 206 base.RaiseExceptionIfNecessary(); 207 return ((HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>)(this.results[0]));204 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> Result { 205 get { 206 base.RaiseExceptionIfNecessary(); 207 return ((HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto>)(this.results[0])); 208 208 } 209 209 } … … 221 221 } 222 222 223 public HeuristicLab.Hive.Contracts.Response ResultReceived Result {224 get { 225 base.RaiseExceptionIfNecessary(); 226 return ((HeuristicLab.Hive.Contracts.Response ResultReceived)(this.results[0]));223 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived Result { 224 get { 225 base.RaiseExceptionIfNecessary(); 226 return ((HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived)(this.results[0])); 227 227 } 228 228 } … … 240 240 } 241 241 242 public HeuristicLab.Hive.Contracts.Response ResultReceived Result {243 get { 244 base.RaiseExceptionIfNecessary(); 245 return ((HeuristicLab.Hive.Contracts.Response ResultReceived)(this.results[0]));242 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived Result { 243 get { 244 base.RaiseExceptionIfNecessary(); 245 return ((HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived)(this.results[0])); 246 246 } 247 247 } … … 259 259 } 260 260 261 public HeuristicLab.Hive.Contracts.Response Result {262 get { 263 base.RaiseExceptionIfNecessary(); 264 return ((HeuristicLab.Hive.Contracts.Response )(this.results[0]));261 public HeuristicLab.Hive.Contracts.ResponseObjects.Response Result { 262 get { 263 base.RaiseExceptionIfNecessary(); 264 return ((HeuristicLab.Hive.Contracts.ResponseObjects.Response)(this.results[0])); 265 265 } 266 266 } … … 278 278 } 279 279 280 public HeuristicLab.Hive.Contracts.Response Result {281 get { 282 base.RaiseExceptionIfNecessary(); 283 return ((HeuristicLab.Hive.Contracts.Response )(this.results[0]));284 } 285 } 286 } 287 288 [System.Diagnostics.DebuggerStepThroughAttribute()] 289 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "4.0.0.0")] 290 public partial class SendPluginsCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs {291 292 private object[] results; 293 294 public SendPluginsCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) :295 base(exception, cancelled, userState) { 296 this.results = results; 297 } 298 299 public HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> Result {300 get { 301 base.RaiseExceptionIfNecessary(); 302 return ((HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>)(this.results[0]));280 public HeuristicLab.Hive.Contracts.ResponseObjects.Response Result { 281 get { 282 base.RaiseExceptionIfNecessary(); 283 return ((HeuristicLab.Hive.Contracts.ResponseObjects.Response)(this.results[0])); 284 } 285 } 286 } 287 288 [System.Diagnostics.DebuggerStepThroughAttribute()] 289 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "4.0.0.0")] 290 public partial class GetPluginsCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs { 291 292 private object[] results; 293 294 public GetPluginsCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) : 295 base(exception, cancelled, userState) { 296 this.results = results; 297 } 298 299 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> Result { 300 get { 301 base.RaiseExceptionIfNecessary(); 302 return ((HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto>)(this.results[0])); 303 303 } 304 304 } … … 316 316 } 317 317 318 public HeuristicLab.Hive.Contracts.Response Calendar Result {319 get { 320 base.RaiseExceptionIfNecessary(); 321 return ((HeuristicLab.Hive.Contracts.Response Calendar)(this.results[0]));318 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar Result { 319 get { 320 base.RaiseExceptionIfNecessary(); 321 return ((HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar)(this.results[0])); 322 322 } 323 323 } … … 335 335 } 336 336 337 public HeuristicLab.Hive.Contracts.Response Result {338 get { 339 base.RaiseExceptionIfNecessary(); 340 return ((HeuristicLab.Hive.Contracts.Response )(this.results[0]));341 } 342 } 343 } 344 345 [System.Diagnostics.DebuggerStepThroughAttribute()] 346 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "4.0.0.0")] 347 public partial class SendStreamedJobCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs {348 349 private object[] results; 350 351 public SendStreamedJobCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) :337 public HeuristicLab.Hive.Contracts.ResponseObjects.Response Result { 338 get { 339 base.RaiseExceptionIfNecessary(); 340 return ((HeuristicLab.Hive.Contracts.ResponseObjects.Response)(this.results[0])); 341 } 342 } 343 } 344 345 [System.Diagnostics.DebuggerStepThroughAttribute()] 346 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "4.0.0.0")] 347 public partial class GetStreamedJobCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs { 348 349 private object[] results; 350 351 public GetStreamedJobCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) : 352 352 base(exception, cancelled, userState) { 353 353 this.results = results; … … 364 364 [System.Diagnostics.DebuggerStepThroughAttribute()] 365 365 [System.CodeDom.Compiler.GeneratedCodeAttribute("System.ServiceModel", "4.0.0.0")] 366 public partial class SendStreamedPluginsCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs {367 368 private object[] results; 369 370 public SendStreamedPluginsCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) :366 public partial class GetStreamedPluginsCompletedEventArgs : System.ComponentModel.AsyncCompletedEventArgs { 367 368 private object[] results; 369 370 public GetStreamedPluginsCompletedEventArgs(object[] results, System.Exception exception, bool cancelled, object userState) : 371 371 base(exception, cancelled, userState) { 372 372 this.results = results; … … 392 392 } 393 393 394 public HeuristicLab.Hive.Contracts.Response ResultReceived Result {395 get { 396 base.RaiseExceptionIfNecessary(); 397 return ((HeuristicLab.Hive.Contracts.Response ResultReceived)(this.results[0]));394 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived Result { 395 get { 396 base.RaiseExceptionIfNecessary(); 397 return ((HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived)(this.results[0])); 398 398 } 399 399 } … … 411 411 } 412 412 413 public HeuristicLab.Hive.Contracts.Response ResultReceived Result {414 get { 415 base.RaiseExceptionIfNecessary(); 416 return ((HeuristicLab.Hive.Contracts.Response ResultReceived)(this.results[0]));413 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived Result { 414 get { 415 base.RaiseExceptionIfNecessary(); 416 return ((HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived)(this.results[0])); 417 417 } 418 418 } … … 465 465 private System.Threading.SendOrPostCallback onIsJobStillNeededCompletedDelegate; 466 466 467 private BeginOperationDelegate onBegin SendPluginsDelegate;468 469 private EndOperationDelegate onEnd SendPluginsDelegate;470 471 private System.Threading.SendOrPostCallback on SendPluginsCompletedDelegate;467 private BeginOperationDelegate onBeginGetPluginsDelegate; 468 469 private EndOperationDelegate onEndGetPluginsDelegate; 470 471 private System.Threading.SendOrPostCallback onGetPluginsCompletedDelegate; 472 472 473 473 private BeginOperationDelegate onBeginGetCalendarDelegate; … … 483 483 private System.Threading.SendOrPostCallback onSetCalendarStatusCompletedDelegate; 484 484 485 private BeginOperationDelegate onBegin SendStreamedJobDelegate;486 487 private EndOperationDelegate onEnd SendStreamedJobDelegate;488 489 private System.Threading.SendOrPostCallback on SendStreamedJobCompletedDelegate;490 491 private BeginOperationDelegate onBegin SendStreamedPluginsDelegate;492 493 private EndOperationDelegate onEnd SendStreamedPluginsDelegate;494 495 private System.Threading.SendOrPostCallback on SendStreamedPluginsCompletedDelegate;485 private BeginOperationDelegate onBeginGetStreamedJobDelegate; 486 487 private EndOperationDelegate onEndGetStreamedJobDelegate; 488 489 private System.Threading.SendOrPostCallback onGetStreamedJobCompletedDelegate; 490 491 private BeginOperationDelegate onBeginGetStreamedPluginsDelegate; 492 493 private EndOperationDelegate onEndGetStreamedPluginsDelegate; 494 495 private System.Threading.SendOrPostCallback onGetStreamedPluginsCompletedDelegate; 496 496 497 497 private BeginOperationDelegate onBeginStoreFinishedJobResultStreamedDelegate; … … 540 540 public event System.EventHandler<IsJobStillNeededCompletedEventArgs> IsJobStillNeededCompleted; 541 541 542 public event System.EventHandler< SendPluginsCompletedEventArgs> SendPluginsCompleted;542 public event System.EventHandler<GetPluginsCompletedEventArgs> GetPluginsCompleted; 543 543 544 544 public event System.EventHandler<GetCalendarCompletedEventArgs> GetCalendarCompleted; … … 546 546 public event System.EventHandler<SetCalendarStatusCompletedEventArgs> SetCalendarStatusCompleted; 547 547 548 public event System.EventHandler< SendStreamedJobCompletedEventArgs> SendStreamedJobCompleted;549 550 public event System.EventHandler< SendStreamedPluginsCompletedEventArgs> SendStreamedPluginsCompleted;548 public event System.EventHandler<GetStreamedJobCompletedEventArgs> GetStreamedJobCompleted; 549 550 public event System.EventHandler<GetStreamedPluginsCompletedEventArgs> GetStreamedPluginsCompleted; 551 551 552 552 public event System.EventHandler<StoreFinishedJobResultStreamedCompletedEventArgs> StoreFinishedJobResultStreamedCompleted; … … 554 554 public event System.EventHandler<ProcessSnapshotStreamedCompletedEventArgs> ProcessSnapshotStreamedCompleted; 555 555 556 public HeuristicLab.Hive.Contracts.Response Login(HeuristicLab.Hive.Contracts.BusinessObjects.ClientDto clientInfo) {556 public HeuristicLab.Hive.Contracts.ResponseObjects.Response Login(HeuristicLab.Hive.Contracts.BusinessObjects.ClientDto clientInfo) { 557 557 return base.Channel.Login(clientInfo); 558 558 } … … 564 564 565 565 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 566 public HeuristicLab.Hive.Contracts.Response EndLogin(System.IAsyncResult result) {566 public HeuristicLab.Hive.Contracts.ResponseObjects.Response EndLogin(System.IAsyncResult result) { 567 567 return base.Channel.EndLogin(result); 568 568 } … … 574 574 575 575 private object[] OnEndLogin(System.IAsyncResult result) { 576 HeuristicLab.Hive.Contracts.Response retVal = this.EndLogin(result);576 HeuristicLab.Hive.Contracts.ResponseObjects.Response retVal = this.EndLogin(result); 577 577 return new object[] { 578 578 retVal}; … … 604 604 } 605 605 606 public HeuristicLab.Hive.Contracts.Response HeartBeat ProcessHeartBeat(HeuristicLab.Hive.Contracts.BusinessObjects.HeartBeatData hbData) {606 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat ProcessHeartBeat(HeuristicLab.Hive.Contracts.BusinessObjects.HeartBeatData hbData) { 607 607 return base.Channel.ProcessHeartBeat(hbData); 608 608 } … … 614 614 615 615 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 616 public HeuristicLab.Hive.Contracts.Response HeartBeat EndProcessHeartBeat(System.IAsyncResult result) {616 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat EndProcessHeartBeat(System.IAsyncResult result) { 617 617 return base.Channel.EndProcessHeartBeat(result); 618 618 } … … 624 624 625 625 private object[] OnEndProcessHeartBeat(System.IAsyncResult result) { 626 HeuristicLab.Hive.Contracts.Response HeartBeat retVal = this.EndProcessHeartBeat(result);626 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseHeartBeat retVal = this.EndProcessHeartBeat(result); 627 627 return new object[] { 628 628 retVal}; … … 654 654 } 655 655 656 public HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> GetJob(System.Guid clientId) {656 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> GetJob(System.Guid clientId) { 657 657 return base.Channel.GetJob(clientId); 658 658 } … … 664 664 665 665 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 666 public HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> EndGetJob(System.IAsyncResult result) {666 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> EndGetJob(System.IAsyncResult result) { 667 667 return base.Channel.EndGetJob(result); 668 668 } … … 674 674 675 675 private object[] OnEndGetJob(System.IAsyncResult result) { 676 HeuristicLab.Hive.Contracts.ResponseObject <HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> retVal = this.EndGetJob(result);676 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseObject<HeuristicLab.Hive.Contracts.BusinessObjects.JobDto> retVal = this.EndGetJob(result); 677 677 return new object[] { 678 678 retVal}; … … 704 704 } 705 705 706 public HeuristicLab.Hive.Contracts.Response ResultReceived StoreFinishedJobResult(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception) {706 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived StoreFinishedJobResult(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception) { 707 707 return base.Channel.StoreFinishedJobResult(clientId, jobId, result, percentage, exception); 708 708 } … … 714 714 715 715 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 716 public HeuristicLab.Hive.Contracts.Response ResultReceived EndStoreFinishedJobResult(System.IAsyncResult result) {716 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived EndStoreFinishedJobResult(System.IAsyncResult result) { 717 717 return base.Channel.EndStoreFinishedJobResult(result); 718 718 } … … 728 728 729 729 private object[] OnEndStoreFinishedJobResult(System.IAsyncResult result) { 730 HeuristicLab.Hive.Contracts.Response ResultReceived retVal = this.EndStoreFinishedJobResult(result);730 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived retVal = this.EndStoreFinishedJobResult(result); 731 731 return new object[] { 732 732 retVal}; … … 762 762 } 763 763 764 public HeuristicLab.Hive.Contracts.Response ResultReceived ProcessSnapshot(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception) {764 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived ProcessSnapshot(System.Guid clientId, System.Guid jobId, byte[] result, double percentage, string exception) { 765 765 return base.Channel.ProcessSnapshot(clientId, jobId, result, percentage, exception); 766 766 } … … 772 772 773 773 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 774 public HeuristicLab.Hive.Contracts.Response ResultReceived EndProcessSnapshot(System.IAsyncResult result) {774 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived EndProcessSnapshot(System.IAsyncResult result) { 775 775 return base.Channel.EndProcessSnapshot(result); 776 776 } … … 786 786 787 787 private object[] OnEndProcessSnapshot(System.IAsyncResult result) { 788 HeuristicLab.Hive.Contracts.Response ResultReceived retVal = this.EndProcessSnapshot(result);788 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived retVal = this.EndProcessSnapshot(result); 789 789 return new object[] { 790 790 retVal}; … … 820 820 } 821 821 822 public HeuristicLab.Hive.Contracts.Response Logout(System.Guid clientId) {822 public HeuristicLab.Hive.Contracts.ResponseObjects.Response Logout(System.Guid clientId) { 823 823 return base.Channel.Logout(clientId); 824 824 } … … 830 830 831 831 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 832 public HeuristicLab.Hive.Contracts.Response EndLogout(System.IAsyncResult result) {832 public HeuristicLab.Hive.Contracts.ResponseObjects.Response EndLogout(System.IAsyncResult result) { 833 833 return base.Channel.EndLogout(result); 834 834 } … … 840 840 841 841 private object[] OnEndLogout(System.IAsyncResult result) { 842 HeuristicLab.Hive.Contracts.Response retVal = this.EndLogout(result);842 HeuristicLab.Hive.Contracts.ResponseObjects.Response retVal = this.EndLogout(result); 843 843 return new object[] { 844 844 retVal}; … … 870 870 } 871 871 872 public HeuristicLab.Hive.Contracts.Response IsJobStillNeeded(System.Guid jobId) {872 public HeuristicLab.Hive.Contracts.ResponseObjects.Response IsJobStillNeeded(System.Guid jobId) { 873 873 return base.Channel.IsJobStillNeeded(jobId); 874 874 } … … 880 880 881 881 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 882 public HeuristicLab.Hive.Contracts.Response EndIsJobStillNeeded(System.IAsyncResult result) {882 public HeuristicLab.Hive.Contracts.ResponseObjects.Response EndIsJobStillNeeded(System.IAsyncResult result) { 883 883 return base.Channel.EndIsJobStillNeeded(result); 884 884 } … … 890 890 891 891 private object[] OnEndIsJobStillNeeded(System.IAsyncResult result) { 892 HeuristicLab.Hive.Contracts.Response retVal = this.EndIsJobStillNeeded(result);892 HeuristicLab.Hive.Contracts.ResponseObjects.Response retVal = this.EndIsJobStillNeeded(result); 893 893 return new object[] { 894 894 retVal}; … … 920 920 } 921 921 922 public HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> SendPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList) {923 return base.Channel. SendPlugins(pluginList);924 } 925 926 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 927 public System.IAsyncResult Begin SendPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, System.AsyncCallback callback, object asyncState) {928 return base.Channel.Begin SendPlugins(pluginList, callback, asyncState);929 } 930 931 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 932 public HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> EndSendPlugins(System.IAsyncResult result) {933 return base.Channel.End SendPlugins(result);934 } 935 936 private System.IAsyncResult OnBegin SendPlugins(object[] inValues, System.AsyncCallback callback, object asyncState) {922 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> GetPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList) { 923 return base.Channel.GetPlugins(pluginList); 924 } 925 926 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 927 public System.IAsyncResult BeginGetPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, System.AsyncCallback callback, object asyncState) { 928 return base.Channel.BeginGetPlugins(pluginList, callback, asyncState); 929 } 930 931 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 932 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> EndGetPlugins(System.IAsyncResult result) { 933 return base.Channel.EndGetPlugins(result); 934 } 935 936 private System.IAsyncResult OnBeginGetPlugins(object[] inValues, System.AsyncCallback callback, object asyncState) { 937 937 HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList = ((HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[])(inValues[0])); 938 return this.Begin SendPlugins(pluginList, callback, asyncState);939 } 940 941 private object[] OnEnd SendPlugins(System.IAsyncResult result) {942 HeuristicLab.Hive.Contracts.Response List<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> retVal = this.EndSendPlugins(result);943 return new object[] { 944 retVal}; 945 } 946 947 private void On SendPluginsCompleted(object state) {948 if ((this. SendPluginsCompleted != null)) {949 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 950 this. SendPluginsCompleted(this, new SendPluginsCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState));951 } 952 } 953 954 public void SendPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList) {955 this. SendPluginsAsync(pluginList, null);956 } 957 958 public void SendPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, object userState) {959 if ((this.onBegin SendPluginsDelegate == null)) {960 this.onBegin SendPluginsDelegate = new BeginOperationDelegate(this.OnBeginSendPlugins);961 } 962 if ((this.onEnd SendPluginsDelegate == null)) {963 this.onEnd SendPluginsDelegate = new EndOperationDelegate(this.OnEndSendPlugins);964 } 965 if ((this.on SendPluginsCompletedDelegate == null)) {966 this.on SendPluginsCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnSendPluginsCompleted);967 } 968 base.InvokeAsync(this.onBegin SendPluginsDelegate, new object[] {969 pluginList}, this.onEnd SendPluginsDelegate, this.onSendPluginsCompletedDelegate, userState);970 } 971 972 public HeuristicLab.Hive.Contracts.Response Calendar GetCalendar(System.Guid clientId) {938 return this.BeginGetPlugins(pluginList, callback, asyncState); 939 } 940 941 private object[] OnEndGetPlugins(System.IAsyncResult result) { 942 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseList<HeuristicLab.PluginInfrastructure.CachedHivePluginInfoDto> retVal = this.EndGetPlugins(result); 943 return new object[] { 944 retVal}; 945 } 946 947 private void OnGetPluginsCompleted(object state) { 948 if ((this.GetPluginsCompleted != null)) { 949 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 950 this.GetPluginsCompleted(this, new GetPluginsCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState)); 951 } 952 } 953 954 public void GetPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList) { 955 this.GetPluginsAsync(pluginList, null); 956 } 957 958 public void GetPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, object userState) { 959 if ((this.onBeginGetPluginsDelegate == null)) { 960 this.onBeginGetPluginsDelegate = new BeginOperationDelegate(this.OnBeginGetPlugins); 961 } 962 if ((this.onEndGetPluginsDelegate == null)) { 963 this.onEndGetPluginsDelegate = new EndOperationDelegate(this.OnEndGetPlugins); 964 } 965 if ((this.onGetPluginsCompletedDelegate == null)) { 966 this.onGetPluginsCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnGetPluginsCompleted); 967 } 968 base.InvokeAsync(this.onBeginGetPluginsDelegate, new object[] { 969 pluginList}, this.onEndGetPluginsDelegate, this.onGetPluginsCompletedDelegate, userState); 970 } 971 972 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar GetCalendar(System.Guid clientId) { 973 973 return base.Channel.GetCalendar(clientId); 974 974 } … … 980 980 981 981 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 982 public HeuristicLab.Hive.Contracts.Response Calendar EndGetCalendar(System.IAsyncResult result) {982 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar EndGetCalendar(System.IAsyncResult result) { 983 983 return base.Channel.EndGetCalendar(result); 984 984 } … … 990 990 991 991 private object[] OnEndGetCalendar(System.IAsyncResult result) { 992 HeuristicLab.Hive.Contracts.Response Calendar retVal = this.EndGetCalendar(result);992 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseCalendar retVal = this.EndGetCalendar(result); 993 993 return new object[] { 994 994 retVal}; … … 1020 1020 } 1021 1021 1022 public HeuristicLab.Hive.Contracts.Response SetCalendarStatus(System.Guid clientId, HeuristicLab.Hive.Contracts.BusinessObjects.CalendarState state) {1022 public HeuristicLab.Hive.Contracts.ResponseObjects.Response SetCalendarStatus(System.Guid clientId, HeuristicLab.Hive.Contracts.BusinessObjects.CalendarState state) { 1023 1023 return base.Channel.SetCalendarStatus(clientId, state); 1024 1024 } … … 1030 1030 1031 1031 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1032 public HeuristicLab.Hive.Contracts.Response EndSetCalendarStatus(System.IAsyncResult result) {1032 public HeuristicLab.Hive.Contracts.ResponseObjects.Response EndSetCalendarStatus(System.IAsyncResult result) { 1033 1033 return base.Channel.EndSetCalendarStatus(result); 1034 1034 } … … 1041 1041 1042 1042 private object[] OnEndSetCalendarStatus(System.IAsyncResult result) { 1043 HeuristicLab.Hive.Contracts.Response retVal = this.EndSetCalendarStatus(result);1043 HeuristicLab.Hive.Contracts.ResponseObjects.Response retVal = this.EndSetCalendarStatus(result); 1044 1044 return new object[] { 1045 1045 retVal}; … … 1072 1072 } 1073 1073 1074 public System.IO.Stream SendStreamedJob(System.Guid clientId) {1075 return base.Channel. SendStreamedJob(clientId);1076 } 1077 1078 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1079 public System.IAsyncResult Begin SendStreamedJob(System.Guid clientId, System.AsyncCallback callback, object asyncState) {1080 return base.Channel.Begin SendStreamedJob(clientId, callback, asyncState);1081 } 1082 1083 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1084 public System.IO.Stream End SendStreamedJob(System.IAsyncResult result) {1085 return base.Channel.End SendStreamedJob(result);1086 } 1087 1088 private System.IAsyncResult OnBegin SendStreamedJob(object[] inValues, System.AsyncCallback callback, object asyncState) {1074 public System.IO.Stream GetStreamedJob(System.Guid clientId) { 1075 return base.Channel.GetStreamedJob(clientId); 1076 } 1077 1078 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1079 public System.IAsyncResult BeginGetStreamedJob(System.Guid clientId, System.AsyncCallback callback, object asyncState) { 1080 return base.Channel.BeginGetStreamedJob(clientId, callback, asyncState); 1081 } 1082 1083 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1084 public System.IO.Stream EndGetStreamedJob(System.IAsyncResult result) { 1085 return base.Channel.EndGetStreamedJob(result); 1086 } 1087 1088 private System.IAsyncResult OnBeginGetStreamedJob(object[] inValues, System.AsyncCallback callback, object asyncState) { 1089 1089 System.Guid clientId = ((System.Guid)(inValues[0])); 1090 return this.Begin SendStreamedJob(clientId, callback, asyncState);1091 } 1092 1093 private object[] OnEnd SendStreamedJob(System.IAsyncResult result) {1094 System.IO.Stream retVal = this.End SendStreamedJob(result);1095 return new object[] { 1096 retVal}; 1097 } 1098 1099 private void On SendStreamedJobCompleted(object state) {1100 if ((this. SendStreamedJobCompleted != null)) {1101 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 1102 this. SendStreamedJobCompleted(this, new SendStreamedJobCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState));1103 } 1104 } 1105 1106 public void SendStreamedJobAsync(System.Guid clientId) {1107 this. SendStreamedJobAsync(clientId, null);1108 } 1109 1110 public void SendStreamedJobAsync(System.Guid clientId, object userState) {1111 if ((this.onBegin SendStreamedJobDelegate == null)) {1112 this.onBegin SendStreamedJobDelegate = new BeginOperationDelegate(this.OnBeginSendStreamedJob);1113 } 1114 if ((this.onEnd SendStreamedJobDelegate == null)) {1115 this.onEnd SendStreamedJobDelegate = new EndOperationDelegate(this.OnEndSendStreamedJob);1116 } 1117 if ((this.on SendStreamedJobCompletedDelegate == null)) {1118 this.on SendStreamedJobCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnSendStreamedJobCompleted);1119 } 1120 base.InvokeAsync(this.onBegin SendStreamedJobDelegate, new object[] {1121 clientId}, this.onEnd SendStreamedJobDelegate, this.onSendStreamedJobCompletedDelegate, userState);1122 } 1123 1124 public System.IO.Stream SendStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList) {1125 return base.Channel. SendStreamedPlugins(pluginList);1126 } 1127 1128 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1129 public System.IAsyncResult Begin SendStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, System.AsyncCallback callback, object asyncState) {1130 return base.Channel.Begin SendStreamedPlugins(pluginList, callback, asyncState);1131 } 1132 1133 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1134 public System.IO.Stream End SendStreamedPlugins(System.IAsyncResult result) {1135 return base.Channel.End SendStreamedPlugins(result);1136 } 1137 1138 private System.IAsyncResult OnBegin SendStreamedPlugins(object[] inValues, System.AsyncCallback callback, object asyncState) {1090 return this.BeginGetStreamedJob(clientId, callback, asyncState); 1091 } 1092 1093 private object[] OnEndGetStreamedJob(System.IAsyncResult result) { 1094 System.IO.Stream retVal = this.EndGetStreamedJob(result); 1095 return new object[] { 1096 retVal}; 1097 } 1098 1099 private void OnGetStreamedJobCompleted(object state) { 1100 if ((this.GetStreamedJobCompleted != null)) { 1101 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 1102 this.GetStreamedJobCompleted(this, new GetStreamedJobCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState)); 1103 } 1104 } 1105 1106 public void GetStreamedJobAsync(System.Guid clientId) { 1107 this.GetStreamedJobAsync(clientId, null); 1108 } 1109 1110 public void GetStreamedJobAsync(System.Guid clientId, object userState) { 1111 if ((this.onBeginGetStreamedJobDelegate == null)) { 1112 this.onBeginGetStreamedJobDelegate = new BeginOperationDelegate(this.OnBeginGetStreamedJob); 1113 } 1114 if ((this.onEndGetStreamedJobDelegate == null)) { 1115 this.onEndGetStreamedJobDelegate = new EndOperationDelegate(this.OnEndGetStreamedJob); 1116 } 1117 if ((this.onGetStreamedJobCompletedDelegate == null)) { 1118 this.onGetStreamedJobCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnGetStreamedJobCompleted); 1119 } 1120 base.InvokeAsync(this.onBeginGetStreamedJobDelegate, new object[] { 1121 clientId}, this.onEndGetStreamedJobDelegate, this.onGetStreamedJobCompletedDelegate, userState); 1122 } 1123 1124 public System.IO.Stream GetStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList) { 1125 return base.Channel.GetStreamedPlugins(pluginList); 1126 } 1127 1128 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1129 public System.IAsyncResult BeginGetStreamedPlugins(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, System.AsyncCallback callback, object asyncState) { 1130 return base.Channel.BeginGetStreamedPlugins(pluginList, callback, asyncState); 1131 } 1132 1133 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1134 public System.IO.Stream EndGetStreamedPlugins(System.IAsyncResult result) { 1135 return base.Channel.EndGetStreamedPlugins(result); 1136 } 1137 1138 private System.IAsyncResult OnBeginGetStreamedPlugins(object[] inValues, System.AsyncCallback callback, object asyncState) { 1139 1139 HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList = ((HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[])(inValues[0])); 1140 return this.Begin SendStreamedPlugins(pluginList, callback, asyncState);1141 } 1142 1143 private object[] OnEnd SendStreamedPlugins(System.IAsyncResult result) {1144 System.IO.Stream retVal = this.End SendStreamedPlugins(result);1145 return new object[] { 1146 retVal}; 1147 } 1148 1149 private void On SendStreamedPluginsCompleted(object state) {1150 if ((this. SendStreamedPluginsCompleted != null)) {1151 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 1152 this. SendStreamedPluginsCompleted(this, new SendStreamedPluginsCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState));1153 } 1154 } 1155 1156 public void SendStreamedPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList) {1157 this. SendStreamedPluginsAsync(pluginList, null);1158 } 1159 1160 public void SendStreamedPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, object userState) {1161 if ((this.onBegin SendStreamedPluginsDelegate == null)) {1162 this.onBegin SendStreamedPluginsDelegate = new BeginOperationDelegate(this.OnBeginSendStreamedPlugins);1163 } 1164 if ((this.onEnd SendStreamedPluginsDelegate == null)) {1165 this.onEnd SendStreamedPluginsDelegate = new EndOperationDelegate(this.OnEndSendStreamedPlugins);1166 } 1167 if ((this.on SendStreamedPluginsCompletedDelegate == null)) {1168 this.on SendStreamedPluginsCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnSendStreamedPluginsCompleted);1169 } 1170 base.InvokeAsync(this.onBegin SendStreamedPluginsDelegate, new object[] {1171 pluginList}, this.onEnd SendStreamedPluginsDelegate, this.onSendStreamedPluginsCompletedDelegate, userState);1172 } 1173 1174 public HeuristicLab.Hive.Contracts.Response ResultReceived StoreFinishedJobResultStreamed(System.IO.Stream stream) {1140 return this.BeginGetStreamedPlugins(pluginList, callback, asyncState); 1141 } 1142 1143 private object[] OnEndGetStreamedPlugins(System.IAsyncResult result) { 1144 System.IO.Stream retVal = this.EndGetStreamedPlugins(result); 1145 return new object[] { 1146 retVal}; 1147 } 1148 1149 private void OnGetStreamedPluginsCompleted(object state) { 1150 if ((this.GetStreamedPluginsCompleted != null)) { 1151 InvokeAsyncCompletedEventArgs e = ((InvokeAsyncCompletedEventArgs)(state)); 1152 this.GetStreamedPluginsCompleted(this, new GetStreamedPluginsCompletedEventArgs(e.Results, e.Error, e.Cancelled, e.UserState)); 1153 } 1154 } 1155 1156 public void GetStreamedPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList) { 1157 this.GetStreamedPluginsAsync(pluginList, null); 1158 } 1159 1160 public void GetStreamedPluginsAsync(HeuristicLab.Hive.Contracts.BusinessObjects.HivePluginInfoDto[] pluginList, object userState) { 1161 if ((this.onBeginGetStreamedPluginsDelegate == null)) { 1162 this.onBeginGetStreamedPluginsDelegate = new BeginOperationDelegate(this.OnBeginGetStreamedPlugins); 1163 } 1164 if ((this.onEndGetStreamedPluginsDelegate == null)) { 1165 this.onEndGetStreamedPluginsDelegate = new EndOperationDelegate(this.OnEndGetStreamedPlugins); 1166 } 1167 if ((this.onGetStreamedPluginsCompletedDelegate == null)) { 1168 this.onGetStreamedPluginsCompletedDelegate = new System.Threading.SendOrPostCallback(this.OnGetStreamedPluginsCompleted); 1169 } 1170 base.InvokeAsync(this.onBeginGetStreamedPluginsDelegate, new object[] { 1171 pluginList}, this.onEndGetStreamedPluginsDelegate, this.onGetStreamedPluginsCompletedDelegate, userState); 1172 } 1173 1174 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived StoreFinishedJobResultStreamed(System.IO.Stream stream) { 1175 1175 return base.Channel.StoreFinishedJobResultStreamed(stream); 1176 1176 } … … 1182 1182 1183 1183 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1184 public HeuristicLab.Hive.Contracts.Response ResultReceived EndStoreFinishedJobResultStreamed(System.IAsyncResult result) {1184 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived EndStoreFinishedJobResultStreamed(System.IAsyncResult result) { 1185 1185 return base.Channel.EndStoreFinishedJobResultStreamed(result); 1186 1186 } … … 1192 1192 1193 1193 private object[] OnEndStoreFinishedJobResultStreamed(System.IAsyncResult result) { 1194 HeuristicLab.Hive.Contracts.Response ResultReceived retVal = this.EndStoreFinishedJobResultStreamed(result);1194 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived retVal = this.EndStoreFinishedJobResultStreamed(result); 1195 1195 return new object[] { 1196 1196 retVal}; … … 1222 1222 } 1223 1223 1224 public HeuristicLab.Hive.Contracts.Response ResultReceived ProcessSnapshotStreamed(System.IO.Stream stream) {1224 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived ProcessSnapshotStreamed(System.IO.Stream stream) { 1225 1225 return base.Channel.ProcessSnapshotStreamed(stream); 1226 1226 } … … 1232 1232 1233 1233 [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Advanced)] 1234 public HeuristicLab.Hive.Contracts.Response ResultReceived EndProcessSnapshotStreamed(System.IAsyncResult result) {1234 public HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived EndProcessSnapshotStreamed(System.IAsyncResult result) { 1235 1235 return base.Channel.EndProcessSnapshotStreamed(result); 1236 1236 } … … 1242 1242 1243 1243 private object[] OnEndProcessSnapshotStreamed(System.IAsyncResult result) { 1244 HeuristicLab.Hive.Contracts.Response ResultReceived retVal = this.EndProcessSnapshotStreamed(result);1244 HeuristicLab.Hive.Contracts.ResponseObjects.ResponseResultReceived retVal = this.EndProcessSnapshotStreamed(result); 1245 1245 return new object[] { 1246 1246 retVal}; -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/ServerService/Reference.svcmap
r4254 r4263 27 27 <MetadataFile FileName="HeuristicLab.Hive.Contracts.BusinessObjects1.xsd" MetadataType="Schema" ID="abb70224-775d-4edc-986c-20eede5dbe04" SourceId="1" SourceUrl="net.tcp://10.42.1.154:9000/HiveServer/mex" /> 28 28 <MetadataFile FileName="HeuristicLab.DataAccess1.xsd" MetadataType="Schema" ID="55cbe34c-d0be-42ef-989a-a97018741832" SourceId="1" SourceUrl="net.tcp://10.42.1.154:9000/HiveServer/mex" /> 29 <MetadataFile FileName="HeuristicLab.Hive.Contracts.ResponseObjects.xsd" MetadataType="Schema" ID="9df34145-9053-480f-bf81-db99bfff513c" SourceId="1" SourceUrl="net.tcp://10.42.1.154:9000/HiveServer/mex" /> 29 30 <MetadataFile FileName="HeuristicLab.Hive.Contracts1.xsd" MetadataType="Schema" ID="d4834dd8-d9fe-4ce9-b5e9-dd9fe5451fbe" SourceId="1" SourceUrl="net.tcp://10.42.1.154:9000/HiveServer/mex" /> 30 31 <MetadataFile FileName="Arrays1.xsd" MetadataType="Schema" ID="7f60dd4e-614e-4b85-a4e7-a4caac529103" SourceId="1" SourceUrl="net.tcp://10.42.1.154:9000/HiveServer/mex" /> -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/ServerService/service1.wsdl
r4254 r4263 19 19 <xsd:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.BusinessObjects" /> 20 20 <xsd:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.DataAccess" /> 21 <xsd:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" /> 21 22 <xsd:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts" /> 22 23 <xsd:import namespace="http://schemas.microsoft.com/2003/10/Serialization/Arrays" /> … … 68 69 <wsdl:part name="parameters" element="tns:IsJobStillNeededResponse" /> 69 70 </wsdl:message> 70 <wsdl:message name="ISlaveFacade_ SendPlugins_InputMessage">71 <wsdl:part name="parameters" element="tns: SendPlugins" />72 </wsdl:message> 73 <wsdl:message name="ISlaveFacade_ SendPlugins_OutputMessage">74 <wsdl:part name="parameters" element="tns: SendPluginsResponse" />71 <wsdl:message name="ISlaveFacade_GetPlugins_InputMessage"> 72 <wsdl:part name="parameters" element="tns:GetPlugins" /> 73 </wsdl:message> 74 <wsdl:message name="ISlaveFacade_GetPlugins_OutputMessage"> 75 <wsdl:part name="parameters" element="tns:GetPluginsResponse" /> 75 76 </wsdl:message> 76 77 <wsdl:message name="ISlaveFacade_GetCalendar_InputMessage"> … … 86 87 <wsdl:part name="parameters" element="tns:SetCalendarStatusResponse" /> 87 88 </wsdl:message> 88 <wsdl:message name="ISlaveFacade_ SendStreamedJob_InputMessage">89 <wsdl:part name="parameters" element="tns: SendStreamedJob" />90 </wsdl:message> 91 <wsdl:message name="ISlaveFacade_ SendStreamedJob_OutputMessage">92 <wsdl:part name="parameters" element="tns: SendStreamedJobResponse" />93 </wsdl:message> 94 <wsdl:message name="ISlaveFacade_ SendStreamedPlugins_InputMessage">95 <wsdl:part name="parameters" element="tns: SendStreamedPlugins" />96 </wsdl:message> 97 <wsdl:message name="ISlaveFacade_ SendStreamedPlugins_OutputMessage">98 <wsdl:part name="parameters" element="tns: SendStreamedPluginsResponse" />89 <wsdl:message name="ISlaveFacade_GetStreamedJob_InputMessage"> 90 <wsdl:part name="parameters" element="tns:GetStreamedJob" /> 91 </wsdl:message> 92 <wsdl:message name="ISlaveFacade_GetStreamedJob_OutputMessage"> 93 <wsdl:part name="parameters" element="tns:GetStreamedJobResponse" /> 94 </wsdl:message> 95 <wsdl:message name="ISlaveFacade_GetStreamedPlugins_InputMessage"> 96 <wsdl:part name="parameters" element="tns:GetStreamedPlugins" /> 97 </wsdl:message> 98 <wsdl:message name="ISlaveFacade_GetStreamedPlugins_OutputMessage"> 99 <wsdl:part name="parameters" element="tns:GetStreamedPluginsResponse" /> 99 100 </wsdl:message> 100 101 <wsdl:message name="ISlaveFacade_StoreFinishedJobResultStreamed_InputMessage"> … … 139 140 <wsdl:output wsaw:Action="http://tempuri.org/ISlaveCommunicator/IsJobStillNeededResponse" message="tns:ISlaveFacade_IsJobStillNeeded_OutputMessage" /> 140 141 </wsdl:operation> 141 <wsdl:operation name=" SendPlugins">142 <wsdl:input wsaw:Action="http://tempuri.org/ISlaveCommunicator/ SendPlugins" message="tns:ISlaveFacade_SendPlugins_InputMessage" />143 <wsdl:output wsaw:Action="http://tempuri.org/ISlaveCommunicator/ SendPluginsResponse" message="tns:ISlaveFacade_SendPlugins_OutputMessage" />142 <wsdl:operation name="GetPlugins"> 143 <wsdl:input wsaw:Action="http://tempuri.org/ISlaveCommunicator/GetPlugins" message="tns:ISlaveFacade_GetPlugins_InputMessage" /> 144 <wsdl:output wsaw:Action="http://tempuri.org/ISlaveCommunicator/GetPluginsResponse" message="tns:ISlaveFacade_GetPlugins_OutputMessage" /> 144 145 </wsdl:operation> 145 146 <wsdl:operation name="GetCalendar"> … … 151 152 <wsdl:output wsaw:Action="http://tempuri.org/ISlaveCommunicator/SetCalendarStatusResponse" message="tns:ISlaveFacade_SetCalendarStatus_OutputMessage" /> 152 153 </wsdl:operation> 153 <wsdl:operation name=" SendStreamedJob">154 <wsdl:input wsaw:Action="http://tempuri.org/ISlaveFacade/ SendStreamedJob" message="tns:ISlaveFacade_SendStreamedJob_InputMessage" />155 <wsdl:output wsaw:Action="http://tempuri.org/ISlaveFacade/ SendStreamedJobResponse" message="tns:ISlaveFacade_SendStreamedJob_OutputMessage" />156 </wsdl:operation> 157 <wsdl:operation name=" SendStreamedPlugins">158 <wsdl:input wsaw:Action="http://tempuri.org/ISlaveFacade/ SendStreamedPlugins" message="tns:ISlaveFacade_SendStreamedPlugins_InputMessage" />159 <wsdl:output wsaw:Action="http://tempuri.org/ISlaveFacade/ SendStreamedPluginsResponse" message="tns:ISlaveFacade_SendStreamedPlugins_OutputMessage" />154 <wsdl:operation name="GetStreamedJob"> 155 <wsdl:input wsaw:Action="http://tempuri.org/ISlaveFacade/GetStreamedJob" message="tns:ISlaveFacade_GetStreamedJob_InputMessage" /> 156 <wsdl:output wsaw:Action="http://tempuri.org/ISlaveFacade/GetStreamedJobResponse" message="tns:ISlaveFacade_GetStreamedJob_OutputMessage" /> 157 </wsdl:operation> 158 <wsdl:operation name="GetStreamedPlugins"> 159 <wsdl:input wsaw:Action="http://tempuri.org/ISlaveFacade/GetStreamedPlugins" message="tns:ISlaveFacade_GetStreamedPlugins_InputMessage" /> 160 <wsdl:output wsaw:Action="http://tempuri.org/ISlaveFacade/GetStreamedPluginsResponse" message="tns:ISlaveFacade_GetStreamedPlugins_OutputMessage" /> 160 161 </wsdl:operation> 161 162 <wsdl:operation name="StoreFinishedJobResultStreamed"> … … 235 236 </wsdl:output> 236 237 </wsdl:operation> 237 <wsdl:operation name=" SendPlugins">238 <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/ SendPlugins" style="document" />238 <wsdl:operation name="GetPlugins"> 239 <soap12:operation soapAction="http://tempuri.org/ISlaveCommunicator/GetPlugins" style="document" /> 239 240 <wsdl:input> 240 241 <soap12:body use="literal" /> … … 262 263 </wsdl:output> 263 264 </wsdl:operation> 264 <wsdl:operation name=" SendStreamedJob">265 <soap12:operation soapAction="http://tempuri.org/ISlaveFacade/ SendStreamedJob" style="document" />266 <wsdl:input> 267 <soap12:body use="literal" /> 268 </wsdl:input> 269 <wsdl:output> 270 <soap12:body use="literal" /> 271 </wsdl:output> 272 </wsdl:operation> 273 <wsdl:operation name=" SendStreamedPlugins">274 <soap12:operation soapAction="http://tempuri.org/ISlaveFacade/ SendStreamedPlugins" style="document" />265 <wsdl:operation name="GetStreamedJob"> 266 <soap12:operation soapAction="http://tempuri.org/ISlaveFacade/GetStreamedJob" style="document" /> 267 <wsdl:input> 268 <soap12:body use="literal" /> 269 </wsdl:input> 270 <wsdl:output> 271 <soap12:body use="literal" /> 272 </wsdl:output> 273 </wsdl:operation> 274 <wsdl:operation name="GetStreamedPlugins"> 275 <soap12:operation soapAction="http://tempuri.org/ISlaveFacade/GetStreamedPlugins" style="document" /> 275 276 <wsdl:input> 276 277 <soap12:body use="literal" /> -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/Service References/ServerService/service2.xsd
r4254 r4263 2 2 <xs:schema xmlns:tns="http://tempuri.org/" elementFormDefault="qualified" targetNamespace="http://tempuri.org/" xmlns:xs="http://www.w3.org/2001/XMLSchema"> 3 3 <xs:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.BusinessObjects" /> 4 <xs:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " />4 <xs:import namespace="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" /> 5 5 <xs:import namespace="http://schemas.microsoft.com/2003/10/Serialization/" /> 6 6 <xs:import namespace="http://schemas.microsoft.com/Message" /> … … 15 15 <xs:complexType> 16 16 <xs:sequence> 17 <xs:element xmlns:q2="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="LoginResult" nillable="true" type="q2:Response" />17 <xs:element xmlns:q2="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="LoginResult" nillable="true" type="q2:Response" /> 18 18 </xs:sequence> 19 19 </xs:complexType> … … 29 29 <xs:complexType> 30 30 <xs:sequence> 31 <xs:element xmlns:q4="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="ProcessHeartBeatResult" nillable="true" type="q4:ResponseHeartBeat" />31 <xs:element xmlns:q4="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="ProcessHeartBeatResult" nillable="true" type="q4:ResponseHeartBeat" /> 32 32 </xs:sequence> 33 33 </xs:complexType> … … 43 43 <xs:complexType> 44 44 <xs:sequence> 45 <xs:element xmlns:q6="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="GetJobResult" nillable="true" type="q6:ResponseObjectOfJobDtoZAa7YIsz" />45 <xs:element xmlns:q6="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="GetJobResult" nillable="true" type="q6:ResponseObjectOfJobDtoZAa7YIsz" /> 46 46 </xs:sequence> 47 47 </xs:complexType> … … 61 61 <xs:complexType> 62 62 <xs:sequence> 63 <xs:element xmlns:q9="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="StoreFinishedJobResultResult" nillable="true" type="q9:ResponseResultReceived" />63 <xs:element xmlns:q9="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="StoreFinishedJobResultResult" nillable="true" type="q9:ResponseResultReceived" /> 64 64 </xs:sequence> 65 65 </xs:complexType> … … 79 79 <xs:complexType> 80 80 <xs:sequence> 81 <xs:element xmlns:q12="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="ProcessSnapshotResult" nillable="true" type="q12:ResponseResultReceived" />81 <xs:element xmlns:q12="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="ProcessSnapshotResult" nillable="true" type="q12:ResponseResultReceived" /> 82 82 </xs:sequence> 83 83 </xs:complexType> … … 93 93 <xs:complexType> 94 94 <xs:sequence> 95 <xs:element xmlns:q14="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="LogoutResult" nillable="true" type="q14:Response" />95 <xs:element xmlns:q14="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="LogoutResult" nillable="true" type="q14:Response" /> 96 96 </xs:sequence> 97 97 </xs:complexType> … … 107 107 <xs:complexType> 108 108 <xs:sequence> 109 <xs:element xmlns:q16="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="IsJobStillNeededResult" nillable="true" type="q16:Response" />110 </xs:sequence> 111 </xs:complexType> 112 </xs:element> 113 <xs:element name=" SendPlugins">109 <xs:element xmlns:q16="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="IsJobStillNeededResult" nillable="true" type="q16:Response" /> 110 </xs:sequence> 111 </xs:complexType> 112 </xs:element> 113 <xs:element name="GetPlugins"> 114 114 <xs:complexType> 115 115 <xs:sequence> … … 118 118 </xs:complexType> 119 119 </xs:element> 120 <xs:element name=" SendPluginsResponse">121 <xs:complexType> 122 <xs:sequence> 123 <xs:element xmlns:q18="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="SendPluginsResult" nillable="true" type="q18:ResponseListOfCachedHivePluginInfoDtoZMwZop09" />120 <xs:element name="GetPluginsResponse"> 121 <xs:complexType> 122 <xs:sequence> 123 <xs:element xmlns:q18="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="GetPluginsResult" nillable="true" type="q18:ResponseListOfCachedHivePluginInfoDtoZMwZop09" /> 124 124 </xs:sequence> 125 125 </xs:complexType> … … 135 135 <xs:complexType> 136 136 <xs:sequence> 137 <xs:element xmlns:q20="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="GetCalendarResult" nillable="true" type="q20:ResponseCalendar" />137 <xs:element xmlns:q20="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="GetCalendarResult" nillable="true" type="q20:ResponseCalendar" /> 138 138 </xs:sequence> 139 139 </xs:complexType> … … 150 150 <xs:complexType> 151 151 <xs:sequence> 152 <xs:element xmlns:q23="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="SetCalendarStatusResult" nillable="true" type="q23:Response" />153 </xs:sequence> 154 </xs:complexType> 155 </xs:element> 156 <xs:element name=" SendStreamedJob">152 <xs:element xmlns:q23="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="SetCalendarStatusResult" nillable="true" type="q23:Response" /> 153 </xs:sequence> 154 </xs:complexType> 155 </xs:element> 156 <xs:element name="GetStreamedJob"> 157 157 <xs:complexType> 158 158 <xs:sequence> … … 161 161 </xs:complexType> 162 162 </xs:element> 163 <xs:element name=" SendStreamedJobResponse">164 <xs:complexType> 165 <xs:sequence> 166 <xs:element xmlns:q25="http://schemas.microsoft.com/Message" name=" SendStreamedJobResult" type="q25:StreamBody" />167 </xs:sequence> 168 </xs:complexType> 169 </xs:element> 170 <xs:element name=" SendStreamedPlugins">163 <xs:element name="GetStreamedJobResponse"> 164 <xs:complexType> 165 <xs:sequence> 166 <xs:element xmlns:q25="http://schemas.microsoft.com/Message" name="GetStreamedJobResult" type="q25:StreamBody" /> 167 </xs:sequence> 168 </xs:complexType> 169 </xs:element> 170 <xs:element name="GetStreamedPlugins"> 171 171 <xs:complexType> 172 172 <xs:sequence> … … 175 175 </xs:complexType> 176 176 </xs:element> 177 <xs:element name=" SendStreamedPluginsResponse">178 <xs:complexType> 179 <xs:sequence> 180 <xs:element xmlns:q27="http://schemas.microsoft.com/Message" name=" SendStreamedPluginsResult" type="q27:StreamBody" />177 <xs:element name="GetStreamedPluginsResponse"> 178 <xs:complexType> 179 <xs:sequence> 180 <xs:element xmlns:q27="http://schemas.microsoft.com/Message" name="GetStreamedPluginsResult" type="q27:StreamBody" /> 181 181 </xs:sequence> 182 182 </xs:complexType> … … 192 192 <xs:complexType> 193 193 <xs:sequence> 194 <xs:element xmlns:q29="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="StoreFinishedJobResultStreamedResult" nillable="true" type="q29:ResponseResultReceived" />194 <xs:element xmlns:q29="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="StoreFinishedJobResultStreamedResult" nillable="true" type="q29:ResponseResultReceived" /> 195 195 </xs:sequence> 196 196 </xs:complexType> … … 206 206 <xs:complexType> 207 207 <xs:sequence> 208 <xs:element xmlns:q31="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts " minOccurs="0" name="ProcessSnapshotStreamedResult" nillable="true" type="q31:ResponseResultReceived" />208 <xs:element xmlns:q31="http://schemas.datacontract.org/2004/07/HeuristicLab.Hive.Contracts.ResponseObjects" minOccurs="0" name="ProcessSnapshotStreamedResult" nillable="true" type="q31:ResponseResultReceived" /> 209 209 </xs:sequence> 210 210 </xs:complexType> -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Communication/3.3/WcfService.cs
r4254 r4263 37 37 using Service = HeuristicLab.Hive.Slave.Communication.ServerService; 38 38 using HeuristicLab.Hive.Slave.Communication.ServerService; 39 using HeuristicLab.Hive.Contracts.ResponseObjects; 39 40 40 41 /// <summary> … … 95 96 Logger.Debug("Registring new Events"); 96 97 proxy.LoginCompleted += new EventHandler<LoginCompletedEventArgs>(proxy_LoginCompleted); 97 proxy. SendStreamedJobCompleted += new EventHandler<SendStreamedJobCompletedEventArgs>(proxy_SendStreamedJobCompleted);98 proxy.GetStreamedJobCompleted += new EventHandler<GetStreamedJobCompletedEventArgs>(proxy_GetStreamedJobCompleted); 98 99 proxy.StoreFinishedJobResultStreamedCompleted += new EventHandler<StoreFinishedJobResultStreamedCompletedEventArgs>(proxy_StoreFinishedJobResultStreamedCompleted); 99 100 proxy.ProcessSnapshotStreamedCompleted += new EventHandler<ProcessSnapshotStreamedCompletedEventArgs>(proxy_ProcessSnapshotStreamedCompleted); … … 159 160 } 160 161 161 162 163 162 /// <summary> 164 163 /// Methods for the Server Login … … 184 183 if (ConnState == NetworkEnum.WcfConnState.Connected) { 185 184 Logger.Debug("STARTED: Login Sync"); 186 HeuristicLab.Hive.Contracts.Response res = proxy.Login(clientInfo);187 if ( !res.Success) {185 Response res = proxy.Login(clientInfo); 186 if (res.StatusMessage != ResponseStatus.Ok) { 188 187 Logger.Error("FAILED: Login Failed! " + res.StatusMessage); 189 throw new Exception(res.StatusMessage );188 throw new Exception(res.StatusMessage.ToString()); 190 189 } else { 191 190 Logger.Info("ENDED: Login succeeded" + res.StatusMessage); … … 204 203 /// </summary> 205 204 #region PullJob 206 public event System.EventHandler<GetJobCompletedEventArgs> SendJobCompleted;207 public void SendJobAsync(Guid guid) {205 public event System.EventHandler<GetJobCompletedEventArgs> GetJobCompleted; 206 public void GetJobAsync(Guid guid) { 208 207 if (ConnState == NetworkEnum.WcfConnState.Loggedin) { 209 208 Logger.Debug("STARTED: Fetching of Jobs from Server for Client"); 210 proxy. SendStreamedJobAsync(guid);211 } 212 } 213 214 void proxy_ SendStreamedJobCompleted(object sender, SendStreamedJobCompletedEventArgs e) {209 proxy.GetStreamedJobAsync(guid); 210 } 211 } 212 213 void proxy_GetStreamedJobCompleted(object sender, GetStreamedJobCompletedEventArgs e) { 215 214 if (e.Error == null) { 216 215 Logger.Debug("ENDED: Fetching of Jobs from Server for Client"); … … 237 236 238 237 GetJobCompletedEventArgs completedEventArgs = new GetJobCompletedEventArgs(new object[] { response, memStream.GetBuffer() }, e.Error, e.Cancelled, e.UserState); 239 SendJobCompleted(sender, completedEventArgs);238 GetJobCompleted(sender, completedEventArgs); 240 239 } catch (Exception ex) { 241 240 Logger.Error(ex); … … 257 256 /// </summary> 258 257 #region SendJobResults 259 public event System.EventHandler<StoreFinishedJobResultCompletedEventArgs> StoreFinishedJobResultCompleted;260 public void StoreFinishedJobResultAsync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) {258 public event System.EventHandler<StoreFinishedJobResultCompletedEventArgs> GetFinishedJobResultCompleted; 259 public void GetFinishedJobResultAsync(Guid clientId, Guid jobId, byte[] result, double percentage, Exception exception, bool finished) { 261 260 if (ConnState == NetworkEnum.WcfConnState.Loggedin) { 262 261 Logger.Debug("STARTED: Sending back the finished job results"); … … 279 278 StoreFinishedJobResultCompletedEventArgs args = new StoreFinishedJobResultCompletedEventArgs(new object[] { e.Result }, e.Error, e.Cancelled, e.UserState); 280 279 Logger.Debug("calling the Finished Job Event"); 281 StoreFinishedJobResultCompleted(sender, args);280 GetFinishedJobResultCompleted(sender, args); 282 281 Logger.Debug("ENDED: Sending back the finished job results"); 283 282 } else { … … 328 327 329 328 private void proxy_ProcessHeartBeatCompleted(object sender, ProcessHeartBeatCompletedEventArgs e) { 330 if (e.Error == null && e.Result.S uccess) {329 if (e.Error == null && e.Result.StatusMessage == ResponseStatus.Ok) { 331 330 ProcessHeartBeatCompleted(sender, e); 332 331 Logger.Debug("ENDED: sending heartbeats"); … … 394 393 Logger.Debug("STARTED: Requesting Plugins for Job"); 395 394 Logger.Debug("STARTED: Getting the stream"); 396 Stream stream = proxy. SendStreamedPlugins(requestedPlugins.ToArray());395 Stream stream = proxy.GetStreamedPlugins(requestedPlugins.ToArray()); 397 396 Logger.Debug("ENDED: Getting the stream"); 398 397 BinaryFormatter formatter = new BinaryFormatter(); -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Core/3.3/ConfigurationManager/UptimeManager.cs
r4254 r4263 10 10 using HeuristicLab.Hive.Contracts; 11 11 using HeuristicLab.Tracing; 12 using HeuristicLab.Hive.Contracts.ResponseObjects; 12 13 13 14 namespace HeuristicLab.Hive.Slave.Core.ConfigurationManager { -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Core/3.3/Core.cs
r4254 r4263 47 47 using HeuristicLab.Core; 48 48 using System.IO; 49 using HeuristicLab.Hive.Contracts.ResponseObjects; 49 50 50 51 namespace HeuristicLab.Hive.Slave.Core { … … 88 89 wcfService = WcfService.Instance; 89 90 wcfService.LoginCompleted += new EventHandler<LoginCompletedEventArgs>(wcfService_LoginCompleted); 90 wcfService. SendJobCompleted += new EventHandler<GetJobCompletedEventArgs>(wcfService_GetJobCompleted);91 wcfService. StoreFinishedJobResultCompleted += new EventHandler<StoreFinishedJobResultCompletedEventArgs>(wcfService_StoreFinishedJobResultCompleted);91 wcfService.GetJobCompleted += new EventHandler<GetJobCompletedEventArgs>(wcfService_GetJobCompleted); 92 wcfService.GetFinishedJobResultCompleted += new EventHandler<StoreFinishedJobResultCompletedEventArgs>(wcfService_StoreFinishedJobResultCompleted); 92 93 wcfService.ProcessSnapshotCompleted += new EventHandler<ProcessSnapshotCompletedEventArgs>(wcfService_ProcessSnapshotCompleted); 93 94 wcfService.ConnectionRestored += new EventHandler(wcfService_ConnectionRestored); … … 153 154 case MessageContainer.MessageType.FetchJob: 154 155 if (!CurrentlyFetching) { 155 wcfService. SendJobAsync(ConfigManager.Instance.GetClientInfo().Id);156 wcfService.GetJobAsync(ConfigManager.Instance.GetClientInfo().Id); 156 157 CurrentlyFetching = true; 157 158 } else … … 232 233 if (WcfService.Instance.ConnState == NetworkEnum.WcfConnState.Loggedin) { 233 234 Logger.Info("Sending the finished job with id: " + jId); 234 wcfService. StoreFinishedJobResultAsync(ConfigManager.Instance.GetClientInfo().Id, jId, sJob, 1.0, engines[jId].CurrentException, true);235 wcfService.GetFinishedJobResultAsync(ConfigManager.Instance.GetClientInfo().Id, jId, sJob, 1.0, engines[jId].CurrentException, true); 235 236 } else { 236 237 Logger.Info("Storing the finished job with id: " + jId + " to hdd"); … … 286 287 /// <param name="e"></param> 287 288 void wcfService_LoginCompleted(object sender, LoginCompletedEventArgs e) { 288 if (e.Result.S uccess) {289 if (e.Result.StatusMessage == ResponseStatus.Ok) { 289 290 CurrentlyFetching = false; 290 291 Logger.Info("Login completed to Hive Server @ " + DateTime.Now); 291 292 } else 292 Logger.Error("Error during login: " + e.Result.StatusMessage );293 Logger.Error("Error during login: " + e.Result.StatusMessage.ToString()); 293 294 } 294 295 … … 299 300 /// <param name="e"></param> 300 301 void wcfService_GetJobCompleted(object sender, GetJobCompletedEventArgs e) { 301 if (e.Result.StatusMessage != ApplicationConstants.RESPONSE_COMMUNICATOR_NO_JOBS_LEFT) {302 if (e.Result.StatusMessage != ResponseStatus.GetJob_NoJobsAvailable) { 302 303 Logger.Info("Received new job with id " + e.Result.Obj.Id); 303 304 bool sandboxed = false; … … 355 356 Logger.Info("Job submitted with id " + e.Result.JobId); 356 357 KillAppDomain(e.Result.JobId); 357 if (e.Result.S uccess) {358 if (e.Result.StatusMessage == ResponseStatus.Ok) { 358 359 SlaveStatusInfo.JobsProcessed++; 359 360 Logger.Info("Increased ProcessedJobs to:" + SlaveStatusInfo.JobsProcessed); … … 415 416 private void FetchCalendarFromServer() { 416 417 ResponseCalendar calres = wcfService.GetCalendarSync(ConfigManager.Instance.GetClientInfo().Id); 417 if (calres.S uccess) {418 if (calres.StatusMessage == ResponseStatus.Ok) { 418 419 if (UptimeManager.Instance.SetAppointments(false, calres)) { 419 420 Logger.Info("Remote calendar installed"); -
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Slave.Core/3.3/JobStorage/JobStorageManager.cs
r4254 r4263 12 12 using System.Xml; 13 13 using HeuristicLab.Tracing; 14 using HeuristicLab.Hive.Contracts.ResponseObjects; 14 15 15 16 namespace HeuristicLab.Hive.Slave.Core.JobStorage { … … 49 50 try { 50 51 byte[] job = File.ReadAllBytes(path + filename + ".dat"); 51 if (WcfService.Instance.IsJobStillNeeded(storedJobsList[index - 1].JobID).StatusMessage == ApplicationConstants.RESPONSE_COMMUNICATOR_SEND_JOBRESULT) {52 if (WcfService.Instance.IsJobStillNeeded(storedJobsList[index - 1].JobID).StatusMessage == ResponseStatus.Ok) { 52 53 ResponseResultReceived res = WcfService.Instance.StoreFinishedJobResultsSync(ConfigManager.Instance.GetClientInfo().Id, storedJobsList[index - 1].JobID, job, 1.00, null, true); 53 if (!res.Success) 54 Logger.Error("sending of job failed: " + res.StatusMessage); 55 else 56 Logger.Info("Sending of job " + storedJobsList[index - 1].JobID + " done"); 54 Logger.Info("Sending of job " + storedJobsList[index - 1].JobID + " done"); 57 55 } 58 56 SlaveStatusInfo.JobsProcessed++;
Note: See TracChangeset
for help on using the changeset viewer.