http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
 
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
index 852f85c..174dfdd 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html
@@ -18,8 +18,8 @@
     catch(err) {
     }
 //-->
-var methods = 
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":9,"i38":10,"i39":10,"i40":10};
-var tabs = {65535:["t0","All Methods"],1:["t1","Static 
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
+var methods = 
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
 var tableTab = "tableTab";
@@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab";
 <hr>
 <br>
 <pre>@InterfaceAudience.Private
-public class <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.123">ReplicationSourceManager</a>
+public class <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.116">ReplicationSourceManager</a>
 extends <a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object</a>
 implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationListener.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationListener</a></pre>
 <div class="block">This class is responsible to manage all the replication 
sources. There are two classes of
@@ -329,7 +329,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 </a>
 <h3>Method Summary</h3>
 <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" 
summary="Method Summary table, listing methods, and an explanation">
-<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span 
class="tabEnd">&nbsp;</span></span><span id="t1" class="tableTab"><span><a 
href="javascript:show(1);">Static Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a 
href="javascript:show(2);">Instance Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t4" class="tableTab"><span><a 
href="javascript:show(8);">Concrete Methods</a></span><span 
class="tabEnd">&nbsp;</span></span></caption>
+<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span 
class="tabEnd">&nbsp;</span></span><span id="t2" class="tableTab"><span><a 
href="javascript:show(2);">Instance Methods</a></span><span 
class="tabEnd">&nbsp;</span></span><span id="t4" class="tableTab"><span><a 
href="javascript:show(8);">Concrete Methods</a></span><span 
class="tabEnd">&nbsp;</span></span></caption>
 <tr>
 <th class="colFirst" scope="col">Modifier and Type</th>
 <th class="colLast" scope="col">Method and Description</th>
@@ -538,29 +538,16 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 </td>
 </tr>
 <tr id="i36" class="altColor">
-<td class="colFirst"><code>(package private) void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#scopeWALEdits-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-">scopeWALEdits</a></span>(<a
 href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" 
title="interface in org.apache.hadoop.hbase.wal">WALKey</a>&nbsp;logKey,
-             <a 
href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class 
in org.apache.hadoop.hbase.wal">WALEdit</a>&nbsp;logEdit)</code>&nbsp;</td>
-</tr>
-<tr id="i37" class="rowColor">
-<td class="colFirst"><code>(package private) static void</code></td>
-<td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#scopeWALEdits-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-org.apache.hadoop.conf.Configuration-">scopeWALEdits</a></span>(<a
 href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" 
title="interface in org.apache.hadoop.hbase.wal">WALKey</a>&nbsp;logKey,
-             <a 
href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class 
in org.apache.hadoop.hbase.wal">WALEdit</a>&nbsp;logEdit,
-             org.apache.hadoop.conf.Configuration&nbsp;conf)</code>
-<div class="block">Utility method used to set the correct scopes on each log 
key.</div>
-</td>
-</tr>
-<tr id="i38" class="altColor">
 <td class="colFirst"><code>private void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#throwIOExceptionWhenFail-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager.ReplicationQueueOperation-">throwIOExceptionWhenFail</a></span>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a>&nbsp;op)</code>&nbsp;</td>
 </tr>
-<tr id="i39" class="rowColor">
+<tr id="i37" class="rowColor">
 <td class="colFirst"><code>private void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#transferQueues-org.apache.hadoop.hbase.ServerName-">transferQueues</a></span>(<a
 href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class 
in org.apache.hadoop.hbase">ServerName</a>&nbsp;deadRS)</code>
 <div class="block">Transfer all the queues of the specified to this region 
server.</div>
 </td>
 </tr>
-<tr id="i40" class="altColor">
+<tr id="i38" class="altColor">
 <td class="colFirst"><code>(package private) void</code></td>
 <td class="colLast"><code><span class="memberNameLink"><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#waitUntilCanBePushed-byte:A-long-java.lang.String-">waitUntilCanBePushed</a></span>(byte[]&nbsp;encodedName,
                     long&nbsp;seq,
@@ -596,7 +583,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>LOG</h4>
-<pre>private static final&nbsp;org.slf4j.Logger <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.124">LOG</a></pre>
+<pre>private static final&nbsp;org.slf4j.Logger <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.117">LOG</a></pre>
 </li>
 </ul>
 <a name="sources">
@@ -605,7 +592,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>sources</h4>
-<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentMap</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&gt;
 <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.126">sources</a></pre>
+<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentMap</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&gt;
 <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.119">sources</a></pre>
 </li>
 </ul>
 <a name="oldsources">
@@ -614,7 +601,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>oldsources</h4>
-<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&gt;
 <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.128">oldsources</a></pre>
+<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&gt;
 <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.121">oldsources</a></pre>
 </li>
 </ul>
 <a name="queueStorage">
@@ -623,7 +610,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>queueStorage</h4>
-<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.129">queueStorage</a></pre>
+<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.122">queueStorage</a></pre>
 </li>
 </ul>
 <a name="replicationTracker">
@@ -632,7 +619,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>replicationTracker</h4>
-<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationTracker</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.130">replicationTracker</a></pre>
+<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationTracker</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.123">replicationTracker</a></pre>
 </li>
 </ul>
 <a name="replicationPeers">
@@ -641,7 +628,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>replicationPeers</h4>
-<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
 title="class in org.apache.hadoop.hbase.replication">ReplicationPeers</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.131">replicationPeers</a></pre>
+<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
 title="class in org.apache.hadoop.hbase.replication">ReplicationPeers</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.124">replicationPeers</a></pre>
 </li>
 </ul>
 <a name="clusterId">
@@ -650,7 +637,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>clusterId</h4>
-<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/UUID.html?is-external=true";
 title="class or interface in java.util">UUID</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.133">clusterId</a></pre>
+<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/UUID.html?is-external=true";
 title="class or interface in java.util">UUID</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.126">clusterId</a></pre>
 </li>
 </ul>
 <a name="server">
@@ -659,7 +646,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>server</h4>
-<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface 
in org.apache.hadoop.hbase">Server</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.135">server</a></pre>
+<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/Server.html" title="interface 
in org.apache.hadoop.hbase">Server</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.128">server</a></pre>
 </li>
 </ul>
 <a name="walsById">
@@ -668,7 +655,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>walsById</h4>
-<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentMap</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&gt;&gt; <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replicatio
 n/regionserver/ReplicationSourceManager.html#line.140">walsById</a></pre>
+<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentMap</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&gt;&gt; <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replicatio
 n/regionserver/ReplicationSourceManager.html#line.133">walsById</a></pre>
 </li>
 </ul>
 <a name="walsByIdRecoveredQueues">
@@ -677,7 +664,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>walsByIdRecoveredQueues</h4>
-<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentMap</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&gt;&gt; <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replicatio
 
n/regionserver/ReplicationSourceManager.html#line.144">walsByIdRecoveredQueues</a></pre>
+<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentMap</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&gt;&gt; <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replicatio
 
n/regionserver/ReplicationSourceManager.html#line.137">walsByIdRecoveredQueues</a></pre>
 </li>
 </ul>
 <a name="conf">
@@ -686,7 +673,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>conf</h4>
-<pre>private final&nbsp;org.apache.hadoop.conf.Configuration <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.146">conf</a></pre>
+<pre>private final&nbsp;org.apache.hadoop.conf.Configuration <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.139">conf</a></pre>
 </li>
 </ul>
 <a name="fs">
@@ -695,7 +682,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>fs</h4>
-<pre>private final&nbsp;org.apache.hadoop.fs.FileSystem <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.147">fs</a></pre>
+<pre>private final&nbsp;org.apache.hadoop.fs.FileSystem <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.140">fs</a></pre>
 </li>
 </ul>
 <a name="latestPaths">
@@ -704,7 +691,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>latestPaths</h4>
-<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true";
 title="class or interface in 
java.util">Set</a>&lt;org.apache.hadoop.fs.Path&gt; <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.149">latestPaths</a></pre>
+<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true";
 title="class or interface in 
java.util">Set</a>&lt;org.apache.hadoop.fs.Path&gt; <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.142">latestPaths</a></pre>
 </li>
 </ul>
 <a name="logDir">
@@ -713,7 +700,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>logDir</h4>
-<pre>private final&nbsp;org.apache.hadoop.fs.Path <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.151">logDir</a></pre>
+<pre>private final&nbsp;org.apache.hadoop.fs.Path <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.144">logDir</a></pre>
 </li>
 </ul>
 <a name="oldLogDir">
@@ -722,7 +709,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>oldLogDir</h4>
-<pre>private final&nbsp;org.apache.hadoop.fs.Path <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.153">oldLogDir</a></pre>
+<pre>private final&nbsp;org.apache.hadoop.fs.Path <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.146">oldLogDir</a></pre>
 </li>
 </ul>
 <a name="walFileLengthProvider">
@@ -731,7 +718,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>walFileLengthProvider</h4>
-<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.154">walFileLengthProvider</a></pre>
+<pre>private final&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/WALFileLengthProvider.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">WALFileLengthProvider</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.147">walFileLengthProvider</a></pre>
 </li>
 </ul>
 <a name="sleepBeforeFailover">
@@ -740,7 +727,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>sleepBeforeFailover</h4>
-<pre>private final&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.156">sleepBeforeFailover</a></pre>
+<pre>private final&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.149">sleepBeforeFailover</a></pre>
 </li>
 </ul>
 <a name="executor">
@@ -749,7 +736,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>executor</h4>
-<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.html?is-external=true";
 title="class or interface in java.util.concurrent">ThreadPoolExecutor</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.158">executor</a></pre>
+<pre>private final&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.html?is-external=true";
 title="class or interface in java.util.concurrent">ThreadPoolExecutor</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.151">executor</a></pre>
 </li>
 </ul>
 <a name="replicationForBulkLoadDataEnabled">
@@ -758,7 +745,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>replicationForBulkLoadDataEnabled</h4>
-<pre>private final&nbsp;boolean <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.160">replicationForBulkLoadDataEnabled</a></pre>
+<pre>private final&nbsp;boolean <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.153">replicationForBulkLoadDataEnabled</a></pre>
 </li>
 </ul>
 <a name="connection">
@@ -767,7 +754,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>connection</h4>
-<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" 
title="interface in org.apache.hadoop.hbase.client">Connection</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.162">connection</a></pre>
+<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" 
title="interface in org.apache.hadoop.hbase.client">Connection</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.155">connection</a></pre>
 </li>
 </ul>
 <a name="replicationWaitTime">
@@ -776,7 +763,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>replicationWaitTime</h4>
-<pre>private&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.163">replicationWaitTime</a></pre>
+<pre>private&nbsp;long <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.156">replicationWaitTime</a></pre>
 </li>
 </ul>
 <a name="totalBufferUsed">
@@ -785,7 +772,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockListLast">
 <li class="blockList">
 <h4>totalBufferUsed</h4>
-<pre>private&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true";
 title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.165">totalBufferUsed</a></pre>
+<pre>private&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true";
 title="class or interface in java.util.concurrent.atomic">AtomicLong</a> <a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.158">totalBufferUsed</a></pre>
 </li>
 </ul>
 </li>
@@ -802,7 +789,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockListLast">
 <li class="blockList">
 <h4>ReplicationSourceManager</h4>
-<pre>public&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.179">ReplicationSourceManager</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a>&nbsp;queueStorage,
+<pre>public&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.172">ReplicationSourceManager</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationQueueStorage.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationQueueStorage</a>&nbsp;queueStorage,
                                 <a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
 title="class in 
org.apache.hadoop.hbase.replication">ReplicationPeers</a>&nbsp;replicationPeers,
                                 <a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationTracker.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationTracker</a>&nbsp;replicationTracker,
                                 org.apache.hadoop.conf.Configuration&nbsp;conf,
@@ -844,7 +831,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>init</h4>
-<pre><a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true";
 title="class or interface in java.util.concurrent">Future</a>&lt;?&gt;&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.227">init</a>()
+<pre><a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true";
 title="class or interface in java.util.concurrent">Future</a>&lt;?&gt;&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.220">init</a>()
         throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <div class="block">Adds a normal source per registered peer cluster and tries 
to process all old region server wal
  queues
@@ -862,7 +849,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>adoptAbandonedQueues</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.239">adoptAbandonedQueues</a>()</pre>
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.232">adoptAbandonedQueues</a>()</pre>
 </li>
 </ul>
 <a name="addPeer-java.lang.String-">
@@ -871,7 +858,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>addPeer</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.268">addPeer</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.261">addPeer</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)
              throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <div class="block">1. Add peer to replicationPeers 2. Add the normal source 
