diff options
Diffstat (limited to 'src/main/java/derms/net')
| -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/net/rmulticast/Wait.java | 15 |
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); - } -} |