hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject [08/35] hbase-site git commit: Published site at 9250bf809155ebe93fd6ae8a0485b22c744fdf70.
Date Tue, 15 Nov 2016 05:45:59 GMT
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f17356a7/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyNodeFailoverWorker.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyNodeFailoverWorker.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyNodeFailoverWorker.html
index 9da7348..d3a77ec 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyNodeFailoverWorker.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyNodeFailoverWorker.html
@@ -551,121 +551,123 @@
 <span class="sourceLineNo">543</span>        List&lt;String&gt; queues = rq.getUnClaimedQueueIds(deadRsZnode);<a name="line.543"></a>
 <span class="sourceLineNo">544</span>        for(String queue:queues){<a name="line.544"></a>
 <span class="sourceLineNo">545</span>          Pair&lt;String, SortedSet&lt;String&gt;&gt; pair = rq.claimQueue(deadRsZnode, queue);<a name="line.545"></a>
-<span class="sourceLineNo">546</span>          logZnodesMap.put(pair.getFirst(), pair.getSecond());<a name="line.546"></a>
-<span class="sourceLineNo">547</span>        }<a name="line.547"></a>
-<span class="sourceLineNo">548</span>        server.abort("Done with testing", null);<a name="line.548"></a>
-<span class="sourceLineNo">549</span>      } catch (Exception e) {<a name="line.549"></a>
-<span class="sourceLineNo">550</span>        LOG.error("Got exception while running NodeFailoverWorker", e);<a name="line.550"></a>
-<span class="sourceLineNo">551</span>      } finally {<a name="line.551"></a>
-<span class="sourceLineNo">552</span>        latch.countDown();<a name="line.552"></a>
-<span class="sourceLineNo">553</span>      }<a name="line.553"></a>
-<span class="sourceLineNo">554</span>    }<a name="line.554"></a>
-<span class="sourceLineNo">555</span><a name="line.555"></a>
-<span class="sourceLineNo">556</span>    /**<a name="line.556"></a>
-<span class="sourceLineNo">557</span>     * @return 1 when the map is not empty.<a name="line.557"></a>
-<span class="sourceLineNo">558</span>     */<a name="line.558"></a>
-<span class="sourceLineNo">559</span>    private int isLogZnodesMapPopulated() {<a name="line.559"></a>
-<span class="sourceLineNo">560</span>      Collection&lt;Set&lt;String&gt;&gt; sets = logZnodesMap.values();<a name="line.560"></a>
-<span class="sourceLineNo">561</span>      if (sets.size() &gt; 1) {<a name="line.561"></a>
-<span class="sourceLineNo">562</span>        throw new RuntimeException("unexpected size of logZnodesMap: " + sets.size());<a name="line.562"></a>
-<span class="sourceLineNo">563</span>      }<a name="line.563"></a>
-<span class="sourceLineNo">564</span>      if (sets.size() == 1) {<a name="line.564"></a>
-<span class="sourceLineNo">565</span>        Set&lt;String&gt; s = sets.iterator().next();<a name="line.565"></a>
-<span class="sourceLineNo">566</span>        for (String file : files) {<a name="line.566"></a>
-<span class="sourceLineNo">567</span>          // at least one file was missing<a name="line.567"></a>
-<span class="sourceLineNo">568</span>          if (!s.contains(file)) {<a name="line.568"></a>
-<span class="sourceLineNo">569</span>            return 0;<a name="line.569"></a>
-<span class="sourceLineNo">570</span>          }<a name="line.570"></a>
-<span class="sourceLineNo">571</span>        }<a name="line.571"></a>
-<span class="sourceLineNo">572</span>        return 1; // we found all the files<a name="line.572"></a>
-<span class="sourceLineNo">573</span>      }<a name="line.573"></a>
-<span class="sourceLineNo">574</span>      return 0;<a name="line.574"></a>
-<span class="sourceLineNo">575</span>    }<a name="line.575"></a>
-<span class="sourceLineNo">576</span>  }<a name="line.576"></a>
-<span class="sourceLineNo">577</span><a name="line.577"></a>
-<span class="sourceLineNo">578</span>  static class FailInitializeDummyReplicationSource extends ReplicationSourceDummy {<a name="line.578"></a>
+<span class="sourceLineNo">546</span>          if (pair != null) {<a name="line.546"></a>
+<span class="sourceLineNo">547</span>            logZnodesMap.put(pair.getFirst(), pair.getSecond());<a name="line.547"></a>
+<span class="sourceLineNo">548</span>          }<a name="line.548"></a>
+<span class="sourceLineNo">549</span>        }<a name="line.549"></a>
+<span class="sourceLineNo">550</span>        server.abort("Done with testing", null);<a name="line.550"></a>
+<span class="sourceLineNo">551</span>      } catch (Exception e) {<a name="line.551"></a>
+<span class="sourceLineNo">552</span>        LOG.error("Got exception while running NodeFailoverWorker", e);<a name="line.552"></a>
+<span class="sourceLineNo">553</span>      } finally {<a name="line.553"></a>
+<span class="sourceLineNo">554</span>        latch.countDown();<a name="line.554"></a>
+<span class="sourceLineNo">555</span>      }<a name="line.555"></a>
+<span class="sourceLineNo">556</span>    }<a name="line.556"></a>
+<span class="sourceLineNo">557</span><a name="line.557"></a>
+<span class="sourceLineNo">558</span>    /**<a name="line.558"></a>
+<span class="sourceLineNo">559</span>     * @return 1 when the map is not empty.<a name="line.559"></a>
+<span class="sourceLineNo">560</span>     */<a name="line.560"></a>
+<span class="sourceLineNo">561</span>    private int isLogZnodesMapPopulated() {<a name="line.561"></a>
+<span class="sourceLineNo">562</span>      Collection&lt;Set&lt;String&gt;&gt; sets = logZnodesMap.values();<a name="line.562"></a>
+<span class="sourceLineNo">563</span>      if (sets.size() &gt; 1) {<a name="line.563"></a>
+<span class="sourceLineNo">564</span>        throw new RuntimeException("unexpected size of logZnodesMap: " + sets.size());<a name="line.564"></a>
+<span class="sourceLineNo">565</span>      }<a name="line.565"></a>
+<span class="sourceLineNo">566</span>      if (sets.size() == 1) {<a name="line.566"></a>
+<span class="sourceLineNo">567</span>        Set&lt;String&gt; s = sets.iterator().next();<a name="line.567"></a>
+<span class="sourceLineNo">568</span>        for (String file : files) {<a name="line.568"></a>
+<span class="sourceLineNo">569</span>          // at least one file was missing<a name="line.569"></a>
+<span class="sourceLineNo">570</span>          if (!s.contains(file)) {<a name="line.570"></a>
+<span class="sourceLineNo">571</span>            return 0;<a name="line.571"></a>
+<span class="sourceLineNo">572</span>          }<a name="line.572"></a>
+<span class="sourceLineNo">573</span>        }<a name="line.573"></a>
+<span class="sourceLineNo">574</span>        return 1; // we found all the files<a name="line.574"></a>
+<span class="sourceLineNo">575</span>      }<a name="line.575"></a>
+<span class="sourceLineNo">576</span>      return 0;<a name="line.576"></a>
+<span class="sourceLineNo">577</span>    }<a name="line.577"></a>
+<span class="sourceLineNo">578</span>  }<a name="line.578"></a>
 <span class="sourceLineNo">579</span><a name="line.579"></a>
