iota-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tonyfaust...@apache.org
Subject [04/10] incubator-iota git commit: Cleanup ORCHESTRATION_CACHE.orchestration_metadata when orchestration is terminated.
Date Wed, 28 Sep 2016 01:19:14 GMT
Cleanup ORCHESTRATION_CACHE.orchestration_metadata when orchestration is terminated.


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

Branch: refs/heads/master
Commit: 8da99385e542479bf38e0c71c9ffbbe5e69540ef
Parents: a37164e
Author: Barbara Gomes <barbaramaltagomes@gmail.com>
Authored: Thu Jul 28 17:31:42 2016 -0700
Committer: Barbara Gomes <barbaramaltagomes@gmail.com>
Committed: Thu Jul 28 17:31:42 2016 -0700

----------------------------------------------------------------------
 fey-core/src/main/scala/org/apache/iota/fey/FeyCore.scala | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-iota/blob/8da99385/fey-core/src/main/scala/org/apache/iota/fey/FeyCore.scala
----------------------------------------------------------------------
diff --git a/fey-core/src/main/scala/org/apache/iota/fey/FeyCore.scala b/fey-core/src/main/scala/org/apache/iota/fey/FeyCore.scala
index 4909a0b..8541ee4 100644
--- a/fey-core/src/main/scala/org/apache/iota/fey/FeyCore.scala
+++ b/fey-core/src/main/scala/org/apache/iota/fey/FeyCore.scala
@@ -101,6 +101,7 @@ protected class FeyCore extends Actor with ActorLogging{
     monitoring_actor ! Monitor.TERMINATE(actorRef.path.toString, Utils.getTimestamp)
     log.info(s"TERMINATED ${actorRef.path.name}")
     FEY_CACHE.activeOrchestrations.remove(actorRef.path.name)
+    ORCHESTRATION_CACHE.orchestration_metadata.remove(actorRef.path.name)
     if(!FEY_CACHE.orchestrationsAwaitingTermination.isEmpty) {
       checkForOrchestrationWaitingForTermination(actorRef.path.name)
     }


Mime
View raw message