You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by gi...@apache.org on 2018/01/18 15:31:22 UTC
[23/27] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cc91ad79/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html
index c47888d..f47d1bd 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.DelayedTask.html
@@ -355,53 +355,56 @@
<span class="sourceLineNo">347</span> super(key, 0);<a name="line.347"></a>
<span class="sourceLineNo">348</span> }<a name="line.348"></a>
<span class="sourceLineNo">349</span><a name="line.349"></a>
-<span class="sourceLineNo">350</span> public TRemote getKey() {<a name="line.350"></a>
-<span class="sourceLineNo">351</span> return getObject();<a name="line.351"></a>
-<span class="sourceLineNo">352</span> }<a name="line.352"></a>
-<span class="sourceLineNo">353</span><a name="line.353"></a>
-<span class="sourceLineNo">354</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.354"></a>
-<span class="sourceLineNo">355</span> if (this.operations == null) {<a name="line.355"></a>
-<span class="sourceLineNo">356</span> this.operations = new HashSet<>();<a name="line.356"></a>
-<span class="sourceLineNo">357</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.357"></a>
-<span class="sourceLineNo">358</span> timeoutExecutor.add(this);<a name="line.358"></a>
-<span class="sourceLineNo">359</span> }<a name="line.359"></a>
-<span class="sourceLineNo">360</span> this.operations.add(operation);<a name="line.360"></a>
-<span class="sourceLineNo">361</span> if (this.operations.size() > queueMaxSize) {<a name="line.361"></a>
-<span class="sourceLineNo">362</span> timeoutExecutor.remove(this);<a name="line.362"></a>
-<span class="sourceLineNo">363</span> dispatch();<a name="line.363"></a>
-<span class="sourceLineNo">364</span> }<a name="line.364"></a>
-<span class="sourceLineNo">365</span> }<a name="line.365"></a>
-<span class="sourceLineNo">366</span><a name="line.366"></a>
-<span class="sourceLineNo">367</span> public synchronized void dispatch() {<a name="line.367"></a>
-<span class="sourceLineNo">368</span> if (operations != null) {<a name="line.368"></a>
-<span class="sourceLineNo">369</span> remoteDispatch(getKey(), operations);<a name="line.369"></a>
-<span class="sourceLineNo">370</span> this.operations = null;<a name="line.370"></a>
-<span class="sourceLineNo">371</span> }<a name="line.371"></a>
-<span class="sourceLineNo">372</span> }<a name="line.372"></a>
-<span class="sourceLineNo">373</span><a name="line.373"></a>
-<span class="sourceLineNo">374</span> public synchronized void abortOperationsInQueue() {<a name="line.374"></a>
-<span class="sourceLineNo">375</span> if (operations != null) {<a name="line.375"></a>
-<span class="sourceLineNo">376</span> abortPendingOperations(getKey(), operations);<a name="line.376"></a>
-<span class="sourceLineNo">377</span> this.operations = null;<a name="line.377"></a>
-<span class="sourceLineNo">378</span> }<a name="line.378"></a>
-<span class="sourceLineNo">379</span> }<a name="line.379"></a>
-<span class="sourceLineNo">380</span><a name="line.380"></a>
-<span class="sourceLineNo">381</span> @Override<a name="line.381"></a>
-<span class="sourceLineNo">382</span> public String toString() {<a name="line.382"></a>
-<span class="sourceLineNo">383</span> return super.toString() + ", operations=" + this.operations;<a name="line.383"></a>
-<span class="sourceLineNo">384</span> }<a name="line.384"></a>
-<span class="sourceLineNo">385</span> }<a name="line.385"></a>
-<span class="sourceLineNo">386</span><a name="line.386"></a>
-<span class="sourceLineNo">387</span> /**<a name="line.387"></a>
-<span class="sourceLineNo">388</span> * Delayed object that holds a FutureTask.<a name="line.388"></a>
-<span class="sourceLineNo">389</span> * used to submit something later to the thread-pool.<a name="line.389"></a>
-<span class="sourceLineNo">390</span> */<a name="line.390"></a>
-<span class="sourceLineNo">391</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.391"></a>
-<span class="sourceLineNo">392</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.392"></a>
-<span class="sourceLineNo">393</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.393"></a>
-<span class="sourceLineNo">394</span> }<a name="line.394"></a>
-<span class="sourceLineNo">395</span> }<a name="line.395"></a>
-<span class="sourceLineNo">396</span>}<a name="line.396"></a>
+<span class="sourceLineNo">350</span> @Override<a name="line.350"></a>
+<span class="sourceLineNo">351</span> public TRemote getKey() {<a name="line.351"></a>
+<span class="sourceLineNo">352</span> return getObject();<a name="line.352"></a>
+<span class="sourceLineNo">353</span> }<a name="line.353"></a>
+<span class="sourceLineNo">354</span><a name="line.354"></a>
+<span class="sourceLineNo">355</span> @Override<a name="line.355"></a>
+<span class="sourceLineNo">356</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.356"></a>
+<span class="sourceLineNo">357</span> if (this.operations == null) {<a name="line.357"></a>
+<span class="sourceLineNo">358</span> this.operations = new HashSet<>();<a name="line.358"></a>
+<span class="sourceLineNo">359</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.359"></a>
+<span class="sourceLineNo">360</span> timeoutExecutor.add(this);<a name="line.360"></a>
+<span class="sourceLineNo">361</span> }<a name="line.361"></a>
+<span class="sourceLineNo">362</span> this.operations.add(operation);<a name="line.362"></a>
+<span class="sourceLineNo">363</span> if (this.operations.size() > queueMaxSize) {<a name="line.363"></a>
+<span class="sourceLineNo">364</span> timeoutExecutor.remove(this);<a name="line.364"></a>
+<span class="sourceLineNo">365</span> dispatch();<a name="line.365"></a>
+<span class="sourceLineNo">366</span> }<a name="line.366"></a>
+<span class="sourceLineNo">367</span> }<a name="line.367"></a>
+<span class="sourceLineNo">368</span><a name="line.368"></a>
+<span class="sourceLineNo">369</span> @Override<a name="line.369"></a>
+<span class="sourceLineNo">370</span> public synchronized void dispatch() {<a name="line.370"></a>
+<span class="sourceLineNo">371</span> if (operations != null) {<a name="line.371"></a>
+<span class="sourceLineNo">372</span> remoteDispatch(getKey(), operations);<a name="line.372"></a>
+<span class="sourceLineNo">373</span> this.operations = null;<a name="line.373"></a>
+<span class="sourceLineNo">374</span> }<a name="line.374"></a>
+<span class="sourceLineNo">375</span> }<a name="line.375"></a>
+<span class="sourceLineNo">376</span><a name="line.376"></a>
+<span class="sourceLineNo">377</span> public synchronized void abortOperationsInQueue() {<a name="line.377"></a>
+<span class="sourceLineNo">378</span> if (operations != null) {<a name="line.378"></a>
+<span class="sourceLineNo">379</span> abortPendingOperations(getKey(), operations);<a name="line.379"></a>
+<span class="sourceLineNo">380</span> this.operations = null;<a name="line.380"></a>
+<span class="sourceLineNo">381</span> }<a name="line.381"></a>
+<span class="sourceLineNo">382</span> }<a name="line.382"></a>
+<span class="sourceLineNo">383</span><a name="line.383"></a>
+<span class="sourceLineNo">384</span> @Override<a name="line.384"></a>
+<span class="sourceLineNo">385</span> public String toString() {<a name="line.385"></a>
+<span class="sourceLineNo">386</span> return super.toString() + ", operations=" + this.operations;<a name="line.386"></a>
+<span class="sourceLineNo">387</span> }<a name="line.387"></a>
+<span class="sourceLineNo">388</span> }<a name="line.388"></a>
+<span class="sourceLineNo">389</span><a name="line.389"></a>
+<span class="sourceLineNo">390</span> /**<a name="line.390"></a>
+<span class="sourceLineNo">391</span> * Delayed object that holds a FutureTask.<a name="line.391"></a>
+<span class="sourceLineNo">392</span> * used to submit something later to the thread-pool.<a name="line.392"></a>
+<span class="sourceLineNo">393</span> */<a name="line.393"></a>
+<span class="sourceLineNo">394</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.394"></a>
+<span class="sourceLineNo">395</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.395"></a>
+<span class="sourceLineNo">396</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.396"></a>
+<span class="sourceLineNo">397</span> }<a name="line.397"></a>
+<span class="sourceLineNo">398</span> }<a name="line.398"></a>
+<span class="sourceLineNo">399</span>}<a name="line.399"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cc91ad79/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html
index c47888d..f47d1bd 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteNode.html
@@ -355,53 +355,56 @@
<span class="sourceLineNo">347</span> super(key, 0);<a name="line.347"></a>
<span class="sourceLineNo">348</span> }<a name="line.348"></a>
<span class="sourceLineNo">349</span><a name="line.349"></a>
-<span class="sourceLineNo">350</span> public TRemote getKey() {<a name="line.350"></a>
-<span class="sourceLineNo">351</span> return getObject();<a name="line.351"></a>
-<span class="sourceLineNo">352</span> }<a name="line.352"></a>
-<span class="sourceLineNo">353</span><a name="line.353"></a>
-<span class="sourceLineNo">354</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.354"></a>
-<span class="sourceLineNo">355</span> if (this.operations == null) {<a name="line.355"></a>
-<span class="sourceLineNo">356</span> this.operations = new HashSet<>();<a name="line.356"></a>
-<span class="sourceLineNo">357</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.357"></a>
-<span class="sourceLineNo">358</span> timeoutExecutor.add(this);<a name="line.358"></a>
-<span class="sourceLineNo">359</span> }<a name="line.359"></a>
-<span class="sourceLineNo">360</span> this.operations.add(operation);<a name="line.360"></a>
-<span class="sourceLineNo">361</span> if (this.operations.size() > queueMaxSize) {<a name="line.361"></a>
-<span class="sourceLineNo">362</span> timeoutExecutor.remove(this);<a name="line.362"></a>
-<span class="sourceLineNo">363</span> dispatch();<a name="line.363"></a>
-<span class="sourceLineNo">364</span> }<a name="line.364"></a>
-<span class="sourceLineNo">365</span> }<a name="line.365"></a>
-<span class="sourceLineNo">366</span><a name="line.366"></a>
-<span class="sourceLineNo">367</span> public synchronized void dispatch() {<a name="line.367"></a>
-<span class="sourceLineNo">368</span> if (operations != null) {<a name="line.368"></a>
-<span class="sourceLineNo">369</span> remoteDispatch(getKey(), operations);<a name="line.369"></a>
-<span class="sourceLineNo">370</span> this.operations = null;<a name="line.370"></a>
-<span class="sourceLineNo">371</span> }<a name="line.371"></a>
-<span class="sourceLineNo">372</span> }<a name="line.372"></a>
-<span class="sourceLineNo">373</span><a name="line.373"></a>
-<span class="sourceLineNo">374</span> public synchronized void abortOperationsInQueue() {<a name="line.374"></a>
-<span class="sourceLineNo">375</span> if (operations != null) {<a name="line.375"></a>
-<span class="sourceLineNo">376</span> abortPendingOperations(getKey(), operations);<a name="line.376"></a>
-<span class="sourceLineNo">377</span> this.operations = null;<a name="line.377"></a>
-<span class="sourceLineNo">378</span> }<a name="line.378"></a>
-<span class="sourceLineNo">379</span> }<a name="line.379"></a>
-<span class="sourceLineNo">380</span><a name="line.380"></a>
-<span class="sourceLineNo">381</span> @Override<a name="line.381"></a>
-<span class="sourceLineNo">382</span> public String toString() {<a name="line.382"></a>
-<span class="sourceLineNo">383</span> return super.toString() + ", operations=" + this.operations;<a name="line.383"></a>
-<span class="sourceLineNo">384</span> }<a name="line.384"></a>
-<span class="sourceLineNo">385</span> }<a name="line.385"></a>
-<span class="sourceLineNo">386</span><a name="line.386"></a>
-<span class="sourceLineNo">387</span> /**<a name="line.387"></a>
-<span class="sourceLineNo">388</span> * Delayed object that holds a FutureTask.<a name="line.388"></a>
-<span class="sourceLineNo">389</span> * used to submit something later to the thread-pool.<a name="line.389"></a>
-<span class="sourceLineNo">390</span> */<a name="line.390"></a>
-<span class="sourceLineNo">391</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.391"></a>
-<span class="sourceLineNo">392</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.392"></a>
-<span class="sourceLineNo">393</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.393"></a>
-<span class="sourceLineNo">394</span> }<a name="line.394"></a>
-<span class="sourceLineNo">395</span> }<a name="line.395"></a>
-<span class="sourceLineNo">396</span>}<a name="line.396"></a>
+<span class="sourceLineNo">350</span> @Override<a name="line.350"></a>
+<span class="sourceLineNo">351</span> public TRemote getKey() {<a name="line.351"></a>
+<span class="sourceLineNo">352</span> return getObject();<a name="line.352"></a>
+<span class="sourceLineNo">353</span> }<a name="line.353"></a>
+<span class="sourceLineNo">354</span><a name="line.354"></a>
+<span class="sourceLineNo">355</span> @Override<a name="line.355"></a>
+<span class="sourceLineNo">356</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.356"></a>
+<span class="sourceLineNo">357</span> if (this.operations == null) {<a name="line.357"></a>
+<span class="sourceLineNo">358</span> this.operations = new HashSet<>();<a name="line.358"></a>
+<span class="sourceLineNo">359</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.359"></a>
+<span class="sourceLineNo">360</span> timeoutExecutor.add(this);<a name="line.360"></a>
+<span class="sourceLineNo">361</span> }<a name="line.361"></a>
+<span class="sourceLineNo">362</span> this.operations.add(operation);<a name="line.362"></a>
+<span class="sourceLineNo">363</span> if (this.operations.size() > queueMaxSize) {<a name="line.363"></a>
+<span class="sourceLineNo">364</span> timeoutExecutor.remove(this);<a name="line.364"></a>
+<span class="sourceLineNo">365</span> dispatch();<a name="line.365"></a>
+<span class="sourceLineNo">366</span> }<a name="line.366"></a>
+<span class="sourceLineNo">367</span> }<a name="line.367"></a>
+<span class="sourceLineNo">368</span><a name="line.368"></a>
+<span class="sourceLineNo">369</span> @Override<a name="line.369"></a>
+<span class="sourceLineNo">370</span> public synchronized void dispatch() {<a name="line.370"></a>
+<span class="sourceLineNo">371</span> if (operations != null) {<a name="line.371"></a>
+<span class="sourceLineNo">372</span> remoteDispatch(getKey(), operations);<a name="line.372"></a>
+<span class="sourceLineNo">373</span> this.operations = null;<a name="line.373"></a>
+<span class="sourceLineNo">374</span> }<a name="line.374"></a>
+<span class="sourceLineNo">375</span> }<a name="line.375"></a>
+<span class="sourceLineNo">376</span><a name="line.376"></a>
+<span class="sourceLineNo">377</span> public synchronized void abortOperationsInQueue() {<a name="line.377"></a>
+<span class="sourceLineNo">378</span> if (operations != null) {<a name="line.378"></a>
+<span class="sourceLineNo">379</span> abortPendingOperations(getKey(), operations);<a name="line.379"></a>
+<span class="sourceLineNo">380</span> this.operations = null;<a name="line.380"></a>
+<span class="sourceLineNo">381</span> }<a name="line.381"></a>
+<span class="sourceLineNo">382</span> }<a name="line.382"></a>
+<span class="sourceLineNo">383</span><a name="line.383"></a>
+<span class="sourceLineNo">384</span> @Override<a name="line.384"></a>
+<span class="sourceLineNo">385</span> public String toString() {<a name="line.385"></a>
+<span class="sourceLineNo">386</span> return super.toString() + ", operations=" + this.operations;<a name="line.386"></a>
+<span class="sourceLineNo">387</span> }<a name="line.387"></a>
+<span class="sourceLineNo">388</span> }<a name="line.388"></a>
+<span class="sourceLineNo">389</span><a name="line.389"></a>
+<span class="sourceLineNo">390</span> /**<a name="line.390"></a>
+<span class="sourceLineNo">391</span> * Delayed object that holds a FutureTask.<a name="line.391"></a>
+<span class="sourceLineNo">392</span> * used to submit something later to the thread-pool.<a name="line.392"></a>
+<span class="sourceLineNo">393</span> */<a name="line.393"></a>
+<span class="sourceLineNo">394</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.394"></a>
+<span class="sourceLineNo">395</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.395"></a>
+<span class="sourceLineNo">396</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.396"></a>
+<span class="sourceLineNo">397</span> }<a name="line.397"></a>
+<span class="sourceLineNo">398</span> }<a name="line.398"></a>
+<span class="sourceLineNo">399</span>}<a name="line.399"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cc91ad79/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html
index c47888d..f47d1bd 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteOperation.html
@@ -355,53 +355,56 @@
<span class="sourceLineNo">347</span> super(key, 0);<a name="line.347"></a>
<span class="sourceLineNo">348</span> }<a name="line.348"></a>
<span class="sourceLineNo">349</span><a name="line.349"></a>
-<span class="sourceLineNo">350</span> public TRemote getKey() {<a name="line.350"></a>
-<span class="sourceLineNo">351</span> return getObject();<a name="line.351"></a>
-<span class="sourceLineNo">352</span> }<a name="line.352"></a>
-<span class="sourceLineNo">353</span><a name="line.353"></a>
-<span class="sourceLineNo">354</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.354"></a>
-<span class="sourceLineNo">355</span> if (this.operations == null) {<a name="line.355"></a>
-<span class="sourceLineNo">356</span> this.operations = new HashSet<>();<a name="line.356"></a>
-<span class="sourceLineNo">357</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.357"></a>
-<span class="sourceLineNo">358</span> timeoutExecutor.add(this);<a name="line.358"></a>
-<span class="sourceLineNo">359</span> }<a name="line.359"></a>
-<span class="sourceLineNo">360</span> this.operations.add(operation);<a name="line.360"></a>
-<span class="sourceLineNo">361</span> if (this.operations.size() > queueMaxSize) {<a name="line.361"></a>
-<span class="sourceLineNo">362</span> timeoutExecutor.remove(this);<a name="line.362"></a>
-<span class="sourceLineNo">363</span> dispatch();<a name="line.363"></a>
-<span class="sourceLineNo">364</span> }<a name="line.364"></a>
-<span class="sourceLineNo">365</span> }<a name="line.365"></a>
-<span class="sourceLineNo">366</span><a name="line.366"></a>
-<span class="sourceLineNo">367</span> public synchronized void dispatch() {<a name="line.367"></a>
-<span class="sourceLineNo">368</span> if (operations != null) {<a name="line.368"></a>
-<span class="sourceLineNo">369</span> remoteDispatch(getKey(), operations);<a name="line.369"></a>
-<span class="sourceLineNo">370</span> this.operations = null;<a name="line.370"></a>
-<span class="sourceLineNo">371</span> }<a name="line.371"></a>
-<span class="sourceLineNo">372</span> }<a name="line.372"></a>
-<span class="sourceLineNo">373</span><a name="line.373"></a>
-<span class="sourceLineNo">374</span> public synchronized void abortOperationsInQueue() {<a name="line.374"></a>
-<span class="sourceLineNo">375</span> if (operations != null) {<a name="line.375"></a>
-<span class="sourceLineNo">376</span> abortPendingOperations(getKey(), operations);<a name="line.376"></a>
-<span class="sourceLineNo">377</span> this.operations = null;<a name="line.377"></a>
-<span class="sourceLineNo">378</span> }<a name="line.378"></a>
-<span class="sourceLineNo">379</span> }<a name="line.379"></a>
-<span class="sourceLineNo">380</span><a name="line.380"></a>
-<span class="sourceLineNo">381</span> @Override<a name="line.381"></a>
-<span class="sourceLineNo">382</span> public String toString() {<a name="line.382"></a>
-<span class="sourceLineNo">383</span> return super.toString() + ", operations=" + this.operations;<a name="line.383"></a>
-<span class="sourceLineNo">384</span> }<a name="line.384"></a>
-<span class="sourceLineNo">385</span> }<a name="line.385"></a>
-<span class="sourceLineNo">386</span><a name="line.386"></a>
-<span class="sourceLineNo">387</span> /**<a name="line.387"></a>
-<span class="sourceLineNo">388</span> * Delayed object that holds a FutureTask.<a name="line.388"></a>
-<span class="sourceLineNo">389</span> * used to submit something later to the thread-pool.<a name="line.389"></a>
-<span class="sourceLineNo">390</span> */<a name="line.390"></a>
-<span class="sourceLineNo">391</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.391"></a>
-<span class="sourceLineNo">392</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.392"></a>
-<span class="sourceLineNo">393</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.393"></a>
-<span class="sourceLineNo">394</span> }<a name="line.394"></a>
-<span class="sourceLineNo">395</span> }<a name="line.395"></a>
-<span class="sourceLineNo">396</span>}<a name="line.396"></a>
+<span class="sourceLineNo">350</span> @Override<a name="line.350"></a>
+<span class="sourceLineNo">351</span> public TRemote getKey() {<a name="line.351"></a>
+<span class="sourceLineNo">352</span> return getObject();<a name="line.352"></a>
+<span class="sourceLineNo">353</span> }<a name="line.353"></a>
+<span class="sourceLineNo">354</span><a name="line.354"></a>
+<span class="sourceLineNo">355</span> @Override<a name="line.355"></a>
+<span class="sourceLineNo">356</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.356"></a>
+<span class="sourceLineNo">357</span> if (this.operations == null) {<a name="line.357"></a>
+<span class="sourceLineNo">358</span> this.operations = new HashSet<>();<a name="line.358"></a>
+<span class="sourceLineNo">359</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.359"></a>
+<span class="sourceLineNo">360</span> timeoutExecutor.add(this);<a name="line.360"></a>
+<span class="sourceLineNo">361</span> }<a name="line.361"></a>
+<span class="sourceLineNo">362</span> this.operations.add(operation);<a name="line.362"></a>
+<span class="sourceLineNo">363</span> if (this.operations.size() > queueMaxSize) {<a name="line.363"></a>
+<span class="sourceLineNo">364</span> timeoutExecutor.remove(this);<a name="line.364"></a>
+<span class="sourceLineNo">365</span> dispatch();<a name="line.365"></a>
+<span class="sourceLineNo">366</span> }<a name="line.366"></a>
+<span class="sourceLineNo">367</span> }<a name="line.367"></a>
+<span class="sourceLineNo">368</span><a name="line.368"></a>
+<span class="sourceLineNo">369</span> @Override<a name="line.369"></a>
+<span class="sourceLineNo">370</span> public synchronized void dispatch() {<a name="line.370"></a>
+<span class="sourceLineNo">371</span> if (operations != null) {<a name="line.371"></a>
+<span class="sourceLineNo">372</span> remoteDispatch(getKey(), operations);<a name="line.372"></a>
+<span class="sourceLineNo">373</span> this.operations = null;<a name="line.373"></a>
+<span class="sourceLineNo">374</span> }<a name="line.374"></a>
+<span class="sourceLineNo">375</span> }<a name="line.375"></a>
+<span class="sourceLineNo">376</span><a name="line.376"></a>
+<span class="sourceLineNo">377</span> public synchronized void abortOperationsInQueue() {<a name="line.377"></a>
+<span class="sourceLineNo">378</span> if (operations != null) {<a name="line.378"></a>
+<span class="sourceLineNo">379</span> abortPendingOperations(getKey(), operations);<a name="line.379"></a>
+<span class="sourceLineNo">380</span> this.operations = null;<a name="line.380"></a>
+<span class="sourceLineNo">381</span> }<a name="line.381"></a>
+<span class="sourceLineNo">382</span> }<a name="line.382"></a>
+<span class="sourceLineNo">383</span><a name="line.383"></a>
+<span class="sourceLineNo">384</span> @Override<a name="line.384"></a>
+<span class="sourceLineNo">385</span> public String toString() {<a name="line.385"></a>
+<span class="sourceLineNo">386</span> return super.toString() + ", operations=" + this.operations;<a name="line.386"></a>
+<span class="sourceLineNo">387</span> }<a name="line.387"></a>
+<span class="sourceLineNo">388</span> }<a name="line.388"></a>
+<span class="sourceLineNo">389</span><a name="line.389"></a>
+<span class="sourceLineNo">390</span> /**<a name="line.390"></a>
+<span class="sourceLineNo">391</span> * Delayed object that holds a FutureTask.<a name="line.391"></a>
+<span class="sourceLineNo">392</span> * used to submit something later to the thread-pool.<a name="line.392"></a>
+<span class="sourceLineNo">393</span> */<a name="line.393"></a>
+<span class="sourceLineNo">394</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.394"></a>
+<span class="sourceLineNo">395</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.395"></a>
+<span class="sourceLineNo">396</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.396"></a>
+<span class="sourceLineNo">397</span> }<a name="line.397"></a>
+<span class="sourceLineNo">398</span> }<a name="line.398"></a>
+<span class="sourceLineNo">399</span>}<a name="line.399"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cc91ad79/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html
index c47888d..f47d1bd 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.RemoteProcedure.html
@@ -355,53 +355,56 @@
<span class="sourceLineNo">347</span> super(key, 0);<a name="line.347"></a>
<span class="sourceLineNo">348</span> }<a name="line.348"></a>
<span class="sourceLineNo">349</span><a name="line.349"></a>
-<span class="sourceLineNo">350</span> public TRemote getKey() {<a name="line.350"></a>
-<span class="sourceLineNo">351</span> return getObject();<a name="line.351"></a>
-<span class="sourceLineNo">352</span> }<a name="line.352"></a>
-<span class="sourceLineNo">353</span><a name="line.353"></a>
-<span class="sourceLineNo">354</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.354"></a>
-<span class="sourceLineNo">355</span> if (this.operations == null) {<a name="line.355"></a>
-<span class="sourceLineNo">356</span> this.operations = new HashSet<>();<a name="line.356"></a>
-<span class="sourceLineNo">357</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.357"></a>
-<span class="sourceLineNo">358</span> timeoutExecutor.add(this);<a name="line.358"></a>
-<span class="sourceLineNo">359</span> }<a name="line.359"></a>
-<span class="sourceLineNo">360</span> this.operations.add(operation);<a name="line.360"></a>
-<span class="sourceLineNo">361</span> if (this.operations.size() > queueMaxSize) {<a name="line.361"></a>
-<span class="sourceLineNo">362</span> timeoutExecutor.remove(this);<a name="line.362"></a>
-<span class="sourceLineNo">363</span> dispatch();<a name="line.363"></a>
-<span class="sourceLineNo">364</span> }<a name="line.364"></a>
-<span class="sourceLineNo">365</span> }<a name="line.365"></a>
-<span class="sourceLineNo">366</span><a name="line.366"></a>
-<span class="sourceLineNo">367</span> public synchronized void dispatch() {<a name="line.367"></a>
-<span class="sourceLineNo">368</span> if (operations != null) {<a name="line.368"></a>
-<span class="sourceLineNo">369</span> remoteDispatch(getKey(), operations);<a name="line.369"></a>
-<span class="sourceLineNo">370</span> this.operations = null;<a name="line.370"></a>
-<span class="sourceLineNo">371</span> }<a name="line.371"></a>
-<span class="sourceLineNo">372</span> }<a name="line.372"></a>
-<span class="sourceLineNo">373</span><a name="line.373"></a>
-<span class="sourceLineNo">374</span> public synchronized void abortOperationsInQueue() {<a name="line.374"></a>
-<span class="sourceLineNo">375</span> if (operations != null) {<a name="line.375"></a>
-<span class="sourceLineNo">376</span> abortPendingOperations(getKey(), operations);<a name="line.376"></a>
-<span class="sourceLineNo">377</span> this.operations = null;<a name="line.377"></a>
-<span class="sourceLineNo">378</span> }<a name="line.378"></a>
-<span class="sourceLineNo">379</span> }<a name="line.379"></a>
-<span class="sourceLineNo">380</span><a name="line.380"></a>
-<span class="sourceLineNo">381</span> @Override<a name="line.381"></a>
-<span class="sourceLineNo">382</span> public String toString() {<a name="line.382"></a>
-<span class="sourceLineNo">383</span> return super.toString() + ", operations=" + this.operations;<a name="line.383"></a>
-<span class="sourceLineNo">384</span> }<a name="line.384"></a>
-<span class="sourceLineNo">385</span> }<a name="line.385"></a>
-<span class="sourceLineNo">386</span><a name="line.386"></a>
-<span class="sourceLineNo">387</span> /**<a name="line.387"></a>
-<span class="sourceLineNo">388</span> * Delayed object that holds a FutureTask.<a name="line.388"></a>
-<span class="sourceLineNo">389</span> * used to submit something later to the thread-pool.<a name="line.389"></a>
-<span class="sourceLineNo">390</span> */<a name="line.390"></a>
-<span class="sourceLineNo">391</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.391"></a>
-<span class="sourceLineNo">392</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.392"></a>
-<span class="sourceLineNo">393</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.393"></a>
-<span class="sourceLineNo">394</span> }<a name="line.394"></a>
-<span class="sourceLineNo">395</span> }<a name="line.395"></a>
-<span class="sourceLineNo">396</span>}<a name="line.396"></a>
+<span class="sourceLineNo">350</span> @Override<a name="line.350"></a>
+<span class="sourceLineNo">351</span> public TRemote getKey() {<a name="line.351"></a>
+<span class="sourceLineNo">352</span> return getObject();<a name="line.352"></a>
+<span class="sourceLineNo">353</span> }<a name="line.353"></a>
+<span class="sourceLineNo">354</span><a name="line.354"></a>
+<span class="sourceLineNo">355</span> @Override<a name="line.355"></a>
+<span class="sourceLineNo">356</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.356"></a>
+<span class="sourceLineNo">357</span> if (this.operations == null) {<a name="line.357"></a>
+<span class="sourceLineNo">358</span> this.operations = new HashSet<>();<a name="line.358"></a>
+<span class="sourceLineNo">359</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.359"></a>
+<span class="sourceLineNo">360</span> timeoutExecutor.add(this);<a name="line.360"></a>
+<span class="sourceLineNo">361</span> }<a name="line.361"></a>
+<span class="sourceLineNo">362</span> this.operations.add(operation);<a name="line.362"></a>
+<span class="sourceLineNo">363</span> if (this.operations.size() > queueMaxSize) {<a name="line.363"></a>
+<span class="sourceLineNo">364</span> timeoutExecutor.remove(this);<a name="line.364"></a>
+<span class="sourceLineNo">365</span> dispatch();<a name="line.365"></a>
+<span class="sourceLineNo">366</span> }<a name="line.366"></a>
+<span class="sourceLineNo">367</span> }<a name="line.367"></a>
+<span class="sourceLineNo">368</span><a name="line.368"></a>
+<span class="sourceLineNo">369</span> @Override<a name="line.369"></a>
+<span class="sourceLineNo">370</span> public synchronized void dispatch() {<a name="line.370"></a>
+<span class="sourceLineNo">371</span> if (operations != null) {<a name="line.371"></a>
+<span class="sourceLineNo">372</span> remoteDispatch(getKey(), operations);<a name="line.372"></a>
+<span class="sourceLineNo">373</span> this.operations = null;<a name="line.373"></a>
+<span class="sourceLineNo">374</span> }<a name="line.374"></a>
+<span class="sourceLineNo">375</span> }<a name="line.375"></a>
+<span class="sourceLineNo">376</span><a name="line.376"></a>
+<span class="sourceLineNo">377</span> public synchronized void abortOperationsInQueue() {<a name="line.377"></a>
+<span class="sourceLineNo">378</span> if (operations != null) {<a name="line.378"></a>
+<span class="sourceLineNo">379</span> abortPendingOperations(getKey(), operations);<a name="line.379"></a>
+<span class="sourceLineNo">380</span> this.operations = null;<a name="line.380"></a>
+<span class="sourceLineNo">381</span> }<a name="line.381"></a>
+<span class="sourceLineNo">382</span> }<a name="line.382"></a>
+<span class="sourceLineNo">383</span><a name="line.383"></a>
+<span class="sourceLineNo">384</span> @Override<a name="line.384"></a>
+<span class="sourceLineNo">385</span> public String toString() {<a name="line.385"></a>
+<span class="sourceLineNo">386</span> return super.toString() + ", operations=" + this.operations;<a name="line.386"></a>
+<span class="sourceLineNo">387</span> }<a name="line.387"></a>
+<span class="sourceLineNo">388</span> }<a name="line.388"></a>
+<span class="sourceLineNo">389</span><a name="line.389"></a>
+<span class="sourceLineNo">390</span> /**<a name="line.390"></a>
+<span class="sourceLineNo">391</span> * Delayed object that holds a FutureTask.<a name="line.391"></a>
+<span class="sourceLineNo">392</span> * used to submit something later to the thread-pool.<a name="line.392"></a>
+<span class="sourceLineNo">393</span> */<a name="line.393"></a>
+<span class="sourceLineNo">394</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.394"></a>
+<span class="sourceLineNo">395</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.395"></a>
+<span class="sourceLineNo">396</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.396"></a>
+<span class="sourceLineNo">397</span> }<a name="line.397"></a>
+<span class="sourceLineNo">398</span> }<a name="line.398"></a>
+<span class="sourceLineNo">399</span>}<a name="line.399"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cc91ad79/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html
index c47888d..f47d1bd 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.TimeoutExecutorThread.html
@@ -355,53 +355,56 @@
<span class="sourceLineNo">347</span> super(key, 0);<a name="line.347"></a>
<span class="sourceLineNo">348</span> }<a name="line.348"></a>
<span class="sourceLineNo">349</span><a name="line.349"></a>
-<span class="sourceLineNo">350</span> public TRemote getKey() {<a name="line.350"></a>
-<span class="sourceLineNo">351</span> return getObject();<a name="line.351"></a>
-<span class="sourceLineNo">352</span> }<a name="line.352"></a>
-<span class="sourceLineNo">353</span><a name="line.353"></a>
-<span class="sourceLineNo">354</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.354"></a>
-<span class="sourceLineNo">355</span> if (this.operations == null) {<a name="line.355"></a>
-<span class="sourceLineNo">356</span> this.operations = new HashSet<>();<a name="line.356"></a>
-<span class="sourceLineNo">357</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.357"></a>
-<span class="sourceLineNo">358</span> timeoutExecutor.add(this);<a name="line.358"></a>
-<span class="sourceLineNo">359</span> }<a name="line.359"></a>
-<span class="sourceLineNo">360</span> this.operations.add(operation);<a name="line.360"></a>
-<span class="sourceLineNo">361</span> if (this.operations.size() > queueMaxSize) {<a name="line.361"></a>
-<span class="sourceLineNo">362</span> timeoutExecutor.remove(this);<a name="line.362"></a>
-<span class="sourceLineNo">363</span> dispatch();<a name="line.363"></a>
-<span class="sourceLineNo">364</span> }<a name="line.364"></a>
-<span class="sourceLineNo">365</span> }<a name="line.365"></a>
-<span class="sourceLineNo">366</span><a name="line.366"></a>
-<span class="sourceLineNo">367</span> public synchronized void dispatch() {<a name="line.367"></a>
-<span class="sourceLineNo">368</span> if (operations != null) {<a name="line.368"></a>
-<span class="sourceLineNo">369</span> remoteDispatch(getKey(), operations);<a name="line.369"></a>
-<span class="sourceLineNo">370</span> this.operations = null;<a name="line.370"></a>
-<span class="sourceLineNo">371</span> }<a name="line.371"></a>
-<span class="sourceLineNo">372</span> }<a name="line.372"></a>
-<span class="sourceLineNo">373</span><a name="line.373"></a>
-<span class="sourceLineNo">374</span> public synchronized void abortOperationsInQueue() {<a name="line.374"></a>
-<span class="sourceLineNo">375</span> if (operations != null) {<a name="line.375"></a>
-<span class="sourceLineNo">376</span> abortPendingOperations(getKey(), operations);<a name="line.376"></a>
-<span class="sourceLineNo">377</span> this.operations = null;<a name="line.377"></a>
-<span class="sourceLineNo">378</span> }<a name="line.378"></a>
-<span class="sourceLineNo">379</span> }<a name="line.379"></a>
-<span class="sourceLineNo">380</span><a name="line.380"></a>
-<span class="sourceLineNo">381</span> @Override<a name="line.381"></a>
-<span class="sourceLineNo">382</span> public String toString() {<a name="line.382"></a>
-<span class="sourceLineNo">383</span> return super.toString() + ", operations=" + this.operations;<a name="line.383"></a>
-<span class="sourceLineNo">384</span> }<a name="line.384"></a>
-<span class="sourceLineNo">385</span> }<a name="line.385"></a>
-<span class="sourceLineNo">386</span><a name="line.386"></a>
-<span class="sourceLineNo">387</span> /**<a name="line.387"></a>
-<span class="sourceLineNo">388</span> * Delayed object that holds a FutureTask.<a name="line.388"></a>
-<span class="sourceLineNo">389</span> * used to submit something later to the thread-pool.<a name="line.389"></a>
-<span class="sourceLineNo">390</span> */<a name="line.390"></a>
-<span class="sourceLineNo">391</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.391"></a>
-<span class="sourceLineNo">392</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.392"></a>
-<span class="sourceLineNo">393</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.393"></a>
-<span class="sourceLineNo">394</span> }<a name="line.394"></a>
-<span class="sourceLineNo">395</span> }<a name="line.395"></a>
-<span class="sourceLineNo">396</span>}<a name="line.396"></a>
+<span class="sourceLineNo">350</span> @Override<a name="line.350"></a>
+<span class="sourceLineNo">351</span> public TRemote getKey() {<a name="line.351"></a>
+<span class="sourceLineNo">352</span> return getObject();<a name="line.352"></a>
+<span class="sourceLineNo">353</span> }<a name="line.353"></a>
+<span class="sourceLineNo">354</span><a name="line.354"></a>
+<span class="sourceLineNo">355</span> @Override<a name="line.355"></a>
+<span class="sourceLineNo">356</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.356"></a>
+<span class="sourceLineNo">357</span> if (this.operations == null) {<a name="line.357"></a>
+<span class="sourceLineNo">358</span> this.operations = new HashSet<>();<a name="line.358"></a>
+<span class="sourceLineNo">359</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.359"></a>
+<span class="sourceLineNo">360</span> timeoutExecutor.add(this);<a name="line.360"></a>
+<span class="sourceLineNo">361</span> }<a name="line.361"></a>
+<span class="sourceLineNo">362</span> this.operations.add(operation);<a name="line.362"></a>
+<span class="sourceLineNo">363</span> if (this.operations.size() > queueMaxSize) {<a name="line.363"></a>
+<span class="sourceLineNo">364</span> timeoutExecutor.remove(this);<a name="line.364"></a>
+<span class="sourceLineNo">365</span> dispatch();<a name="line.365"></a>
+<span class="sourceLineNo">366</span> }<a name="line.366"></a>
+<span class="sourceLineNo">367</span> }<a name="line.367"></a>
+<span class="sourceLineNo">368</span><a name="line.368"></a>
+<span class="sourceLineNo">369</span> @Override<a name="line.369"></a>
+<span class="sourceLineNo">370</span> public synchronized void dispatch() {<a name="line.370"></a>
+<span class="sourceLineNo">371</span> if (operations != null) {<a name="line.371"></a>
+<span class="sourceLineNo">372</span> remoteDispatch(getKey(), operations);<a name="line.372"></a>
+<span class="sourceLineNo">373</span> this.operations = null;<a name="line.373"></a>
+<span class="sourceLineNo">374</span> }<a name="line.374"></a>
+<span class="sourceLineNo">375</span> }<a name="line.375"></a>
+<span class="sourceLineNo">376</span><a name="line.376"></a>
+<span class="sourceLineNo">377</span> public synchronized void abortOperationsInQueue() {<a name="line.377"></a>
+<span class="sourceLineNo">378</span> if (operations != null) {<a name="line.378"></a>
+<span class="sourceLineNo">379</span> abortPendingOperations(getKey(), operations);<a name="line.379"></a>
+<span class="sourceLineNo">380</span> this.operations = null;<a name="line.380"></a>
+<span class="sourceLineNo">381</span> }<a name="line.381"></a>
+<span class="sourceLineNo">382</span> }<a name="line.382"></a>
+<span class="sourceLineNo">383</span><a name="line.383"></a>
+<span class="sourceLineNo">384</span> @Override<a name="line.384"></a>
+<span class="sourceLineNo">385</span> public String toString() {<a name="line.385"></a>
+<span class="sourceLineNo">386</span> return super.toString() + ", operations=" + this.operations;<a name="line.386"></a>
+<span class="sourceLineNo">387</span> }<a name="line.387"></a>
+<span class="sourceLineNo">388</span> }<a name="line.388"></a>
+<span class="sourceLineNo">389</span><a name="line.389"></a>
+<span class="sourceLineNo">390</span> /**<a name="line.390"></a>
+<span class="sourceLineNo">391</span> * Delayed object that holds a FutureTask.<a name="line.391"></a>
+<span class="sourceLineNo">392</span> * used to submit something later to the thread-pool.<a name="line.392"></a>
+<span class="sourceLineNo">393</span> */<a name="line.393"></a>
+<span class="sourceLineNo">394</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.394"></a>
+<span class="sourceLineNo">395</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.395"></a>
+<span class="sourceLineNo">396</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.396"></a>
+<span class="sourceLineNo">397</span> }<a name="line.397"></a>
+<span class="sourceLineNo">398</span> }<a name="line.398"></a>
+<span class="sourceLineNo">399</span>}<a name="line.399"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cc91ad79/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html
index c47888d..f47d1bd 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/RemoteProcedureDispatcher.html
@@ -355,53 +355,56 @@
<span class="sourceLineNo">347</span> super(key, 0);<a name="line.347"></a>
<span class="sourceLineNo">348</span> }<a name="line.348"></a>
<span class="sourceLineNo">349</span><a name="line.349"></a>
-<span class="sourceLineNo">350</span> public TRemote getKey() {<a name="line.350"></a>
-<span class="sourceLineNo">351</span> return getObject();<a name="line.351"></a>
-<span class="sourceLineNo">352</span> }<a name="line.352"></a>
-<span class="sourceLineNo">353</span><a name="line.353"></a>
-<span class="sourceLineNo">354</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.354"></a>
-<span class="sourceLineNo">355</span> if (this.operations == null) {<a name="line.355"></a>
-<span class="sourceLineNo">356</span> this.operations = new HashSet<>();<a name="line.356"></a>
-<span class="sourceLineNo">357</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.357"></a>
-<span class="sourceLineNo">358</span> timeoutExecutor.add(this);<a name="line.358"></a>
-<span class="sourceLineNo">359</span> }<a name="line.359"></a>
-<span class="sourceLineNo">360</span> this.operations.add(operation);<a name="line.360"></a>
-<span class="sourceLineNo">361</span> if (this.operations.size() > queueMaxSize) {<a name="line.361"></a>
-<span class="sourceLineNo">362</span> timeoutExecutor.remove(this);<a name="line.362"></a>
-<span class="sourceLineNo">363</span> dispatch();<a name="line.363"></a>
-<span class="sourceLineNo">364</span> }<a name="line.364"></a>
-<span class="sourceLineNo">365</span> }<a name="line.365"></a>
-<span class="sourceLineNo">366</span><a name="line.366"></a>
-<span class="sourceLineNo">367</span> public synchronized void dispatch() {<a name="line.367"></a>
-<span class="sourceLineNo">368</span> if (operations != null) {<a name="line.368"></a>
-<span class="sourceLineNo">369</span> remoteDispatch(getKey(), operations);<a name="line.369"></a>
-<span class="sourceLineNo">370</span> this.operations = null;<a name="line.370"></a>
-<span class="sourceLineNo">371</span> }<a name="line.371"></a>
-<span class="sourceLineNo">372</span> }<a name="line.372"></a>
-<span class="sourceLineNo">373</span><a name="line.373"></a>
-<span class="sourceLineNo">374</span> public synchronized void abortOperationsInQueue() {<a name="line.374"></a>
-<span class="sourceLineNo">375</span> if (operations != null) {<a name="line.375"></a>
-<span class="sourceLineNo">376</span> abortPendingOperations(getKey(), operations);<a name="line.376"></a>
-<span class="sourceLineNo">377</span> this.operations = null;<a name="line.377"></a>
-<span class="sourceLineNo">378</span> }<a name="line.378"></a>
-<span class="sourceLineNo">379</span> }<a name="line.379"></a>
-<span class="sourceLineNo">380</span><a name="line.380"></a>
-<span class="sourceLineNo">381</span> @Override<a name="line.381"></a>
-<span class="sourceLineNo">382</span> public String toString() {<a name="line.382"></a>
-<span class="sourceLineNo">383</span> return super.toString() + ", operations=" + this.operations;<a name="line.383"></a>
-<span class="sourceLineNo">384</span> }<a name="line.384"></a>
-<span class="sourceLineNo">385</span> }<a name="line.385"></a>
-<span class="sourceLineNo">386</span><a name="line.386"></a>
-<span class="sourceLineNo">387</span> /**<a name="line.387"></a>
-<span class="sourceLineNo">388</span> * Delayed object that holds a FutureTask.<a name="line.388"></a>
-<span class="sourceLineNo">389</span> * used to submit something later to the thread-pool.<a name="line.389"></a>
-<span class="sourceLineNo">390</span> */<a name="line.390"></a>
-<span class="sourceLineNo">391</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.391"></a>
-<span class="sourceLineNo">392</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.392"></a>
-<span class="sourceLineNo">393</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.393"></a>
-<span class="sourceLineNo">394</span> }<a name="line.394"></a>
-<span class="sourceLineNo">395</span> }<a name="line.395"></a>
-<span class="sourceLineNo">396</span>}<a name="line.396"></a>
+<span class="sourceLineNo">350</span> @Override<a name="line.350"></a>
+<span class="sourceLineNo">351</span> public TRemote getKey() {<a name="line.351"></a>
+<span class="sourceLineNo">352</span> return getObject();<a name="line.352"></a>
+<span class="sourceLineNo">353</span> }<a name="line.353"></a>
+<span class="sourceLineNo">354</span><a name="line.354"></a>
+<span class="sourceLineNo">355</span> @Override<a name="line.355"></a>
+<span class="sourceLineNo">356</span> public synchronized void add(final RemoteProcedure operation) {<a name="line.356"></a>
+<span class="sourceLineNo">357</span> if (this.operations == null) {<a name="line.357"></a>
+<span class="sourceLineNo">358</span> this.operations = new HashSet<>();<a name="line.358"></a>
+<span class="sourceLineNo">359</span> setTimeout(EnvironmentEdgeManager.currentTime() + operationDelay);<a name="line.359"></a>
+<span class="sourceLineNo">360</span> timeoutExecutor.add(this);<a name="line.360"></a>
+<span class="sourceLineNo">361</span> }<a name="line.361"></a>
+<span class="sourceLineNo">362</span> this.operations.add(operation);<a name="line.362"></a>
+<span class="sourceLineNo">363</span> if (this.operations.size() > queueMaxSize) {<a name="line.363"></a>
+<span class="sourceLineNo">364</span> timeoutExecutor.remove(this);<a name="line.364"></a>
+<span class="sourceLineNo">365</span> dispatch();<a name="line.365"></a>
+<span class="sourceLineNo">366</span> }<a name="line.366"></a>
+<span class="sourceLineNo">367</span> }<a name="line.367"></a>
+<span class="sourceLineNo">368</span><a name="line.368"></a>
+<span class="sourceLineNo">369</span> @Override<a name="line.369"></a>
+<span class="sourceLineNo">370</span> public synchronized void dispatch() {<a name="line.370"></a>
+<span class="sourceLineNo">371</span> if (operations != null) {<a name="line.371"></a>
+<span class="sourceLineNo">372</span> remoteDispatch(getKey(), operations);<a name="line.372"></a>
+<span class="sourceLineNo">373</span> this.operations = null;<a name="line.373"></a>
+<span class="sourceLineNo">374</span> }<a name="line.374"></a>
+<span class="sourceLineNo">375</span> }<a name="line.375"></a>
+<span class="sourceLineNo">376</span><a name="line.376"></a>
+<span class="sourceLineNo">377</span> public synchronized void abortOperationsInQueue() {<a name="line.377"></a>
+<span class="sourceLineNo">378</span> if (operations != null) {<a name="line.378"></a>
+<span class="sourceLineNo">379</span> abortPendingOperations(getKey(), operations);<a name="line.379"></a>
+<span class="sourceLineNo">380</span> this.operations = null;<a name="line.380"></a>
+<span class="sourceLineNo">381</span> }<a name="line.381"></a>
+<span class="sourceLineNo">382</span> }<a name="line.382"></a>
+<span class="sourceLineNo">383</span><a name="line.383"></a>
+<span class="sourceLineNo">384</span> @Override<a name="line.384"></a>
+<span class="sourceLineNo">385</span> public String toString() {<a name="line.385"></a>
+<span class="sourceLineNo">386</span> return super.toString() + ", operations=" + this.operations;<a name="line.386"></a>
+<span class="sourceLineNo">387</span> }<a name="line.387"></a>
+<span class="sourceLineNo">388</span> }<a name="line.388"></a>
+<span class="sourceLineNo">389</span><a name="line.389"></a>
+<span class="sourceLineNo">390</span> /**<a name="line.390"></a>
+<span class="sourceLineNo">391</span> * Delayed object that holds a FutureTask.<a name="line.391"></a>
+<span class="sourceLineNo">392</span> * used to submit something later to the thread-pool.<a name="line.392"></a>
+<span class="sourceLineNo">393</span> */<a name="line.393"></a>
+<span class="sourceLineNo">394</span> private static final class DelayedTask extends DelayedContainerWithTimestamp<FutureTask<Void>> {<a name="line.394"></a>
+<span class="sourceLineNo">395</span> public DelayedTask(final FutureTask<Void> task, final long delay, final TimeUnit unit) {<a name="line.395"></a>
+<span class="sourceLineNo">396</span> super(task, EnvironmentEdgeManager.currentTime() + unit.toMillis(delay));<a name="line.396"></a>
+<span class="sourceLineNo">397</span> }<a name="line.397"></a>
+<span class="sourceLineNo">398</span> }<a name="line.398"></a>
+<span class="sourceLineNo">399</span>}<a name="line.399"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cc91ad79/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPrettyPrinter.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPrettyPrinter.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPrettyPrinter.html
index 699cc15..eab77c3 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPrettyPrinter.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/store/wal/ProcedureWALPrettyPrinter.html
@@ -157,44 +157,45 @@
<span class="sourceLineNo">149</span> * @throws IOException<a name="line.149"></a>
<span class="sourceLineNo">150</span> * Thrown upon file system errors etc.<a name="line.150"></a>
<span class="sourceLineNo">151</span> */<a name="line.151"></a>
-<span class="sourceLineNo">152</span> public int run(final String[] args) throws IOException {<a name="line.152"></a>
-<span class="sourceLineNo">153</span> // create options<a name="line.153"></a>
-<span class="sourceLineNo">154</span> Options options = new Options();<a name="line.154"></a>
-<span class="sourceLineNo">155</span> options.addOption("h", "help", false, "Output help message");<a name="line.155"></a>
-<span class="sourceLineNo">156</span> options.addOption("f", "file", true, "File to print");<a name="line.156"></a>
-<span class="sourceLineNo">157</span><a name="line.157"></a>
-<span class="sourceLineNo">158</span> final List<Path> files = new ArrayList<>();<a name="line.158"></a>
-<span class="sourceLineNo">159</span> try {<a name="line.159"></a>
-<span class="sourceLineNo">160</span> CommandLine cmd = new PosixParser().parse(options, args);<a name="line.160"></a>
-<span class="sourceLineNo">161</span><a name="line.161"></a>
-<span class="sourceLineNo">162</span> if (cmd.hasOption("f")) {<a name="line.162"></a>
-<span class="sourceLineNo">163</span> files.add(new Path(cmd.getOptionValue("f")));<a name="line.163"></a>
-<span class="sourceLineNo">164</span> }<a name="line.164"></a>
-<span class="sourceLineNo">165</span><a name="line.165"></a>
-<span class="sourceLineNo">166</span> if (files.isEmpty() || cmd.hasOption("h")) {<a name="line.166"></a>
-<span class="sourceLineNo">167</span> HelpFormatter formatter = new HelpFormatter();<a name="line.167"></a>
-<span class="sourceLineNo">168</span> formatter.printHelp("ProcedureWALPrettyPrinter ", options, true);<a name="line.168"></a>
-<span class="sourceLineNo">169</span> return(-1);<a name="line.169"></a>
-<span class="sourceLineNo">170</span> }<a name="line.170"></a>
-<span class="sourceLineNo">171</span> } catch (ParseException e) {<a name="line.171"></a>
-<span class="sourceLineNo">172</span> e.printStackTrace();<a name="line.172"></a>
-<span class="sourceLineNo">173</span> HelpFormatter formatter = new HelpFormatter();<a name="line.173"></a>
-<span class="sourceLineNo">174</span> formatter.printHelp("ProcedureWALPrettyPrinter ", options, true);<a name="line.174"></a>
-<span class="sourceLineNo">175</span> return(-1);<a name="line.175"></a>
-<span class="sourceLineNo">176</span> }<a name="line.176"></a>
-<span class="sourceLineNo">177</span> // get configuration, file system, and process the given files<a name="line.177"></a>
-<span class="sourceLineNo">178</span> for (Path file : files) {<a name="line.178"></a>
-<span class="sourceLineNo">179</span> processFile(getConf(), file);<a name="line.179"></a>
-<span class="sourceLineNo">180</span> }<a name="line.180"></a>
-<span class="sourceLineNo">181</span> return(0);<a name="line.181"></a>
-<span class="sourceLineNo">182</span> }<a name="line.182"></a>
-<span class="sourceLineNo">183</span><a name="line.183"></a>
-<span class="sourceLineNo">184</span> public static void main(String[] args) throws Exception {<a name="line.184"></a>
-<span class="sourceLineNo">185</span> final Configuration conf = HBaseConfiguration.create();<a name="line.185"></a>
-<span class="sourceLineNo">186</span> int exitCode = ToolRunner.run(conf, new ProcedureWALPrettyPrinter(), args);<a name="line.186"></a>
-<span class="sourceLineNo">187</span> System.exit(exitCode);<a name="line.187"></a>
-<span class="sourceLineNo">188</span> }<a name="line.188"></a>
-<span class="sourceLineNo">189</span>}<a name="line.189"></a>
+<span class="sourceLineNo">152</span> @Override<a name="line.152"></a>
+<span class="sourceLineNo">153</span> public int run(final String[] args) throws IOException {<a name="line.153"></a>
+<span class="sourceLineNo">154</span> // create options<a name="line.154"></a>
+<span class="sourceLineNo">155</span> Options options = new Options();<a name="line.155"></a>
+<span class="sourceLineNo">156</span> options.addOption("h", "help", false, "Output help message");<a name="line.156"></a>
+<span class="sourceLineNo">157</span> options.addOption("f", "file", true, "File to print");<a name="line.157"></a>
+<span class="sourceLineNo">158</span><a name="line.158"></a>
+<span class="sourceLineNo">159</span> final List<Path> files = new ArrayList<>();<a name="line.159"></a>
+<span class="sourceLineNo">160</span> try {<a name="line.160"></a>
+<span class="sourceLineNo">161</span> CommandLine cmd = new PosixParser().parse(options, args);<a name="line.161"></a>
+<span class="sourceLineNo">162</span><a name="line.162"></a>
+<span class="sourceLineNo">163</span> if (cmd.hasOption("f")) {<a name="line.163"></a>
+<span class="sourceLineNo">164</span> files.add(new Path(cmd.getOptionValue("f")));<a name="line.164"></a>
+<span class="sourceLineNo">165</span> }<a name="line.165"></a>
+<span class="sourceLineNo">166</span><a name="line.166"></a>
+<span class="sourceLineNo">167</span> if (files.isEmpty() || cmd.hasOption("h")) {<a name="line.167"></a>
+<span class="sourceLineNo">168</span> HelpFormatter formatter = new HelpFormatter();<a name="line.168"></a>
+<span class="sourceLineNo">169</span> formatter.printHelp("ProcedureWALPrettyPrinter ", options, true);<a name="line.169"></a>
+<span class="sourceLineNo">170</span> return(-1);<a name="line.170"></a>
+<span class="sourceLineNo">171</span> }<a name="line.171"></a>
+<span class="sourceLineNo">172</span> } catch (ParseException e) {<a name="line.172"></a>
+<span class="sourceLineNo">173</span> e.printStackTrace();<a name="line.173"></a>
+<span class="sourceLineNo">174</span> HelpFormatter formatter = new HelpFormatter();<a name="line.174"></a>
+<span class="sourceLineNo">175</span> formatter.printHelp("ProcedureWALPrettyPrinter ", options, true);<a name="line.175"></a>
+<span class="sourceLineNo">176</span> return(-1);<a name="line.176"></a>
+<span class="sourceLineNo">177</span> }<a name="line.177"></a>
+<span class="sourceLineNo">178</span> // get configuration, file system, and process the given files<a name="line.178"></a>
+<span class="sourceLineNo">179</span> for (Path file : files) {<a name="line.179"></a>
+<span class="sourceLineNo">180</span> processFile(getConf(), file);<a name="line.180"></a>
+<span class="sourceLineNo">181</span> }<a name="line.181"></a>
+<span class="sourceLineNo">182</span> return(0);<a name="line.182"></a>
+<span class="sourceLineNo">183</span> }<a name="line.183"></a>
+<span class="sourceLineNo">184</span><a name="line.184"></a>
+<span class="sourceLineNo">185</span> public static void main(String[] args) throws Exception {<a name="line.185"></a>
+<span class="sourceLineNo">186</span> final Configuration conf = HBaseConfiguration.create();<a name="line.186"></a>
+<span class="sourceLineNo">187</span> int exitCode = ToolRunner.run(conf, new ProcedureWALPrettyPrinter(), args);<a name="line.187"></a>
+<span class="sourceLineNo">188</span> System.exit(exitCode);<a name="line.188"></a>
+<span class="sourceLineNo">189</span> }<a name="line.189"></a>
+<span class="sourceLineNo">190</span>}<a name="line.190"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/cc91ad79/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/util/ByteSlot.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/util/ByteSlot.html b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/util/ByteSlot.html
index 88340bd..0baa03a 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/util/ByteSlot.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/procedure2/util/ByteSlot.html
@@ -89,44 +89,46 @@
<span class="sourceLineNo">081</span> buf[offset] = (byte)b;<a name="line.81"></a>
<span class="sourceLineNo">082</span> }<a name="line.82"></a>
<span class="sourceLineNo">083</span><a name="line.83"></a>
-<span class="sourceLineNo">084</span> public void write(int b) {<a name="line.84"></a>
-<span class="sourceLineNo">085</span> ensureCapacity(size + 1);<a name="line.85"></a>
-<span class="sourceLineNo">086</span> buf[size++] = (byte)b;<a name="line.86"></a>
-<span class="sourceLineNo">087</span> }<a name="line.87"></a>
-<span class="sourceLineNo">088</span><a name="line.88"></a>
-<span class="sourceLineNo">089</span> public void write(byte[] b, int off, int len) {<a name="line.89"></a>
-<span class="sourceLineNo">090</span> ensureCapacity(size + len);<a name="line.90"></a>
-<span class="sourceLineNo">091</span> System.arraycopy(b, off, buf, size, len);<a name="line.91"></a>
-<span class="sourceLineNo">092</span> size += len;<a name="line.92"></a>
-<span class="sourceLineNo">093</span> }<a name="line.93"></a>
-<span class="sourceLineNo">094</span><a name="line.94"></a>
-<span class="sourceLineNo">095</span> public void writeTo(final OutputStream stream) throws IOException {<a name="line.95"></a>
-<span class="sourceLineNo">096</span> if (head != 0) {<a name="line.96"></a>
-<span class="sourceLineNo">097</span> stream.write(buf, head, size - head);<a name="line.97"></a>
-<span class="sourceLineNo">098</span> stream.write(buf, 0, head);<a name="line.98"></a>
-<span class="sourceLineNo">099</span> } else {<a name="line.99"></a>
-<span class="sourceLineNo">100</span> stream.write(buf, 0, size);<a name="line.100"></a>
-<span class="sourceLineNo">101</span> }<a name="line.101"></a>
-<span class="sourceLineNo">102</span> }<a name="line.102"></a>
-<span class="sourceLineNo">103</span><a name="line.103"></a>
-<span class="sourceLineNo">104</span> private void ensureCapacity(int minCapacity) {<a name="line.104"></a>
-<span class="sourceLineNo">105</span> minCapacity = (minCapacity + (GROW_ALIGN - 1)) & -GROW_ALIGN;<a name="line.105"></a>
-<span class="sourceLineNo">106</span> if (buf == null) {<a name="line.106"></a>
-<span class="sourceLineNo">107</span> buf = new byte[minCapacity];<a name="line.107"></a>
-<span class="sourceLineNo">108</span> } else if (minCapacity > buf.length) {<a name="line.108"></a>
-<span class="sourceLineNo">109</span> int newCapacity;<a name="line.109"></a>
-<span class="sourceLineNo">110</span> if (buf.length <= LARGE_GROW_SIZE_THRESHOLD) {<a name="line.110"></a>
-<span class="sourceLineNo">111</span> newCapacity = buf.length << 1;<a name="line.111"></a>
-<span class="sourceLineNo">112</span> } else {<a name="line.112"></a>
-<span class="sourceLineNo">113</span> newCapacity = buf.length + LARGE_GROW_SIZE;<a name="line.113"></a>
-<span class="sourceLineNo">114</span> }<a name="line.114"></a>
-<span class="sourceLineNo">115</span> if (minCapacity > newCapacity) {<a name="line.115"></a>
-<span class="sourceLineNo">116</span> newCapacity = minCapacity;<a name="line.116"></a>
-<span class="sourceLineNo">117</span> }<a name="line.117"></a>
-<span class="sourceLineNo">118</span> buf = Arrays.copyOf(buf, newCapacity);<a name="line.118"></a>
-<span class="sourceLineNo">119</span> }<a name="line.119"></a>
-<span class="sourceLineNo">120</span> }<a name="line.120"></a>
-<span class="sourceLineNo">121</span>}<a name="line.121"></a>
+<span class="sourceLineNo">084</span> @Override<a name="line.84"></a>
+<span class="sourceLineNo">085</span> public void write(int b) {<a name="line.85"></a>
+<span class="sourceLineNo">086</span> ensureCapacity(size + 1);<a name="line.86"></a>
+<span class="sourceLineNo">087</span> buf[size++] = (byte)b;<a name="line.87"></a>
+<span class="sourceLineNo">088</span> }<a name="line.88"></a>
+<span class="sourceLineNo">089</span><a name="line.89"></a>
+<span class="sourceLineNo">090</span> @Override<a name="line.90"></a>
+<span class="sourceLineNo">091</span> public void write(byte[] b, int off, int len) {<a name="line.91"></a>
+<span class="sourceLineNo">092</span> ensureCapacity(size + len);<a name="line.92"></a>
+<span class="sourceLineNo">093</span> System.arraycopy(b, off, buf, size, len);<a name="line.93"></a>
+<span class="sourceLineNo">094</span> size += len;<a name="line.94"></a>
+<span class="sourceLineNo">095</span> }<a name="line.95"></a>
+<span class="sourceLineNo">096</span><a name="line.96"></a>
+<span class="sourceLineNo">097</span> public void writeTo(final OutputStream stream) throws IOException {<a name="line.97"></a>
+<span class="sourceLineNo">098</span> if (head != 0) {<a name="line.98"></a>
+<span class="sourceLineNo">099</span> stream.write(buf, head, size - head);<a name="line.99"></a>
+<span class="sourceLineNo">100</span> stream.write(buf, 0, head);<a name="line.100"></a>
+<span class="sourceLineNo">101</span> } else {<a name="line.101"></a>
+<span class="sourceLineNo">102</span> stream.write(buf, 0, size);<a name="line.102"></a>
+<span class="sourceLineNo">103</span> }<a name="line.103"></a>
+<span class="sourceLineNo">104</span> }<a name="line.104"></a>
+<span class="sourceLineNo">105</span><a name="line.105"></a>
+<span class="sourceLineNo">106</span> private void ensureCapacity(int minCapacity) {<a name="line.106"></a>
+<span class="sourceLineNo">107</span> minCapacity = (minCapacity + (GROW_ALIGN - 1)) & -GROW_ALIGN;<a name="line.107"></a>
+<span class="sourceLineNo">108</span> if (buf == null) {<a name="line.108"></a>
+<span class="sourceLineNo">109</span> buf = new byte[minCapacity];<a name="line.109"></a>
+<span class="sourceLineNo">110</span> } else if (minCapacity > buf.length) {<a name="line.110"></a>
+<span class="sourceLineNo">111</span> int newCapacity;<a name="line.111"></a>
+<span class="sourceLineNo">112</span> if (buf.length <= LARGE_GROW_SIZE_THRESHOLD) {<a name="line.112"></a>
+<span class="sourceLineNo">113</span> newCapacity = buf.length << 1;<a name="line.113"></a>
+<span class="sourceLineNo">114</span> } else {<a name="line.114"></a>
+<span class="sourceLineNo">115</span> newCapacity = buf.length + LARGE_GROW_SIZE;<a name="line.115"></a>
+<span class="sourceLineNo">116</span> }<a name="line.116"></a>
+<span class="sourceLineNo">117</span> if (minCapacity > newCapacity) {<a name="line.117"></a>
+<span class="sourceLineNo">118</span> newCapacity = minCapacity;<a name="line.118"></a>
+<span class="sourceLineNo">119</span> }<a name="line.119"></a>
+<span class="sourceLineNo">120</span> buf = Arrays.copyOf(buf, newCapacity);<a name="line.120"></a>
+<span class="sourceLineNo">121</span> }<a name="line.121"></a>
+<span class="sourceLineNo">122</span> }<a name="line.122"></a>
+<span class="sourceLineNo">123</span>}<a name="line.123"></a>