Changeset 2078 for trunk/sources/HeuristicLab.Grid.HiveBridge/3.2/HiveGridServerWrapper.cs

Timestamp:

06/22/09 15:10:03 (15 years ago)

Author:

gkronber

Message:

Snapshot results should be ignored in the HiveGridServerWrapper. Using Canceled property of the engine to discriminate between snapshots and final results. #642 (Hive backend for CEDMA)

File:

• trunk/sources/HeuristicLab.Grid.HiveBridge/3.2/HiveGridServerWrapper.cs (modified) (1 diff)

trunk/sources/HeuristicLab.Grid.HiveBridge/3.2/HiveGridServerWrapper.cs

@@ -70 +70 @@
         response.Success && response.Obj != null) {
         HeuristicLab.Hive.Engine.Job restoredJob = (HeuristicLab.Hive.Engine.Job)PersistenceManager.RestoreFromGZip(response.Obj.Result);
-        // Serialize the engine
-        MemoryStream memStream = new MemoryStream();
-        GZipStream stream = new GZipStream(memStream, CompressionMode.Compress, true);
-        XmlDocument document = PersistenceManager.CreateXmlDocument();
-        Dictionary<Guid, IStorable> dictionary = new Dictionary<Guid, IStorable>();
-        XmlNode rootNode = document.CreateElement("Root");
-        document.AppendChild(rootNode);
-        rootNode.AppendChild(PersistenceManager.Persist(restoredJob.Engine, document, dictionary));
-        document.Save(stream);
-        stream.Close();
-        return memStream.ToArray();
-      } else return null;
+        // only return the engine when it wasn't canceled (result is only a snapshot)
+        if (!restoredJob.Engine.Canceled) {
+          // Serialize the engine
+          MemoryStream memStream = new MemoryStream();
+          GZipStream stream = new GZipStream(memStream, CompressionMode.Compress, true);
+          XmlDocument document = PersistenceManager.CreateXmlDocument();
+          Dictionary<Guid, IStorable> dictionary = new Dictionary<Guid, IStorable>();
+          XmlNode rootNode = document.CreateElement("Root");
+          document.AppendChild(rootNode);
+          rootNode.AppendChild(PersistenceManager.Persist(restoredJob.Engine, document, dictionary));
+          document.Save(stream);
+          stream.Close();
+          return memStream.ToArray();
+        }
+      }
+
+      return null;
     }