and related replication queue 3. Add
  HFile Refs</div>
@@ -889,7 +876,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>removePeer</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.289">removePeer</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)</pre>
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.282">removePeer</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)</pre>
 <div class="block">1. Remove peer for replicationPeers 2. Remove all the 
recovered sources for the specified id
  and related replication queues 3. Remove the normal source and related 
replication queue 4.
  Remove HFile Refs</div>
@@ -905,7 +892,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>createSource</h4>
-<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.331">createSource</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;queueId,
+<pre>private&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.324">createSource</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;queueId,
                                                 <a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeer.html"
 title="interface in 
org.apache.hadoop.hbase.replication">ReplicationPeer</a>&nbsp;replicationPeer)
                                          throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <div class="block">Factory method to create a replication source</div>
@@ -925,7 +912,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>addSource</h4>
-<pre><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.350">addSource</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)
+<pre><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.343">addSource</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)
                               throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <div class="block">Add a normal source for the given peer on this region 
server. Meanwhile, add new replication
  queue to storage. For the newly added peer, we only need to enqueue the 
latest log of each wal
@@ -946,7 +933,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>refreshSources</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.384">refreshSources</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.377">refreshSources</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)
                     throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <div class="block">Close the previous replication sources of this peer id and 
open new sources to trigger the new
  replication state changes or new replication config changes. Here we don't 
