Skip to content

Commit

Permalink
misc-6 (#205)
Browse files Browse the repository at this point in the history
* handle potential npe

* handle potential npe
  • Loading branch information
Hellblazer authored Jun 2, 2024
1 parent aa700a0 commit 24e8036
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions thoth/src/main/java/com/salesforce/apollo/thoth/KerlDHT.java
Original file line number Diff line number Diff line change
Expand Up @@ -848,7 +848,7 @@ private <T> boolean mutate(HashMultiset<T> gathered, Optional<T> futureSailor, D
RingCommunications.Destination<Member, DhtService> destination, String action) {
if (futureSailor.isEmpty()) {
log.debug("Failed {}: {} tally: {} from: {} on: {}", action, identifier, tally.get(),
destination.member().getId(), member.getId());
destination.member() == null ? "<null>" : destination.member().getId(), member.getId());
return !isTimedOut.get();
}
T content = futureSailor.get();
Expand All @@ -867,7 +867,7 @@ private <T> boolean read(CompletableFuture<T> result, HashMultiset<T> gathered,
RingCommunications.Destination<Member, DhtService> destination, String action, T empty) {
if (futureSailor.isEmpty()) {
log.debug("Failed {}: {} tally: {} from: {} on: {}", action, identifier, tally,
destination.member().getId(), member.getId());
destination.member() == null ? "<null>" : destination.member().getId(), member.getId());
return !isTimedOut.get();
}
T content = futureSailor.get();
Expand Down

0 comments on commit 24e8036

Please sign in to comment.