iota-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tonyfaust...@apache.org
Subject incubator-iota git commit: [IOTA-36] Fixing bug when checkpointing
Date Thu, 09 Feb 2017 19:47:48 GMT
Repository: incubator-iota
Updated Branches:
  refs/heads/master 49138d689 -> 119fe7d5a


[IOTA-36] Fixing bug when checkpointing


Project: http://git-wip-us.apache.org/repos/asf/incubator-iota/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-iota/commit/119fe7d5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-iota/tree/119fe7d5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-iota/diff/119fe7d5

Branch: refs/heads/master
Commit: 119fe7d5a9f899e192bde08ba2f91a413b8c3645
Parents: 49138d6
Author: Barbara Gomes <barbaramaltagomes@gmail.com>
Authored: Wed Feb 1 18:16:41 2017 -0800
Committer: Barbara Gomes <barbaramaltagomes@gmail.com>
Committed: Wed Feb 1 18:16:41 2017 -0800

----------------------------------------------------------------------
 fey-core/src/main/scala/org/apache/iota/fey/Utils.scala | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/119fe7d5/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
----------------------------------------------------------------------
diff --git a/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala b/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
index 3bf0eb8..5577ea6 100644
--- a/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
+++ b/fey-core/src/main/scala/org/apache/iota/fey/Utils.scala
@@ -137,6 +137,7 @@ protected object Utils {
               file.delete()
             }
             ORCHESTRATION_CACHE.orchestration_metadata.remove(orchestrationID)
+            ORCHESTRATION_CACHE.orchestration_globals.remove(orchestrationID)
             ORCHESTRATION_CACHE.orchestration_name.remove(orchestrationID)
           }
         case Some(orch) =>
@@ -145,10 +146,13 @@ protected object Utils {
             case Some(metadata) =>
               val ensembleJSON = metadata.map(ensenble => ensenble._2)
               val name: String = ORCHESTRATION_CACHE.orchestration_name.getOrElse(orchestrationID,
"NOT SAVED")
+              val globals = ORCHESTRATION_CACHE.orchestration_globals.getOrElse(orchestrationID,
HashMap.empty).map(global => global._2)
+
               val orchestrationSpec = Json.obj(JSON_PATH.GUID -> orchestrationID,
                 JSON_PATH.COMMAND -> "RECREATE",
                 JSON_PATH.ORCHESTRATION_NAME -> name,
                 JSON_PATH.ORCHESTRATION_TIMESTAMP -> System.currentTimeMillis.toString,
+                JSON_PATH.GLOBAL_PERFORMERS -> globals,
                 JSON_PATH.ENSEMBLES -> ensembleJSON
               )
 


Mime
View raw message