You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by in...@apache.org on 2019/06/25 02:05:48 UTC
[hadoop] branch branch-3.2 updated: HDFS-14541. When
evictableMmapped or evictable size is zero,
do not throw NoSuchElementException.
This is an automated email from the ASF dual-hosted git repository.
inigoiri pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.2 by this push:
new 0966407 HDFS-14541. When evictableMmapped or evictable size is zero, do not throw NoSuchElementException.
0966407 is described below
commit 0966407ad6fddb7adf60dba846d1f7c8a13b8ec1
Author: Inigo Goiri <in...@apache.org>
AuthorDate: Mon Jun 24 19:02:41 2019 -0700
HDFS-14541. When evictableMmapped or evictable size is zero, do not throw NoSuchElementException.
---
.../hdfs/shortcircuit/ShortCircuitCache.java | 40 ++++++----------------
1 file changed, 11 insertions(+), 29 deletions(-)
diff --git a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/shortcircuit/ShortCircuitCache.java b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/shortcircuit/ShortCircuitCache.java
index aa982d0..5acac2f 100644
--- a/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/shortcircuit/ShortCircuitCache.java
+++ b/hadoop-hdfs-project/hadoop-hdfs-client/src/main/java/org/apache/hadoop/hdfs/shortcircuit/ShortCircuitCache.java
@@ -109,13 +109,8 @@ public class ShortCircuitCache implements Closeable {
int numDemoted = demoteOldEvictableMmaped(curMs);
int numPurged = 0;
Long evictionTimeNs;
- while (true) {
- Object eldestKey;
- try {
- eldestKey = evictable.firstKey();
- } catch (NoSuchElementException e) {
- break;
- }
+ while (!evictable.isEmpty()) {
+ Object eldestKey = evictable.firstKey();
evictionTimeNs = (Long)eldestKey;
long evictionTimeMs =
TimeUnit.MILLISECONDS.convert(evictionTimeNs, TimeUnit.NANOSECONDS);
@@ -493,13 +488,8 @@ public class ShortCircuitCache implements Closeable {
boolean needMoreSpace = false;
Long evictionTimeNs;
- while (true) {
- Object eldestKey;
- try {
- eldestKey = evictableMmapped.firstKey();
- } catch (NoSuchElementException e) {
- break;
- }
+ while (!evictableMmapped.isEmpty()) {
+ Object eldestKey = evictableMmapped.firstKey();
evictionTimeNs = (Long)eldestKey;
long evictionTimeMs =
TimeUnit.MILLISECONDS.convert(evictionTimeNs, TimeUnit.NANOSECONDS);
@@ -533,23 +523,15 @@ public class ShortCircuitCache implements Closeable {
long now = Time.monotonicNow();
demoteOldEvictableMmaped(now);
- while (true) {
- long evictableSize = evictable.size();
- long evictableMmappedSize = evictableMmapped.size();
- if (evictableSize + evictableMmappedSize <= maxTotalSize) {
- return;
- }
+ while (evictable.size() + evictableMmapped.size() > maxTotalSize) {
ShortCircuitReplica replica;
- try {
- if (evictableSize == 0) {
- replica = (ShortCircuitReplica)evictableMmapped.get(evictableMmapped
- .firstKey());
- } else {
- replica = (ShortCircuitReplica)evictable.get(evictable.firstKey());
- }
- } catch (NoSuchElementException e) {
- break;
+ if (evictable.isEmpty()) {
+ replica = (ShortCircuitReplica) evictableMmapped
+ .get(evictableMmapped.firstKey());
+ } else {
+ replica = (ShortCircuitReplica) evictable.get(evictable.firstKey());
}
+
if (LOG.isTraceEnabled()) {
LOG.trace(this + ": trimEvictionMaps is purging " + replica +
StringUtils.getStackTrace(Thread.currentThread()));
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org