You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2013/04/06 08:06:09 UTC
svn commit: r1465198 [16/41] - in /hbase/hbase.apache.org/trunk: ./ css/
hbase-assembly/ images/ xref-test/ xref-test/org/apache/hadoop/hbase/
xref-test/org/apache/hadoop/hbase/client/
xref-test/org/apache/hadoop/hbase/client/replication/ xref-test/org...
Modified: hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/package-frame.html
URL: http://svn.apache.org/viewvc/hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/package-frame.html?rev=1465198&r1=1465197&r2=1465198&view=diff
==============================================================================
--- hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/package-frame.html (original)
+++ hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/package-frame.html Sat Apr 6 06:06:07 2013
@@ -49,6 +49,12 @@
<a href="TestReplicationSource.html" target="classFrame">TestReplicationSource</a>
</li>
<li>
+ <a href="TestReplicationStateBasic.html" target="classFrame">TestReplicationStateBasic</a>
+ </li>
+ <li>
+ <a href="TestReplicationStateZKImpl.html" target="classFrame">TestReplicationStateZKImpl</a>
+ </li>
+ <li>
<a href="TestReplicationZookeeper.html" target="classFrame">TestReplicationZookeeper</a>
</li>
</ul>
Modified: hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/package-summary.html
URL: http://svn.apache.org/viewvc/hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/package-summary.html?rev=1465198&r1=1465197&r2=1465198&view=diff
==============================================================================
--- hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/package-summary.html (original)
+++ hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/package-summary.html Sat Apr 6 06:06:07 2013
@@ -92,6 +92,16 @@
</tr>
<tr>
<td>
+ <a href="TestReplicationStateBasic.html" target="classFrame">TestReplicationStateBasic</a>
+ </td>
+ </tr>
+ <tr>
+ <td>
+ <a href="TestReplicationStateZKImpl.html" target="classFrame">TestReplicationStateZKImpl</a>
+ </td>
+ </tr>
+ <tr>
+ <td>
<a href="TestReplicationZookeeper.html" target="classFrame">TestReplicationZookeeper</a>
</td>
</tr>
Modified: hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html
URL: http://svn.apache.org/viewvc/hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html?rev=1465198&r1=1465197&r2=1465198&view=diff
==============================================================================
--- hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html (original)
+++ hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html Sat Apr 6 06:06:07 2013
@@ -235,7 +235,7 @@
<a class="jxr_linenumber" name="225" href="#225">225</a> }
<a class="jxr_linenumber" name="226" href="#226">226</a>
<a class="jxr_linenumber" name="227" href="#227">227</a> @Test
-<a class="jxr_linenumber" name="228" href="#228">228</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testNodeFailoverWorkerCopyQueuesFromRSUsingMulti() <strong class="jxr_keyword">throws</strong> Exception {
+<a class="jxr_linenumber" name="228" href="#228">228</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testClaimQueues() <strong class="jxr_keyword">throws</strong> Exception {
<a class="jxr_linenumber" name="229" href="#229">229</a> LOG.debug(<span class="jxr_string">"testNodeFailoverWorkerCopyQueuesFromRSUsingMulti"</span>);
<a class="jxr_linenumber" name="230" href="#230">230</a> conf.setBoolean(HConstants.ZOOKEEPER_USEMULTI, <strong class="jxr_keyword">true</strong>);
<a class="jxr_linenumber" name="231" href="#231">231</a> <strong class="jxr_keyword">final</strong> Server server = <strong class="jxr_keyword">new</strong> <a href="../../../../../../org/apache/hadoop/hbase/replication/TestReplicationZookeeper.html">DummyServer</a>(<span class="jxr_string">"hostname0.example.org"</span>);
@@ -298,13 +298,13 @@
<a class="jxr_linenumber" name="288" href="#288">288</a> <em class="jxr_comment">// simulate three servers fail sequentially</em>
<a class="jxr_linenumber" name="289" href="#289">289</a> ReplicationZookeeper rz1 = <strong class="jxr_keyword">new</strong> ReplicationZookeeper(s1, <strong class="jxr_keyword">new</strong> AtomicBoolean(<strong class="jxr_keyword">true</strong>));
<a class="jxr_linenumber" name="290" href="#290">290</a> SortedMap<String, SortedSet<String>> testMap =
-<a class="jxr_linenumber" name="291" href="#291">291</a> rz1.copyQueuesFromRSUsingMulti(server.getServerName().getServerName());
+<a class="jxr_linenumber" name="291" href="#291">291</a> rz1.claimQueues(server.getServerName().getServerName());
<a class="jxr_linenumber" name="292" href="#292">292</a> rz1.close();
<a class="jxr_linenumber" name="293" href="#293">293</a> ReplicationZookeeper rz2 = <strong class="jxr_keyword">new</strong> ReplicationZookeeper(s2, <strong class="jxr_keyword">new</strong> AtomicBoolean(<strong class="jxr_keyword">true</strong>));
-<a class="jxr_linenumber" name="294" href="#294">294</a> testMap = rz2.copyQueuesFromRSUsingMulti(s1.getServerName().getServerName());
+<a class="jxr_linenumber" name="294" href="#294">294</a> testMap = rz2.claimQueues(s1.getServerName().getServerName());
<a class="jxr_linenumber" name="295" href="#295">295</a> rz2.close();
<a class="jxr_linenumber" name="296" href="#296">296</a> ReplicationZookeeper rz3 = <strong class="jxr_keyword">new</strong> ReplicationZookeeper(s3, <strong class="jxr_keyword">new</strong> AtomicBoolean(<strong class="jxr_keyword">true</strong>));
-<a class="jxr_linenumber" name="297" href="#297">297</a> testMap = rz3.copyQueuesFromRSUsingMulti(s2.getServerName().getServerName());
+<a class="jxr_linenumber" name="297" href="#297">297</a> testMap = rz3.claimQueues(s2.getServerName().getServerName());
<a class="jxr_linenumber" name="298" href="#298">298</a> rz3.close();
<a class="jxr_linenumber" name="299" href="#299">299</a>
<a class="jxr_linenumber" name="300" href="#300">300</a> ReplicationSource s = <strong class="jxr_keyword">new</strong> ReplicationSource();
@@ -337,7 +337,7 @@
<a class="jxr_linenumber" name="327" href="#327">327</a> @Override
<a class="jxr_linenumber" name="328" href="#328">328</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> run() {
<a class="jxr_linenumber" name="329" href="#329">329</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="330" href="#330">330</a> logZnodesMap = rz.copyQueuesFromRSUsingMulti(deadRsZnode);
+<a class="jxr_linenumber" name="330" href="#330">330</a> logZnodesMap = rz.claimQueues(deadRsZnode);
<a class="jxr_linenumber" name="331" href="#331">331</a> rz.close();
<a class="jxr_linenumber" name="332" href="#332">332</a> server.abort(<span class="jxr_string">"Done with testing"</span>, <strong class="jxr_keyword">null</strong>);
<a class="jxr_linenumber" name="333" href="#333">333</a> } <strong class="jxr_keyword">catch</strong> (Exception e) {