You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by dl...@apache.org on 2020/12/05 01:24:12 UTC

[asterixdb] 01/04: [NO ISSUE][ING] Set active entity as suspended on suspension success

This is an automated email from the ASF dual-hosted git repository.

dlych pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git

commit 70a7d5882f89f42b8653d8a4d9ebda37ace902c6
Author: Murtadha Hubail <mh...@apache.org>
AuthorDate: Thu Dec 3 20:32:04 2020 +0300

    [NO ISSUE][ING] Set active entity as suspended on suspension success
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Details:
    
    - When an active entity is suspended successfully, set the
      suspended flag regardless of the state.
    
    Change-Id: I42f8d92e1719103d94aa07801b987466e2c1a11d
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/9143
    Integration-Tests: Jenkins <je...@fulliautomatix.ics.uci.edu>
    Tested-by: Jenkins <je...@fulliautomatix.ics.uci.edu>
    Reviewed-by: Till Westmann <ti...@apache.org>
---
 .../java/org/apache/asterix/app/active/ActiveEntityEventsListener.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
index 0f5dec7..c90cde0 100644
--- a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
+++ b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
@@ -609,6 +609,7 @@ public abstract class ActiveEntityEventsListener implements IActiveEntityControl
             suspendTask.get();
             LOGGER.log(level, "waiting for state to become SUSPENDED or TEMPORARILY_FAILED");
             subscriber.sync();
+            suspended = true;
         } catch (Exception e) {
             synchronized (this) {
                 if (LOGGER.isErrorEnabled()) {