need to change
@@ -965,7 +952,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>removeRecoveredSource</h4>
-<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.432">removeRecoveredSource</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;src)</pre>
+<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.425">removeRecoveredSource</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;src)</pre>
 <div class="block">Clear the metrics and related replication queue of the 
specified old source</div>
 <dl>
 <dt><span class="paramLabel">Parameters:</span></dt>
@@ -979,7 +966,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>removeSource</h4>
-<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.445">removeSource</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;src)</pre>
+<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.438">removeSource</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;src)</pre>
 <div class="block">Clear the metrics and related replication queue of the 
specified old source</div>
 <dl>
 <dt><span class="paramLabel">Parameters:</span></dt>
@@ -993,7 +980,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>deleteQueue</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.458">deleteQueue</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;queueId)</pre>
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.451">deleteQueue</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;queueId)</pre>
 <div class="block">Delete a complete queue of wals associated with a 
replication source</div>
 <dl>
 <dt><span class="paramLabel">Parameters:</span></dt>
@@ -1007,7 +994,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>abortWhenFail</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.467">abortWhenFail</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a>&nbsp;op)</pre>
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.460">abortWhenFail</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a>&nbsp;op)</pre>
 </li>
 </ul>
 <a 
name="throwIOExceptionWhenFail-org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager.ReplicationQueueOperation-">
@@ -1016,7 +1003,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>throwIOExceptionWhenFail</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.475">throwIOExceptionWhenFail</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a>&nbsp;op)
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.468">throwIOExceptionWhenFail</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a>&nbsp;op)
                                throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
