summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/net
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/derms/net')
-rw-r--r--src/main/java/derms/net/rmulticast/Announce.java1
-rw-r--r--src/main/java/derms/net/rmulticast/Prune.java2
-rw-r--r--src/main/java/derms/net/rmulticast/Timeout.java2
-rw-r--r--src/main/java/derms/net/rmulticast/Wait.java15
4 files changed, 5 insertions, 15 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/net/rmulticast/Wait.java
deleted file mode 100644
index f1180ed..0000000
--- a/src/main/java/derms/net/rmulticast/Wait.java
+++ /dev/null
@@ -1,15 +0,0 @@
-package derms.net.rmulticast;
-
-import java.time.Duration;
-import java.time.Instant;
-
-class Wait {
- static void forDuration(Duration dur) throws InterruptedException {
- Instant start = Instant.now();
- Duration elapsed;
- do {
- Thread.yield();
- elapsed = Duration.between(start, Instant.now());
- } while (elapsed.compareTo(dur) < 0);
- }
-}