HBASE-11096 stop method of Master and RegionServer coprocessor is not invoked (Qiang Tian)

hbase-server/src/main/java/org/apache/hadoop/hbase/coprocessor/CoprocessorHost.java

@@ -254,6 +254,9 @@ public abstract class CoprocessorHost<E extends CoprocessorEnvironment> {
 
   public void shutdown(CoprocessorEnvironment e) {
     if (e instanceof Environment) {
+      if (LOG.isDebugEnabled()) {
+        LOG.debug("Stop coprocessor " + e.getInstance().getClass().getName());
+      }
       ((Environment)e).shutdown();
     } else {
       LOG.warn("Shutdown called on unknown environment: "+

hbase-server/src/main/java/org/apache/hadoop/hbase/master/MasterCoprocessorHost.java

@@ -1331,6 +1331,8 @@ public class MasterCoprocessorHost
           break;
         }
       }
+      // invoke coprocessor stop method
+      shutdown(env);
     }
   }
 
@@ -1353,6 +1355,8 @@ public class MasterCoprocessorHost
           break;
         }
       }
+      // invoke coprocessor stop method
+      shutdown(env);
     }
   }
 

hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegionServer.java

@@ -1629,6 +1629,7 @@ public class HRegionServer extends HasThread implements
 
   @Override
   public void stop(final String msg) {
+    if (!this.stopped) {
       try {
         if (this.rsHost != null) {
           this.rsHost.preStop(msg);
@@ -1641,6 +1642,7 @@ public class HRegionServer extends HasThread implements
         LOG.warn("The region server did not stop", exp);
       }
     }
+  }
 
   public void waitForServerOnline(){
     while (!isOnline() && !isStopped()){

hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.java

@@ -72,6 +72,8 @@ public class RegionServerCoprocessorHost extends
           break;
         }
       }
+      // invoke coprocessor stop method
+      shutdown(env);
     }
   }
 

hbase-server/src/test/java/org/apache/hadoop/hbase/coprocessor/TestCoprocessorStop.java

@@ -0,0 +1,125 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.hadoop.hbase.coprocessor;
+
+import java.io.IOException;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.*;
+import org.apache.hadoop.hbase.master.HMaster;
+import org.apache.hadoop.hbase.master.MasterCoprocessorHost;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.fs.FileSystem;
+
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+import static org.junit.Assert.assertTrue;
+
+
+/**
+ * Tests for master and regionserver coprocessor stop method
+ *
+ */
+@Category(MediumTests.class)
+public class TestCoprocessorStop {
+  private static final Log LOG = LogFactory.getLog(TestCoprocessorStop.class);
+  private static HBaseTestingUtility UTIL = new HBaseTestingUtility();
+  private static final String MASTER_FILE =
+                              "master" + System.currentTimeMillis();
+  private static final String REGIONSERVER_FILE =
+                              "regionserver" + System.currentTimeMillis();
+
+  public static class FooCoprocessor implements Coprocessor {
+    @Override
+    public void start(CoprocessorEnvironment env) throws IOException {
+      String where = null;
+
+      if (env instanceof MasterCoprocessorEnvironment) {
+        // if running on HMaster
+        where = "master";
+      } else if (env instanceof RegionServerCoprocessorEnvironment) {
+        where = "regionserver";
+      } else if (env instanceof RegionCoprocessorEnvironment) {
+        LOG.error("on RegionCoprocessorEnvironment!!");
+      }
+      LOG.info("start coprocessor on " + where);
+    }
+
+    @Override
+    public void stop(CoprocessorEnvironment env) throws IOException {
+      String fileName = null;
+
+      if (env instanceof MasterCoprocessorEnvironment) {
+        // if running on HMaster
+        fileName = MASTER_FILE;
+      } else if (env instanceof RegionServerCoprocessorEnvironment) {
+        fileName = REGIONSERVER_FILE;
+      } else if (env instanceof RegionCoprocessorEnvironment) {
+        LOG.error("on RegionCoprocessorEnvironment!!");
+      }
+
+      Configuration conf = UTIL.getConfiguration();
+      Path resultFile = new Path(UTIL.getDataTestDirOnTestFS(), fileName);
+      FileSystem fs = FileSystem.get(conf);
+
+      boolean result = fs.createNewFile(resultFile);
+      LOG.info("create file " + resultFile + " return rc " + result);
+    }
+  }
+
+  @BeforeClass
+  public static void setupBeforeClass() throws Exception {
+    Configuration conf = UTIL.getConfiguration();
+
+    conf.set(CoprocessorHost.MASTER_COPROCESSOR_CONF_KEY,
+      FooCoprocessor.class.getName());
+    conf.set(CoprocessorHost.REGIONSERVER_COPROCESSOR_CONF_KEY,
+      FooCoprocessor.class.getName());
+
+    UTIL.startMiniCluster();
+  }
+
+  @AfterClass
+  public static void tearDownAfterClass() throws Exception {
+    UTIL.shutdownMiniCluster();
+  }
+
+  @Test
+  public void testStopped() throws Exception {
+    //shutdown hbase only. then check flag file.
+    MiniHBaseCluster cluster = UTIL.getHBaseCluster();
+    LOG.info("shutdown hbase cluster...");
+    cluster.shutdown();
+    LOG.info("wait for the hbase cluster shutdown...");
+    cluster.waitUntilShutDown();
+
+    Configuration conf = UTIL.getConfiguration();
+    FileSystem fs = FileSystem.get(conf);
+
+    Path resultFile = new Path(UTIL.getDataTestDirOnTestFS(), MASTER_FILE);
+    assertTrue("Master flag file should have been created",fs.exists(resultFile));
+
+    resultFile = new Path(UTIL.getDataTestDirOnTestFS(), REGIONSERVER_FILE);
+    assertTrue("RegionServer flag file should have been created",fs.exists(resultFile));
+  }
+}