[3/4] git commit: ACCUMULO-2422 reset watch on non-delete events

[ec...@apache.org]

ACCUMULO-2422 reset watch on non-delete events


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/7d70ef58
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/7d70ef58
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/7d70ef58

Branch: refs/heads/1.6.0-SNAPSHOT
Commit: 7d70ef5848cf6b42752ec708e0442d4b7aa98c2f
Parents: a12bde8
Author: Eric Newton <er...@gmail.com>
Authored: Fri Feb 28 12:52:21 2014 -0500
Committer: Eric Newton <er...@gmail.com>
Committed: Fri Feb 28 12:52:21 2014 -0500

----------------------------------------------------------------------
 .../test/functional/BackupMasterIT.java         | 63 ++++++++++++++++++++
 1 file changed, 63 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/7d70ef58/test/src/test/java/org/apache/accumulo/test/functional/BackupMasterIT.java
----------------------------------------------------------------------
diff --git a/test/src/test/java/org/apache/accumulo/test/functional/BackupMasterIT.java b/test/src/test/java/org/apache/accumulo/test/functional/BackupMasterIT.java
new file mode 100644
index 0000000..8d530a7
--- /dev/null
+++ b/test/src/test/java/org/apache/accumulo/test/functional/BackupMasterIT.java
@@ -0,0 +1,63 @@
+/*
+ * 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.accumulo.test.functional;
+
+import java.util.Collections;
+import java.util.List;
+
+import org.apache.accumulo.fate.util.UtilWaitThread;
+import org.apache.accumulo.fate.zookeeper.ZooReaderWriter;
+import org.apache.accumulo.fate.zookeeper.ZooUtil.NodeMissingPolicy;
+import org.apache.accumulo.master.Master;
+import org.junit.Test;
+
+public class BackupMasterIT extends ConfigurableMacIT {
+
+  @Test(timeout= 10 * 1000)
+  public void test() throws Exception {
+    // wait for master
+    UtilWaitThread.sleep(1000);
+    // create a backup
+    Process backup = exec(Master.class);
+    try {
+      ZooReaderWriter writer = new ZooReaderWriter(cluster.getZooKeepers(), 30*1000, "digest", "accumulo:DONTTELL".getBytes());
+      String root = "/accumulo/" + getConnector().getInstance().getInstanceID();
+      List<String> children = Collections.emptyList();
+      // wait for 2 lock entries
+      do {
+        UtilWaitThread.sleep(100);
+        children = writer.getChildren(root + "/masters/lock");
+      } while (children.size() != 2);
+      Collections.sort(children);
+      // wait for the backup master to learn to be the backup
+      UtilWaitThread.sleep(1000);
+      // generate a false zookeeper event
+      String lockPath = root + "/masters/lock/" + children.get(0);
+      byte data[] = writer.getData(lockPath, null);
+      writer.getZooKeeper().setData(lockPath, data, -1);
+      // let it propagate
+      UtilWaitThread.sleep(500);
+      // kill the master by removing its lock
+      writer.recursiveDelete(lockPath, NodeMissingPolicy.FAIL);
+      // ensure the backup becomes the master
+      getConnector().tableOperations().create(getTableNames(1)[0]);
+    } finally {
+      backup.destroy();
+    }
+  }
+
+}