From 65f48a512ad63802a2031e2452f18653bf770c4c Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Mon, 18 Nov 2024 11:05:28 -0500 Subject: rmulticast.ReceivedSet.Entry: add isBefore/After methods --- src/main/java/derms/net/rmulticast/ReceivedSet.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/src/main/java/derms/net/rmulticast/ReceivedSet.java b/src/main/java/derms/net/rmulticast/ReceivedSet.java index 16b586b..5bd3d85 100644 --- a/src/main/java/derms/net/rmulticast/ReceivedSet.java +++ b/src/main/java/derms/net/rmulticast/ReceivedSet.java @@ -47,7 +47,7 @@ class ReceivedSet { Message peekOldest() { Entry oldest = null; for (Entry e : received.values()) - if (oldest == null || e.timestamp.isBefore(oldest.timestamp)) + if (oldest == null || e.isBefore(oldest)) oldest = e; if (oldest == null) return null; @@ -57,7 +57,7 @@ class ReceivedSet { Message mostRecentSentBy(InetAddress member) throws NoSuchElementException { Entry recent = null; for (Entry e : received.values()) - if (e.msg.isSentBy(member) && (recent == null || e.timestamp.isAfter(recent.timestamp))) + if (e.msg.isSentBy(member) && (recent == null || e.isAfter(recent))) recent = e; if (recent == null) throw new NoSuchElementException("no message from " + member + " in received list."); @@ -82,6 +82,14 @@ class ReceivedSet { this.timestamp = Instant.now(); } + private boolean isBefore(Entry other) { + return this.timestamp.isBefore(other.timestamp); + } + + private boolean isAfter(Entry other) { + return this.timestamp.isAfter(other.timestamp); + } + @Override public int hashCode() { return msg.hashCode(); -- cgit v1.2.3