diff options
Diffstat (limited to 'src/main/java/derms')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/Announce.java | 1 | ||||
| -rw-r--r-- | src/main/java/derms/net/rmulticast/Prune.java | 2 | ||||
| -rw-r--r-- | src/main/java/derms/net/rmulticast/Timeout.java | 2 | ||||
| -rw-r--r-- | src/main/java/derms/util/Wait.java (renamed from src/main/java/derms/net/rmulticast/Wait.java) | 7 |
4 files changed, 9 insertions, 3 deletions
diff --git a/src/main/java/derms/net/rmulticast/Announce.java b/src/main/java/derms/net/rmulticast/Announce.java index 08d817d..41d72ed 100644 --- a/src/main/java/derms/net/rmulticast/Announce.java +++ b/src/main/java/derms/net/rmulticast/Announce.java @@ -2,6 +2,7 @@ package derms.net.rmulticast; import derms.net.ConcurrentMulticastSocket; import derms.net.Packet; +import derms.util.Wait; import java.io.IOException; import java.net.DatagramPacket; diff --git a/src/main/java/derms/net/rmulticast/Prune.java b/src/main/java/derms/net/rmulticast/Prune.java index c156bcc..05f7448 100644 --- a/src/main/java/derms/net/rmulticast/Prune.java +++ b/src/main/java/derms/net/rmulticast/Prune.java @@ -1,5 +1,7 @@ package derms.net.rmulticast; +import derms.util.Wait; + import java.net.InetAddress; import java.time.Duration; import java.util.ArrayList; diff --git a/src/main/java/derms/net/rmulticast/Timeout.java b/src/main/java/derms/net/rmulticast/Timeout.java index 79eb606..d55abe0 100644 --- a/src/main/java/derms/net/rmulticast/Timeout.java +++ b/src/main/java/derms/net/rmulticast/Timeout.java @@ -1,5 +1,7 @@ package derms.net.rmulticast; +import derms.util.Wait; + import java.time.Duration; import java.util.Set; import java.util.concurrent.BlockingQueue; diff --git a/src/main/java/derms/net/rmulticast/Wait.java b/src/main/java/derms/util/Wait.java index f1180ed..1e77020 100644 --- a/src/main/java/derms/net/rmulticast/Wait.java +++ b/src/main/java/derms/util/Wait.java @@ -1,10 +1,11 @@ -package derms.net.rmulticast; +package derms.util; import java.time.Duration; import java.time.Instant; -class Wait { - static void forDuration(Duration dur) throws InterruptedException { +public class Wait { + /** Yield the thread for the specified duration. */ + public static void forDuration(Duration dur) throws InterruptedException { Instant start = Instant.now(); Duration elapsed; do { |