@@ -1030,7 +1017,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>abortAndThrowIOExceptionWhenFail</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.483">abortAndThrowIOExceptionWhenFail</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a>&nbsp;op)
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.476">abortAndThrowIOExceptionWhenFail</a>(<a
 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.ReplicationQueueOperation.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceManager.ReplicationQueueOperation</a>&nbsp;op)
                                        throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
@@ -1044,7 +1031,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>logPositionAndCleanOldLogs</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.500">logPositionAndCleanOldLogs</a>(org.apache.hadoop.fs.Path&nbsp;log,
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.493">logPositionAndCleanOldLogs</a>(org.apache.hadoop.fs.Path&nbsp;log,
                                        <a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;queueId,
                                        long&nbsp;position,
                                        boolean&nbsp;queueRecovered)</pre>
@@ -1065,7 +1052,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>cleanOldLogs</h4>
-<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.516">cleanOldLogs</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;log,
+<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.509">cleanOldLogs</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;log,
                   <a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;queueId,
                   boolean&nbsp;queueRecovered)</pre>
 <div class="block">Cleans a log file and all older logs from replication 
queue. Called when we are sure that a log
@@ -1084,7 +1071,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>cleanOldLogs</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.534">cleanOldLogs</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&nbsp;wals,
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.527">cleanOldLogs</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&nbsp;wals,
                           <a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;key,
                           <a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;id)</pre>
 </li>
