diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-11-16 13:14:11 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-11-16 13:14:11 -0500 |
| commit | 27956d3af0d4549b4250dbd036f3f86a430108fd (patch) | |
| tree | 65cd01cba843182bdb32ea591c68ba0f9c8a7e31 /src/main/java/derms/net/rmulticast/Prune.java | |
| parent | 034bace1a53943838e49a7d2442025276f60bc55 (diff) | |
| download | soen423-27956d3af0d4549b4250dbd036f3f86a430108fd.zip | |
reliable multicast: add log messages
Diffstat (limited to 'src/main/java/derms/net/rmulticast/Prune.java')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/Prune.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/main/java/derms/net/rmulticast/Prune.java b/src/main/java/derms/net/rmulticast/Prune.java index 05f7448..8dfadf6 100644 --- a/src/main/java/derms/net/rmulticast/Prune.java +++ b/src/main/java/derms/net/rmulticast/Prune.java @@ -46,8 +46,10 @@ class Prune<T extends MessagePayload> implements Runnable { for (InetAddress member : groupMembers) { try { Message<T> c = received.mostRecentSentBy(member); - if (!receivedByMemberAtTimeOfSending(a, member, c)) + if (!receivedByMemberAtTimeOfSending(a, member, c)) { + log.info(member.toString() + " has not received " + a + "; cannot prune it."); return; // Member has not received a -- cannot prune it. + } } catch (NoSuchElementException e) { log.warning("No message received from " + member); return; @@ -56,6 +58,7 @@ class Prune<T extends MessagePayload> implements Runnable { // All group members have received and acknowledged message a. It is safe to delete. received.remove(a); + log.info("Removed " + a + " from received list."); } /** |