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<String> 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<String, SortedSet<String>> 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<Set<String>> sets = logZnodesMap.values();<a name="line.560"></a> -<span class="sourceLineNo">561</span> if (sets.size() > 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<String> 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<Set<String>> sets = logZnodesMap.values();<a name="line.562"></a> +<span class="sourceLineNo">563</span> if (sets.size() > 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<String> 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<String> 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<String, SortedSet<String>> 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<Set<String>> sets = logZnodesMap.values();<a name="line.560"></a> -<span class="sourceLineNo">561</span> if (sets.size() > 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<String> 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<Set<String>> sets = logZnodesMap.values();<a name="line.562"></a> +<span class="sourceLineNo">563</span> if (sets.size() > 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<String> 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<String> 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<String, SortedSet<String>> 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<Set<String>> sets = logZnodesMap.values();<a name="line.560"></a> -<span class="sourceLineNo">561</span> if (sets.size() > 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<String> 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<Set<String>> sets = logZnodesMap.values();<a name="line.562"></a> +<span class="sourceLineNo">563</span> if (sets.size() > 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<String> 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<String> 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<String, SortedSet<String>> 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<Set<String>> sets = logZnodesMap.values();<a name="line.560"></a> -<span class="sourceLineNo">561</span> if (sets.size() > 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<String> 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<Set<String>> sets = logZnodesMap.values();<a name="line.562"></a> +<span class="sourceLineNo">563</span> if (sets.size() > 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<String> 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>
