[infinispan-commits] Infinispan SVN: r641 - trunk/core/src/test/java/org/infinispan/test/fwk.

[infinispan-commits at lists.jboss.org]

Author: mircea.markus
Date: 2009-08-07 13:43:40 -0400 (Fri, 07 Aug 2009)
New Revision: 641

Modified:
   trunk/core/src/test/java/org/infinispan/test/fwk/TcpMPingEnvironmentTest.java
Log:
added new test to narrow down the problem

Modified: trunk/core/src/test/java/org/infinispan/test/fwk/TcpMPingEnvironmentTest.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/test/fwk/TcpMPingEnvironmentTest.java	2009-08-06 20:46:15 UTC (rev 640)
+++ trunk/core/src/test/java/org/infinispan/test/fwk/TcpMPingEnvironmentTest.java	2009-08-07 17:43:40 UTC (rev 641)
@@ -1,21 +1,25 @@
 package org.infinispan.test.fwk;
 
+import org.infinispan.util.logging.Log;
+import org.infinispan.util.logging.LogFactory;
 import org.jgroups.JChannel;
 import org.jgroups.View;
+import static org.testng.Assert.fail;
+import org.testng.annotations.AfterMethod;
 import org.testng.annotations.Test;
-import org.testng.annotations.AfterMethod;
-import static org.testng.Assert.fail;
-import org.infinispan.util.logging.Log;
-import org.infinispan.util.logging.LogFactory;
 
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.net.MulticastSocket;
+import java.net.SocketAddress;
+import java.util.ArrayList;
 import java.util.List;
-import java.util.ArrayList;
 import java.util.Properties;
 
 /**
  * The purpose of this class is to test that/if tcp + mping works fine in the given environment.
  *
- *  @author Mircea.Markus at jboss.com
+ * @author Mircea.Markus at jboss.com
  */
 @Test(testName = "test,fwk.TcpMPingEnvironmentTest", groups = "functional")
 public class TcpMPingEnvironmentTest {
@@ -66,6 +70,27 @@
       success = true;
    }
 
+
+   public void testMcastSocketCreation() throws Exception {
+      InetAddress mcast_addr = InetAddress.getByName("228.10.10.5");
+      SocketAddress saddr = new InetSocketAddress(mcast_addr, 43589);
+      MulticastSocket retval = null;
+      try {
+         success = false;
+         retval = new MulticastSocket(saddr);
+         success = true;
+      } finally {
+         if (retval != null) {
+            try {
+               retval.close();
+            } catch (Exception e) {
+               e.printStackTrace();
+            }
+         }
+      }
+   }
+
+
    private void expectView(JChannel... channels) throws Exception {
       for (int i = 0; i < 20; i++) {
          boolean success = true;