Free cookie consent management tool by TermsFeed Policy Generator

Ignore:
Timestamp:
09/17/10 10:26:55 (14 years ago)
Author:
cneumuel
Message:
  • Refactored HL.Hive.Experiment. JobItems are not called HiveJobs and OptimizerJobs do not contain a hierarchy anymore.
  • Dynamic generation of jobs on a slave are not reflected on the client user interface.
  • Optimizer-Trees are now strictly synchronized with the HiveJob-Trees (also the ComputeInParallel property is taken into account when the Child HiveJobs are created)
  • Improved the way a class can report progress and lock the UI (IProgressReporter, IProgress, Progress, ProgressView)
  • Changes were made to the config-files, so that server and clients work with blade12.hpc.fh-hagenberg.at
  • Lots of small changes and bugfixes
File:
1 edited

Legend:

Unmodified
Added
Removed
  • branches/3.3-Hive/sources/HeuristicLab.Hive/HeuristicLab.Hive.Server.Core/3.3/Facades/SlaveFacade.cs

    r4368 r4423  
    6262    [PrincipalPermission(SecurityAction.Demand, Role = HiveRoles.Slave)]
    6363    public ResponseHeartBeat ProcessHeartBeat(HeartBeatData hbData) {
    64       using (contextFactory.GetContext()) {
     64      using (contextFactory.GetContext(false)) { // due to concurrency issues with lifecycle-heartbeat do the transaction inside
    6565        return slaveCommunicator.ProcessHeartBeat(hbData);
    6666      }
     
    7777    [PrincipalPermission(SecurityAction.Demand, Role = HiveRoles.Administrator)]
    7878    [PrincipalPermission(SecurityAction.Demand, Role = HiveRoles.Slave)]
    79     public ResponseResultReceived StoreFinishedJobResult(Guid slaveId, Guid jobId, byte[] result, double percentage, string exception) {
    80       using (contextFactory.GetContext()) {
    81         ServiceLocator.GetAuthorizationManager().AuthorizeForJobs(jobId);
    82         return slaveCommunicator.StoreFinishedJobResult(slaveId, jobId, result, percentage, exception);
     79    public ResponseResultReceived StoreFinishedJobResult(Guid slaveId, Guid jobId, byte[] result, TimeSpan executionTime, string exception) {
     80      using (contextFactory.GetContext()) {
     81        ServiceLocator.GetAuthorizationManager().AuthorizeJobs(jobId);
     82        return slaveCommunicator.StoreFinishedJobResult(slaveId, jobId, result, executionTime, exception);
    8383      }
    8484    }
     
    108108    [PrincipalPermission(SecurityAction.Demand, Role = HiveRoles.Administrator)]
    109109    [PrincipalPermission(SecurityAction.Demand, Role = HiveRoles.Slave)]
    110     public ResponseResultReceived ProcessSnapshot(Guid slaveId, Guid jobId, byte[] result, double percentage, string exception) {
    111       using (contextFactory.GetContext()) {
    112         ServiceLocator.GetAuthorizationManager().AuthorizeForJobs(jobId);
    113         return slaveCommunicator.ProcessSnapshot(slaveId, jobId, result, percentage, exception);
     110    public ResponseResultReceived ProcessSnapshot(Guid slaveId, Guid jobId, byte[] result, TimeSpan executionTime, string exception) {
     111      using (contextFactory.GetContext()) {
     112        ServiceLocator.GetAuthorizationManager().AuthorizeJobs(jobId);
     113        return slaveCommunicator.ProcessSnapshot(slaveId, jobId, result, executionTime, exception);
    114114      }
    115115    }
     
    136136      using (contextFactory.GetContext()) {
    137137        return jobManager.AddChildJob(parentJobId, serializedJob);
    138        
    139138      }
    140139    }
     
    149148    [PrincipalPermission(SecurityAction.Demand, Role = HiveRoles.Slave)]
    150149    public Stream GetStreamedJob(Guid slaveId) {
     150      ServiceLocator.GetLifecycleManager().JobsCurrentlyTransferring++;
    151151      using (contextFactory.GetContext(false)) {
    152152        ResponseObject<JobDto> job = null;
     
    170170            stream.Dispose();
    171171          }
     172          ServiceLocator.GetLifecycleManager().JobsCurrentlyTransferring--;
    172173        });
    173174
     
    221222      }
    222223    }
     224
     225    [PrincipalPermission(SecurityAction.Demand, Role = HiveRoles.Administrator)]
     226    [PrincipalPermission(SecurityAction.Demand, Role = HiveRoles.Slave)]
     227    public Response DeleteChildJobs(Guid jobId) {
     228      using (contextFactory.GetContext()) {
     229        return jobManager.DeleteChildJobs(jobId);
     230      }
     231    }
     232
    223233    #endregion
    224234  }
Note: See TracChangeset for help on using the changeset viewer.