You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by mh...@apache.org on 2018/10/27 21:19:51 UTC

asterixdb-bad git commit: [NO ISSUE][BAD] Coordinated Change For Active Suspend Refactoring

Repository: asterixdb-bad
Updated Branches:
  refs/heads/master eebcbe598 -> 64c2ad2ef


[NO ISSUE][BAD] Coordinated Change For Active Suspend Refactoring

Change-Id: Ifb40d76f208b7f42184f70b0e25d05f1875b4486


Project: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/repo
Commit: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/commit/64c2ad2e
Tree: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/tree/64c2ad2e
Diff: http://git-wip-us.apache.org/repos/asf/asterixdb-bad/diff/64c2ad2e

Branch: refs/heads/master
Commit: 64c2ad2ef5cbda81c282e4d88843957ab68aa3e4
Parents: eebcbe5
Author: Murtadha Hubail <mu...@couchbase.com>
Authored: Thu Oct 18 09:53:39 2018 +0300
Committer: Murtadha Hubail <mu...@couchbase.com>
Committed: Thu Oct 18 09:53:39 2018 +0300

----------------------------------------------------------------------
 .../asterix/bad/metadata/DeployedJobSpecEventListener.java      | 5 +++++
 1 file changed, 5 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/asterixdb-bad/blob/64c2ad2e/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java
----------------------------------------------------------------------
diff --git a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java
index 3ec2c43..70e780e 100644
--- a/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java
+++ b/asterix-bad/src/main/java/org/apache/asterix/bad/metadata/DeployedJobSpecEventListener.java
@@ -217,4 +217,9 @@ public class DeployedJobSpecEventListener implements IActiveEntityEventsListener
     public int getRunningInstance() {
         return runningInstance;
     }
+
+    @Override
+    public synchronized boolean isSuspended() {
+        return state == ActivityState.SUSPENDED;
+    }
 }