-<span class="sourceLineNo">580</span>    @Override<a name="line.580"></a>
-<span class="sourceLineNo">581</span>    public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager,<a name="line.581"></a>
-<span class="sourceLineNo">582</span>        ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId,<a name="line.582"></a>
-<span class="sourceLineNo">583</span>        UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics)<a name="line.583"></a>
-<span class="sourceLineNo">584</span>        throws IOException {<a name="line.584"></a>
-<span class="sourceLineNo">585</span>      throw new IOException("Failing deliberately");<a name="line.585"></a>
-<span class="sourceLineNo">586</span>    }<a name="line.586"></a>
-<span class="sourceLineNo">587</span>  }<a name="line.587"></a>
-<span class="sourceLineNo">588</span><a name="line.588"></a>
-<span class="sourceLineNo">589</span>  static class DummyServer implements Server {<a name="line.589"></a>
-<span class="sourceLineNo">590</span>    String hostname;<a name="line.590"></a>
-<span class="sourceLineNo">591</span><a name="line.591"></a>
-<span class="sourceLineNo">592</span>    DummyServer() {<a name="line.592"></a>
-<span class="sourceLineNo">593</span>      hostname = "hostname.example.org";<a name="line.593"></a>
-<span class="sourceLineNo">594</span>    }<a name="line.594"></a>
-<span class="sourceLineNo">595</span><a name="line.595"></a>
-<span class="sourceLineNo">596</span>    DummyServer(String hostname) {<a name="line.596"></a>
-<span class="sourceLineNo">597</span>      this.hostname = hostname;<a name="line.597"></a>
-<span class="sourceLineNo">598</span>    }<a name="line.598"></a>
-<span class="sourceLineNo">599</span><a name="line.599"></a>
-<span class="sourceLineNo">600</span>    @Override<a name="line.600"></a>
-<span class="sourceLineNo">601</span>    public Configuration getConfiguration() {<a name="line.601"></a>
-<span class="sourceLineNo">602</span>      return conf;<a name="line.602"></a>
-<span class="sourceLineNo">603</span>    }<a name="line.603"></a>
-<span class="sourceLineNo">604</span><a name="line.604"></a>
-<span class="sourceLineNo">605</span>    @Override<a name="line.605"></a>
-<span class="sourceLineNo">606</span>    public ZooKeeperWatcher getZooKeeper() {<a name="line.606"></a>
-<span class="sourceLineNo">607</span>      return zkw;<a name="line.607"></a>
-<span class="sourceLineNo">608</span>    }<a name="line.608"></a>
-<span class="sourceLineNo">609</span><a name="line.609"></a>
-<span class="sourceLineNo">610</span>    @Override<a name="line.610"></a>
-<span class="sourceLineNo">611</span>    public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.611"></a>
-<span class="sourceLineNo">612</span>      return null;<a name="line.612"></a>
-<span class="sourceLineNo">613</span>    }<a name="line.613"></a>
-<span class="sourceLineNo">614</span>    @Override<a name="line.614"></a>
-<span class="sourceLineNo">615</span>    public ClusterConnection getConnection() {<a name="line.615"></a>
-<span class="sourceLineNo">616</span>      return null;<a name="line.616"></a>
-<span class="sourceLineNo">617</span>    }<a name="line.617"></a>
-<span class="sourceLineNo">618</span><a name="line.618"></a>
-<span class="sourceLineNo">619</span>    @Override<a name="line.619"></a>
-<span class="sourceLineNo">620</span>    public MetaTableLocator getMetaTableLocator() {<a name="line.620"></a>
-<span class="sourceLineNo">621</span>      return null;<a name="line.621"></a>
-<span class="sourceLineNo">622</span>    }<a name="line.622"></a>
-<span class="sourceLineNo">623</span><a name="line.623"></a>
-<span class="sourceLineNo">624</span>    @Override<a name="line.624"></a>
-<span class="sourceLineNo">625</span>    public ServerName getServerName() {<a name="line.625"></a>
-<span class="sourceLineNo">626</span>      return ServerName.valueOf(hostname, 1234, 1L);<a name="line.626"></a>
-<span class="sourceLineNo">627</span>    }<a name="line.627"></a>
-<span class="sourceLineNo">628</span><a name="line.628"></a>
-<span class="sourceLineNo">629</span>    @Override<a name="line.629"></a>
-<span class="sourceLineNo">630</span>    public void abort(String why, Throwable e) {<a name="line.630"></a>
-<span class="sourceLineNo">631</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.631"></a>
-<span class="sourceLineNo">632</span>    }<a name="line.632"></a>
-<span class="sourceLineNo">633</span><a name="line.633"></a>
-<span class="sourceLineNo">634</span>    @Override<a name="line.634"></a>
-<span class="sourceLineNo">635</span>    public boolean isAborted() {<a name="line.635"></a>
-<span class="sourceLineNo">636</span>      return false;<a name="line.636"></a>
-<span class="sourceLineNo">637</span>    }<a name="line.637"></a>
-<span class="sourceLineNo">638</span><a name="line.638"></a>
-<span class="sourceLineNo">639</span>    @Override<a name="line.639"></a>
-<span class="sourceLineNo">640</span>    public void stop(String why) {<a name="line.640"></a>
-<span class="sourceLineNo">641</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.641"></a>
-<span class="sourceLineNo">642</span>    }<a name="line.642"></a>
-<span class="sourceLineNo">643</span><a name="line.643"></a>
-<span class="sourceLineNo">644</span>    @Override<a name="line.644"></a>
-<span class="sourceLineNo">645</span>    public boolean isStopped() {<a name="line.645"></a>
-<span class="sourceLineNo">646</span>      return false; // To change body of implemented methods use File | Settings | File Templates.<a name="line.646"></a>
-<span class="sourceLineNo">647</span>    }<a name="line.647"></a>
-<span class="sourceLineNo">648</span><a name="line.648"></a>
-<span class="sourceLineNo">649</span>    @Override<a name="line.649"></a>
-<span class="sourceLineNo">650</span>    public ChoreService getChoreService() {<a name="line.650"></a>
-<span class="sourceLineNo">651</span>      return null;<a name="line.651"></a>
-<span class="sourceLineNo">652</span>    }<a name="line.652"></a>
-<span class="sourceLineNo">653</span><a name="line.653"></a>
-<span class="sourceLineNo">654</span>    @Override<a name="line.654"></a>
-<span class="sourceLineNo">655</span>    public ClusterConnection getClusterConnection() {<a name="line.655"></a>
-<span class="sourceLineNo">656</span>      // TODO Auto-generated method stub<a name="line.656"></a>
-<span class="sourceLineNo">657</span>      return null;<a name="line.657"></a>
-<span class="sourceLineNo">658</span>    }<a name="line.658"></a>
-<span class="sourceLineNo">659</span>  }<a name="line.659"></a>
-<span class="sourceLineNo">660</span>}<a name="line.660"></a>
+<span class="sourceLineNo">580</span>  static class FailInitializeDummyReplicationSource extends ReplicationSourceDummy {<a name="line.580"></a>
+<span class="sourceLineNo">581</span><a name="line.581"></a>
+<span class="sourceLineNo">582</span>    @Override<a name="line.582"></a>
+<span class="sourceLineNo">583</span>    public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager,<a name="line.583"></a>
+<span class="sourceLineNo">584</span>        ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId,<a name="line.584"></a>
+<span class="sourceLineNo">585</span>        UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics)<a name="line.585"></a>
+<span class="sourceLineNo">586</span>        throws IOException {<a name="line.586"></a>
+<span class="sourceLineNo">587</span>      throw new IOException("Failing deliberately");<a name="line.587"></a>
+<span class="sourceLineNo">588</span>    }<a name="line.588"></a>
+<span class="sourceLineNo">589</span>  }<a name="line.589"></a>
+<span class="sourceLineNo">590</span><a name="line.590"></a>
+<span class="sourceLineNo">591</span>  static class DummyServer implements Server {<a name="line.591"></a>
+<span class="sourceLineNo">592</span>    String hostname;<a name="line.592"></a>
+<span class="sourceLineNo">593</span><a name="line.593"></a>
+<span class="sourceLineNo">594</span>    DummyServer() {<a name="line.594"></a>
+<span class="sourceLineNo">595</span>      hostname = "hostname.example.org";<a name="line.595"></a>
+<span class="sourceLineNo">596</span>    }<a name="line.596"></a>
+<span class="sourceLineNo">597</span><a name="line.597"></a>
+<span class="sourceLineNo">598</span>    DummyServer(String hostname) {<a name="line.598"></a>
+<span class="sourceLineNo">599</span>      this.hostname = hostname;<a name="line.599"></a>
+<span class="sourceLineNo">600</span>    }<a name="line.600"></a>
+<span class="sourceLineNo">601</span><a name="line.601"></a>
+<span class="sourceLineNo">602</span>    @Override<a name="line.602"></a>
+<span class="sourceLineNo">603</span>    public Configuration getConfiguration() {<a name="line.603"></a>
+<span class="sourceLineNo">604</span>      return conf;<a name="line.604"></a>
+<span class="sourceLineNo">605</span>    }<a name="line.605"></a>
+<span class="sourceLineNo">606</span><a name="line.606"></a>
+<span class="sourceLineNo">607</span>    @Override<a name="line.607"></a>
+<span class="sourceLineNo">608</span>    public ZooKeeperWatcher getZooKeeper() {<a name="line.608"></a>
+<span class="sourceLineNo">609</span>      return zkw;<a name="line.609"></a>
+<span class="sourceLineNo">610</span>    }<a name="line.610"></a>
+<span class="sourceLineNo">611</span><a name="line.611"></a>
+<span class="sourceLineNo">612</span>    @Override<a name="line.612"></a>
+<span class="sourceLineNo">613</span>    public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.613"></a>
+<span class="sourceLineNo">614</span>      return null;<a name="line.614"></a>
+<span class="sourceLineNo">615</span>    }<a name="line.615"></a>
+<span class="sourceLineNo">616</span>    @Override<a name="line.616"></a>
+<span class="sourceLineNo">617</span>    public ClusterConnection getConnection() {<a name="line.617"></a>
+<span class="sourceLineNo">618</span>      return null;<a name="line.618"></a>
+<span class="sourceLineNo">619</span>    }<a name="line.619"></a>
+<span class="sourceLineNo">620</span><a name="line.620"></a>
+<span class="sourceLineNo">621</span>    @Override<a name="line.621"></a>
+<span class="sourceLineNo">622</span>    public MetaTableLocator getMetaTableLocator() {<a name="line.622"></a>
+<span class="sourceLineNo">623</span>      return null;<a name="line.623"></a>
+<span class="sourceLineNo">624</span>    }<a name="line.624"></a>
+<span class="sourceLineNo">625</span><a name="line.625"></a>
+<span class="sourceLineNo">626</span>    @Override<a name="line.626"></a>
+<span class="sourceLineNo">627</span>    public ServerName getServerName() {<a name="line.627"></a>
+<span class="sourceLineNo">628</span>      return ServerName.valueOf(hostname, 1234, 1L);<a name="line.628"></a>
+<span class="sourceLineNo">629</span>    }<a name="line.629"></a>
+<span class="sourceLineNo">630</span><a name="line.630"></a>
+<span class="sourceLineNo">631</span>    @Override<a name="line.631"></a>
+<span class="sourceLineNo">632</span>    public void abort(String why, Throwable e) {<a name="line.632"></a>
+<span class="sourceLineNo">633</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.633"></a>
+<span class="sourceLineNo">634</span>    }<a name="line.634"></a>
+<span class="sourceLineNo">635</span><a name="line.635"></a>
+<span class="sourceLineNo">636</span>    @Override<a name="line.636"></a>
+<span class="sourceLineNo">637</span>    public boolean isAborted() {<a name="line.637"></a>
+<span class="sourceLineNo">638</span>      return false;<a name="line.638"></a>
+<span class="sourceLineNo">639</span>    }<a name="line.639"></a>
+<span class="sourceLineNo">640</span><a name="line.640"></a>
+<span class="sourceLineNo">641</span>    @Override<a name="line.641"></a>
+<span class="sourceLineNo">642</span>    public void stop(String why) {<a name="line.642"></a>
+<span class="sourceLineNo">643</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.643"></a>
+<span class="sourceLineNo">644</span>    }<a name="line.644"></a>
+<span class="sourceLineNo">645</span><a name="line.645"></a>
+<span class="sourceLineNo">646</span>    @Override<a name="line.646"></a>
+<span class="sourceLineNo">647</span>    public boolean isStopped() {<a name="line.647"></a>
+<span class="sourceLineNo">648</span>      return false; // To change body of implemented methods use File | Settings | File Templates.<a name="line.648"></a>
+<span class="sourceLineNo">649</span>    }<a name="line.649"></a>
+<span class="sourceLineNo">650</span><a name="line.650"></a>
+<span class="sourceLineNo">651</span>    @Override<a name="line.651"></a>
+<span class="sourceLineNo">652</span>    public ChoreService getChoreService() {<a name="line.652"></a>
+<span class="sourceLineNo">653</span>      return null;<a name="line.653"></a>
+<span class="sourceLineNo">654</span>    }<a name="line.654"></a>
+<span class="sourceLineNo">655</span><a name="line.655"></a>
+<span class="sourceLineNo">656</span>    @Override<a name="line.656"></a>
+<span class="sourceLineNo">657</span>    public ClusterConnection getClusterConnection() {<a name="line.657"></a>
+<span class="sourceLineNo">658</span>      // TODO Auto-generated method stub<a name="line.658"></a>
+<span class="sourceLineNo">659</span>      return null;<a name="line.659"></a>
+<span class="sourceLineNo">660</span>    }<a name="line.660"></a>
+<span class="sourceLineNo">661</span>  }<a name="line.661"></a>
+<span class="sourceLineNo">662</span>}<a name="line.662"></a>
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f17356a7/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyServer.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyServer.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyServer.html
index 9da7348..d3a77ec 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyServer.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.DummyServer.html
@@ -551,121 +551,123 @@
 <span class="sourceLineNo">543</span>        List&lt;String&gt; queues = rq.getUnClaimedQueueIds(deadRsZnode);<a name="line.543"></a>
 <span class="sourceLineNo">544</span>        for(String queue:queues){<a name="line.544"></a>
 <span class="sourceLineNo">545</span>          Pair&lt;String, SortedSet&lt;String&gt;&gt; pair = rq.claimQueue(deadRsZnode, queue);<a name="line.545"></a>
-<span class="sourceLineNo">546</span>          logZnodesMap.put(pair.getFirst(), pair.getSecond());<a name="line.546"></a>
-<span class="sourceLineNo">547</span>        }<a name="line.547"></a>
-<span class="sourceLineNo">548</span>        server.abort("Done with testing", null);<a name="line.548"></a>
-<span class="sourceLineNo">549</span>      } catch (Exception e) {<a name="line.549"></a>
-<span class="sourceLineNo">550</span>        LOG.error("Got exception while running NodeFailoverWorker", e);<a name="line.550"></a>
-<span class="sourceLineNo">551</span>      } finally {<a name="line.551"></a>
-<span class="sourceLineNo">552</span>        latch.countDown();<a name="line.552"></a>
-<span class="sourceLineNo">553</span>      }<a name="line.553"></a>
-<span class="sourceLineNo">554</span>    }<a name="line.554"></a>
-<span class="sourceLineNo">555</span><a name="line.555"></a>
-<span class="sourceLineNo">556</span>    /**<a name="line.556"></a>
-<span class="sourceLineNo">557</span>     * @return 1 when the map is not empty.<a name="line.557"></a>
-<span class="sourceLineNo">558</span>     */<a name="line.558"></a>
-<span class="sourceLineNo">559</span>    private int isLogZnodesMapPopulated() {<a name="line.559"></a>
-<span class="sourceLineNo">560</span>      Collection&lt;Set&lt;String&gt;&gt; sets = logZnodesMap.values();<a name="line.560"></a>
-<span class="sourceLineNo">561</span>      if (sets.size() &gt; 1) {<a name="line.561"></a>
-<span class="sourceLineNo">562</span>        throw new RuntimeException("unexpected size of logZnodesMap: " + sets.size());<a name="line.562"></a>
-<span class="sourceLineNo">563</span>      }<a name="line.563"></a>
-<span class="sourceLineNo">564</span>      if (sets.size() == 1) {<a name="line.564"></a>
-<span class="sourceLineNo">565</span>        Set&lt;String&gt; s = sets.iterator().next();<a name="line.565"></a>
-<span class="sourceLineNo">566</span>        for (String file : files) {<a name="line.566"></a>
-<span class="sourceLineNo">567</span>          // at least one file was missing<a name="line.567"></a>
-<span class="sourceLineNo">568</span>          if (!s.contains(file)) {<a name="line.568"></a>
-<span class="sourceLineNo">569</span>            return 0;<a name="line.569"></a>
-<span class="sourceLineNo">570</span>          }<a name="line.570"></a>
-<span class="sourceLineNo">571</span>        }<a name="line.571"></a>
-<span class="sourceLineNo">572</span>        return 1; // we found all the files<a name="line.572"></a>
-<span class="sourceLineNo">573</span>      }<a name="line.573"></a>
-<span class="sourceLineNo">574</span>      return 0;<a name="line.574"></a>
-<span class="sourceLineNo">575</span>    }<a name="line.575"></a>
-<span class="sourceLineNo">576</span>  }<a name="line.576"></a>
-<span class="sourceLineNo">577</span><a name="line.577"></a>
-<span class="sourceLineNo">578</span>  static class FailInitializeDummyReplicationSource extends ReplicationSourceDummy {<a name="line.578"></a>
+<span class="sourceLineNo">546</span>          if (pair != null) {<a name="line.546"></a>
+<span class="sourceLineNo">547</span>            logZnodesMap.put(pair.getFirst(), pair.getSecond());<a name="line.547"></a>
+<span class="sourceLineNo">548</span>          }<a name="line.548"></a>
+<span class="sourceLineNo">549</span>        }<a name="line.549"></a>
+<span class="sourceLineNo">550</span>        server.abort("Done with testing", null);<a name="line.550"></a>
+<span class="sourceLineNo">551</span>      } catch (Exception e) {<a name="line.551"></a>
+<span class="sourceLineNo">552</span>        LOG.error("Got exception while running NodeFailoverWorker", e);<a name="line.552"></a>
+<span class="sourceLineNo">553</span>      } finally {<a name="line.553"></a>
+<span class="sourceLineNo">554</span>        latch.countDown();<a name="line.554"></a>
+<span class="sourceLineNo">555</span>      }<a name="line.555"></a>
+<span class="sourceLineNo">556</span>    }<a name="line.556"></a>
+<span class="sourceLineNo">557</span><a name="line.557"></a>
+<span class="sourceLineNo">558</span>    /**<a name="line.558"></a>
+<span class="sourceLineNo">559</span>     * @return 1 when the map is not empty.<a name="line.559"></a>
+<span class="sourceLineNo">560</span>     */<a name="line.560"></a>
+<span class="sourceLineNo">561</span>    private int isLogZnodesMapPopulated() {<a name="line.561"></a>
+<span class="sourceLineNo">562</span>      Collection&lt;Set&lt;String&gt;&gt; sets = logZnodesMap.values();<a name="line.562"></a>
+<span class="sourceLineNo">563</span>      if (sets.size() &gt; 1) {<a name="line.563"></a>
+<span class="sourceLineNo">564</span>        throw new RuntimeException("unexpected size of logZnodesMap: " + sets.size());<a name="line.564"></a>
+<span class="sourceLineNo">565</span>      }<a name="line.565"></a>
+<span class="sourceLineNo">566</span>      if (sets.size() == 1) {<a name="line.566"></a>
+<span class="sourceLineNo">567</span>        Set&lt;String&gt; s = sets.iterator().next();<a name="line.567"></a>
+<span class="sourceLineNo">568</span>        for (String file : files) {<a name="line.568"></a>
+<span class="sourceLineNo">569</span>          // at least one file was missing<a name="line.569"></a>
+<span class="sourceLineNo">570</span>          if (!s.contains(file)) {<a name="line.570"></a>
+<span class="sourceLineNo">571</span>            return 0;<a name="line.571"></a>
+<span class="sourceLineNo">572</span>          }<a name="line.572"></a>
+<span class="sourceLineNo">573</span>        }<a name="line.573"></a>
+<span class="sourceLineNo">574</span>        return 1; // we found all the files<a name="line.574"></a>
+<span class="sourceLineNo">575</span>      }<a name="line.575"></a>
+<span class="sourceLineNo">576</span>      return 0;<a name="line.576"></a>
+<span class="sourceLineNo">577</span>    }<a name="line.577"></a>
+<span class="sourceLineNo">578</span>  }<a name="line.578"></a>
 <span class="sourceLineNo">579</span><a name="line.579"></a>
