svn commit: r1464276 [2/2] - in /hbase/branches/0.95: hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/master/ hbase-server/src/main/java/org/apache/hadoop/hbase/replication/...

[st...@apache.org]

Modified: hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.java?rev=1464276&r1=1464275&r2=1464276&view=diff
==============================================================================
--- hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.java (original)
+++ hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.java Thu Apr  4 03:49:47 2013
@@ -225,7 +225,7 @@ public class TestReplicationSourceManage
   }
   
   @Test
-  public void testNodeFailoverWorkerCopyQueuesFromRSUsingMulti() throws Exception {
+  public void testClaimQueues() throws Exception {
     LOG.debug("testNodeFailoverWorkerCopyQueuesFromRSUsingMulti");
     conf.setBoolean(HConstants.ZOOKEEPER_USEMULTI, true);
     final Server server = new DummyServer("hostname0.example.org");
@@ -288,13 +288,13 @@ public class TestReplicationSourceManage
     // simulate three servers fail sequentially
     ReplicationZookeeper rz1 = new ReplicationZookeeper(s1, new AtomicBoolean(true));
     SortedMap<String, SortedSet<String>> testMap =
-        rz1.copyQueuesFromRSUsingMulti(server.getServerName().getServerName());
+        rz1.claimQueues(server.getServerName().getServerName());
     rz1.close();
     ReplicationZookeeper rz2 = new ReplicationZookeeper(s2, new AtomicBoolean(true));
-    testMap = rz2.copyQueuesFromRSUsingMulti(s1.getServerName().getServerName());
+    testMap = rz2.claimQueues(s1.getServerName().getServerName());
     rz2.close();
     ReplicationZookeeper rz3 = new ReplicationZookeeper(s3, new AtomicBoolean(true));
-    testMap = rz3.copyQueuesFromRSUsingMulti(s2.getServerName().getServerName());
+    testMap = rz3.claimQueues(s2.getServerName().getServerName());
     rz3.close();
 
     ReplicationSource s = new ReplicationSource();
@@ -327,7 +327,7 @@ public class TestReplicationSourceManage
     @Override
     public void run() {
       try {
-        logZnodesMap = rz.copyQueuesFromRSUsingMulti(deadRsZnode);
+        logZnodesMap = rz.claimQueues(deadRsZnode);
         rz.close();
         server.abort("Done with testing", null);
       } catch (Exception e) {