Free cookie consent management tool by TermsFeed Policy Generator

Ignore:
Timestamp:
03/12/10 10:57:21 (15 years ago)
Author:
kgrading
Message:

changed the complete DAL to LINQ 2 SQL (with the exception of the job streaming), did a lot of refactoring, Introduced DTOs (that are named DTOs for better understanding), added the spring.NET Interceptor, reintroduced transactions and cleaned up the whole JobResult thing and updated a part of the config merger (#830)

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/sources/HeuristicLab.Hive.Engine/3.2/HiveEngine.cs

    r2846 r3011  
    101101
    102102      for (int i = 0; i < loops; i++) {
    103         ResponseObject<Contracts.BusinessObjects.Job> res = executionEngineFacade.AddJob(jobObj);
     103        ResponseObject<Contracts.BusinessObjects.JobDto> res = executionEngineFacade.AddJob(jobObj);
    104104        jobId = res.Obj.Id;
    105105      }
     
    112112      Thread t = new Thread(() => {
    113113        IExecutionEngineFacade executionEngineFacade = ServiceLocator.CreateExecutionEngineFacade(HiveServerUrl);
    114         ResponseObject<SerializedJobResult> response = null;
     114        ResponseObject<SerializedJob> response = null;
    115115        Job restoredJob = null;
    116116        do {
     
    128128            if (response.Success && response.Obj != null) {
    129129              HiveLogger.Debug("HiveEngine: Results-polling - Got result!");
    130               restoredJob = (Job)PersistenceManager.RestoreFromGZip(response.Obj.SerializedJobResultData);
     130              restoredJob = (Job)PersistenceManager.RestoreFromGZip(response.Obj.SerializedJobData);
    131131              HiveLogger.Debug("HiveEngine: Results-polling - IsSnapshotResult: " + (restoredJob.Progress<1.0));
    132132            }
     
    146146      IExecutionEngineFacade executionEngineFacade = ServiceLocator.CreateExecutionEngineFacade(HiveServerUrl);
    147147      int retryCount = 0;
    148       ResponseObject<SerializedJobResult> response;
     148      ResponseObject<SerializedJob> response;
    149149      lock (locker) {
    150150        HiveLogger.Debug("HiveEngine: Abort - RequestSnapshot");
     
    174174        }
    175175      }
    176       SerializedJobResult jobResult = response.Obj;
     176      SerializedJob jobResult = response.Obj;
    177177      if (jobResult != null) {
    178178        HiveLogger.Debug("HiveEngine: Results-polling - Got result!");
    179         job = (Job)PersistenceManager.RestoreFromGZip(jobResult.SerializedJobResultData);
     179        job = (Job)PersistenceManager.RestoreFromGZip(jobResult.SerializedJobData);
    180180        ControlManager.Manager.ShowControl(job.Engine.CreateView());
    181181      }
     
    210210
    211211    private HeuristicLab.Hive.Contracts.BusinessObjects.SerializedJob CreateJobObj() {
    212       HeuristicLab.Hive.Contracts.BusinessObjects.Job jobObj =
    213         new HeuristicLab.Hive.Contracts.BusinessObjects.Job();
     212      HeuristicLab.Hive.Contracts.BusinessObjects.JobDto jobObj =
     213        new HeuristicLab.Hive.Contracts.BusinessObjects.JobDto();
    214214
    215215      MemoryStream memStream = new MemoryStream();
     
    240240      }
    241241
    242       List<HivePluginInfo> pluginsNeeded =
    243         new List<HivePluginInfo>();
     242      List<HivePluginInfoDto> pluginsNeeded =
     243        new List<HivePluginInfoDto>();
    244244      foreach (IPluginDescription uniquePlugin in plugins) {
    245         HivePluginInfo pluginInfo =
    246           new HivePluginInfo();
     245        HivePluginInfoDto pluginInfo =
     246          new HivePluginInfoDto();
    247247        pluginInfo.Name = uniquePlugin.Name;
    248248        pluginInfo.Version = uniquePlugin.Version.ToString();
Note: See TracChangeset for help on using the changeset viewer.