-<span class="sourceLineNo">580</span>    @Override<a name="line.580"></a>
-<span class="sourceLineNo">581</span>    public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager,<a name="line.581"></a>
-<span class="sourceLineNo">582</span>        ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId,<a name="line.582"></a>
-<span class="sourceLineNo">583</span>        UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics)<a name="line.583"></a>
-<span class="sourceLineNo">584</span>        throws IOException {<a name="line.584"></a>
-<span class="sourceLineNo">585</span>      throw new IOException("Failing deliberately");<a name="line.585"></a>
-<span class="sourceLineNo">586</span>    }<a name="line.586"></a>
-<span class="sourceLineNo">587</span>  }<a name="line.587"></a>
-<span class="sourceLineNo">588</span><a name="line.588"></a>
-<span class="sourceLineNo">589</span>  static class DummyServer implements Server {<a name="line.589"></a>
-<span class="sourceLineNo">590</span>    String hostname;<a name="line.590"></a>
-<span class="sourceLineNo">591</span><a name="line.591"></a>
-<span class="sourceLineNo">592</span>    DummyServer() {<a name="line.592"></a>
-<span class="sourceLineNo">593</span>      hostname = "hostname.example.org";<a name="line.593"></a>
-<span class="sourceLineNo">594</span>    }<a name="line.594"></a>
-<span class="sourceLineNo">595</span><a name="line.595"></a>
-<span class="sourceLineNo">596</span>    DummyServer(String hostname) {<a name="line.596"></a>
-<span class="sourceLineNo">597</span>      this.hostname = hostname;<a name="line.597"></a>
-<span class="sourceLineNo">598</span>    }<a name="line.598"></a>
-<span class="sourceLineNo">599</span><a name="line.599"></a>
-<span class="sourceLineNo">600</span>    @Override<a name="line.600"></a>
-<span class="sourceLineNo">601</span>    public Configuration getConfiguration() {<a name="line.601"></a>
-<span class="sourceLineNo">602</span>      return conf;<a name="line.602"></a>
-<span class="sourceLineNo">603</span>    }<a name="line.603"></a>
-<span class="sourceLineNo">604</span><a name="line.604"></a>
-<span class="sourceLineNo">605</span>    @Override<a name="line.605"></a>
-<span class="sourceLineNo">606</span>    public ZooKeeperWatcher getZooKeeper() {<a name="line.606"></a>
-<span class="sourceLineNo">607</span>      return zkw;<a name="line.607"></a>
-<span class="sourceLineNo">608</span>    }<a name="line.608"></a>
-<span class="sourceLineNo">609</span><a name="line.609"></a>
-<span class="sourceLineNo">610</span>    @Override<a name="line.610"></a>
-<span class="sourceLineNo">611</span>    public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.611"></a>
-<span class="sourceLineNo">612</span>      return null;<a name="line.612"></a>
-<span class="sourceLineNo">613</span>    }<a name="line.613"></a>
-<span class="sourceLineNo">614</span>    @Override<a name="line.614"></a>
-<span class="sourceLineNo">615</span>    public ClusterConnection getConnection() {<a name="line.615"></a>
-<span class="sourceLineNo">616</span>      return null;<a name="line.616"></a>
-<span class="sourceLineNo">617</span>    }<a name="line.617"></a>
-<span class="sourceLineNo">618</span><a name="line.618"></a>
-<span class="sourceLineNo">619</span>    @Override<a name="line.619"></a>
-<span class="sourceLineNo">620</span>    public MetaTableLocator getMetaTableLocator() {<a name="line.620"></a>
-<span class="sourceLineNo">621</span>      return null;<a name="line.621"></a>
-<span class="sourceLineNo">622</span>    }<a name="line.622"></a>
-<span class="sourceLineNo">623</span><a name="line.623"></a>
-<span class="sourceLineNo">624</span>    @Override<a name="line.624"></a>
-<span class="sourceLineNo">625</span>    public ServerName getServerName() {<a name="line.625"></a>
-<span class="sourceLineNo">626</span>      return ServerName.valueOf(hostname, 1234, 1L);<a name="line.626"></a>
-<span class="sourceLineNo">627</span>    }<a name="line.627"></a>
-<span class="sourceLineNo">628</span><a name="line.628"></a>
-<span class="sourceLineNo">629</span>    @Override<a name="line.629"></a>
-<span class="sourceLineNo">630</span>    public void abort(String why, Throwable e) {<a name="line.630"></a>
-<span class="sourceLineNo">631</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.631"></a>
-<span class="sourceLineNo">632</span>    }<a name="line.632"></a>
-<span class="sourceLineNo">633</span><a name="line.633"></a>
-<span class="sourceLineNo">634</span>    @Override<a name="line.634"></a>
-<span class="sourceLineNo">635</span>    public boolean isAborted() {<a name="line.635"></a>
-<span class="sourceLineNo">636</span>      return false;<a name="line.636"></a>
-<span class="sourceLineNo">637</span>    }<a name="line.637"></a>
-<span class="sourceLineNo">638</span><a name="line.638"></a>
-<span class="sourceLineNo">639</span>    @Override<a name="line.639"></a>
-<span class="sourceLineNo">640</span>    public void stop(String why) {<a name="line.640"></a>
-<span class="sourceLineNo">641</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.641"></a>
-<span class="sourceLineNo">642</span>    }<a name="line.642"></a>
-<span class="sourceLineNo">643</span><a name="line.643"></a>
-<span class="sourceLineNo">644</span>    @Override<a name="line.644"></a>
-<span class="sourceLineNo">645</span>    public boolean isStopped() {<a name="line.645"></a>
-<span class="sourceLineNo">646</span>      return false; // To change body of implemented methods use File | Settings | File Templates.<a name="line.646"></a>
-<span class="sourceLineNo">647</span>    }<a name="line.647"></a>
-<span class="sourceLineNo">648</span><a name="line.648"></a>
-<span class="sourceLineNo">649</span>    @Override<a name="line.649"></a>
-<span class="sourceLineNo">650</span>    public ChoreService getChoreService() {<a name="line.650"></a>
-<span class="sourceLineNo">651</span>      return null;<a name="line.651"></a>
-<span class="sourceLineNo">652</span>    }<a name="line.652"></a>
-<span class="sourceLineNo">653</span><a name="line.653"></a>
-<span class="sourceLineNo">654</span>    @Override<a name="line.654"></a>
-<span class="sourceLineNo">655</span>    public ClusterConnection getClusterConnection() {<a name="line.655"></a>
-<span class="sourceLineNo">656</span>      // TODO Auto-generated method stub<a name="line.656"></a>
-<span class="sourceLineNo">657</span>      return null;<a name="line.657"></a>
-<span class="sourceLineNo">658</span>    }<a name="line.658"></a>
-<span class="sourceLineNo">659</span>  }<a name="line.659"></a>
-<span class="sourceLineNo">660</span>}<a name="line.660"></a>
+<span class="sourceLineNo">580</span>  static class FailInitializeDummyReplicationSource extends ReplicationSourceDummy {<a name="line.580"></a>
+<span class="sourceLineNo">581</span><a name="line.581"></a>
+<span class="sourceLineNo">582</span>    @Override<a name="line.582"></a>
+<span class="sourceLineNo">583</span>    public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager,<a name="line.583"></a>
+<span class="sourceLineNo">584</span>        ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId,<a name="line.584"></a>
+<span class="sourceLineNo">585</span>        UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics)<a name="line.585"></a>
+<span class="sourceLineNo">586</span>        throws IOException {<a name="line.586"></a>
+<span class="sourceLineNo">587</span>      throw new IOException("Failing deliberately");<a name="line.587"></a>
+<span class="sourceLineNo">588</span>    }<a name="line.588"></a>
+<span class="sourceLineNo">589</span>  }<a name="line.589"></a>
+<span class="sourceLineNo">590</span><a name="line.590"></a>
+<span class="sourceLineNo">591</span>  static class DummyServer implements Server {<a name="line.591"></a>
+<span class="sourceLineNo">592</span>    String hostname;<a name="line.592"></a>
+<span class="sourceLineNo">593</span><a name="line.593"></a>
+<span class="sourceLineNo">594</span>    DummyServer() {<a name="line.594"></a>
+<span class="sourceLineNo">595</span>      hostname = "hostname.example.org";<a name="line.595"></a>
+<span class="sourceLineNo">596</span>    }<a name="line.596"></a>
+<span class="sourceLineNo">597</span><a name="line.597"></a>
+<span class="sourceLineNo">598</span>    DummyServer(String hostname) {<a name="line.598"></a>
+<span class="sourceLineNo">599</span>      this.hostname = hostname;<a name="line.599"></a>
+<span class="sourceLineNo">600</span>    }<a name="line.600"></a>
+<span class="sourceLineNo">601</span><a name="line.601"></a>
+<span class="sourceLineNo">602</span>    @Override<a name="line.602"></a>
+<span class="sourceLineNo">603</span>    public Configuration getConfiguration() {<a name="line.603"></a>
+<span class="sourceLineNo">604</span>      return conf;<a name="line.604"></a>
+<span class="sourceLineNo">605</span>    }<a name="line.605"></a>
+<span class="sourceLineNo">606</span><a name="line.606"></a>
+<span class="sourceLineNo">607</span>    @Override<a name="line.607"></a>
+<span class="sourceLineNo">608</span>    public ZooKeeperWatcher getZooKeeper() {<a name="line.608"></a>
+<span class="sourceLineNo">609</span>      return zkw;<a name="line.609"></a>
+<span class="sourceLineNo">610</span>    }<a name="line.610"></a>
+<span class="sourceLineNo">611</span><a name="line.611"></a>
+<span class="sourceLineNo">612</span>    @Override<a name="line.612"></a>
+<span class="sourceLineNo">613</span>    public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.613"></a>
+<span class="sourceLineNo">614</span>      return null;<a name="line.614"></a>
+<span class="sourceLineNo">615</span>    }<a name="line.615"></a>
+<span class="sourceLineNo">616</span>    @Override<a name="line.616"></a>
+<span class="sourceLineNo">617</span>    public ClusterConnection getConnection() {<a name="line.617"></a>
+<span class="sourceLineNo">618</span>      return null;<a name="line.618"></a>
+<span class="sourceLineNo">619</span>    }<a name="line.619"></a>
+<span class="sourceLineNo">620</span><a name="line.620"></a>
+<span class="sourceLineNo">621</span>    @Override<a name="line.621"></a>
+<span class="sourceLineNo">622</span>    public MetaTableLocator getMetaTableLocator() {<a name="line.622"></a>
+<span class="sourceLineNo">623</span>      return null;<a name="line.623"></a>
+<span class="sourceLineNo">624</span>    }<a name="line.624"></a>
+<span class="sourceLineNo">625</span><a name="line.625"></a>
+<span class="sourceLineNo">626</span>    @Override<a name="line.626"></a>
+<span class="sourceLineNo">627</span>    public ServerName getServerName() {<a name="line.627"></a>
+<span class="sourceLineNo">628</span>      return ServerName.valueOf(hostname, 1234, 1L);<a name="line.628"></a>
+<span class="sourceLineNo">629</span>    }<a name="line.629"></a>
+<span class="sourceLineNo">630</span><a name="line.630"></a>
+<span class="sourceLineNo">631</span>    @Override<a name="line.631"></a>
+<span class="sourceLineNo">632</span>    public void abort(String why, Throwable e) {<a name="line.632"></a>
+<span class="sourceLineNo">633</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.633"></a>
+<span class="sourceLineNo">634</span>    }<a name="line.634"></a>
+<span class="sourceLineNo">635</span><a name="line.635"></a>
+<span class="sourceLineNo">636</span>    @Override<a name="line.636"></a>
+<span class="sourceLineNo">637</span>    public boolean isAborted() {<a name="line.637"></a>
+<span class="sourceLineNo">638</span>      return false;<a name="line.638"></a>
+<span class="sourceLineNo">639</span>    }<a name="line.639"></a>
+<span class="sourceLineNo">640</span><a name="line.640"></a>
+<span class="sourceLineNo">641</span>    @Override<a name="line.641"></a>
+<span class="sourceLineNo">642</span>    public void stop(String why) {<a name="line.642"></a>
+<span class="sourceLineNo">643</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.643"></a>
+<span class="sourceLineNo">644</span>    }<a name="line.644"></a>
+<span class="sourceLineNo">645</span><a name="line.645"></a>
+<span class="sourceLineNo">646</span>    @Override<a name="line.646"></a>
+<span class="sourceLineNo">647</span>    public boolean isStopped() {<a name="line.647"></a>
+<span class="sourceLineNo">648</span>      return false; // To change body of implemented methods use File | Settings | File Templates.<a name="line.648"></a>
+<span class="sourceLineNo">649</span>    }<a name="line.649"></a>
+<span class="sourceLineNo">650</span><a name="line.650"></a>
+<span class="sourceLineNo">651</span>    @Override<a name="line.651"></a>
+<span class="sourceLineNo">652</span>    public ChoreService getChoreService() {<a name="line.652"></a>
+<span class="sourceLineNo">653</span>      return null;<a name="line.653"></a>
+<span class="sourceLineNo">654</span>    }<a name="line.654"></a>
+<span class="sourceLineNo">655</span><a name="line.655"></a>
+<span class="sourceLineNo">656</span>    @Override<a name="line.656"></a>
+<span class="sourceLineNo">657</span>    public ClusterConnection getClusterConnection() {<a name="line.657"></a>
+<span class="sourceLineNo">658</span>      // TODO Auto-generated method stub<a name="line.658"></a>
+<span class="sourceLineNo">659</span>      return null;<a name="line.659"></a>
+<span class="sourceLineNo">660</span>    }<a name="line.660"></a>
+<span class="sourceLineNo">661</span>  }<a name="line.661"></a>
+<span class="sourceLineNo">662</span>}<a name="line.662"></a>
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f17356a7/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.FailInitializeDummyReplicationSource.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.FailInitializeDummyReplicationSource.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.FailInitializeDummyReplicationSource.html
index 9da7348..d3a77ec 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.FailInitializeDummyReplicationSource.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.FailInitializeDummyReplicationSource.html
@@ -551,121 +551,123 @@
 <span class="sourceLineNo">543</span>        List&lt;String&gt; queues = rq.getUnClaimedQueueIds(deadRsZnode);<a name="line.543"></a>
 <span class="sourceLineNo">544</span>        for(String queue:queues){<a name="line.544"></a>
 <span class="sourceLineNo">545</span>          Pair&lt;String, SortedSet&lt;String&gt;&gt; pair = rq.claimQueue(deadRsZnode, queue);<a name="line.545"></a>
-<span class="sourceLineNo">546</span>          logZnodesMap.put(pair.getFirst(), pair.getSecond());<a name="line.546"></a>
-<span class="sourceLineNo">547</span>        }<a name="line.547"></a>
-<span class="sourceLineNo">548</span>        server.abort("Done with testing", null);<a name="line.548"></a>
-<span class="sourceLineNo">549</span>      } catch (Exception e) {<a name="line.549"></a>
-<span class="sourceLineNo">550</span>        LOG.error("Got exception while running NodeFailoverWorker", e);<a name="line.550"></a>
-<span class="sourceLineNo">551</span>      } finally {<a name="line.551"></a>
-<span class="sourceLineNo">552</span>        latch.countDown();<a name="line.552"></a>
-<span class="sourceLineNo">553</span>      }<a name="line.553"></a>
-<span class="sourceLineNo">554</span>    }<a name="line.554"></a>
-<span class="sourceLineNo">555</span><a name="line.555"></a>
-<span class="sourceLineNo">556</span>    /**<a name="line.556"></a>
-<span class="sourceLineNo">557</span>     * @return 1 when the map is not empty.<a name="line.557"></a>
-<span class="sourceLineNo">558</span>     */<a name="line.558"></a>
-<span class="sourceLineNo">559</span>    private int isLogZnodesMapPopulated() {<a name="line.559"></a>
-<span class="sourceLineNo">560</span>      Collection&lt;Set&lt;String&gt;&gt; sets = logZnodesMap.values();<a name="line.560"></a>
-<span class="sourceLineNo">561</span>      if (sets.size() &gt; 1) {<a name="line.561"></a>
-<span class="sourceLineNo">562</span>        throw new RuntimeException("unexpected size of logZnodesMap: " + sets.size());<a name="line.562"></a>
-<span class="sourceLineNo">563</span>      }<a name="line.563"></a>
-<span class="sourceLineNo">564</span>      if (sets.size() == 1) {<a name="line.564"></a>
-<span class="sourceLineNo">565</span>        Set&lt;String&gt; s = sets.iterator().next();<a name="line.565"></a>
-<span class="sourceLineNo">566</span>        for (String file : files) {<a name="line.566"></a>
-<span class="sourceLineNo">567</span>          // at least one file was missing<a name="line.567"></a>
-<span class="sourceLineNo">568</span>          if (!s.contains(file)) {<a name="line.568"></a>
-<span class="sourceLineNo">569</span>            return 0;<a name="line.569"></a>
-<span class="sourceLineNo">570</span>          }<a name="line.570"></a>
-<span class="sourceLineNo">571</span>        }<a name="line.571"></a>
-<span class="sourceLineNo">572</span>        return 1; // we found all the files<a name="line.572"></a>
-<span class="sourceLineNo">573</span>      }<a name="line.573"></a>
-<span class="sourceLineNo">574</span>      return 0;<a name="line.574"></a>
-<span class="sourceLineNo">575</span>    }<a name="line.575"></a>
-<span class="sourceLineNo">576</span>  }<a name="line.576"></a>
-<span class="sourceLineNo">577</span><a name="line.577"></a>
-<span class="sourceLineNo">578</span>  static class FailInitializeDummyReplicationSource extends ReplicationSourceDummy {<a name="line.578"></a>
+<span class="sourceLineNo">546</span>          if (pair != null) {<a name="line.546"></a>
+<span class="sourceLineNo">547</span>            logZnodesMap.put(pair.getFirst(), pair.getSecond());<a name="line.547"></a>
+<span class="sourceLineNo">548</span>          }<a name="line.548"></a>
+<span class="sourceLineNo">549</span>        }<a name="line.549"></a>
+<span class="sourceLineNo">550</span>        server.abort("Done with testing", null);<a name="line.550"></a>
+<span class="sourceLineNo">551</span>      } catch (Exception e) {<a name="line.551"></a>
+<span class="sourceLineNo">552</span>        LOG.error("Got exception while running NodeFailoverWorker", e);<a name="line.552"></a>
+<span class="sourceLineNo">553</span>      } finally {<a name="line.553"></a>
+<span class="sourceLineNo">554</span>        latch.countDown();<a name="line.554"></a>
+<span class="sourceLineNo">555</span>      }<a name="line.555"></a>
+<span class="sourceLineNo">556</span>    }<a name="line.556"></a>
+<span class="sourceLineNo">557</span><a name="line.557"></a>
+<span class="sourceLineNo">558</span>    /**<a name="line.558"></a>
+<span class="sourceLineNo">559</span>     * @return 1 when the map is not empty.<a name="line.559"></a>
+<span class="sourceLineNo">560</span>     */<a name="line.560"></a>
+<span class="sourceLineNo">561</span>    private int isLogZnodesMapPopulated() {<a name="line.561"></a>
+<span class="sourceLineNo">562</span>      Collection&lt;Set&lt;String&gt;&gt; sets = logZnodesMap.values();<a name="line.562"></a>
+<span class="sourceLineNo">563</span>      if (sets.size() &gt; 1) {<a name="line.563"></a>
+<span class="sourceLineNo">564</span>        throw new RuntimeException("unexpected size of logZnodesMap: " + sets.size());<a name="line.564"></a>
+<span class="sourceLineNo">565</span>      }<a name="line.565"></a>
+<span class="sourceLineNo">566</span>      if (sets.size() == 1) {<a name="line.566"></a>
+<span class="sourceLineNo">567</span>        Set&lt;String&gt; s = sets.iterator().next();<a name="line.567"></a>
+<span class="sourceLineNo">568</span>        for (String file : files) {<a name="line.568"></a>
+<span class="sourceLineNo">569</span>          // at least one file was missing<a name="line.569"></a>
+<span class="sourceLineNo">570</span>          if (!s.contains(file)) {<a name="line.570"></a>
+<span class="sourceLineNo">571</span>            return 0;<a name="line.571"></a>
+<span class="sourceLineNo">572</span>          }<a name="line.572"></a>
+<span class="sourceLineNo">573</span>        }<a name="line.573"></a>
+<span class="sourceLineNo">574</span>        return 1; // we found all the files<a name="line.574"></a>
+<span class="sourceLineNo">575</span>      }<a name="line.575"></a>
+<span class="sourceLineNo">576</span>      return 0;<a name="line.576"></a>
+<span class="sourceLineNo">577</span>    }<a name="line.577"></a>
+<span class="sourceLineNo">578</span>  }<a name="line.578"></a>
 <span class="sourceLineNo">579</span><a name="line.579"></a>