@@ -1095,7 +1082,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>preLogRoll</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.547">preLogRoll</a>(org.apache.hadoop.fs.Path&nbsp;newLog)
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.540">preLogRoll</a>(org.apache.hadoop.fs.Path&nbsp;newLog)
                 throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
@@ -1109,7 +1096,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>postLogRoll</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.604">postLogRoll</a>(org.apache.hadoop.fs.Path&nbsp;newLog)
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.597">postLogRoll</a>(org.apache.hadoop.fs.Path&nbsp;newLog)
                  throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
@@ -1117,49 +1104,13 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 </dl>
 </li>
 </ul>
-<a 
name="scopeWALEdits-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-">
-<!--   -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>scopeWALEdits</h4>
-<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.611">scopeWALEdits</a>(<a
 href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" 
title="interface in org.apache.hadoop.hbase.wal">WALKey</a>&nbsp;logKey,
-                   <a 
href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class 
in org.apache.hadoop.hbase.wal">WALEdit</a>&nbsp;logEdit)
-            throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
-<dl>
-<dt><span class="throwsLabel">Throws:</span></dt>
-<dd><code><a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></code></dd>
-</dl>
-</li>
-</ul>
-<a 
name="scopeWALEdits-org.apache.hadoop.hbase.wal.WALKey-org.apache.hadoop.hbase.wal.WALEdit-org.apache.hadoop.conf.Configuration-">
-<!--   -->
-</a>
-<ul class="blockList">
-<li class="blockList">
-<h4>scopeWALEdits</h4>
-<pre>static&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.623">scopeWALEdits</a>(<a
 href="../../../../../../org/apache/hadoop/hbase/wal/WALKey.html" 
title="interface in org.apache.hadoop.hbase.wal">WALKey</a>&nbsp;logKey,
-                          <a 
href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class 
in org.apache.hadoop.hbase.wal">WALEdit</a>&nbsp;logEdit,
-                          org.apache.hadoop.conf.Configuration&nbsp;conf)
-                   throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
-<div class="block">Utility method used to set the correct scopes on each log 
key. Doesn't set a scope on keys from
- compaction WAL edits and if the scope is local.</div>
-<dl>
-<dt><span class="paramLabel">Parameters:</span></dt>
-<dd><code>logKey</code> - Key that may get scoped according to its edits</dd>
-<dd><code>logEdit</code> - Edits used to lookup the scopes</dd>
-<dt><span class="throwsLabel">Throws:</span></dt>
-<dd><code><a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></code> - If failed to 
parse the WALEdit</dd>
-</dl>
-</li>
-</ul>
 <a name="regionServerRemoved-java.lang.String-">
 <!--   -->
 </a>
 <ul class="blockList">
 <li class="blockList">
 <h4>regionServerRemoved</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.649">regionServerRemoved</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;regionserver)</pre>
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.605">regionServerRemoved</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;regionserver)</pre>
 <div class="block"><span class="descfrmTypeLabel">Description copied from 
interface:&nbsp;<code><a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationListener.html#regionServerRemoved-java.lang.String-">ReplicationListener</a></code></span></div>
 <div class="block">A region server has been removed from the local 
cluster</div>
 <dl>
@@ -1176,7 +1127,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>transferQueues</h4>
-<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.659">transferQueues</a>(<a
 href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class 
in org.apache.hadoop.hbase">ServerName</a>&nbsp;deadRS)</pre>
+<pre>private&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.615">transferQueues</a>(<a
 href="../../../../../../org/apache/hadoop/hbase/ServerName.html" title="class 
in org.apache.hadoop.hbase">ServerName</a>&nbsp;deadRS)</pre>
 <div class="block">Transfer all the queues of the specified to this region 
server. First it tries to grab a lock
  and if it works it will move the old queues and finally will delete the old 
queues.
  <p>
@@ -1189,7 +1140,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>join</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.788">join</a>()</pre>
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.751">join</a>()</pre>
 <div class="block">Terminate the replication on this region server</div>
 </li>
 </ul>
