- Timestamp:
- 12/20/11 13:54:57 (12 years ago)
- Location:
- branches/HeuristicLab.Hive.Azure
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/HeuristicLab.Hive.Azure
- Property svn:ignore
-
old new 4 4 *.suo 5 5 *.vsp 6 Doxygen 6 7 Google.ProtocolBuffers-0.9.1.dll 7 8 HeuristicLab 3.3.5.1.ReSharper.user 8 9 HeuristicLab 3.3.6.0.ReSharper.user 9 10 HeuristicLab.4.5.resharper.user 11 HeuristicLab.ExtLibs.6.0.ReSharper.user 10 12 HeuristicLab.resharper.user 11 13 ProtoGen.exe … … 16 18 bin 17 19 protoc.exe 18 HeuristicLab.ExtLibs.6.0.ReSharper.user19 Doxygen
-
- Property svn:mergeinfo changed
- Property svn:ignore
-
branches/HeuristicLab.Hive.Azure/HeuristicLab.Clients.Hive/3.3
- Property svn:ignore
-
old new 1 1 obj 2 2 Plugin.cs 3 bin
-
- Property svn:ignore
-
branches/HeuristicLab.Hive.Azure/HeuristicLab.Clients.Hive/3.3/RefreshableJob.cs
r6976 r7215 51 51 OnJobChanged(); 52 52 OnToStringChanged(this, EventArgs.Empty); 53 job_ItemImageChanged(this, EventArgs.Empty); 53 54 } 54 55 } … … 194 195 this.Job = new Job(); 195 196 this.log = new ThreadSafeLog(); 196 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>( 2, 2);197 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>(Settings.Default.MaxParallelDownloads, Settings.Default.MaxParallelDownloads); 197 198 this.jobDownloader.ExceptionOccured += new EventHandler<EventArgs<Exception>>(jobDownloader_ExceptionOccured); 198 199 this.HiveTasks = new ItemCollection<HiveTask>(); … … 202 203 this.Job = hiveExperiment; 203 204 this.log = new ThreadSafeLog(); 204 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>( 2, 2);205 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>(Settings.Default.MaxParallelDownloads, Settings.Default.MaxParallelDownloads); 205 206 this.jobDownloader.ExceptionOccured += new EventHandler<EventArgs<Exception>>(jobDownloader_ExceptionOccured); 206 207 this.HiveTasks = new ItemCollection<HiveTask>(); … … 208 209 protected RefreshableJob(RefreshableJob original, Cloner cloner) { 209 210 cloner.RegisterClonedObject(original, this); 210 this.Job = original.Job;211 this.Job = cloner.Clone(original.Job); 211 212 this.IsControllable = original.IsControllable; 212 213 this.log = cloner.Clone(original.log); 213 214 this.RefreshAutomatically = false; // do not start results polling automatically 214 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>( 2, 2);215 this.jobDownloader = new ConcurrentTaskDownloader<ItemTask>(Settings.Default.MaxParallelDownloads, Settings.Default.MaxParallelDownloads); 215 216 this.jobDownloader.ExceptionOccured += new EventHandler<EventArgs<Exception>>(jobDownloader_ExceptionOccured); 216 217 this.HiveTasks = cloner.Clone(original.HiveTasks); … … 230 231 public void StartResultPolling() { 231 232 if (jobResultPoller == null) { 232 jobResultPoller = new JobResultPoller(job.Id, /*ApplicationConstants.ResultPollingInterval*/new TimeSpan(0, 0, 5)); //TODO: find a better place for ApplicationConstants233 jobResultPoller = new JobResultPoller(job.Id, Settings.Default.ResultPollingInterval); 233 234 RegisterResultPollingEvents(); 234 235 jobResultPoller.AutoResumeOnException = true; … … 276 277 log.LogMessage(string.Format("Downloading task {0}", lightweightTask.Id)); 277 278 hiveTask.IsDownloading = true; 278 jobDownloader.DownloadTask (hiveTask.Task, (localJob, itemJob) => {279 jobDownloader.DownloadTaskData(hiveTask.Task, (localJob, itemJob) => { 279 280 log.LogMessage(string.Format("Finished downloading task {0}", localJob.Id)); 280 281 HiveTask localHiveTask = GetHiveJobById(localJob.Id); … … 533 534 public virtual void OnLoaded() { 534 535 this.UpdateTotalExecutionTime(); 536 this.OnStateLogListChanged(); 535 537 536 538 if (this.ExecutionState != ExecutionState.Stopped) {
Note: See TracChangeset
for help on using the changeset viewer.