source: branches/3.3-HiveMigration/sources/HeuristicLab.Hive/HeuristicLab.Hive.Engine/3.3/Job.cs @ 4107

#region License Information
/* HeuristicLab
 * Copyright (C) 2002-2008 Heuristic and Evolutionary Algorithms Laboratory (HEAL)
 *
 * This file is part of HeuristicLab.
 *
 * HeuristicLab is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * HeuristicLab is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with HeuristicLab. If not, see <http://www.gnu.org/licenses/>.
 */
#endregion

using System;
using System.Collections.Generic;
using System.Text;
using HeuristicLab.Core;
using System.Threading;
using HeuristicLab.Hive.JobBase;
using System.Xml;
using HeuristicLab.Data;
using HeuristicLab.Common;
using HeuristicLab.Persistence.Default.CompositeSerializers.Storable;

namespace HeuristicLab.Hive.Engine {
  /// <summary>
  /// Represents a job that wraps an engine that should be executed in the hive.
  /// </summary>
  [StorableClass]
  public class Job : IJob {
    [Storable]
    private IEngine engine;
    public IEngine Engine {
      get { return engine; }
    }

    public Job()
      : base() {
      
      engine = new SequentialEngine.SequentialEngine();
      //engine.Priority = ThreadPriority.Lowest;
      RegisterEvents();
    }

    private void RegisterEvents() {
      engine.Stopped += new EventHandler(engine_Stopped);
      engine.ExceptionOccurred += new EventHandler<EventArgs<Exception>>(engine_ExceptionOccurred);
    }

    private void DeregisterEvents() {
      engine.Stopped -= new EventHandler(engine_Stopped);
      engine.ExceptionOccurred -= new EventHandler<EventArgs<Exception>>(engine_ExceptionOccurred);
    }

    void engine_Stopped(object sender, EventArgs e) {
      if (Engine.ExecutionState != ExecutionState.Stopped) this.progress = 0.0;
      else this.progress = 1.0;
      var listeners = JobStopped;
      if (listeners != null)
        listeners(this, e);
    }

    void engine_ExceptionOccurred(object sender, EventArgs<Exception> e) {
      this.progress = 0.0;
      var listeners = JobFailed;
      if (listeners != null)
        listeners(this, e);
    }


    #region IJob Members

    public event EventHandler JobStopped;
    public event EventHandler JobFailed;

    [Storable]
    public long JobId {
      get;
      set;
    }

    [Storable]
    private double progress;
    public double Progress {
      get {
        //DoubleValue progress = Engine.GlobalScope.GetVariableValue<DoubleData>("Progress", false, false); [chn] not possible in 3.3?

        return engine.ExecutionState == ExecutionState.Stopped ? 1.0 : 0.0;
      }
      set { throw new NotSupportedException(); }
    }

    public bool Running {
      get {
        return Engine.ExecutionState == ExecutionState.Started;
      }
      set {
        throw new NotSupportedException();
      }
    }

    public void Run() {
      throw new NotSupportedException();
    }

    public void Start() {
      Engine.Start();
    }

    public void Stop() {
      Engine.Stop();
    }

    #endregion

    //public override System.Xml.XmlNode GetXmlNode(string name, System.Xml.XmlDocument document, IDictionary<Guid, IStorable> persistedObjects) {
    //  XmlNode node = base.GetXmlNode(name, document, persistedObjects);
    //  XmlAttribute idAttr = document.CreateAttribute("JobId");
    //  idAttr.Value = XmlConvert.ToString(JobId);
    //  XmlAttribute progressAttr = document.CreateAttribute("Progress");
    //  progressAttr.Value = XmlConvert.ToString(progress);
    //  node.Attributes.Append(idAttr);
    //  node.Attributes.Append(progressAttr);
    //  node.AppendChild(PersistenceManager.Persist("Engine", Engine, document, persistedObjects));
    //  return node;
    //}
    //public override void Populate(System.Xml.XmlNode node, IDictionary<Guid, IStorable> restoredObjects) {
    //  base.Populate(node, restoredObjects);
    //  JobId = XmlConvert.ToInt64(node.Attributes["JobId"].Value);
    //  progress = XmlConvert.ToDouble(node.Attributes["Progress"].Value);
    //  DeregisterEvents();
    //  engine = (SequentialEngine.SequentialEngine)PersistenceManager.Restore(node.SelectSingleNode("Engine"), restoredObjects);
    //  RegisterEvents();
    //}
  }
}