-<span class="sourceLineNo">580</span>    @Override<a name="line.580"></a>
-<span class="sourceLineNo">581</span>    public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager,<a name="line.581"></a>
-<span class="sourceLineNo">582</span>        ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId,<a name="line.582"></a>
-<span class="sourceLineNo">583</span>        UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics)<a name="line.583"></a>
-<span class="sourceLineNo">584</span>        throws IOException {<a name="line.584"></a>
-<span class="sourceLineNo">585</span>      throw new IOException("Failing deliberately");<a name="line.585"></a>
-<span class="sourceLineNo">586</span>    }<a name="line.586"></a>
-<span class="sourceLineNo">587</span>  }<a name="line.587"></a>
-<span class="sourceLineNo">588</span><a name="line.588"></a>
-<span class="sourceLineNo">589</span>  static class DummyServer implements Server {<a name="line.589"></a>
-<span class="sourceLineNo">590</span>    String hostname;<a name="line.590"></a>
-<span class="sourceLineNo">591</span><a name="line.591"></a>
-<span class="sourceLineNo">592</span>    DummyServer() {<a name="line.592"></a>
-<span class="sourceLineNo">593</span>      hostname = "hostname.example.org";<a name="line.593"></a>
-<span class="sourceLineNo">594</span>    }<a name="line.594"></a>
-<span class="sourceLineNo">595</span><a name="line.595"></a>
-<span class="sourceLineNo">596</span>    DummyServer(String hostname) {<a name="line.596"></a>
-<span class="sourceLineNo">597</span>      this.hostname = hostname;<a name="line.597"></a>
-<span class="sourceLineNo">598</span>    }<a name="line.598"></a>
-<span class="sourceLineNo">599</span><a name="line.599"></a>
-<span class="sourceLineNo">600</span>    @Override<a name="line.600"></a>
-<span class="sourceLineNo">601</span>    public Configuration getConfiguration() {<a name="line.601"></a>
-<span class="sourceLineNo">602</span>      return conf;<a name="line.602"></a>
-<span class="sourceLineNo">603</span>    }<a name="line.603"></a>
-<span class="sourceLineNo">604</span><a name="line.604"></a>
-<span class="sourceLineNo">605</span>    @Override<a name="line.605"></a>
-<span class="sourceLineNo">606</span>    public ZooKeeperWatcher getZooKeeper() {<a name="line.606"></a>
-<span class="sourceLineNo">607</span>      return zkw;<a name="line.607"></a>
-<span class="sourceLineNo">608</span>    }<a name="line.608"></a>
-<span class="sourceLineNo">609</span><a name="line.609"></a>
-<span class="sourceLineNo">610</span>    @Override<a name="line.610"></a>
-<span class="sourceLineNo">611</span>    public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.611"></a>
-<span class="sourceLineNo">612</span>      return null;<a name="line.612"></a>
-<span class="sourceLineNo">613</span>    }<a name="line.613"></a>
-<span class="sourceLineNo">614</span>    @Override<a name="line.614"></a>
-<span class="sourceLineNo">615</span>    public ClusterConnection getConnection() {<a name="line.615"></a>
-<span class="sourceLineNo">616</span>      return null;<a name="line.616"></a>
-<span class="sourceLineNo">617</span>    }<a name="line.617"></a>
-<span class="sourceLineNo">618</span><a name="line.618"></a>
-<span class="sourceLineNo">619</span>    @Override<a name="line.619"></a>
-<span class="sourceLineNo">620</span>    public MetaTableLocator getMetaTableLocator() {<a name="line.620"></a>
-<span class="sourceLineNo">621</span>      return null;<a name="line.621"></a>
-<span class="sourceLineNo">622</span>    }<a name="line.622"></a>
-<span class="sourceLineNo">623</span><a name="line.623"></a>
-<span class="sourceLineNo">624</span>    @Override<a name="line.624"></a>
-<span class="sourceLineNo">625</span>    public ServerName getServerName() {<a name="line.625"></a>
-<span class="sourceLineNo">626</span>      return ServerName.valueOf(hostname, 1234, 1L);<a name="line.626"></a>
-<span class="sourceLineNo">627</span>    }<a name="line.627"></a>
-<span class="sourceLineNo">628</span><a name="line.628"></a>
-<span class="sourceLineNo">629</span>    @Override<a name="line.629"></a>
-<span class="sourceLineNo">630</span>    public void abort(String why, Throwable e) {<a name="line.630"></a>
-<span class="sourceLineNo">631</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.631"></a>
-<span class="sourceLineNo">632</span>    }<a name="line.632"></a>
-<span class="sourceLineNo">633</span><a name="line.633"></a>
-<span class="sourceLineNo">634</span>    @Override<a name="line.634"></a>
-<span class="sourceLineNo">635</span>    public boolean isAborted() {<a name="line.635"></a>
-<span class="sourceLineNo">636</span>      return false;<a name="line.636"></a>
-<span class="sourceLineNo">637</span>    }<a name="line.637"></a>
-<span class="sourceLineNo">638</span><a name="line.638"></a>
-<span class="sourceLineNo">639</span>    @Override<a name="line.639"></a>
-<span class="sourceLineNo">640</span>    public void stop(String why) {<a name="line.640"></a>
-<span class="sourceLineNo">641</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.641"></a>
-<span class="sourceLineNo">642</span>    }<a name="line.642"></a>
-<span class="sourceLineNo">643</span><a name="line.643"></a>
-<span class="sourceLineNo">644</span>    @Override<a name="line.644"></a>
-<span class="sourceLineNo">645</span>    public boolean isStopped() {<a name="line.645"></a>
-<span class="sourceLineNo">646</span>      return false; // To change body of implemented methods use File | Settings | File Templates.<a name="line.646"></a>
-<span class="sourceLineNo">647</span>    }<a name="line.647"></a>
-<span class="sourceLineNo">648</span><a name="line.648"></a>
-<span class="sourceLineNo">649</span>    @Override<a name="line.649"></a>
-<span class="sourceLineNo">650</span>    public ChoreService getChoreService() {<a name="line.650"></a>
-<span class="sourceLineNo">651</span>      return null;<a name="line.651"></a>
-<span class="sourceLineNo">652</span>    }<a name="line.652"></a>
-<span class="sourceLineNo">653</span><a name="line.653"></a>
-<span class="sourceLineNo">654</span>    @Override<a name="line.654"></a>
-<span class="sourceLineNo">655</span>    public ClusterConnection getClusterConnection() {<a name="line.655"></a>
-<span class="sourceLineNo">656</span>      // TODO Auto-generated method stub<a name="line.656"></a>
-<span class="sourceLineNo">657</span>      return null;<a name="line.657"></a>
-<span class="sourceLineNo">658</span>    }<a name="line.658"></a>
-<span class="sourceLineNo">659</span>  }<a name="line.659"></a>
-<span class="sourceLineNo">660</span>}<a name="line.660"></a>
+<span class="sourceLineNo">580</span>  static class FailInitializeDummyReplicationSource extends ReplicationSourceDummy {<a name="line.580"></a>
+<span class="sourceLineNo">581</span><a name="line.581"></a>
+<span class="sourceLineNo">582</span>    @Override<a name="line.582"></a>
+<span class="sourceLineNo">583</span>    public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager,<a name="line.583"></a>
+<span class="sourceLineNo">584</span>        ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId,<a name="line.584"></a>
+<span class="sourceLineNo">585</span>        UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics)<a name="line.585"></a>
+<span class="sourceLineNo">586</span>        throws IOException {<a name="line.586"></a>
+<span class="sourceLineNo">587</span>      throw new IOException("Failing deliberately");<a name="line.587"></a>
+<span class="sourceLineNo">588</span>    }<a name="line.588"></a>
+<span class="sourceLineNo">589</span>  }<a name="line.589"></a>
+<span class="sourceLineNo">590</span><a name="line.590"></a>
+<span class="sourceLineNo">591</span>  static class DummyServer implements Server {<a name="line.591"></a>
+<span class="sourceLineNo">592</span>    String hostname;<a name="line.592"></a>
+<span class="sourceLineNo">593</span><a name="line.593"></a>
+<span class="sourceLineNo">594</span>    DummyServer() {<a name="line.594"></a>
+<span class="sourceLineNo">595</span>      hostname = "hostname.example.org";<a name="line.595"></a>
+<span class="sourceLineNo">596</span>    }<a name="line.596"></a>
+<span class="sourceLineNo">597</span><a name="line.597"></a>
+<span class="sourceLineNo">598</span>    DummyServer(String hostname) {<a name="line.598"></a>
+<span class="sourceLineNo">599</span>      this.hostname = hostname;<a name="line.599"></a>
+<span class="sourceLineNo">600</span>    }<a name="line.600"></a>
+<span class="sourceLineNo">601</span><a name="line.601"></a>
+<span class="sourceLineNo">602</span>    @Override<a name="line.602"></a>
+<span class="sourceLineNo">603</span>    public Configuration getConfiguration() {<a name="line.603"></a>
+<span class="sourceLineNo">604</span>      return conf;<a name="line.604"></a>
+<span class="sourceLineNo">605</span>    }<a name="line.605"></a>
+<span class="sourceLineNo">606</span><a name="line.606"></a>
+<span class="sourceLineNo">607</span>    @Override<a name="line.607"></a>
+<span class="sourceLineNo">608</span>    public ZooKeeperWatcher getZooKeeper() {<a name="line.608"></a>
+<span class="sourceLineNo">609</span>      return zkw;<a name="line.609"></a>
+<span class="sourceLineNo">610</span>    }<a name="line.610"></a>
+<span class="sourceLineNo">611</span><a name="line.611"></a>
+<span class="sourceLineNo">612</span>    @Override<a name="line.612"></a>
+<span class="sourceLineNo">613</span>    public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.613"></a>
+<span class="sourceLineNo">614</span>      return null;<a name="line.614"></a>
+<span class="sourceLineNo">615</span>    }<a name="line.615"></a>
+<span class="sourceLineNo">616</span>    @Override<a name="line.616"></a>
+<span class="sourceLineNo">617</span>    public ClusterConnection getConnection() {<a name="line.617"></a>
+<span class="sourceLineNo">618</span>      return null;<a name="line.618"></a>
+<span class="sourceLineNo">619</span>    }<a name="line.619"></a>
+<span class="sourceLineNo">620</span><a name="line.620"></a>
+<span class="sourceLineNo">621</span>    @Override<a name="line.621"></a>
+<span class="sourceLineNo">622</span>    public MetaTableLocator getMetaTableLocator() {<a name="line.622"></a>
+<span class="sourceLineNo">623</span>      return null;<a name="line.623"></a>
+<span class="sourceLineNo">624</span>    }<a name="line.624"></a>
+<span class="sourceLineNo">625</span><a name="line.625"></a>
+<span class="sourceLineNo">626</span>    @Override<a name="line.626"></a>
+<span class="sourceLineNo">627</span>    public ServerName getServerName() {<a name="line.627"></a>
+<span class="sourceLineNo">628</span>      return ServerName.valueOf(hostname, 1234, 1L);<a name="line.628"></a>
+<span class="sourceLineNo">629</span>    }<a name="line.629"></a>
+<span class="sourceLineNo">630</span><a name="line.630"></a>
+<span class="sourceLineNo">631</span>    @Override<a name="line.631"></a>
+<span class="sourceLineNo">632</span>    public void abort(String why, Throwable e) {<a name="line.632"></a>
+<span class="sourceLineNo">633</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.633"></a>
+<span class="sourceLineNo">634</span>    }<a name="line.634"></a>
+<span class="sourceLineNo">635</span><a name="line.635"></a>
+<span class="sourceLineNo">636</span>    @Override<a name="line.636"></a>
+<span class="sourceLineNo">637</span>    public boolean isAborted() {<a name="line.637"></a>
+<span class="sourceLineNo">638</span>      return false;<a name="line.638"></a>
+<span class="sourceLineNo">639</span>    }<a name="line.639"></a>
+<span class="sourceLineNo">640</span><a name="line.640"></a>
+<span class="sourceLineNo">641</span>    @Override<a name="line.641"></a>
+<span class="sourceLineNo">642</span>    public void stop(String why) {<a name="line.642"></a>
+<span class="sourceLineNo">643</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.643"></a>
+<span class="sourceLineNo">644</span>    }<a name="line.644"></a>
+<span class="sourceLineNo">645</span><a name="line.645"></a>
+<span class="sourceLineNo">646</span>    @Override<a name="line.646"></a>
+<span class="sourceLineNo">647</span>    public boolean isStopped() {<a name="line.647"></a>
+<span class="sourceLineNo">648</span>      return false; // To change body of implemented methods use File | Settings | File Templates.<a name="line.648"></a>
+<span class="sourceLineNo">649</span>    }<a name="line.649"></a>
+<span class="sourceLineNo">650</span><a name="line.650"></a>
+<span class="sourceLineNo">651</span>    @Override<a name="line.651"></a>
+<span class="sourceLineNo">652</span>    public ChoreService getChoreService() {<a name="line.652"></a>
+<span class="sourceLineNo">653</span>      return null;<a name="line.653"></a>
+<span class="sourceLineNo">654</span>    }<a name="line.654"></a>
+<span class="sourceLineNo">655</span><a name="line.655"></a>
+<span class="sourceLineNo">656</span>    @Override<a name="line.656"></a>
+<span class="sourceLineNo">657</span>    public ClusterConnection getClusterConnection() {<a name="line.657"></a>
+<span class="sourceLineNo">658</span>      // TODO Auto-generated method stub<a name="line.658"></a>
+<span class="sourceLineNo">659</span>      return null;<a name="line.659"></a>
+<span class="sourceLineNo">660</span>    }<a name="line.660"></a>
+<span class="sourceLineNo">661</span>  }<a name="line.661"></a>
+<span class="sourceLineNo">662</span>}<a name="line.662"></a>
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f17356a7/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html
index 9da7348..d3a77ec 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/TestReplicationSourceManager.html
@@ -551,121 +551,123 @@
 <span class="sourceLineNo">543</span>        List&lt;String&gt; queues = rq.getUnClaimedQueueIds(deadRsZnode);<a name="line.543"></a>
 <span class="sourceLineNo">544</span>        for(String queue:queues){<a name="line.544"></a>
 <span class="sourceLineNo">545</span>          Pair&lt;String, SortedSet&lt;String&gt;&gt; pair = rq.claimQueue(deadRsZnode, queue);<a name="line.545"></a>
-<span class="sourceLineNo">546</span>          logZnodesMap.put(pair.getFirst(), pair.getSecond());<a name="line.546"></a>
-<span class="sourceLineNo">547</span>        }<a name="line.547"></a>
-<span class="sourceLineNo">548</span>        server.abort("Done with testing", null);<a name="line.548"></a>
-<span class="sourceLineNo">549</span>      } catch (Exception e) {<a name="line.549"></a>
-<span class="sourceLineNo">550</span>        LOG.error("Got exception while running NodeFailoverWorker", e);<a name="line.550"></a>
-<span class="sourceLineNo">551</span>      } finally {<a name="line.551"></a>
-<span class="sourceLineNo">552</span>        latch.countDown();<a name="line.552"></a>
-<span class="sourceLineNo">553</span>      }<a name="line.553"></a>
-<span class="sourceLineNo">554</span>    }<a name="line.554"></a>
-<span class="sourceLineNo">555</span><a name="line.555"></a>
-<span class="sourceLineNo">556</span>    /**<a name="line.556"></a>
-<span class="sourceLineNo">557</span>     * @return 1 when the map is not empty.<a name="line.557"></a>
-<span class="sourceLineNo">558</span>     */<a name="line.558"></a>
-<span class="sourceLineNo">559</span>    private int isLogZnodesMapPopulated() {<a name="line.559"></a>
-<span class="sourceLineNo">560</span>      Collection&lt;Set&lt;String&gt;&gt; sets = logZnodesMap.values();<a name="line.560"></a>
-<span class="sourceLineNo">561</span>      if (sets.size() &gt; 1) {<a name="line.561"></a>
-<span class="sourceLineNo">562</span>        throw new RuntimeException("unexpected size of logZnodesMap: " + sets.size());<a name="line.562"></a>
-<span class="sourceLineNo">563</span>      }<a name="line.563"></a>
-<span class="sourceLineNo">564</span>      if (sets.size() == 1) {<a name="line.564"></a>
-<span class="sourceLineNo">565</span>        Set&lt;String&gt; s = sets.iterator().next();<a name="line.565"></a>
-<span class="sourceLineNo">566</span>        for (String file : files) {<a name="line.566"></a>
-<span class="sourceLineNo">567</span>          // at least one file was missing<a name="line.567"></a>
-<span class="sourceLineNo">568</span>          if (!s.contains(file)) {<a name="line.568"></a>
-<span class="sourceLineNo">569</span>            return 0;<a name="line.569"></a>
-<span class="sourceLineNo">570</span>          }<a name="line.570"></a>
-<span class="sourceLineNo">571</span>        }<a name="line.571"></a>
-<span class="sourceLineNo">572</span>        return 1; // we found all the files<a name="line.572"></a>
-<span class="sourceLineNo">573</span>      }<a name="line.573"></a>
-<span class="sourceLineNo">574</span>      return 0;<a name="line.574"></a>
-<span class="sourceLineNo">575</span>    }<a name="line.575"></a>
-<span class="sourceLineNo">576</span>  }<a name="line.576"></a>
-<span class="sourceLineNo">577</span><a name="line.577"></a>
-<span class="sourceLineNo">578</span>  static class FailInitializeDummyReplicationSource extends ReplicationSourceDummy {<a name="line.578"></a>
+<span class="sourceLineNo">546</span>          if (pair != null) {<a name="line.546"></a>
+<span class="sourceLineNo">547</span>            logZnodesMap.put(pair.getFirst(), pair.getSecond());<a name="line.547"></a>
+<span class="sourceLineNo">548</span>          }<a name="line.548"></a>
+<span class="sourceLineNo">549</span>        }<a name="line.549"></a>
+<span class="sourceLineNo">550</span>        server.abort("Done with testing", null);<a name="line.550"></a>
+<span class="sourceLineNo">551</span>      } catch (Exception e) {<a name="line.551"></a>
+<span class="sourceLineNo">552</span>        LOG.error("Got exception while running NodeFailoverWorker", e);<a name="line.552"></a>
+<span class="sourceLineNo">553</span>      } finally {<a name="line.553"></a>
+<span class="sourceLineNo">554</span>        latch.countDown();<a name="line.554"></a>
+<span class="sourceLineNo">555</span>      }<a name="line.555"></a>
+<span class="sourceLineNo">556</span>    }<a name="line.556"></a>
+<span class="sourceLineNo">557</span><a name="line.557"></a>
+<span class="sourceLineNo">558</span>    /**<a name="line.558"></a>
+<span class="sourceLineNo">559</span>     * @return 1 when the map is not empty.<a name="line.559"></a>
+<span class="sourceLineNo">560</span>     */<a name="line.560"></a>
+<span class="sourceLineNo">561</span>    private int isLogZnodesMapPopulated() {<a name="line.561"></a>
+<span class="sourceLineNo">562</span>      Collection&lt;Set&lt;String&gt;&gt; sets = logZnodesMap.values();<a name="line.562"></a>
+<span class="sourceLineNo">563</span>      if (sets.size() &gt; 1) {<a name="line.563"></a>
+<span class="sourceLineNo">564</span>        throw new RuntimeException("unexpected size of logZnodesMap: " + sets.size());<a name="line.564"></a>
+<span class="sourceLineNo">565</span>      }<a name="line.565"></a>
+<span class="sourceLineNo">566</span>      if (sets.size() == 1) {<a name="line.566"></a>
+<span class="sourceLineNo">567</span>        Set&lt;String&gt; s = sets.iterator().next();<a name="line.567"></a>
+<span class="sourceLineNo">568</span>        for (String file : files) {<a name="line.568"></a>
+<span class="sourceLineNo">569</span>          // at least one file was missing<a name="line.569"></a>
+<span class="sourceLineNo">570</span>          if (!s.contains(file)) {<a name="line.570"></a>
+<span class="sourceLineNo">571</span>            return 0;<a name="line.571"></a>
+<span class="sourceLineNo">572</span>          }<a name="line.572"></a>
+<span class="sourceLineNo">573</span>        }<a name="line.573"></a>
+<span class="sourceLineNo">574</span>        return 1; // we found all the files<a name="line.574"></a>
+<span class="sourceLineNo">575</span>      }<a name="line.575"></a>
+<span class="sourceLineNo">576</span>      return 0;<a name="line.576"></a>
+<span class="sourceLineNo">577</span>    }<a name="line.577"></a>
+<span class="sourceLineNo">578</span>  }<a name="line.578"></a>
 <span class="sourceLineNo">579</span><a name="line.579"></a>