@@ -1199,7 +1150,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getWALs</h4>
-<pre><a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&gt;&gt;&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.800">g
 etWALs</a>()</pre>
+<pre><a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&gt;&gt;&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.763">g
 etWALs</a>()</pre>
 <div class="block">Get a copy of the wals of the normal sources on this 
rs</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1213,7 +1164,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getWalsByIdRecoveredQueues</h4>
-<pre><a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&gt;&gt;&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.809">g
 etWalsByIdRecoveredQueues</a>()</pre>
+<pre><a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>,<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true";
 title="class or interface in java.util">SortedSet</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&gt;&gt;&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.772">g
 etWalsByIdRecoveredQueues</a>()</pre>
 <div class="block">Get a copy of the wals of the recovered sources on this 
rs</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1227,7 +1178,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getSources</h4>
-<pre>public&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&gt;&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.817">getSources</a>()</pre>
+<pre>public&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&gt;&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.780">getSources</a>()</pre>
 <div class="block">Get a list of all the normal sources of this rs</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1241,7 +1192,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getOldSources</h4>
-<pre>public&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&gt;&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.825">getOldSources</a>()</pre>
+<pre>public&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&gt;&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.788">getOldSources</a>()</pre>
 <div class="block">Get a list of all the recovered sources of this rs</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1255,7 +1206,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getSource</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.834">getSource</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceInterface.html"
 title="interface in 
org.apache.hadoop.hbase.replication.regionserver">ReplicationSourceInterface</a>&nbsp;<a
 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.797">getSource</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)</pre>
 <div class="block">Get the normal source for a given peer</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1269,7 +1220,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getAllQueues</h4>
-<pre><a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.839">getAllQueues</a>()
+<pre><a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.802">getAllQueues</a>()
                    throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
 <dl>
 <dt><span class="throwsLabel">Throws:</span></dt>
@@ -1283,7 +1234,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getSizeOfLatestPath</h4>
-<pre>int&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.850">getSizeOfLatestPath</a>()</pre>
+<pre>int&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.813">getSizeOfLatestPath</a>()</pre>
 </li>
 </ul>
 <a name="getTotalBufferUsed--">
@@ -1292,7 +1243,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getTotalBufferUsed</h4>
-<pre>public&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true";
 title="class or interface in 
java.util.concurrent.atomic">AtomicLong</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.857">getTotalBufferUsed</a>()</pre>
+<pre>public&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true";
 title="class or interface in 
java.util.concurrent.atomic">AtomicLong</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.820">getTotalBufferUsed</a>()</pre>
 </li>
 </ul>
 <a name="getOldLogDir--">
@@ -1301,7 +1252,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getOldLogDir</h4>
-<pre>public&nbsp;org.apache.hadoop.fs.Path&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.865">getOldLogDir</a>()</pre>
+<pre>public&nbsp;org.apache.hadoop.fs.Path&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.828">getOldLogDir</a>()</pre>
 <div class="block">Get the directory where wals are archived</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1315,7 +1266,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getLogDir</h4>
-<pre>public&nbsp;org.apache.hadoop.fs.Path&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.873">getLogDir</a>()</pre>
+<pre>public&nbsp;org.apache.hadoop.fs.Path&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.836">getLogDir</a>()</pre>
 <div class="block">Get the directory where wals are stored by their RSs</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1329,7 +1280,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getFs</h4>
-<pre>public&nbsp;org.apache.hadoop.fs.FileSystem&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.881">getFs</a>()</pre>
+<pre>public&nbsp;org.apache.hadoop.fs.FileSystem&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.844">getFs</a>()</pre>
 <div class="block">Get the handle on the local file system</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1343,7 +1294,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getConnection</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" 
title="interface in org.apache.hadoop.hbase.client">Connection</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.885">getConnection</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/client/Connection.html" 
title="interface in org.apache.hadoop.hbase.client">Connection</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.848">getConnection</a>()</pre>
 </li>
 </ul>
 <a name="getReplicationPeers--">
@@ -1352,7 +1303,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getReplicationPeers</h4>
-<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
 title="class in 
org.apache.hadoop.hbase.replication">ReplicationPeers</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.893">getReplicationPeers</a>()</pre>
+<pre>public&nbsp;<a 
href="../../../../../../org/apache/hadoop/hbase/replication/ReplicationPeers.html"
 title="class in 
