# HG changeset patch
# User chegar
# Date 1268232293 0
# Node ID a1682a41e70f7c0ed74c0e068ecae2d5ff415763
# Parent 38f33163accec738f3ffb66e94a524574c217eeb
6933618: java/net/MulticastSocket/NoLoopbackPackets.java fails when rerun
Reviewed-by: alanb
diff -r 38f33163acce -r a1682a41e70f jdk/test/java/net/MulticastSocket/NoLoopbackPackets.java
--- a/jdk/test/java/net/MulticastSocket/NoLoopbackPackets.java Sat Mar 06 14:59:23 2010 -0800
+++ b/jdk/test/java/net/MulticastSocket/NoLoopbackPackets.java Wed Mar 10 14:44:53 2010 +0000
@@ -29,9 +29,7 @@
import java.util.*;
import java.net.*;
-
public class NoLoopbackPackets {
- private static int PORT = 9001;
private static String osname;
static boolean isWindows() {
@@ -68,40 +66,47 @@
return;
}
- // we will send packets to three multicast groups :-
- // 224.1.1.1, ::ffff:224.1.1.2, and ff02::1:1
- //
- List<SocketAddress> groups = new ArrayList<SocketAddress>();
- groups.add(new InetSocketAddress(InetAddress.getByName("224.1.1.1"), PORT));
- groups.add(new InetSocketAddress(InetAddress.getByName("::ffff:224.1.1.2"), PORT));
- groups.add(new InetSocketAddress(InetAddress.getByName("ff02::1:1"), PORT));
+ MulticastSocket msock = null;
+ List<SocketAddress> failedGroups = new ArrayList<SocketAddress>();
+ try {
+ msock = new MulticastSocket();
+ int port = msock.getLocalPort();
- Thread sender = new Thread(new Sender(groups));
- sender.setDaemon(true); // we want sender to stop when main thread exits
- sender.start();
+ // we will send packets to three multicast groups :-
+ // 224.1.1.1, ::ffff:224.1.1.2, and ff02::1:1
+ //
+ List<SocketAddress> groups = new ArrayList<SocketAddress>();
+ groups.add(new InetSocketAddress(InetAddress.getByName("224.1.1.1"), port));
+ groups.add(new InetSocketAddress(InetAddress.getByName("::ffff:224.1.1.2"), port));
+ groups.add(new InetSocketAddress(InetAddress.getByName("ff02::1:1"), port));
+
+ Thread sender = new Thread(new Sender(groups));
+ sender.setDaemon(true); // we want sender to stop when main thread exits
+ sender.start();
- // Now try to receive multicast packets. we should not see any of them
- // since we disable loopback mode.
- //
- MulticastSocket msock = new MulticastSocket(PORT);
- msock.setSoTimeout(5000); // 5 seconds
+ // Now try to receive multicast packets. we should not see any of them
+ // since we disable loopback mode.
+ //
+ msock.setSoTimeout(5000); // 5 seconds
+
+ byte[] buf = new byte[1024];
+ DatagramPacket packet = new DatagramPacket(buf, 0, buf.length);
+ for (SocketAddress group : groups) {
+ msock.joinGroup(group, null);
- byte[] buf = new byte[1024];
- DatagramPacket packet = new DatagramPacket(buf, 0, buf.length);
- List<SocketAddress> failedGroups = new ArrayList<SocketAddress>();
- for (SocketAddress group : groups) {
- msock.joinGroup(group, null);
+ try {
+ msock.receive(packet);
- try {
- msock.receive(packet);
+ // it is an error if we receive something
+ failedGroups.add(group);
+ } catch (SocketTimeoutException e) {
+ // we expect this
+ }
- // it is an error if we receive something
- failedGroups.add(group);
- } catch (SocketTimeoutException e) {
- // we expect this
+ msock.leaveGroup(group, null);
}
-
- msock.leaveGroup(group, null);
+ } finally {
+ if (msock != null) try { msock.close(); } catch (Exception e) {}
}
if (failedGroups.size() > 0) {
@@ -111,36 +116,36 @@
throw new RuntimeException("test failed.");
}
}
-}
+
+ static class Sender implements Runnable {
+ private List<SocketAddress> sendToGroups;
-class Sender implements Runnable {
- private List<SocketAddress> sendToGroups;
-
- public Sender(List<SocketAddress> groups) {
- sendToGroups = groups;
- }
+ public Sender(List<SocketAddress> groups) {
+ sendToGroups = groups;
+ }
- public void run() {
- byte[] buf = "hello world".getBytes();
- List<DatagramPacket> packets = new ArrayList<DatagramPacket>();
+ public void run() {
+ byte[] buf = "hello world".getBytes();
+ List<DatagramPacket> packets = new ArrayList<DatagramPacket>();
- try {
- for (SocketAddress group : sendToGroups) {
- DatagramPacket packet = new DatagramPacket(buf, buf.length, group);
- packets.add(packet);
- }
-
- MulticastSocket msock = new MulticastSocket();
- msock.setLoopbackMode(true); // disable loopback mode
- for (;;) {
- for (DatagramPacket packet : packets) {
- msock.send(packet);
+ try {
+ for (SocketAddress group : sendToGroups) {
+ DatagramPacket packet = new DatagramPacket(buf, buf.length, group);
+ packets.add(packet);
}
- Thread.currentThread().sleep(1000); // 1 second
+ MulticastSocket msock = new MulticastSocket();
+ msock.setLoopbackMode(true); // disable loopback mode
+ for (;;) {
+ for (DatagramPacket packet : packets) {
+ msock.send(packet);
+ }
+
+ Thread.sleep(1000); // 1 second
+ }
+ } catch (Exception e) {
+ throw new RuntimeException(e);
}
- } catch (Exception e) {
- throw new RuntimeException(e);
}
}
}