From e9aaf12f6e872f5ecd082c2f7455b37d08193535 Mon Sep 17 00:00:00 2001
From: larsh <larsh@unknown>
Date: Thu, 19 Jul 2012 04:30:13 +0000
Subject: [PATCH] HBASE-6406 Remove TestReplicationPeer

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1363217 13f79535-47bb-0310-9956-ffa450edef68
---
 .../replication/TestReplicationPeer.java      | 85 -------------------
 1 file changed, 85 deletions(-)
 delete mode 100644 hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationPeer.java

diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationPeer.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationPeer.java
deleted file mode 100644
index 1922d60a77f..00000000000
--- a/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationPeer.java
+++ /dev/null
@@ -1,85 +0,0 @@
-/*
- * 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.replication;
-
-import junit.framework.Assert;
-
-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.zookeeper.ZooKeeperWatcher;
-import org.apache.zookeeper.KeeperException;
-import org.apache.zookeeper.KeeperException.SessionExpiredException;
-import org.junit.*;
-import org.junit.experimental.categories.Category;
-
-@Category(MediumTests.class)
-public class TestReplicationPeer {
-
-  private static final Log LOG = LogFactory.getLog(TestReplicationPeer.class);
-  private static HBaseTestingUtility utility;
-  private static Configuration conf;
-  private static ReplicationPeer rp;
-
-  @BeforeClass
-  public static void setUpBeforeClass() throws Exception {
-    conf = HBaseConfiguration.create();
-    utility = new HBaseTestingUtility(conf);
-    conf = utility.getConfiguration();
-    utility.startMiniZKCluster();
-
-    rp = new ReplicationPeer(conf, "clusterKey", "clusterId");
-  }
-
-
-  @Test(timeout=300000)
-  public void testResetZooKeeperSession() throws Exception {
-    ZooKeeperWatcher zkw = rp.getZkw();
-    zkw.getRecoverableZooKeeper().exists("/1/2", false);
-
-    LOG.info("Expiring ReplicationPeer ZooKeeper session.");
-    utility.expireSession(zkw);
-
-    try {
-      LOG.info("Attempting to use expired ReplicationPeer ZooKeeper session.");
-      // Trying to use the expired session to assert that it is indeed closed
-      zkw.getRecoverableZooKeeper().getZooKeeper().exists("/2/2", false);
-      Assert.fail(
-        "ReplicationPeer ZooKeeper session was not properly expired.");
-    } catch (SessionExpiredException k) {
-      rp.reloadZkWatcher();
-
-      zkw = rp.getZkw();
-
-      // Try to use the connection again
-      LOG.info("Attempting to use refreshed "
-        + "ReplicationPeer ZooKeeper session.");
-      zkw.getRecoverableZooKeeper().exists("/3/2", false);
-
-    } catch (KeeperException.ConnectionLossException ignored) {
-      // We sometimes receive this exception. We just ignore it.
-    }
-  }
-
-
-  @org.junit.Rule
-  public org.apache.hadoop.hbase.ResourceCheckerJUnitRule cu =
-    new org.apache.hadoop.hbase.ResourceCheckerJUnitRule();
-}
-