Changeset 4119 for branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Client.Core/3.3/Core.cs
- Timestamp:
- 07/28/10 17:48:10 (14 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Client.Core/3.3/Core.cs
r4107 r4119 45 45 using HeuristicLab.Hive.Client.Core.JobStorage; 46 46 using HeuristicLab.Tracing; 47 using HeuristicLab.Core; 47 48 48 49 namespace HeuristicLab.Hive.Client.Core { … … 98 99 if (cc.IPAdress != String.Empty && cc.Port != 0) 99 100 wcfService.SetIPAndPort(cc.IPAdress, cc.Port); 100 101 if (!UptimeManager.Instance.CalendarAvailable || UptimeManager.Instance.IsOnline())102 wcfService.Connect();103 101 104 102 //Initialize the heartbeat … … 249 247 if (WcfService.Instance.ConnState == NetworkEnum.WcfConnState.Loggedin) { 250 248 Logger.Info("Sending the finished job with id: " + jId); 251 wcfService.StoreFinishedJobResultAsync(ConfigManager.Instance.GetClientInfo().Id, 252 jId, 253 sJob, 254 1, 255 null, 256 true); 249 wcfService.StoreFinishedJobResultAsync(ConfigManager.Instance.GetClientInfo().Id, jId, sJob, 1.0, null, true); 257 250 } else { 258 251 Logger.Info("Storing the finished job with id: " + jId + " to hdd"); … … 465 458 466 459 foreach (KeyValuePair<Guid, Executor> execKVP in engines) { 467 if ( !execKVP.Value.Running&& execKVP.Value.CurrentMessage == MessageContainer.MessageType.NoMessage) {460 if (execKVP.Value.ExecutionState != ExecutionState.Started && execKVP.Value.CurrentMessage == MessageContainer.MessageType.NoMessage) { 468 461 Logger.Info("Checking for JobId: " + execKVP.Value.JobId); 469 462 Thread finThread = new Thread(new ParameterizedThreadStart(GetFinishedJob)); … … 513 506 } 514 507 515 508 516 509 }
Note: See TracChangeset
for help on using the changeset viewer.