Changeset 1119
- Timestamp:
- 01/14/09 16:03:50 (16 years ago)
- Location:
- trunk/sources
- Files:
-
- 6 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/sources/HeuristicLab.Hive.Client.Core/ConfigurationManager/ConfigManager.cs
r1034 r1119 106 106 return st; 107 107 } 108 109 public Dictionary<long, double> GetProgressOfAllJobs() { 110 Dictionary<long,double> prog = new Dictionary<long,double>(); 111 Dictionary<long, Executor> engines = Core.GetExecutionEngines(); 112 foreach (KeyValuePair<long, Executor> kvp in engines) { 113 Executor e = kvp.Value; 114 prog[e.JobId] = e.Progress; 115 } 116 return prog; 117 } 118 108 119 } 109 120 } -
trunk/sources/HeuristicLab.Hive.Client.Core/Core.cs
r1103 r1119 162 162 AppDomain appDomain = PluginManager.Manager.CreateAndInitAppDomainWithSandbox(e.Result.Job.Id.ToString(), sandboxed, typeof(TestJob)); 163 163 appDomain.UnhandledException += new UnhandledExceptionEventHandler(appDomain_UnhandledException); 164 lock (Locker) { 164 lock (Locker) { 165 165 if (!jobs.ContainsKey(e.Result.Job.Id)) { 166 166 jobs.Add(e.Result.Job.Id, e.Result.Job); -
trunk/sources/HeuristicLab.Hive.Client.Core/Heartbeat.cs
r1097 r1119 74 74 ClientInfo info = ConfigManager.Instance.GetClientInfo(); 75 75 // Todo: remove tempfix for free cores. 76 // TODO: change jobProgress from int to Dictionary of Job and Double 77 HeartBeatData heartBeatData = new HeartBeatData { ClientId = info.ClientId, 78 freeCores = info.NrOfCores - (ClientStatusInfo.JobsFetched - ClientStatusInfo.JobsProcessed), 79 freeMemory = 1000, 80 jobProgress = ClientStatusInfo.JobsFetched - ClientStatusInfo.JobsProcessed}; 76 77 HeartBeatData heartBeatData = new HeartBeatData { 78 ClientId = info.ClientId, 79 freeCores = info.NrOfCores - (ClientStatusInfo.JobsFetched - ClientStatusInfo.JobsProcessed), 80 freeMemory = 1000, 81 jobProgress = ConfigManager.Instance.GetProgressOfAllJobs() 82 }; 81 83 if (wcfService.ConnState == NetworkEnum.WcfConnState.Failed) { 82 84 wcfService.Connect(); -
trunk/sources/HeuristicLab.Hive.Client.ExecutionEngine/Executor.cs
r1097 r1119 53 53 public void Start(byte[] serializedJob) { 54 54 CreationTime = DateTime.Now; 55 Job = (IJob)PersistenceManager.RestoreFromGZip(serializedJob); 55 //Job = (IJob)PersistenceManager.RestoreFromGZip(serializedJob); 56 //debug 57 Job = new TestJob(); 56 58 Job.JobStopped += new EventHandler(Job_JobStopped); 57 59 Job.Start(); -
trunk/sources/HeuristicLab.Hive.Contracts/BusinessObjects/HeartBeatData.cs
r780 r1119 16 16 public int freeCores { get; set; } 17 17 [DataMember] 18 public intjobProgress { get; set; } // TODO: define Type18 public Dictionary<long, double> jobProgress { get; set; } // TODO: define Type 19 19 } 20 20 } -
trunk/sources/HeuristicLab.Hive.JobBase/TestJob.cs
r1023 r1119 67 67 } 68 68 69 public TestJob() { 70 } 71 69 72 70 73 }
Note: See TracChangeset
for help on using the changeset viewer.