org.apache.hadoop.hbase.replication">ReplicationPeers</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.856">getReplicationPeers</a>()</pre>
 <div class="block">Get the ReplicationPeers used by this 
ReplicationSourceManager</div>
 <dl>
 <dt><span class="returnLabel">Returns:</span></dt>
@@ -1366,7 +1317,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>getStats</h4>
-<pre>public&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.900">getStats</a>()</pre>
+<pre>public&nbsp;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.863">getStats</a>()</pre>
 <div class="block">Get a string representation of all the sources' 
metrics</div>
 </li>
 </ul>
@@ -1376,7 +1327,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>addHFileRefs</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.913">addHFileRefs</a>(<a
 href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class 
in org.apache.hadoop.hbase">TableName</a>&nbsp;tableName,
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.876">addHFileRefs</a>(<a
 href="../../../../../../org/apache/hadoop/hbase/TableName.html" title="class 
in org.apache.hadoop.hbase">TableName</a>&nbsp;tableName,
                          byte[]&nbsp;family,
                          <a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="../../../../../../org/apache/hadoop/hbase/util/Pair.html" title="class in 
org.apache.hadoop.hbase.util">Pair</a>&lt;org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path&gt;&gt;&nbsp;pairs)
                   throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a></pre>
@@ -1392,7 +1343,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>cleanUpHFileRefs</h4>
-<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.920">cleanUpHFileRefs</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId,
+<pre>public&nbsp;void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.883">cleanUpHFileRefs</a>(<a
 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId,
                              <a 
href="http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List</a>&lt;<a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&gt;&nbsp;files)</pre>
 </li>
 </ul>
@@ -1402,7 +1353,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockList">
 <li class="blockList">
 <h4>activeFailoverTaskCount</h4>
-<pre>int&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.924">activeFailoverTaskCount</a>()</pre>
+<pre>int&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.887">activeFailoverTaskCount</a>()</pre>
 </li>
 </ul>
 <a name="waitUntilCanBePushed-byte:A-long-java.lang.String-">
@@ -1411,7 +1362,7 @@ implements <a 
href="../../../../../../org/apache/hadoop/hbase/replication/Replic
 <ul class="blockListLast">
 <li class="blockList">
 <h4>waitUntilCanBePushed</h4>
-<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.937">waitUntilCanBePushed</a>(byte[]&nbsp;encodedName,
+<pre>void&nbsp;<a 
href="../../../../../../src-html/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.html#line.900">waitUntilCanBePushed</a>(byte[]&nbsp;encodedName,
                           long&nbsp;seq,
                           <a 
href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String</a>&nbsp;peerId)
                    throws <a 
href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException</a>,

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/6674e3ab/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html
----------------------------------------------------------------------
diff --git 
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html
 
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html
index 9146e74..96a0dce 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html
@@ -50,7 +50,7 @@ var activeTableTab = "activeTableTab";
 <div class="subNav">
 <ul class="navList">
 <li><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in org.apache.hadoop.hbase.replication.regionserver"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html"
 title="class in org.apache.hadoop.hbase.replication.regionserver"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
+<li><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALActionListener.html"
 title="class in org.apache.hadoop.hbase.replication.regionserver"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
 </ul>
 <ul class="navList">
 <li><a 
href="../../../../../../index.html?org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html"
 target="_top">Frames</a></li>
@@ -313,7 +313,7 @@ not permitted.)</div>
 <div class="subNav">
 <ul class="navList">
 <li><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.html"
 title="class in org.apache.hadoop.hbase.replication.regionserver"><span 
class="typeNameLink">Prev&nbsp;Class</span></a></li>
-<li><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALReader.html"
 title="class in org.apache.hadoop.hbase.replication.regionserver"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
+<li><a 
href="../../../../../../org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceWALActionListener.html"
 title="class in org.apache.hadoop.hbase.replication.regionserver"><span 
class="typeNameLink">Next&nbsp;Class</span></a></li>
 </ul>
 <ul class="navList">
 <li><a 
href="../../../../../../index.html?org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceShipper.WorkerState.html"
 target="_top">Frames</a></li>

Reply via email to