Mercurial > hg > Database > Alice
view src/main/java/alice/datasegment/MulticastDataSegmentManager.java @ 419:aefbe41fcf12 dispose
change tab to space
author | sugi |
---|---|
date | Tue, 15 Jul 2014 16:00:22 +0900 |
parents | 0c24894db37e |
children | 6e304a7a60e7 |
line wrap: on
line source
package alice.datasegment; import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.NetworkInterface; import java.net.SocketAddress; import java.net.StandardProtocolFamily; import java.net.StandardSocketOptions; import java.nio.channels.DatagramChannel; import org.apache.log4j.Logger; import alice.daemon.IncomingUdpConnection; import alice.daemon.MulticastConnection; import alice.daemon.OutboundTcpConnection; public class MulticastDataSegmentManager extends RemoteDataSegmentManager { public MulticastDataSegmentManager(String connectionKey ,final String MCASTADDR, final int port, final String nis) { logger = Logger.getLogger(connectionKey); InetAddress mAddr; try { mAddr = InetAddress.getByName(MCASTADDR); DatagramChannel dcr = createDatagramChannel(mAddr, port, nis); dcr.bind(new InetSocketAddress(port)); SocketAddress sAddrr = new InetSocketAddress(mAddr,port); MulticastConnection receiver = new MulticastConnection(dcr, sAddrr); DatagramChannel dcs = createDatagramChannel(mAddr, port, nis); SocketAddress sAddrs = new InetSocketAddress(mAddr,port); connection = new MulticastConnection(dcs, sAddrs); // sender new IncomingUdpConnection((MulticastConnection) connection, receiver, this).start(); new OutboundTcpConnection(connection).start(); // OutboundUdpConnection sender } catch (Exception e) { e.printStackTrace(); } } private DatagramChannel createDatagramChannel(InetAddress group, int port, String nis) { DatagramChannel dc = null; NetworkInterface ni; try { ni = NetworkInterface.getByName(nis); if (ni==null) { System.err.println("Can't open network interface "+nis); throw new IOException(); } if (!ni.supportsMulticast()) { System.err.println("Network interface does not support multicast"+nis); throw new IOException(); } dc = DatagramChannel.open(StandardProtocolFamily.INET); dc.setOption(StandardSocketOptions.SO_REUSEADDR, true); dc.setOption(StandardSocketOptions.IP_MULTICAST_IF, ni); dc.join(group, ni); } catch (Exception e) { e.printStackTrace(); } return dc; } }