openfast-commit Mailing List for OpenFAST (Page 5)

SourceForge Headquarters 225 Broadway Suite 1600 San Diego, CA 92101 +1 (858) 422-6466

Revision: 206
          http://openfast.svn.sourceforge.net/openfast/?rev=206&view=rev
Author:   alohr
Date:     2009-08-28 20:35:17 +0000 (Fri, 28 Aug 2009)

Log Message:
-----------
Allow to specify the multicast network interface used by the MulticastEndpoint

Modified Paths:
--------------
    trunk/src/main/java/org/openfast/examples/OpenFastExample.java
    trunk/src/main/java/org/openfast/examples/consumer/Main.java
    trunk/src/main/java/org/openfast/session/multicast/MulticastEndpoint.java

Modified: trunk/src/main/java/org/openfast/examples/OpenFastExample.java
===================================================================

--- trunk/src/main/java/org/openfast/examples/OpenFastExample.java	2008-12-16 20:25:55 UTC (rev 205)
+++ trunk/src/main/java/org/openfast/examples/OpenFastExample.java	2009-08-28 20:35:17 UTC (rev 206)
@@ -13,6 +13,7 @@
     protected static final String PORT = "port";
     protected static final String PROTOCOL = "protocol";
     protected static final String HOST = "host";
+    protected static final String INTERFACE = "interface";
     protected static final String ERROR = "error";
     protected static final String NAMESPACE_AWARENESS = "ns";
     protected static final String OUTPUT_FILE = "output";

Modified: trunk/src/main/java/org/openfast/examples/consumer/Main.java
===================================================================
--- trunk/src/main/java/org/openfast/examples/consumer/Main.java	2008-12-16 20:25:55 UTC (rev 205)
+++ trunk/src/main/java/org/openfast/examples/consumer/Main.java	2009-08-28 20:35:17 UTC (rev 206)
@@ -19,6 +19,7 @@
         options.addOption("r", PROTOCOL, true, "Protocol [tcp|udp] defaults to tcp");
         options.addOption("p", PORT, true, "Port to connect to");
         options.addOption("h", HOST, true, "The host name of the server (or group name for multicast)");
+        options.addOption("i", INTERFACE, true, "The ip address of the network interface to use");
         options.addOption("e", ERROR, false, "Show stacktrace information");
         options.addOption("t", MESSAGE_TEMPLATE_FILE, true, "Message template definition file");
     }
@@ -38,10 +39,11 @@
             Assert.assertTrue(cl.hasOption(PORT), "The required parameter \"" + PORT + "\" is missing.");
             int port = getInteger(cl, PORT);
             String host = cl.hasOption(HOST) ? cl.getOptionValue(HOST) : "localhost";
+            String ifaddr = cl.hasOption(INTERFACE) ? cl.getOptionValue(INTERFACE) : null;
             
             if (cl.hasOption(PROTOCOL)) {
                 if ("udp".equals(cl.getOptionValue(PROTOCOL))) {
-                    endpoint = new MulticastEndpoint(port, host);
+                    endpoint = new MulticastEndpoint(port, host, ifaddr);
                 }
             }
             if (endpoint == null) {

Modified: trunk/src/main/java/org/openfast/session/multicast/MulticastEndpoint.java
===================================================================
--- trunk/src/main/java/org/openfast/session/multicast/MulticastEndpoint.java	2008-12-16 20:25:55 UTC (rev 205)
+++ trunk/src/main/java/org/openfast/session/multicast/MulticastEndpoint.java	2009-08-28 20:35:17 UTC (rev 206)
@@ -23,6 +23,7 @@
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.MulticastSocket;
+import java.net.SocketException;
 
 import org.openfast.session.Connection;
 import org.openfast.session.ConnectionListener;
@@ -32,10 +33,16 @@
 public class MulticastEndpoint implements Endpoint {
     private int port;
     private String group;
+    private String ifaddr;
     public MulticastEndpoint(int port, String group) {
         this.port = port;
         this.group = group;
+        this.ifaddr = null;
     }
+    public MulticastEndpoint(int port, String group, String ifaddr) {
+    	this(port, group);
+    	this.ifaddr = ifaddr;
+    }
     public void accept() throws FastConnectionException {
         throw new UnsupportedOperationException();
     }
@@ -43,6 +50,13 @@
     public Connection connect() throws FastConnectionException {
         try {
             MulticastSocket socket = new MulticastSocket(port);
+            if (ifaddr != null) {
+                try {
+                    socket.setInterface(InetAddress.getByName(ifaddr));	
+                } catch (SocketException e) {
+                    throw new FastConnectionException(e);
+                }
+            }
             InetAddress groupAddress = InetAddress.getByName(group);
             socket.joinGroup(groupAddress);
             return new MulticastConnection(socket, groupAddress);


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.




2007	Jan	Feb	Mar	Apr	May	Jun	Jul	Aug	Sep	Oct (4)	Nov (7)	Dec (18)
2008	Jan (20)	Feb (7)	Mar	Apr (8)	May (9)	Jun (7)	Jul (23)	Aug (3)	Sep	Oct (16)	Nov	Dec (3)
2009	Jan	Feb	Mar	Apr	May	Jun	Jul	Aug (1)	Sep	Oct	Nov	Dec
2010	Jan	Feb	Mar (1)	Apr	May (6)	Jun (8)	Jul	Aug	Sep	Oct (5)	Nov (2)	Dec
2011	Jan	Feb	Mar	Apr	May	Jun (1)	Jul	Aug	Sep (1)	Oct (30)	Nov	Dec
2012	Jan (4)	Feb (2)	Mar (1)	Apr (23)	May (4)	Jun	Jul (1)	Aug (2)	Sep	Oct	Nov	Dec
2013	Jan	Feb	Mar (7)	Apr	May (1)	Jun	Jul	Aug (1)	Sep	Oct	Nov	Dec

openfast-commit Mailing List for OpenFAST (Page 5)

openfast-commit — Publishes subversion log and diffs on each commit