Skip to content

Commit

Permalink
Fix bugs detected by error prone
Browse files Browse the repository at this point in the history
  • Loading branch information
adejanovski authored and michaelsembwever committed Sep 30, 2017
1 parent 354fe59 commit 3f4f09e
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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<String> getTableNamesBasedOnParam(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand All @@ -193,7 +193,7 @@ public GossipInfo(
}
}

public final class EndpointState {
public static final class EndpointState {

@JsonProperty
public final String endpoint;
Expand Down

0 comments on commit 3f4f09e

Please sign in to comment.