-<span class="sourceLineNo">580</span>    @Override<a name="line.580"></a>
-<span class="sourceLineNo">581</span>    public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager,<a name="line.581"></a>
-<span class="sourceLineNo">582</span>        ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId,<a name="line.582"></a>
-<span class="sourceLineNo">583</span>        UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics)<a name="line.583"></a>
-<span class="sourceLineNo">584</span>        throws IOException {<a name="line.584"></a>
-<span class="sourceLineNo">585</span>      throw new IOException("Failing deliberately");<a name="line.585"></a>
-<span class="sourceLineNo">586</span>    }<a name="line.586"></a>
-<span class="sourceLineNo">587</span>  }<a name="line.587"></a>
-<span class="sourceLineNo">588</span><a name="line.588"></a>
-<span class="sourceLineNo">589</span>  static class DummyServer implements Server {<a name="line.589"></a>
-<span class="sourceLineNo">590</span>    String hostname;<a name="line.590"></a>
-<span class="sourceLineNo">591</span><a name="line.591"></a>
-<span class="sourceLineNo">592</span>    DummyServer() {<a name="line.592"></a>
-<span class="sourceLineNo">593</span>      hostname = "hostname.example.org";<a name="line.593"></a>
-<span class="sourceLineNo">594</span>    }<a name="line.594"></a>
-<span class="sourceLineNo">595</span><a name="line.595"></a>
-<span class="sourceLineNo">596</span>    DummyServer(String hostname) {<a name="line.596"></a>
-<span class="sourceLineNo">597</span>      this.hostname = hostname;<a name="line.597"></a>
-<span class="sourceLineNo">598</span>    }<a name="line.598"></a>
-<span class="sourceLineNo">599</span><a name="line.599"></a>
-<span class="sourceLineNo">600</span>    @Override<a name="line.600"></a>
-<span class="sourceLineNo">601</span>    public Configuration getConfiguration() {<a name="line.601"></a>
-<span class="sourceLineNo">602</span>      return conf;<a name="line.602"></a>
-<span class="sourceLineNo">603</span>    }<a name="line.603"></a>
-<span class="sourceLineNo">604</span><a name="line.604"></a>
-<span class="sourceLineNo">605</span>    @Override<a name="line.605"></a>
-<span class="sourceLineNo">606</span>    public ZooKeeperWatcher getZooKeeper() {<a name="line.606"></a>
-<span class="sourceLineNo">607</span>      return zkw;<a name="line.607"></a>
-<span class="sourceLineNo">608</span>    }<a name="line.608"></a>
-<span class="sourceLineNo">609</span><a name="line.609"></a>
-<span class="sourceLineNo">610</span>    @Override<a name="line.610"></a>
-<span class="sourceLineNo">611</span>    public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.611"></a>
-<span class="sourceLineNo">612</span>      return null;<a name="line.612"></a>
-<span class="sourceLineNo">613</span>    }<a name="line.613"></a>
-<span class="sourceLineNo">614</span>    @Override<a name="line.614"></a>
-<span class="sourceLineNo">615</span>    public ClusterConnection getConnection() {<a name="line.615"></a>
-<span class="sourceLineNo">616</span>      return null;<a name="line.616"></a>
-<span class="sourceLineNo">617</span>    }<a name="line.617"></a>
-<span class="sourceLineNo">618</span><a name="line.618"></a>
-<span class="sourceLineNo">619</span>    @Override<a name="line.619"></a>
-<span class="sourceLineNo">620</span>    public MetaTableLocator getMetaTableLocator() {<a name="line.620"></a>
-<span class="sourceLineNo">621</span>      return null;<a name="line.621"></a>
-<span class="sourceLineNo">622</span>    }<a name="line.622"></a>
-<span class="sourceLineNo">623</span><a name="line.623"></a>
-<span class="sourceLineNo">624</span>    @Override<a name="line.624"></a>
-<span class="sourceLineNo">625</span>    public ServerName getServerName() {<a name="line.625"></a>
-<span class="sourceLineNo">626</span>      return ServerName.valueOf(hostname, 1234, 1L);<a name="line.626"></a>
-<span class="sourceLineNo">627</span>    }<a name="line.627"></a>
-<span class="sourceLineNo">628</span><a name="line.628"></a>
-<span class="sourceLineNo">629</span>    @Override<a name="line.629"></a>
-<span class="sourceLineNo">630</span>    public void abort(String why, Throwable e) {<a name="line.630"></a>
-<span class="sourceLineNo">631</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.631"></a>
-<span class="sourceLineNo">632</span>    }<a name="line.632"></a>
-<span class="sourceLineNo">633</span><a name="line.633"></a>
-<span class="sourceLineNo">634</span>    @Override<a name="line.634"></a>
-<span class="sourceLineNo">635</span>    public boolean isAborted() {<a name="line.635"></a>
-<span class="sourceLineNo">636</span>      return false;<a name="line.636"></a>
-<span class="sourceLineNo">637</span>    }<a name="line.637"></a>
-<span class="sourceLineNo">638</span><a name="line.638"></a>
-<span class="sourceLineNo">639</span>    @Override<a name="line.639"></a>
-<span class="sourceLineNo">640</span>    public void stop(String why) {<a name="line.640"></a>
-<span class="sourceLineNo">641</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.641"></a>
-<span class="sourceLineNo">642</span>    }<a name="line.642"></a>
-<span class="sourceLineNo">643</span><a name="line.643"></a>
-<span class="sourceLineNo">644</span>    @Override<a name="line.644"></a>
-<span class="sourceLineNo">645</span>    public boolean isStopped() {<a name="line.645"></a>
-<span class="sourceLineNo">646</span>      return false; // To change body of implemented methods use File | Settings | File Templates.<a name="line.646"></a>
-<span class="sourceLineNo">647</span>    }<a name="line.647"></a>
-<span class="sourceLineNo">648</span><a name="line.648"></a>
-<span class="sourceLineNo">649</span>    @Override<a name="line.649"></a>
-<span class="sourceLineNo">650</span>    public ChoreService getChoreService() {<a name="line.650"></a>
-<span class="sourceLineNo">651</span>      return null;<a name="line.651"></a>
-<span class="sourceLineNo">652</span>    }<a name="line.652"></a>
-<span class="sourceLineNo">653</span><a name="line.653"></a>
-<span class="sourceLineNo">654</span>    @Override<a name="line.654"></a>
-<span class="sourceLineNo">655</span>    public ClusterConnection getClusterConnection() {<a name="line.655"></a>
-<span class="sourceLineNo">656</span>      // TODO Auto-generated method stub<a name="line.656"></a>
-<span class="sourceLineNo">657</span>      return null;<a name="line.657"></a>
-<span class="sourceLineNo">658</span>    }<a name="line.658"></a>
-<span class="sourceLineNo">659</span>  }<a name="line.659"></a>
-<span class="sourceLineNo">660</span>}<a name="line.660"></a>
+<span class="sourceLineNo">580</span>  static class FailInitializeDummyReplicationSource extends ReplicationSourceDummy {<a name="line.580"></a>
+<span class="sourceLineNo">581</span><a name="line.581"></a>
+<span class="sourceLineNo">582</span>    @Override<a name="line.582"></a>
+<span class="sourceLineNo">583</span>    public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager,<a name="line.583"></a>
+<span class="sourceLineNo">584</span>        ReplicationQueues rq, ReplicationPeers rp, Stoppable stopper, String peerClusterId,<a name="line.584"></a>
+<span class="sourceLineNo">585</span>        UUID clusterId, ReplicationEndpoint replicationEndpoint, MetricsSource metrics)<a name="line.585"></a>
+<span class="sourceLineNo">586</span>        throws IOException {<a name="line.586"></a>
+<span class="sourceLineNo">587</span>      throw new IOException("Failing deliberately");<a name="line.587"></a>
+<span class="sourceLineNo">588</span>    }<a name="line.588"></a>
+<span class="sourceLineNo">589</span>  }<a name="line.589"></a>
+<span class="sourceLineNo">590</span><a name="line.590"></a>
+<span class="sourceLineNo">591</span>  static class DummyServer implements Server {<a name="line.591"></a>
+<span class="sourceLineNo">592</span>    String hostname;<a name="line.592"></a>
+<span class="sourceLineNo">593</span><a name="line.593"></a>
+<span class="sourceLineNo">594</span>    DummyServer() {<a name="line.594"></a>
+<span class="sourceLineNo">595</span>      hostname = "hostname.example.org";<a name="line.595"></a>
+<span class="sourceLineNo">596</span>    }<a name="line.596"></a>
+<span class="sourceLineNo">597</span><a name="line.597"></a>
+<span class="sourceLineNo">598</span>    DummyServer(String hostname) {<a name="line.598"></a>
+<span class="sourceLineNo">599</span>      this.hostname = hostname;<a name="line.599"></a>
+<span class="sourceLineNo">600</span>    }<a name="line.600"></a>
+<span class="sourceLineNo">601</span><a name="line.601"></a>
+<span class="sourceLineNo">602</span>    @Override<a name="line.602"></a>
+<span class="sourceLineNo">603</span>    public Configuration getConfiguration() {<a name="line.603"></a>
+<span class="sourceLineNo">604</span>      return conf;<a name="line.604"></a>
+<span class="sourceLineNo">605</span>    }<a name="line.605"></a>
+<span class="sourceLineNo">606</span><a name="line.606"></a>
+<span class="sourceLineNo">607</span>    @Override<a name="line.607"></a>
+<span class="sourceLineNo">608</span>    public ZooKeeperWatcher getZooKeeper() {<a name="line.608"></a>
+<span class="sourceLineNo">609</span>      return zkw;<a name="line.609"></a>
+<span class="sourceLineNo">610</span>    }<a name="line.610"></a>
+<span class="sourceLineNo">611</span><a name="line.611"></a>
+<span class="sourceLineNo">612</span>    @Override<a name="line.612"></a>
+<span class="sourceLineNo">613</span>    public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.613"></a>
+<span class="sourceLineNo">614</span>      return null;<a name="line.614"></a>
+<span class="sourceLineNo">615</span>    }<a name="line.615"></a>
+<span class="sourceLineNo">616</span>    @Override<a name="line.616"></a>
+<span class="sourceLineNo">617</span>    public ClusterConnection getConnection() {<a name="line.617"></a>
+<span class="sourceLineNo">618</span>      return null;<a name="line.618"></a>
+<span class="sourceLineNo">619</span>    }<a name="line.619"></a>
+<span class="sourceLineNo">620</span><a name="line.620"></a>
+<span class="sourceLineNo">621</span>    @Override<a name="line.621"></a>
+<span class="sourceLineNo">622</span>    public MetaTableLocator getMetaTableLocator() {<a name="line.622"></a>
+<span class="sourceLineNo">623</span>      return null;<a name="line.623"></a>
+<span class="sourceLineNo">624</span>    }<a name="line.624"></a>
+<span class="sourceLineNo">625</span><a name="line.625"></a>
+<span class="sourceLineNo">626</span>    @Override<a name="line.626"></a>
+<span class="sourceLineNo">627</span>    public ServerName getServerName() {<a name="line.627"></a>
+<span class="sourceLineNo">628</span>      return ServerName.valueOf(hostname, 1234, 1L);<a name="line.628"></a>
+<span class="sourceLineNo">629</span>    }<a name="line.629"></a>
+<span class="sourceLineNo">630</span><a name="line.630"></a>
+<span class="sourceLineNo">631</span>    @Override<a name="line.631"></a>
+<span class="sourceLineNo">632</span>    public void abort(String why, Throwable e) {<a name="line.632"></a>
+<span class="sourceLineNo">633</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.633"></a>
+<span class="sourceLineNo">634</span>    }<a name="line.634"></a>
+<span class="sourceLineNo">635</span><a name="line.635"></a>
+<span class="sourceLineNo">636</span>    @Override<a name="line.636"></a>
+<span class="sourceLineNo">637</span>    public boolean isAborted() {<a name="line.637"></a>
+<span class="sourceLineNo">638</span>      return false;<a name="line.638"></a>
+<span class="sourceLineNo">639</span>    }<a name="line.639"></a>
+<span class="sourceLineNo">640</span><a name="line.640"></a>
+<span class="sourceLineNo">641</span>    @Override<a name="line.641"></a>
+<span class="sourceLineNo">642</span>    public void stop(String why) {<a name="line.642"></a>
+<span class="sourceLineNo">643</span>      // To change body of implemented methods use File | Settings | File Templates.<a name="line.643"></a>
+<span class="sourceLineNo">644</span>    }<a name="line.644"></a>
+<span class="sourceLineNo">645</span><a name="line.645"></a>
+<span class="sourceLineNo">646</span>    @Override<a name="line.646"></a>
+<span class="sourceLineNo">647</span>    public boolean isStopped() {<a name="line.647"></a>
+<span class="sourceLineNo">648</span>      return false; // To change body of implemented methods use File | Settings | File Templates.<a name="line.648"></a>
+<span class="sourceLineNo">649</span>    }<a name="line.649"></a>
+<span class="sourceLineNo">650</span><a name="line.650"></a>
+<span class="sourceLineNo">651</span>    @Override<a name="line.651"></a>
+<span class="sourceLineNo">652</span>    public ChoreService getChoreService() {<a name="line.652"></a>
+<span class="sourceLineNo">653</span>      return null;<a name="line.653"></a>
+<span class="sourceLineNo">654</span>    }<a name="line.654"></a>
+<span class="sourceLineNo">655</span><a name="line.655"></a>
+<span class="sourceLineNo">656</span>    @Override<a name="line.656"></a>
+<span class="sourceLineNo">657</span>    public ClusterConnection getClusterConnection() {<a name="line.657"></a>
+<span class="sourceLineNo">658</span>      // TODO Auto-generated method stub<a name="line.658"></a>
+<span class="sourceLineNo">659</span>      return null;<a name="line.659"></a>
+<span class="sourceLineNo">660</span>    }<a name="line.660"></a>
+<span class="sourceLineNo">661</span>  }<a name="line.661"></a>
+<span class="sourceLineNo">662</span>}<a name="line.662"></a>
 
 
 


Mime
View raw message