From 3f4f09e57f5d1d7df4c83168c1ddecdf18cb5dfb Mon Sep 17 00:00:00 2001 From: Alexander Dejanovski Date: Fri, 29 Sep 2017 18:01:51 +0200 Subject: [PATCH] Fix bugs detected by error prone --- .../java/io/cassandrareaper/core/RepairRun.java | 2 +- .../io/cassandrareaper/resources/CommonTools.java | 13 +++++++++---- .../cassandrareaper/resources/view/NodesStatus.java | 4 ++-- 3 files changed, 12 insertions(+), 7 deletions(-) diff --git a/src/server/src/main/java/io/cassandrareaper/core/RepairRun.java b/src/server/src/main/java/io/cassandrareaper/core/RepairRun.java index e6bd6b288..be8be54ad 100644 --- a/src/server/src/main/java/io/cassandrareaper/core/RepairRun.java +++ b/src/server/src/main/java/io/cassandrareaper/core/RepairRun.java @@ -145,7 +145,7 @@ public boolean equals(Object other) { return false; } RepairRun run = (RepairRun) other; - return this.id == run.id && this.repairUnitId == run.repairUnitId; + return this.id.equals(run.id) && this.repairUnitId.equals(run.repairUnitId); } @Override diff --git a/src/server/src/main/java/io/cassandrareaper/resources/CommonTools.java b/src/server/src/main/java/io/cassandrareaper/resources/CommonTools.java index 0e088728f..f5c3c20d2 100644 --- a/src/server/src/main/java/io/cassandrareaper/resources/CommonTools.java +++ b/src/server/src/main/java/io/cassandrareaper/resources/CommonTools.java @@ -362,10 +362,15 @@ public static RepairSchedule storeNewRepairSchedule( } private static boolean isConflictingSchedules(RepairUnit newRepairUnit, RepairUnit existingRepairUnit) { - return (newRepairUnit.getColumnFamilies().isEmpty() && existingRepairUnit.getColumnFamilies().isEmpty()) - || newRepairUnit.getColumnFamilies().isEmpty() && !existingRepairUnit.getColumnFamilies().isEmpty() - || !newRepairUnit.getColumnFamilies().isEmpty() && existingRepairUnit.getColumnFamilies().isEmpty() - || !Sets.intersection(existingRepairUnit.getColumnFamilies(), newRepairUnit.getColumnFamilies()).isEmpty(); + return (newRepairUnit.getColumnFamilies().isEmpty() + && existingRepairUnit.getColumnFamilies().isEmpty()) + || (newRepairUnit.getColumnFamilies().isEmpty() + && !existingRepairUnit.getColumnFamilies().isEmpty()) + || (!newRepairUnit.getColumnFamilies().isEmpty() + && existingRepairUnit.getColumnFamilies().isEmpty()) + || (!Sets.intersection( + existingRepairUnit.getColumnFamilies(), newRepairUnit.getColumnFamilies()) + .isEmpty()); } public static Set getTableNamesBasedOnParam( diff --git a/src/server/src/main/java/io/cassandrareaper/resources/view/NodesStatus.java b/src/server/src/main/java/io/cassandrareaper/resources/view/NodesStatus.java index 4d914ac6e..e3bd1f137 100644 --- a/src/server/src/main/java/io/cassandrareaper/resources/view/NodesStatus.java +++ b/src/server/src/main/java/io/cassandrareaper/resources/view/NodesStatus.java @@ -166,7 +166,7 @@ private static void initPatterns() { ENDPOINT_TOKENS_PATTERNS.add(ENDPOINT_TOKENS_22_PATTERN); } - public final class GossipInfo { + public static final class GossipInfo { @JsonProperty public final String sourceNode; @@ -193,7 +193,7 @@ public GossipInfo( } } - public final class EndpointState { + public static final class EndpointState { @JsonProperty public final String endpoint;