http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntry.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntry.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntry.html index 8a6565b..3a9a7f7 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntry.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntry.html @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * Process all that are passed in even if failure being sure to remove from ramCache else we'll<a name="line.806"></a> <span class="sourceLineNo">807</span> * never undo the references and we'll OOME.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @param entries Presumes list passed in here will be processed by this invocation only. No<a name="line.808"></a> -<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> +<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> <span class="sourceLineNo">810</span> * @throws InterruptedException<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> @VisibleForTesting<a name="line.812"></a> @@ -919,23 +919,23 @@ <span class="sourceLineNo">911</span> }<a name="line.911"></a> <span class="sourceLineNo">912</span><a name="line.912"></a> <span class="sourceLineNo">913</span> /**<a name="line.913"></a> -<span class="sourceLineNo">914</span> * Blocks until elements available in <code>q</code> then tries to grab as many as possible<a name="line.914"></a> +<span class="sourceLineNo">914</span> * Blocks until elements available in {@code q} then tries to grab as many as possible<a name="line.914"></a> <span class="sourceLineNo">915</span> * before returning.<a name="line.915"></a> -<span class="sourceLineNo">916</span> * @param recepticle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> -<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> +<span class="sourceLineNo">916</span> * @param receptacle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> +<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> <span class="sourceLineNo">918</span> * @param q The queue to take from.<a name="line.918"></a> -<span class="sourceLineNo">919</span> * @return <code>receptical laden with elements taken from the queue or empty if none found.<a name="line.919"></a> +<span class="sourceLineNo">919</span> * @return {@code receptacle} laden with elements taken from the queue or empty if none found.<a name="line.919"></a> <span class="sourceLineNo">920</span> */<a name="line.920"></a> <span class="sourceLineNo">921</span> @VisibleForTesting<a name="line.921"></a> <span class="sourceLineNo">922</span> static List<RAMQueueEntry> getRAMQueueEntries(final BlockingQueue<RAMQueueEntry> q,<a name="line.922"></a> -<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptical)<a name="line.923"></a> +<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptacle)<a name="line.923"></a> <span class="sourceLineNo">924</span> throws InterruptedException {<a name="line.924"></a> <span class="sourceLineNo">925</span> // Clear sets all entries to null and sets size to 0. We retain allocations. Presume it<a name="line.925"></a> <span class="sourceLineNo">926</span> // ok even if list grew to accommodate thousands.<a name="line.926"></a> -<span class="sourceLineNo">927</span> receptical.clear();<a name="line.927"></a> -<span class="sourceLineNo">928</span> receptical.add(q.take());<a name="line.928"></a> -<span class="sourceLineNo">929</span> q.drainTo(receptical);<a name="line.929"></a> -<span class="sourceLineNo">930</span> return receptical;<a name="line.930"></a> +<span class="sourceLineNo">927</span> receptacle.clear();<a name="line.927"></a> +<span class="sourceLineNo">928</span> receptacle.add(q.take());<a name="line.928"></a> +<span class="sourceLineNo">929</span> q.drainTo(receptacle);<a name="line.929"></a> +<span class="sourceLineNo">930</span> return receptacle;<a name="line.930"></a> <span class="sourceLineNo">931</span> }<a name="line.931"></a> <span class="sourceLineNo">932</span><a name="line.932"></a> <span class="sourceLineNo">933</span> private void persistToFile() throws IOException {<a name="line.933"></a>
http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntryGroup.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntryGroup.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntryGroup.html index 8a6565b..3a9a7f7 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntryGroup.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.BucketEntryGroup.html @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * Process all that are passed in even if failure being sure to remove from ramCache else we'll<a name="line.806"></a> <span class="sourceLineNo">807</span> * never undo the references and we'll OOME.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @param entries Presumes list passed in here will be processed by this invocation only. No<a name="line.808"></a> -<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> +<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> <span class="sourceLineNo">810</span> * @throws InterruptedException<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> @VisibleForTesting<a name="line.812"></a> @@ -919,23 +919,23 @@ <span class="sourceLineNo">911</span> }<a name="line.911"></a> <span class="sourceLineNo">912</span><a name="line.912"></a> <span class="sourceLineNo">913</span> /**<a name="line.913"></a> -<span class="sourceLineNo">914</span> * Blocks until elements available in <code>q</code> then tries to grab as many as possible<a name="line.914"></a> +<span class="sourceLineNo">914</span> * Blocks until elements available in {@code q} then tries to grab as many as possible<a name="line.914"></a> <span class="sourceLineNo">915</span> * before returning.<a name="line.915"></a> -<span class="sourceLineNo">916</span> * @param recepticle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> -<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> +<span class="sourceLineNo">916</span> * @param receptacle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> +<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> <span class="sourceLineNo">918</span> * @param q The queue to take from.<a name="line.918"></a> -<span class="sourceLineNo">919</span> * @return <code>receptical laden with elements taken from the queue or empty if none found.<a name="line.919"></a> +<span class="sourceLineNo">919</span> * @return {@code receptacle} laden with elements taken from the queue or empty if none found.<a name="line.919"></a> <span class="sourceLineNo">920</span> */<a name="line.920"></a> <span class="sourceLineNo">921</span> @VisibleForTesting<a name="line.921"></a> <span class="sourceLineNo">922</span> static List<RAMQueueEntry> getRAMQueueEntries(final BlockingQueue<RAMQueueEntry> q,<a name="line.922"></a> -<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptical)<a name="line.923"></a> +<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptacle)<a name="line.923"></a> <span class="sourceLineNo">924</span> throws InterruptedException {<a name="line.924"></a> <span class="sourceLineNo">925</span> // Clear sets all entries to null and sets size to 0. We retain allocations. Presume it<a name="line.925"></a> <span class="sourceLineNo">926</span> // ok even if list grew to accommodate thousands.<a name="line.926"></a> -<span class="sourceLineNo">927</span> receptical.clear();<a name="line.927"></a> -<span class="sourceLineNo">928</span> receptical.add(q.take());<a name="line.928"></a> -<span class="sourceLineNo">929</span> q.drainTo(receptical);<a name="line.929"></a> -<span class="sourceLineNo">930</span> return receptical;<a name="line.930"></a> +<span class="sourceLineNo">927</span> receptacle.clear();<a name="line.927"></a> +<span class="sourceLineNo">928</span> receptacle.add(q.take());<a name="line.928"></a> +<span class="sourceLineNo">929</span> q.drainTo(receptacle);<a name="line.929"></a> +<span class="sourceLineNo">930</span> return receptacle;<a name="line.930"></a> <span class="sourceLineNo">931</span> }<a name="line.931"></a> <span class="sourceLineNo">932</span><a name="line.932"></a> <span class="sourceLineNo">933</span> private void persistToFile() throws IOException {<a name="line.933"></a> http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.RAMQueueEntry.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.RAMQueueEntry.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.RAMQueueEntry.html index 8a6565b..3a9a7f7 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.RAMQueueEntry.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.RAMQueueEntry.html @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * Process all that are passed in even if failure being sure to remove from ramCache else we'll<a name="line.806"></a> <span class="sourceLineNo">807</span> * never undo the references and we'll OOME.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @param entries Presumes list passed in here will be processed by this invocation only. No<a name="line.808"></a> -<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> +<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> <span class="sourceLineNo">810</span> * @throws InterruptedException<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> @VisibleForTesting<a name="line.812"></a> @@ -919,23 +919,23 @@ <span class="sourceLineNo">911</span> }<a name="line.911"></a> <span class="sourceLineNo">912</span><a name="line.912"></a> <span class="sourceLineNo">913</span> /**<a name="line.913"></a> -<span class="sourceLineNo">914</span> * Blocks until elements available in <code>q</code> then tries to grab as many as possible<a name="line.914"></a> +<span class="sourceLineNo">914</span> * Blocks until elements available in {@code q} then tries to grab as many as possible<a name="line.914"></a> <span class="sourceLineNo">915</span> * before returning.<a name="line.915"></a> -<span class="sourceLineNo">916</span> * @param recepticle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> -<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> +<span class="sourceLineNo">916</span> * @param receptacle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> +<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> <span class="sourceLineNo">918</span> * @param q The queue to take from.<a name="line.918"></a> -<span class="sourceLineNo">919</span> * @return <code>receptical laden with elements taken from the queue or empty if none found.<a name="line.919"></a> +<span class="sourceLineNo">919</span> * @return {@code receptacle} laden with elements taken from the queue or empty if none found.<a name="line.919"></a> <span class="sourceLineNo">920</span> */<a name="line.920"></a> <span class="sourceLineNo">921</span> @VisibleForTesting<a name="line.921"></a> <span class="sourceLineNo">922</span> static List<RAMQueueEntry> getRAMQueueEntries(final BlockingQueue<RAMQueueEntry> q,<a name="line.922"></a> -<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptical)<a name="line.923"></a> +<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptacle)<a name="line.923"></a> <span class="sourceLineNo">924</span> throws InterruptedException {<a name="line.924"></a> <span class="sourceLineNo">925</span> // Clear sets all entries to null and sets size to 0. We retain allocations. Presume it<a name="line.925"></a> <span class="sourceLineNo">926</span> // ok even if list grew to accommodate thousands.<a name="line.926"></a> -<span class="sourceLineNo">927</span> receptical.clear();<a name="line.927"></a> -<span class="sourceLineNo">928</span> receptical.add(q.take());<a name="line.928"></a> -<span class="sourceLineNo">929</span> q.drainTo(receptical);<a name="line.929"></a> -<span class="sourceLineNo">930</span> return receptical;<a name="line.930"></a> +<span class="sourceLineNo">927</span> receptacle.clear();<a name="line.927"></a> +<span class="sourceLineNo">928</span> receptacle.add(q.take());<a name="line.928"></a> +<span class="sourceLineNo">929</span> q.drainTo(receptacle);<a name="line.929"></a> +<span class="sourceLineNo">930</span> return receptacle;<a name="line.930"></a> <span class="sourceLineNo">931</span> }<a name="line.931"></a> <span class="sourceLineNo">932</span><a name="line.932"></a> <span class="sourceLineNo">933</span> private void persistToFile() throws IOException {<a name="line.933"></a> http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.StatisticsThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.StatisticsThread.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.StatisticsThread.html index 8a6565b..3a9a7f7 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.StatisticsThread.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.StatisticsThread.html @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * Process all that are passed in even if failure being sure to remove from ramCache else we'll<a name="line.806"></a> <span class="sourceLineNo">807</span> * never undo the references and we'll OOME.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @param entries Presumes list passed in here will be processed by this invocation only. No<a name="line.808"></a> -<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> +<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> <span class="sourceLineNo">810</span> * @throws InterruptedException<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> @VisibleForTesting<a name="line.812"></a> @@ -919,23 +919,23 @@ <span class="sourceLineNo">911</span> }<a name="line.911"></a> <span class="sourceLineNo">912</span><a name="line.912"></a> <span class="sourceLineNo">913</span> /**<a name="line.913"></a> -<span class="sourceLineNo">914</span> * Blocks until elements available in <code>q</code> then tries to grab as many as possible<a name="line.914"></a> +<span class="sourceLineNo">914</span> * Blocks until elements available in {@code q} then tries to grab as many as possible<a name="line.914"></a> <span class="sourceLineNo">915</span> * before returning.<a name="line.915"></a> -<span class="sourceLineNo">916</span> * @param recepticle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> -<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> +<span class="sourceLineNo">916</span> * @param receptacle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> +<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> <span class="sourceLineNo">918</span> * @param q The queue to take from.<a name="line.918"></a> -<span class="sourceLineNo">919</span> * @return <code>receptical laden with elements taken from the queue or empty if none found.<a name="line.919"></a> +<span class="sourceLineNo">919</span> * @return {@code receptacle} laden with elements taken from the queue or empty if none found.<a name="line.919"></a> <span class="sourceLineNo">920</span> */<a name="line.920"></a> <span class="sourceLineNo">921</span> @VisibleForTesting<a name="line.921"></a> <span class="sourceLineNo">922</span> static List<RAMQueueEntry> getRAMQueueEntries(final BlockingQueue<RAMQueueEntry> q,<a name="line.922"></a> -<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptical)<a name="line.923"></a> +<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptacle)<a name="line.923"></a> <span class="sourceLineNo">924</span> throws InterruptedException {<a name="line.924"></a> <span class="sourceLineNo">925</span> // Clear sets all entries to null and sets size to 0. We retain allocations. Presume it<a name="line.925"></a> <span class="sourceLineNo">926</span> // ok even if list grew to accommodate thousands.<a name="line.926"></a> -<span class="sourceLineNo">927</span> receptical.clear();<a name="line.927"></a> -<span class="sourceLineNo">928</span> receptical.add(q.take());<a name="line.928"></a> -<span class="sourceLineNo">929</span> q.drainTo(receptical);<a name="line.929"></a> -<span class="sourceLineNo">930</span> return receptical;<a name="line.930"></a> +<span class="sourceLineNo">927</span> receptacle.clear();<a name="line.927"></a> +<span class="sourceLineNo">928</span> receptacle.add(q.take());<a name="line.928"></a> +<span class="sourceLineNo">929</span> q.drainTo(receptacle);<a name="line.929"></a> +<span class="sourceLineNo">930</span> return receptacle;<a name="line.930"></a> <span class="sourceLineNo">931</span> }<a name="line.931"></a> <span class="sourceLineNo">932</span><a name="line.932"></a> <span class="sourceLineNo">933</span> private void persistToFile() throws IOException {<a name="line.933"></a> http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.WriterThread.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.WriterThread.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.WriterThread.html index 8a6565b..3a9a7f7 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.WriterThread.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.WriterThread.html @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * Process all that are passed in even if failure being sure to remove from ramCache else we'll<a name="line.806"></a> <span class="sourceLineNo">807</span> * never undo the references and we'll OOME.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @param entries Presumes list passed in here will be processed by this invocation only. No<a name="line.808"></a> -<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> +<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> <span class="sourceLineNo">810</span> * @throws InterruptedException<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> @VisibleForTesting<a name="line.812"></a> @@ -919,23 +919,23 @@ <span class="sourceLineNo">911</span> }<a name="line.911"></a> <span class="sourceLineNo">912</span><a name="line.912"></a> <span class="sourceLineNo">913</span> /**<a name="line.913"></a> -<span class="sourceLineNo">914</span> * Blocks until elements available in <code>q</code> then tries to grab as many as possible<a name="line.914"></a> +<span class="sourceLineNo">914</span> * Blocks until elements available in {@code q} then tries to grab as many as possible<a name="line.914"></a> <span class="sourceLineNo">915</span> * before returning.<a name="line.915"></a> -<span class="sourceLineNo">916</span> * @param recepticle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> -<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> +<span class="sourceLineNo">916</span> * @param receptacle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> +<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> <span class="sourceLineNo">918</span> * @param q The queue to take from.<a name="line.918"></a> -<span class="sourceLineNo">919</span> * @return <code>receptical laden with elements taken from the queue or empty if none found.<a name="line.919"></a> +<span class="sourceLineNo">919</span> * @return {@code receptacle} laden with elements taken from the queue or empty if none found.<a name="line.919"></a> <span class="sourceLineNo">920</span> */<a name="line.920"></a> <span class="sourceLineNo">921</span> @VisibleForTesting<a name="line.921"></a> <span class="sourceLineNo">922</span> static List<RAMQueueEntry> getRAMQueueEntries(final BlockingQueue<RAMQueueEntry> q,<a name="line.922"></a> -<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptical)<a name="line.923"></a> +<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptacle)<a name="line.923"></a> <span class="sourceLineNo">924</span> throws InterruptedException {<a name="line.924"></a> <span class="sourceLineNo">925</span> // Clear sets all entries to null and sets size to 0. We retain allocations. Presume it<a name="line.925"></a> <span class="sourceLineNo">926</span> // ok even if list grew to accommodate thousands.<a name="line.926"></a> -<span class="sourceLineNo">927</span> receptical.clear();<a name="line.927"></a> -<span class="sourceLineNo">928</span> receptical.add(q.take());<a name="line.928"></a> -<span class="sourceLineNo">929</span> q.drainTo(receptical);<a name="line.929"></a> -<span class="sourceLineNo">930</span> return receptical;<a name="line.930"></a> +<span class="sourceLineNo">927</span> receptacle.clear();<a name="line.927"></a> +<span class="sourceLineNo">928</span> receptacle.add(q.take());<a name="line.928"></a> +<span class="sourceLineNo">929</span> q.drainTo(receptacle);<a name="line.929"></a> +<span class="sourceLineNo">930</span> return receptacle;<a name="line.930"></a> <span class="sourceLineNo">931</span> }<a name="line.931"></a> <span class="sourceLineNo">932</span><a name="line.932"></a> <span class="sourceLineNo">933</span> private void persistToFile() throws IOException {<a name="line.933"></a> http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.html b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.html index 8a6565b..3a9a7f7 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.html @@ -814,7 +814,7 @@ <span class="sourceLineNo">806</span> * Process all that are passed in even if failure being sure to remove from ramCache else we'll<a name="line.806"></a> <span class="sourceLineNo">807</span> * never undo the references and we'll OOME.<a name="line.807"></a> <span class="sourceLineNo">808</span> * @param entries Presumes list passed in here will be processed by this invocation only. No<a name="line.808"></a> -<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> +<span class="sourceLineNo">809</span> * interference expected.<a name="line.809"></a> <span class="sourceLineNo">810</span> * @throws InterruptedException<a name="line.810"></a> <span class="sourceLineNo">811</span> */<a name="line.811"></a> <span class="sourceLineNo">812</span> @VisibleForTesting<a name="line.812"></a> @@ -919,23 +919,23 @@ <span class="sourceLineNo">911</span> }<a name="line.911"></a> <span class="sourceLineNo">912</span><a name="line.912"></a> <span class="sourceLineNo">913</span> /**<a name="line.913"></a> -<span class="sourceLineNo">914</span> * Blocks until elements available in <code>q</code> then tries to grab as many as possible<a name="line.914"></a> +<span class="sourceLineNo">914</span> * Blocks until elements available in {@code q} then tries to grab as many as possible<a name="line.914"></a> <span class="sourceLineNo">915</span> * before returning.<a name="line.915"></a> -<span class="sourceLineNo">916</span> * @param recepticle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> -<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> +<span class="sourceLineNo">916</span> * @param receptacle Where to stash the elements taken from queue. We clear before we use it<a name="line.916"></a> +<span class="sourceLineNo">917</span> * just in case.<a name="line.917"></a> <span class="sourceLineNo">918</span> * @param q The queue to take from.<a name="line.918"></a> -<span class="sourceLineNo">919</span> * @return <code>receptical laden with elements taken from the queue or empty if none found.<a name="line.919"></a> +<span class="sourceLineNo">919</span> * @return {@code receptacle} laden with elements taken from the queue or empty if none found.<a name="line.919"></a> <span class="sourceLineNo">920</span> */<a name="line.920"></a> <span class="sourceLineNo">921</span> @VisibleForTesting<a name="line.921"></a> <span class="sourceLineNo">922</span> static List<RAMQueueEntry> getRAMQueueEntries(final BlockingQueue<RAMQueueEntry> q,<a name="line.922"></a> -<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptical)<a name="line.923"></a> +<span class="sourceLineNo">923</span> final List<RAMQueueEntry> receptacle)<a name="line.923"></a> <span class="sourceLineNo">924</span> throws InterruptedException {<a name="line.924"></a> <span class="sourceLineNo">925</span> // Clear sets all entries to null and sets size to 0. We retain allocations. Presume it<a name="line.925"></a> <span class="sourceLineNo">926</span> // ok even if list grew to accommodate thousands.<a name="line.926"></a> -<span class="sourceLineNo">927</span> receptical.clear();<a name="line.927"></a> -<span class="sourceLineNo">928</span> receptical.add(q.take());<a name="line.928"></a> -<span class="sourceLineNo">929</span> q.drainTo(receptical);<a name="line.929"></a> -<span class="sourceLineNo">930</span> return receptical;<a name="line.930"></a> +<span class="sourceLineNo">927</span> receptacle.clear();<a name="line.927"></a> +<span class="sourceLineNo">928</span> receptacle.add(q.take());<a name="line.928"></a> +<span class="sourceLineNo">929</span> q.drainTo(receptacle);<a name="line.929"></a> +<span class="sourceLineNo">930</span> return receptacle;<a name="line.930"></a> <span class="sourceLineNo">931</span> }<a name="line.931"></a> <span class="sourceLineNo">932</span><a name="line.932"></a> <span class="sourceLineNo">933</span> private void persistToFile() throws IOException {<a name="line.933"></a> http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.CallFuture.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.CallFuture.html b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.CallFuture.html index 0693623..03ccec3 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.CallFuture.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.CallFuture.html @@ -800,7 +800,7 @@ <span class="sourceLineNo">792</span> }<a name="line.792"></a> <span class="sourceLineNo">793</span><a name="line.793"></a> <span class="sourceLineNo">794</span> /**<a name="line.794"></a> -<span class="sourceLineNo">795</span> * Write the RPC header: <MAGIC WORD -- 'HBas'> <ONEBYTE_VERSION> <ONEBYTE_AUTH_TYPE><a name="line.795"></a> +<span class="sourceLineNo">795</span> * Write the RPC header: {@code <MAGIC WORD -- 'HBas'> <ONEBYTE_VERSION> <ONEBYTE_AUTH_TYPE>}<a name="line.795"></a> <span class="sourceLineNo">796</span> */<a name="line.796"></a> <span class="sourceLineNo">797</span> private void writeConnectionHeaderPreamble(OutputStream outStream) throws IOException {<a name="line.797"></a> <span class="sourceLineNo">798</span> // Assemble the preamble up in a buffer first and then send it. Writing individual elements,<a name="line.798"></a> http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.CallSender.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.CallSender.html b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.CallSender.html index 0693623..03ccec3 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.CallSender.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.CallSender.html @@ -800,7 +800,7 @@ <span class="sourceLineNo">792</span> }<a name="line.792"></a> <span class="sourceLineNo">793</span><a name="line.793"></a> <span class="sourceLineNo">794</span> /**<a name="line.794"></a> -<span class="sourceLineNo">795</span> * Write the RPC header: <MAGIC WORD -- 'HBas'> <ONEBYTE_VERSION> <ONEBYTE_AUTH_TYPE><a name="line.795"></a> +<span class="sourceLineNo">795</span> * Write the RPC header: {@code <MAGIC WORD -- 'HBas'> <ONEBYTE_VERSION> <ONEBYTE_AUTH_TYPE>}<a name="line.795"></a> <span class="sourceLineNo">796</span> */<a name="line.796"></a> <span class="sourceLineNo">797</span> private void writeConnectionHeaderPreamble(OutputStream outStream) throws IOException {<a name="line.797"></a> <span class="sourceLineNo">798</span> // Assemble the preamble up in a buffer first and then send it. Writing individual elements,<a name="line.798"></a> http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html index 0693623..03ccec3 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.Connection.html @@ -800,7 +800,7 @@ <span class="sourceLineNo">792</span> }<a name="line.792"></a> <span class="sourceLineNo">793</span><a name="line.793"></a> <span class="sourceLineNo">794</span> /**<a name="line.794"></a> -<span class="sourceLineNo">795</span> * Write the RPC header: <MAGIC WORD -- 'HBas'> <ONEBYTE_VERSION> <ONEBYTE_AUTH_TYPE><a name="line.795"></a> +<span class="sourceLineNo">795</span> * Write the RPC header: {@code <MAGIC WORD -- 'HBas'> <ONEBYTE_VERSION> <ONEBYTE_AUTH_TYPE>}<a name="line.795"></a> <span class="sourceLineNo">796</span> */<a name="line.796"></a> <span class="sourceLineNo">797</span> private void writeConnectionHeaderPreamble(OutputStream outStream) throws IOException {<a name="line.797"></a> <span class="sourceLineNo">798</span> // Assemble the preamble up in a buffer first and then send it. Writing individual elements,<a name="line.798"></a> http://git-wip-us.apache.org/repos/asf/hbase/blob/ef7355e1/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.html b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.html index 0693623..03ccec3 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/ipc/RpcClientImpl.html @@ -800,7 +800,7 @@ <span class="sourceLineNo">792</span> }<a name="line.792"></a> <span class="sourceLineNo">793</span><a name="line.793"></a> <span class="sourceLineNo">794</span> /**<a name="line.794"></a> -<span class="sourceLineNo">795</span> * Write the RPC header: <MAGIC WORD -- 'HBas'> <ONEBYTE_VERSION> <ONEBYTE_AUTH_TYPE><a name="line.795"></a> +<span class="sourceLineNo">795</span> * Write the RPC header: {@code <MAGIC WORD -- 'HBas'> <ONEBYTE_VERSION> <ONEBYTE_AUTH_TYPE>}<a name="line.795"></a> <span class="sourceLineNo">796</span> */<a name="line.796"></a> <span class="sourceLineNo">797</span> private void writeConnectionHeaderPreamble(OutputStream outStream) throws IOException {<a name="line.797"></a> <span class="sourceLineNo">798</span> // Assemble the preamble up in a buffer first and then send it. Writing individual elements,<a name="line.798"></a>
