http://git-wip-us.apache.org/repos/asf/hbase-site/blob/dc4e5c85/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html index ba64531..17e9d14 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>static class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.813">FSHLog.SafePointZigZagLatch</a> +<pre>static class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.782">FSHLog.SafePointZigZagLatch</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></pre> <div class="block">This class is used coordinating two threads holding one thread at a 'safe point' while the orchestrating thread does some work that requires the first thread paused: e.g. holding the WAL @@ -254,7 +254,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>safePointAttainedLatch</h4> -<pre>private volatile <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CountDownLatch.html?is-external=true"; title="class or interface in java.util.concurrent">CountDownLatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.817">safePointAttainedLatch</a></pre> +<pre>private volatile <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CountDownLatch.html?is-external=true"; title="class or interface in java.util.concurrent">CountDownLatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.786">safePointAttainedLatch</a></pre> <div class="block">Count down this latch when safe point attained.</div> </li> </ul> @@ -264,7 +264,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>safePointReleasedLatch</h4> -<pre>private volatile <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CountDownLatch.html?is-external=true"; title="class or interface in java.util.concurrent">CountDownLatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.821">safePointReleasedLatch</a></pre> +<pre>private volatile <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CountDownLatch.html?is-external=true"; title="class or interface in java.util.concurrent">CountDownLatch</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.790">safePointReleasedLatch</a></pre> <div class="block">Latch to wait on. Will be released when we can proceed.</div> </li> </ul> @@ -282,7 +282,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>SafePointZigZagLatch</h4> -<pre><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.813">SafePointZigZagLatch</a>()</pre> +<pre><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.782">SafePointZigZagLatch</a>()</pre> </li> </ul> </li> @@ -299,7 +299,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>checkIfSyncFailed</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.823">checkIfSyncFailed</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> syncFuture) +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.792">checkIfSyncFailed</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> syncFuture) throws <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FailedSyncBeforeLogCloseException.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FailedSyncBeforeLogCloseException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -313,7 +313,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>waitSafePoint</h4> -<pre><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.836">waitSafePoint</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> syncFuture) +<pre><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.805">waitSafePoint</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> syncFuture) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FailedSyncBeforeLogCloseException.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FailedSyncBeforeLogCloseException</a></pre> <div class="block">For Thread A to call when it is ready to wait on the 'safe point' to be attained. Thread A @@ -336,7 +336,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>safePointAttained</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.850">safePointAttained</a>() +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.819">safePointAttained</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <div class="block">Called by Thread B when it attains the 'safe point'. In this method, Thread B signals Thread A it can proceed. Thread B will be held in here until <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#releaseSafePoint--"><code>releaseSafePoint()</code></a> is called @@ -353,7 +353,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>releaseSafePoint</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.859">releaseSafePoint</a>()</pre> +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.828">releaseSafePoint</a>()</pre> <div class="block">Called by Thread A when it is done with the work it needs to do while Thread B is halted. This will release the Thread B held in a call to <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#safePointAttained--"><code>safePointAttained()</code></a></div> </li> @@ -364,7 +364,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>isCocked</h4> -<pre>boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.866">isCocked</a>()</pre> +<pre>boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SafePointZigZagLatch.html#line.835">isCocked</a>()</pre> <dl> <dt><span class="returnLabel">Returns:</span></dt> <dd>True is this is a 'cocked', fresh instance, and not one that has already fired.</dd>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/dc4e5c85/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html index 8bdf507..05ae664 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; </dl> <hr> <br> -<pre>private class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.467">FSHLog.SyncRunner</a> +<pre>private class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.455">FSHLog.SyncRunner</a> extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" title="class in org.apache.hadoop.hbase.util">HasThread</a></pre> <div class="block">Thread to runs the hdfs sync call. This call takes a while to complete. This is the longest pole adding edits to the WAL and this must complete to be sure all edits persisted. We run @@ -269,7 +269,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockList"> <li class="blockList"> <h4>sequence</h4> -<pre>private volatile long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.468">sequence</a></pre> +<pre>private volatile long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.456">sequence</a></pre> </li> </ul> <a name="syncFutures"> @@ -278,7 +278,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockList"> <li class="blockList"> <h4>syncFutures</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.470">syncFutures</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/BlockingQueue.html?is-external=true"; title="class or interface in java.util.concurrent">BlockingQueue</a><<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.458">syncFutures</a></pre> </li> </ul> <a name="takeSyncFuture"> @@ -287,7 +287,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockListLast"> <li class="blockList"> <h4>takeSyncFuture</h4> -<pre>private volatile <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.471">takeSyncFuture</a></pre> +<pre>private volatile <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.459">takeSyncFuture</a></pre> </li> </ul> </li> @@ -304,7 +304,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockListLast"> <li class="blockList"> <h4>SyncRunner</h4> -<pre><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.473">SyncRunner</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> name, +<pre><a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.461">SyncRunner</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> name, int maxHandlersCount)</pre> </li> </ul> @@ -322,7 +322,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockList"> <li class="blockList"> <h4>offer</h4> -<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.491">offer</a>(long sequence, +<pre>void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.479">offer</a>(long sequence, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a>[] syncFutures, int syncFutureCount)</pre> </li> @@ -333,7 +333,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockList"> <li class="blockList"> <h4>releaseSyncFuture</h4> -<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.503">releaseSyncFuture</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> syncFuture, +<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.491">releaseSyncFuture</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> syncFuture, long currentSequence, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> t)</pre> <div class="block">Release the passed <code>syncFuture</code></div> @@ -349,7 +349,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockList"> <li class="blockList"> <h4>releaseSyncFutures</h4> -<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.518">releaseSyncFutures</a>(long currentSequence, +<pre>private int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.506">releaseSyncFutures</a>(long currentSequence, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true"; title="class or interface in java.lang">Throwable</a> t)</pre> <div class="block">Release all SyncFutures whose sequence is <= <code>currentSequence</code>.</div> <dl> @@ -366,7 +366,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockList"> <li class="blockList"> <h4>updateHighestSyncedSequence</h4> -<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.537">updateHighestSyncedSequence</a>(long sequence)</pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.525">updateHighestSyncedSequence</a>(long sequence)</pre> <dl> <dt><span class="paramLabel">Parameters:</span></dt> <dd><code>sequence</code> - The sequence we ran the filesystem sync against.</dd> @@ -381,7 +381,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockList"> <li class="blockList"> <h4>areSyncFuturesReleased</h4> -<pre>boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.552">areSyncFuturesReleased</a>()</pre> +<pre>boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.540">areSyncFuturesReleased</a>()</pre> </li> </ul> <a name="run--"> @@ -390,7 +390,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/util/HasThread.html" <ul class="blockListLast"> <li class="blockList"> <h4>run</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.560">run</a>()</pre> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.SyncRunner.html#line.548">run</a>()</pre> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> <dd><code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true#run--"; title="class or interface in java.lang">run</a></code> in interface <code><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true"; title="class or interface in java.lang">Runnable</a></code></dd> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/dc4e5c85/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html index 37225cc..264a3d4 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/FSHLog.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":9,"i16":10,"i17":10,"i18":10,"i19":10,"i20":9,"i21":10,"i22":10,"i23":9}; -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}; +var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; var tableTab = "tableTab"; @@ -119,7 +119,7 @@ var activeTableTab = "activeTableTab"; <hr> <br> <pre>@InterfaceAudience.Private -public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.76">FSHLog</a> +public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.68">FSHLog</a> extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a>></pre> <div class="block">The default implementation of FSWAL.</div> </li> @@ -218,26 +218,22 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst </td> </tr> <tr class="altColor"> -<td class="colFirst"><code>private long</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#lastTimeCheckLowReplication">lastTimeCheckLowReplication</a></span></code> </td> -</tr> -<tr class="rowColor"> <td class="colFirst"><code>private static org.apache.commons.logging.Log</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#LOG">LOG</a></span></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#lowReplicationRollEnabled">lowReplicationRollEnabled</a></span></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#lowReplicationRollLimit">lowReplicationRollLimit</a></span></code> </td> </tr> -<tr class="altColor"> +<tr class="rowColor"> <td class="colFirst"><code>private int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#minTolerableReplication">minTolerableReplication</a></span></code> </td> </tr> -<tr class="rowColor"> +<tr class="altColor"> <td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.RingBufferEventHandler.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSHLog.RingBufferEventHandler</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#ringBufferEventHandler">ringBufferEventHandler</a></span></code> <div class="block">This fellow is run by the above appendExecutor service but it is all about batching up appends @@ -296,7 +292,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst </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"> </span></span><span id="t1" class="tableTab"><span><a href="javascript:show(1);">Static Methods</a></span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> +<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> <tr> <th class="colFirst" scope="col">Modifier and Type</th> <th class="colLast" scope="col">Method and Description</th> @@ -322,27 +318,27 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#beforeWaitOnSafePoint--">beforeWaitOnSafePoint</a></span>()</code> </td> </tr> <tr id="i3" class="rowColor"> -<td class="colFirst"><code>void</code></td> +<td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#checkLogRoll--">checkLogRoll</a></span>()</code> <div class="block">Schedule a log roll if needed.</div> </td> </tr> <tr id="i4" class="altColor"> -<td class="colFirst"><code>private boolean</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#checkLowReplication--">checkLowReplication</a></span>()</code> </td> -</tr> -<tr id="i5" class="rowColor"> <td class="colFirst"><code>protected <a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#createWriterInstance-org.apache.hadoop.fs.Path-">createWriterInstance</a></span>(org.apache.hadoop.fs.Path path)</code> <div class="block">This method allows subclasses to inject different writers without having to extend other methods like rollWriter().</div> </td> </tr> -<tr id="i6" class="altColor"> +<tr id="i5" class="rowColor"> <td class="colFirst"><code>protected void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#doAppend-org.apache.hadoop.hbase.wal.WALProvider.Writer-org.apache.hadoop.hbase.regionserver.wal.FSWALEntry-">doAppend</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a> writer, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a> entry)</code> </td> </tr> +<tr id="i6" class="altColor"> +<td class="colFirst"><code>protected boolean</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#doCheckLogLowReplication--">doCheckLogLowReplication</a></span>()</code> </td> +</tr> <tr id="i7" class="rowColor"> <td class="colFirst"><code>protected long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#doReplaceWriter-org.apache.hadoop.fs.Path-org.apache.hadoop.fs.Path-org.apache.hadoop.hbase.wal.WALProvider.Writer-">doReplaceWriter</a></span>(org.apache.hadoop.fs.Path oldPath, @@ -354,16 +350,12 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#doShutdown--">doShutdown</a></span>()</code> </td> </tr> <tr id="i9" class="rowColor"> -<td class="colFirst"><code>long</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#getLastTimeCheckLowReplication--">getLastTimeCheckLowReplication</a></span>()</code> </td> -</tr> -<tr id="i10" class="altColor"> <td class="colFirst"><code>(package private) int</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#getLogReplication--">getLogReplication</a></span>()</code> <div class="block">This method gets the datanode replication count for the current WAL.</div> </td> </tr> -<tr id="i11" class="rowColor"> +<tr id="i10" class="altColor"> <td class="colFirst"><code>(package private) <a href="http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true"; title="class or interface in java.io">OutputStream</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#getOutputStream--">getOutputStream</a></span>()</code> <div class="block">Currently, we need to expose the writer's OutputStream to tests so that they can manipulate the @@ -371,73 +363,57 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <code>AbstractTestWALReplay.testReplayEditsWrittenIntoWAL()</code>).</div> </td> </tr> -<tr id="i12" class="altColor"> +<tr id="i11" class="rowColor"> <td class="colFirst"><code>(package private) org.apache.hadoop.hdfs.protocol.DatanodeInfo[]</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#getPipeline--">getPipeline</a></span>()</code> <div class="block">This method gets the pipeline for the current WAL.</div> </td> </tr> -<tr id="i13" class="rowColor"> +<tr id="i12" class="altColor"> <td class="colFirst"><code>private long</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#getSequenceOnRingBuffer--">getSequenceOnRingBuffer</a></span>()</code> </td> </tr> -<tr id="i14" class="altColor"> +<tr id="i13" class="rowColor"> <td class="colFirst"><code>(package private) boolean</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#isLowReplicationRollEnabled--">isLowReplicationRollEnabled</a></span>()</code> </td> </tr> -<tr id="i15" class="rowColor"> -<td class="colFirst"><code>static void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#main-java.lang.String:A-">main</a></span>(<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>[] args)</code> -<div class="block">Pass one or more log file names and it will either dump out a text version on - <code>stdout</code> or split the specified log files.</div> -</td> -</tr> -<tr id="i16" class="altColor"> +<tr id="i14" class="altColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#preemptiveSync-org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter-">preemptiveSync</a></span>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/ProtobufLogWriter.html" title="class in org.apache.hadoop.hbase.regionserver.wal">ProtobufLogWriter</a> nextWriter)</code> <div class="block">Run a sync after opening to set up the pipeline.</div> </td> </tr> -<tr id="i17" class="rowColor"> +<tr id="i15" class="rowColor"> <td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#publishSyncOnRingBuffer--">publishSyncOnRingBuffer</a></span>()</code> </td> </tr> -<tr id="i18" class="altColor"> +<tr id="i16" class="altColor"> <td class="colFirst"><code>private <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a></code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#publishSyncOnRingBuffer-long-">publishSyncOnRingBuffer</a></span>(long sequence)</code> </td> </tr> -<tr id="i19" class="rowColor"> +<tr id="i17" class="rowColor"> <td class="colFirst"><code>private void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#publishSyncThenBlockOnCompletion-org.apache.htrace.core.TraceScope-">publishSyncThenBlockOnCompletion</a></span>(org.apache.htrace.core.TraceScope scope)</code> </td> </tr> -<tr id="i20" class="altColor"> -<td class="colFirst"><code>private static void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#split-org.apache.hadoop.conf.Configuration-org.apache.hadoop.fs.Path-">split</a></span>(org.apache.hadoop.conf.Configuration conf, - org.apache.hadoop.fs.Path p)</code> </td> -</tr> -<tr id="i21" class="rowColor"> +<tr id="i18" class="altColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#sync--">sync</a></span>()</code> <div class="block">Sync what we have in the WAL.</div> </td> </tr> -<tr id="i22" class="altColor"> +<tr id="i19" class="rowColor"> <td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#sync-long-">sync</a></span>(long txid)</code> <div class="block">Sync the WAL if the txId was not already sync'd.</div> </td> </tr> -<tr id="i23" class="rowColor"> -<td class="colFirst"><code>private static void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#usage--">usage</a></span>()</code> </td> -</tr> </table> <ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.org.apache.hadoop.hbase.regionserver.wal.AbstractFSWAL"> <!-- --> </a> <h3>Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a></h3> -<code><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#abortCacheFlush-byte:A-">abortCacheFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#append-W-org.apache.hadoop.hbase.regionserver.wal.FSWALEntry-">append</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#atHeadOfRingBufferEventHandlerAppend--">atHeadOfRingBufferEventHandlerAppend</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#blockOnSync-org.apache.hadoop.hbase.regionserver.wal.SyncFuture-">blockOnSync</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#close--">close</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#completeCacheFlush-byte:A-">completeCacheFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#computeFilename-long-">c omputeFilename</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#findRegionsToForceFlush--">findRegionsToForceFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getCoprocessorHost--">getCoprocessorHost</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getCurrentFileName--">getCurrentFileName</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getEarliestMemStoreSeqNum-byte:A-">getEarliestMemStoreSeqNum</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getEarliestMemStoreSeqNum-byte:A-byte:A-">getEarliestMemStoreSeqNum</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getFilenum--">getFilenum</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getFileNumFromFileName-org.apache.hadoop.fs.Path-"> getFileNumFromFileName</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getFiles--">getFiles</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getLogFileSize--">getLogFileSize</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getLogFileSizeIfBeingWritten-org.apache.hadoop.fs.Path-">getLogFileSizeIfBeingWritten</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getNumLogFiles--">getNumLogFiles</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getNumRolledLogFiles--">getNumRolledLogFiles</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getOldPath--">getOldPath</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getPreallocatedEventCount--">getPreallocatedEventCount</a>, <a href="../../../../../../ org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getSyncFuture-long-">getSyncFuture</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getUnflushedEntriesCount--">getUnflushedEntriesCount</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getWALArchivePath-org.apache.hadoop.fs.Path-org.apache.hadoop.fs.Path-">getWALArchivePath</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#isUnflushedEntries--">isUnflushedEntries</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#postSync-long-int-">postSync</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#registerWALActionsListener-org.apache.hadoop.hbase.regionserver.wal.WALActionsListener-">registerWALActionsListener</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#replaceWriter-org.apa che.hadoop.fs.Path-org.apache.hadoop.fs.Path-W-">replaceWriter</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#requestLogRoll--">requestLogRoll</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#requestLogRoll-boolean-">requestLogRoll</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#rollWriter--">rollWriter</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#rollWriter-boolean-">rollWriter</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#shutdown--">shutdown</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#stampSequenceIdAndPublishToRingBuffer-org.apache.hadoop.hbase.client.RegionInfo-org.apache.hadoop.hbase.wal.WALKeyImpl-org.apache.hadoop.hbase.wal.WALEdit-boolean-com.lmax.disruptor.RingBuffer-">stampSequenceIdAndPublishToRingBuffe r</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#startCacheFlush-byte:A-java.util.Map-">startCacheFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#startCacheFlush-byte:A-java.util.Set-">startCacheFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#toString--">toString</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#unregisterWALActionsListener-org.apache.hadoop.hbase.regionserver.wal.WALActionsListener-">unregisterWALActionsListener</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#updateStore-byte:A-byte:A-java.lang.Long-boolean-">updateStore</a></code></li> +<code><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#abortCacheFlush-byte:A-">abortCacheFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#append-W-org.apache.hadoop.hbase.regionserver.wal.FSWALEntry-">append</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#atHeadOfRingBufferEventHandlerAppend--">atHeadOfRingBufferEventHandlerAppend</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#blockOnSync-org.apache.hadoop.hbase.regionserver.wal.SyncFuture-">blockOnSync</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#checkLogLowReplication-long-">checkLogLowReplication</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#close--">close</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#completeCacheFlush -byte:A-">completeCacheFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#computeFilename-long-">computeFilename</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#findRegionsToForceFlush--">findRegionsToForceFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getCoprocessorHost--">getCoprocessorHost</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getCurrentFileName--">getCurrentFileName</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getEarliestMemStoreSeqNum-byte:A-">getEarliestMemStoreSeqNum</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getEarliestMemStoreSeqNum-byte:A-byte:A-">getEarliestMemStoreSeqNum</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getFilenum--">getFilenu m</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getFileNumFromFileName-org.apache.hadoop.fs.Path-">getFileNumFromFileName</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getFiles--">getFiles</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getLogFileSize--">getLogFileSize</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getLogFileSizeIfBeingWritten-org.apache.hadoop.fs.Path-">getLogFileSizeIfBeingWritten</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getNumLogFiles--">getNumLogFiles</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getNumRolledLogFiles--">getNumRolledLogFiles</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getOldPath--">getOldPath</a>, <a href="../../../../../../or g/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getPreallocatedEventCount--">getPreallocatedEventCount</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getSyncFuture-long-">getSyncFuture</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getUnflushedEntriesCount--">getUnflushedEntriesCount</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#getWALArchivePath-org.apache.hadoop.fs.Path-org.apache.hadoop.fs.Path-">getWALArchivePath</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#isUnflushedEntries--">isUnflushedEntries</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#main-java.lang.String:A-">main</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#postSync-long-int-">postSync</a>, <a href="../../../../../../org/apache/hadoop/hba se/regionserver/wal/AbstractFSWAL.html#registerWALActionsListener-org.apache.hadoop.hbase.regionserver.wal.WALActionsListener-">registerWALActionsListener</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#replaceWriter-org.apache.hadoop.fs.Path-org.apache.hadoop.fs.Path-W-">replaceWriter</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#requestLogRoll--">requestLogRoll</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#requestLogRoll-boolean-">requestLogRoll</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#rollWriter--">rollWriter</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#rollWriter-boolean-">rollWriter</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#shutdown--">shutdown</a>, <a href="../../../../../../org/apache/hadoop/hbase /regionserver/wal/AbstractFSWAL.html#stampSequenceIdAndPublishToRingBuffer-org.apache.hadoop.hbase.client.RegionInfo-org.apache.hadoop.hbase.wal.WALKeyImpl-org.apache.hadoop.hbase.wal.WALEdit-boolean-com.lmax.disruptor.RingBuffer-">stampSequenceIdAndPublishToRingBuffer</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#startCacheFlush-byte:A-java.util.Map-">startCacheFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#startCacheFlush-byte:A-java.util.Set-">startCacheFlush</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#toString--">toString</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#unregisterWALActionsListener-org.apache.hadoop.hbase.regionserver.wal.WALActionsListener-">unregisterWALActionsListener</a>, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#updateStore-byte :A-byte:A-java.lang.Long-boolean-">updateStore</a></code></li> </ul> <ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> @@ -466,7 +442,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>LOG</h4> -<pre>private static final org.apache.commons.logging.Log <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.112">LOG</a></pre> +<pre>private static final org.apache.commons.logging.Log <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.104">LOG</a></pre> </li> </ul> <a name="disruptor"> @@ -475,7 +451,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>disruptor</h4> -<pre>private final com.lmax.disruptor.dsl.Disruptor<<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/RingBufferTruck.html" title="class in org.apache.hadoop.hbase.regionserver.wal">RingBufferTruck</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.121">disruptor</a></pre> +<pre>private final com.lmax.disruptor.dsl.Disruptor<<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/RingBufferTruck.html" title="class in org.apache.hadoop.hbase.regionserver.wal">RingBufferTruck</a>> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.113">disruptor</a></pre> <div class="block">The nexus at which all incoming handlers meet. Does appends and sync with an ordering. Appends and syncs are each put on the ring which means handlers need to smash up against the ring twice (can we make it once only? ... maybe not since time to append is so different from time to sync @@ -489,7 +465,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>ringBufferEventHandler</h4> -<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.RingBufferEventHandler.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSHLog.RingBufferEventHandler</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.129">ringBufferEventHandler</a></pre> +<pre>private final <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.RingBufferEventHandler.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSHLog.RingBufferEventHandler</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.121">ringBufferEventHandler</a></pre> <div class="block">This fellow is run by the above appendExecutor service but it is all about batching up appends and syncs; it may shutdown without cleaning out the last few appends or syncs. To guard against this, keep a reference to this handler and do explicit close on way out to make sure all @@ -502,7 +478,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>hdfs_out</h4> -<pre>private org.apache.hadoop.fs.FSDataOutputStream <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.134">hdfs_out</a></pre> +<pre>private org.apache.hadoop.fs.FSDataOutputStream <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.126">hdfs_out</a></pre> <div class="block">FSDataOutputStream associated with the current SequenceFile.writer</div> </li> </ul> @@ -512,7 +488,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>minTolerableReplication</h4> -<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.139">minTolerableReplication</a></pre> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.131">minTolerableReplication</a></pre> </li> </ul> <a name="consecutiveLogRolls"> @@ -521,7 +497,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>consecutiveLogRolls</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.145">consecutiveLogRolls</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.137">consecutiveLogRolls</a></pre> </li> </ul> <a name="lowReplicationRollLimit"> @@ -530,7 +506,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>lowReplicationRollLimit</h4> -<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.147">lowReplicationRollLimit</a></pre> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.139">lowReplicationRollLimit</a></pre> </li> </ul> <a name="lowReplicationRollEnabled"> @@ -539,7 +515,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>lowReplicationRollEnabled</h4> -<pre>private volatile boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.152">lowReplicationRollEnabled</a></pre> +<pre>private volatile boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.144">lowReplicationRollEnabled</a></pre> </li> </ul> <a name="closeErrorsTolerated"> @@ -548,7 +524,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>closeErrorsTolerated</h4> -<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.155">closeErrorsTolerated</a></pre> +<pre>private final int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.147">closeErrorsTolerated</a></pre> <div class="block">Number of log close errors tolerated before we abort</div> </li> </ul> @@ -558,16 +534,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>closeErrorCount</h4> -<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.157">closeErrorCount</a></pre> -</li> -</ul> -<a name="lastTimeCheckLowReplication"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>lastTimeCheckLowReplication</h4> -<pre>private volatile long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.160">lastTimeCheckLowReplication</a></pre> +<pre>private final <a href="http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true"; title="class or interface in java.util.concurrent.atomic">AtomicInteger</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.149">closeErrorCount</a></pre> </li> </ul> <a name="FIXED_OVERHEAD"> @@ -576,7 +543,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockListLast"> <li class="blockList"> <h4>FIXED_OVERHEAD</h4> -<pre>public static final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.766">FIXED_OVERHEAD</a></pre> +<pre>public static final long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.753">FIXED_OVERHEAD</a></pre> </li> </ul> </li> @@ -593,7 +560,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>FSHLog</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.195">FSHLog</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.183">FSHLog</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path root, <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> logDir, org.apache.hadoop.conf.Configuration conf) @@ -616,7 +583,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockListLast"> <li class="blockList"> <h4>FSHLog</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.218">FSHLog</a>(org.apache.hadoop.fs.FileSystem fs, +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.206">FSHLog</a>(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path rootDir, <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> logDir, <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> archiveDir, @@ -663,7 +630,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>getOutputStream</h4> -<pre><a href="http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true"; title="class or interface in java.io">OutputStream</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.260">getOutputStream</a>()</pre> +<pre><a href="http://docs.oracle.com/javase/8/docs/api/java/io/OutputStream.html?is-external=true"; title="class or interface in java.io">OutputStream</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.248">getOutputStream</a>()</pre> <div class="block">Currently, we need to expose the writer's OutputStream to tests so that they can manipulate the default behavior (such as setting the maxRecoveryErrorCount value for example (see <code>AbstractTestWALReplay.testReplayEditsWrittenIntoWAL()</code>). This is @@ -681,7 +648,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>preemptiveSync</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.268">preemptiveSync</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/ProtobufLogWriter.html" title="class in org.apache.hadoop.hbase.regionserver.wal">ProtobufLogWriter</a> nextWriter)</pre> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.256">preemptiveSync</a>(<a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/ProtobufLogWriter.html" title="class in org.apache.hadoop.hbase.regionserver.wal">ProtobufLogWriter</a> nextWriter)</pre> <div class="block">Run a sync after opening to set up the pipeline.</div> </li> </ul> @@ -691,7 +658,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>createWriterInstance</h4> -<pre>protected <a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.285">createWriterInstance</a>(org.apache.hadoop.fs.Path path) +<pre>protected <a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.273">createWriterInstance</a>(org.apache.hadoop.fs.Path path) 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">This method allows subclasses to inject different writers without having to extend other methods like rollWriter().</div> @@ -711,7 +678,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>afterCreatingZigZagLatch</h4> -<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.298">afterCreatingZigZagLatch</a>()</pre> +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.286">afterCreatingZigZagLatch</a>()</pre> <div class="block">Used to manufacture race condition reliably. For testing only.</div> <dl> <dt><span class="seeLabel">See Also:</span></dt> @@ -725,7 +692,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>beforeWaitOnSafePoint</h4> -<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.305">beforeWaitOnSafePoint</a>()</pre> +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.293">beforeWaitOnSafePoint</a>()</pre> <dl> <dt><span class="seeLabel">See Also:</span></dt> <dd><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#afterCreatingZigZagLatch--"><code>afterCreatingZigZagLatch()</code></a></dd> @@ -738,7 +705,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>doAppend</h4> -<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.309">doAppend</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a> writer, +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.297">doAppend</a>(<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a> writer, <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/FSWALEntry.html" title="class in org.apache.hadoop.hbase.regionserver.wal">FSWALEntry</a> entry) 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> @@ -755,7 +722,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>doReplaceWriter</h4> -<pre>protected long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.314">doReplaceWriter</a>(org.apache.hadoop.fs.Path oldPath, +<pre>protected long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.302">doReplaceWriter</a>(org.apache.hadoop.fs.Path oldPath, org.apache.hadoop.fs.Path newPath, <a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a> nextWriter) 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> @@ -775,7 +742,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>doShutdown</h4> -<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.417">doShutdown</a>() +<pre>protected void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.405">doShutdown</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="overrideSpecifyLabel">Specified by:</span></dt> @@ -791,7 +758,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>append</h4> -<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.445">append</a>(<a href="../../../../../../org/apache/hadoop/hbase/client/RegionInfo.html" title="interface in org.apache.hadoop.hbase.client">RegionInfo</a> hri, +<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.433">append</a>(<a href="../../../../../../org/apache/hadoop/hbase/client/RegionInfo.html" title="interface in org.apache.hadoop.hbase.client">RegionInfo</a> hri, <a href="../../../../../../org/apache/hadoop/hbase/wal/WALKeyImpl.html" title="class in org.apache.hadoop.hbase.wal">WALKeyImpl</a> key, <a href="../../../../../../org/apache/hadoop/hbase/wal/WALEdit.html" title="class in org.apache.hadoop.hbase.wal">WALEdit</a> edits, boolean inMemstore) @@ -834,18 +801,20 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>checkLogRoll</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.630">checkLogRoll</a>()</pre> +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.618">checkLogRoll</a>()</pre> <div class="block">Schedule a log roll if needed.</div> </li> </ul> -<a name="checkLowReplication--"> +<a name="doCheckLogLowReplication--"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>checkLowReplication</h4> -<pre>private boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.649">checkLowReplication</a>()</pre> +<h4>doCheckLogLowReplication</h4> +<pre>protected boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.637">doCheckLogLowReplication</a>()</pre> <dl> +<dt><span class="overrideSpecifyLabel">Specified by:</span></dt> +<dd><code><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html#doCheckLogLowReplication--">doCheckLogLowReplication</a></code> in class <code><a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.html" title="class in org.apache.hadoop.hbase.regionserver.wal">AbstractFSWAL</a><<a href="../../../../../../org/apache/hadoop/hbase/wal/WALProvider.Writer.html" title="interface in org.apache.hadoop.hbase.wal">WALProvider.Writer</a>></code></dd> <dt><span class="returnLabel">Returns:</span></dt> <dd>true if number of replicas for the WAL is lower than threshold</dd> </dl> @@ -857,7 +826,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>getSequenceOnRingBuffer</h4> -<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.695">getSequenceOnRingBuffer</a>()</pre> +<pre>private long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.682">getSequenceOnRingBuffer</a>()</pre> </li> </ul> <a name="publishSyncOnRingBuffer--"> @@ -866,7 +835,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>publishSyncOnRingBuffer</h4> -<pre>private <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.699">publishSyncOnRingBuffer</a>()</pre> +<pre>private <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.686">publishSyncOnRingBuffer</a>()</pre> </li> </ul> <a name="publishSyncOnRingBuffer-long-"> @@ -875,7 +844,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>publishSyncOnRingBuffer</h4> -<pre>private <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.704">publishSyncOnRingBuffer</a>(long sequence)</pre> +<pre>private <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/SyncFuture.html" title="class in org.apache.hadoop.hbase.regionserver.wal">SyncFuture</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.691">publishSyncOnRingBuffer</a>(long sequence)</pre> </li> </ul> <a name="publishSyncThenBlockOnCompletion-org.apache.htrace.core.TraceScope-"> @@ -884,7 +853,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>publishSyncThenBlockOnCompletion</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.717">publishSyncThenBlockOnCompletion</a>(org.apache.htrace.core.TraceScope scope) +<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.704">publishSyncThenBlockOnCompletion</a>(org.apache.htrace.core.TraceScope scope) 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> @@ -898,7 +867,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>getLogReplication</h4> -<pre>int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.731">getLogReplication</a>()</pre> +<pre>int <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.718">getLogReplication</a>()</pre> <div class="block">This method gets the datanode replication count for the current WAL. <p> If the pipeline isn't started yet or is empty, you will get the default replication factor. @@ -916,7 +885,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>sync</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.744">sync</a>() +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.731">sync</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"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.html#sync--">WAL</a></code></span></div> <div class="block">Sync what we have in the WAL.</div> @@ -932,7 +901,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>sync</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.751">sync</a>(long txid) +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.738">sync</a>(long txid) 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"><span class="descfrmTypeLabel">Description copied from interface: <code><a href="../../../../../../org/apache/hadoop/hbase/wal/WAL.html#sync-long-">WAL</a></code></span></div> <div class="block">Sync the WAL if the txId was not already sync'd.</div> @@ -950,56 +919,16 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst <ul class="blockList"> <li class="blockList"> <h4>isLowReplicationRollEnabled</h4> -<pre>boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.762">isLowReplicationRollEnabled</a>()</pre> -</li> -</ul> -<a name="split-org.apache.hadoop.conf.Configuration-org.apache.hadoop.fs.Path-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>split</h4> -<pre>private static void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.770">split</a>(org.apache.hadoop.conf.Configuration conf, - org.apache.hadoop.fs.Path p) - 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="usage--"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>usage</h4> -<pre>private static void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.1121">usage</a>()</pre> -</li> -</ul> -<a name="main-java.lang.String:A-"> -<!-- --> -</a> -<ul class="blockList"> -<li class="blockList"> -<h4>main</h4> -<pre>public static void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.1136">main</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>[] args) - 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">Pass one or more log file names and it will either dump out a text version on - <code>stdout</code> or split the specified log files.</div> -<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> +<pre>boolean <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.749">isLowReplicationRollEnabled</a>()</pre> </li> </ul> <a name="getPipeline--"> <!-- --> </a> -<ul class="blockList"> +<ul class="blockListLast"> <li class="blockList"> <h4>getPipeline</h4> -<pre>org.apache.hadoop.hdfs.protocol.DatanodeInfo[] <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.1171">getPipeline</a>()</pre> +<pre>org.apache.hadoop.hdfs.protocol.DatanodeInfo[] <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.1094">getPipeline</a>()</pre> <div class="block">This method gets the pipeline for the current WAL.</div> <dl> <dt><span class="overrideSpecifyLabel">Specified by:</span></dt> @@ -1007,19 +936,6 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/regionserver/wal/Abst </dl> </li> </ul> -<a name="getLastTimeCheckLowReplication--"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>getLastTimeCheckLowReplication</h4> -<pre>public long <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/FSHLog.html#line.1184">getLastTimeCheckLowReplication</a>()</pre> -<dl> -<dt><span class="returnLabel">Returns:</span></dt> -<dd>last time on checking low replication</dd> -</dl> -</li> -</ul> </li> </ul> </li>
