You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by mb...@apache.org on 2016/07/22 23:36:28 UTC
[4/6] hbase git commit: HBASE-16272 Overflow in ServerName's
compareTo method (Huaxiang Sun)
HBASE-16272 Overflow in ServerName's compareTo method (Huaxiang Sun)
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0ed7d5f8
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0ed7d5f8
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0ed7d5f8
Branch: refs/heads/branch-1.2
Commit: 0ed7d5f80353d3c736838ead73ed8c43fcd6cac4
Parents: 9522191
Author: Matteo Bertozzi <ma...@cloudera.com>
Authored: Fri Jul 22 15:28:04 2016 -0700
Committer: Matteo Bertozzi <ma...@cloudera.com>
Committed: Fri Jul 22 15:39:36 2016 -0700
----------------------------------------------------------------------
.../main/java/org/apache/hadoop/hbase/ServerName.java | 3 ++-
.../apache/hadoop/hbase/io/hfile/LruBlockCache.java | 7 +++----
.../hadoop/hbase/io/hfile/bucket/BucketCache.java | 13 +++++--------
.../apache/hadoop/hbase/ipc/SimpleRpcScheduler.java | 2 +-
.../java/org/apache/hadoop/hbase/util/HBaseFsck.java | 2 +-
5 files changed, 12 insertions(+), 15 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/0ed7d5f8/hbase-client/src/main/java/org/apache/hadoop/hbase/ServerName.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ServerName.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ServerName.java
index 5ccdd35..eef8bee 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ServerName.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ServerName.java
@@ -289,7 +289,8 @@ public class ServerName implements Comparable<ServerName>, Serializable {
if (compare != 0) return compare;
compare = this.getPort() - other.getPort();
if (compare != 0) return compare;
- return (int)(this.getStartcode() - other.getStartcode());
+
+ return Long.compare(this.getStartcode(), other.getStartcode());
}
@Override
http://git-wip-us.apache.org/repos/asf/hbase/blob/0ed7d5f8/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/LruBlockCache.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/LruBlockCache.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/LruBlockCache.java
index e778fd4..c568146 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/LruBlockCache.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/LruBlockCache.java
@@ -738,8 +738,7 @@ public class LruBlockCache implements ResizableBlockCache, HeapSize {
}
public int compareTo(BlockBucket that) {
- if(this.overflow() == that.overflow()) return 0;
- return this.overflow() > that.overflow() ? 1 : -1;
+ return Long.compare(this.overflow(), that.overflow());
}
@Override
@@ -976,13 +975,13 @@ public class LruBlockCache implements ResizableBlockCache, HeapSize {
public int compareTo(CachedBlock other) {
int diff = this.getFilename().compareTo(other.getFilename());
if (diff != 0) return diff;
- diff = (int)(this.getOffset() - other.getOffset());
+ diff = Long.compare(this.getOffset(), other.getOffset());
if (diff != 0) return diff;
if (other.getCachedTime() < 0 || this.getCachedTime() < 0) {
throw new IllegalStateException("" + this.getCachedTime() + ", " +
other.getCachedTime());
}
- return (int)(other.getCachedTime() - this.getCachedTime());
+ return Long.compare(other.getCachedTime(), this.getCachedTime());
}
@Override
http://git-wip-us.apache.org/repos/asf/hbase/blob/0ed7d5f8/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
index f9d8167..75d7ae3 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/BucketCache.java
@@ -1070,9 +1070,7 @@ public class BucketCache implements BlockCache, HeapSize {
@Override
public int compare(BucketEntry o1, BucketEntry o2) {
- long accessCounter1 = o1.accessCounter;
- long accessCounter2 = o2.accessCounter;
- return accessCounter1 < accessCounter2 ? 1 : accessCounter1 == accessCounter2 ? 0 : -1;
+ return Long.compare(o2.accessCounter, o1.accessCounter);
}
};
@@ -1193,9 +1191,7 @@ public class BucketCache implements BlockCache, HeapSize {
@Override
public int compareTo(BucketEntryGroup that) {
- if (this.overflow() == that.overflow())
- return 0;
- return this.overflow() > that.overflow() ? 1 : -1;
+ return Long.compare(this.overflow(), that.overflow());
}
@Override
@@ -1342,13 +1338,14 @@ public class BucketCache implements BlockCache, HeapSize {
public int compareTo(CachedBlock other) {
int diff = this.getFilename().compareTo(other.getFilename());
if (diff != 0) return diff;
- diff = (int)(this.getOffset() - other.getOffset());
+
+ diff = Long.compare(this.getOffset(), other.getOffset());
if (diff != 0) return diff;
if (other.getCachedTime() < 0 || this.getCachedTime() < 0) {
throw new IllegalStateException("" + this.getCachedTime() + ", " +
other.getCachedTime());
}
- return (int)(other.getCachedTime() - this.getCachedTime());
+ return Long.compare(other.getCachedTime(), this.getCachedTime());
}
@Override
http://git-wip-us.apache.org/repos/asf/hbase/blob/0ed7d5f8/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
index 8de714d..aca20e5 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java
@@ -81,7 +81,7 @@ public class SimpleRpcScheduler extends RpcScheduler {
long deadlineB = priority.getDeadline(callB.getHeader(), callB.param);
deadlineA = callA.timestamp + Math.min(deadlineA, maxDelay);
deadlineB = callB.timestamp + Math.min(deadlineB, maxDelay);
- return (int)(deadlineA - deadlineB);
+ return Long.compare(deadlineA, deadlineB);
}
}
http://git-wip-us.apache.org/repos/asf/hbase/blob/0ed7d5f8/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
index af38a49..6797e1a 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java
@@ -3383,7 +3383,7 @@ public class HBaseFsck extends Configured implements Closeable {
final Comparator<Cell> comp = new Comparator<Cell>() {
@Override
public int compare(Cell k1, Cell k2) {
- return (int)(k1.getTimestamp() - k2.getTimestamp());
+ return Long.compare(k1.getTimestamp(), k2.getTimestamp());
}
};