Changeset 816 for trunk/sources/HeuristicLab.Hive.Client.ExecutionEngine/Executor.cs

Timestamp:

11/25/08 23:24:36 (16 years ago)

Author:

kgrading

Message:

implemented the persistance management (#390)

File:

• trunk/sources/HeuristicLab.Hive.Client.ExecutionEngine/Executor.cs (modified) (5 diffs)

trunk/sources/HeuristicLab.Hive.Client.ExecutionEngine/Executor.cs

@@ -29 +29 @@
 using System.IO;
 using HeuristicLab.Hive.Contracts;
+using HeuristicLab.Core;
 
 namespace HeuristicLab.Hive.Client.ExecutionEngine {
@@ -56 +57 @@
     }
 
-    public String GetSnapshot() {
+    public byte[] GetSnapshot() {
       //if the job is still running, something went VERY bad.
       if (Job.Running) {
@@ -64 +65 @@
         CurrentMessage = MessageContainer.MessageType.NoMessage;
         // Pack the whole job inside an xml document
-        String job = SerializeJobObject();        
+        byte[] job = SerializeJobObject();        
         // Restart the job
         Job.Start();
@@ -72 +73 @@
     }
 
-    public String GetFinishedJob() {
+    public byte[] GetFinishedJob() {
       //Job isn't finished!
       if (Job.Running) {
@@ -87 +88 @@
     }
 
-    private String SerializeJobObject() {
-      XmlSerializer serializer = new XmlSerializer(typeof(TestJob));
-      MemoryStream ms = new MemoryStream();
-      serializer.Serialize(ms, Job);
-      StreamReader reader = new StreamReader(ms);
-      return reader.ReadToEnd();       
+    private byte[] SerializeJobObject() {
+      return PersistenceManager.SaveToGZip(Job);
     }
 
-    private void RestoreJobObject(String serializedJob) {
-      System.Text.ASCIIEncoding  encoding=new System.Text.ASCIIEncoding();
-      XmlSerializer serializer = new XmlSerializer(typeof(TestJob));
-      MemoryStream ms = new MemoryStream();
-      ms.Write(encoding.GetBytes(serializedJob), 0, serializedJob.Length);
-      Job = (TestJob) serializer.Deserialize(ms);      
+    private void RestoreJobObject(byte[] sjob) {
+      Job = (IJob)PersistenceManager.RestoreFromGZip(sjob);
     }
 
     public Executor() {
       CurrentMessage = MessageContainer.MessageType.NoMessage;
+      Job = new TestJob();
     }    
   }