Sensix Wireless Sensor Network Middleware    Home    Project Page    Download    CVS  Hosted by

/home/brennan/Software/sensix/source/C^4/sensix/SensixNetworking.java Go to the documentation of this file. /* * Copyright 2008. Los Alamos National Security, LLC. This material * was produced under U.S. Government contract DE-AC52-06NA25396 for * Los Alamos National Laboratory (LANL), which is operated by Los * Alamos National Security, LLC, for the Department of Energy. The * U.S. Government has rights to use, reproduce, and distribute this * software. NEITHER THE GOVERNMENT NOR LOS ALAMOS NATIONAL SECURITY, * LLC, MAKES ANY WARRANTY, EXPRESS OR IMPLIED, OR ASSUMES ANY LEGAL * LIABILITY FOR THE USE OF THIS SOFTWARE. If software is modified to * produce derivative works, such modified software should be clearly * marked, so as not to confuse it with the version available from LANL. * * Additionally, this program is free software; you can redistribute * it and/or modify it under the terms of the GNU General Public * License as published by the Free Software Foundation; version 2 of * the License. Accordingly, this program is distributed in the hope * it will be useful, but WITHOUT ANY WARRANTY; without even the * implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR * PURPOSE. See the GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. */ package sensix; import java.io.*; import java.net.*; import java.util.*; public class SensixNetworking { public static final int SENSIX_PORT = 2989; public static final String MCAST_ADDR_IPv6 = "FF18::178"; public static final String MCAST_ADDR_IPv4 = "224.0.0.178"; public static final String MCAST_ADDR = MCAST_ADDR_IPv4; // NB: the following are for wired networking, adjust as needed public static final int TX_TIMEOUT = 12; // max ms between hdr & body public static final int RETRY_ITVL = 4; // tx retry buffer time (ms) public static final int EMPTY_TIMEOUT = 1000; // ms block on recv private class Listener extends Thread { private SensixMarshalling marshal; private SensixNetworking net; private MulticastSocket socket; public Listener(SensixNetworking n, SensixMarshalling m, MulticastSocket s) { net = n; marshal = m; socket = s; } public void run() { boolean keep_going; synchronized(net) { keep_going = net.running; } while (keep_going) { byte[] raw_msg = new byte[SensixMarshalling.MAX_CMD_SIZE]; DatagramPacket packet = null; try { packet = new DatagramPacket(raw_msg, raw_msg.length); socket.setSoTimeout(EMPTY_TIMEOUT); socket.receive(packet); SocketAddress sender = packet.getSocketAddress(); } catch (SocketTimeoutException e) { socket.disconnect(); synchronized(net) { keep_going = net.running; } continue; } catch (IOException e) { net.log(Logger.LOG.ERROR, "Sensix network listener IO exception: " + e); e.printStackTrace(System.err); synchronized(net) { keep_going = net.running; } continue; } marshal.parse_packet(raw_msg, packet.getLength()); synchronized(net) { keep_going = net.running; } } socket.close(); net.log(Logger.LOG.DEBUG, "Shutting down Sensix network"); } } public boolean running; private SensixMarshalling marshal; private Logger logger; private MulticastSocket[] mcast_sockets; private Listener[] m_threads; public SensixNetworking(SensixMarshalling m, String app, byte debug) throws Exception { marshal = m; logger = new Logger(app, debug); NetworkInterface[] nifs = getAllInterfaces(); if (nifs.length < 1) throw new Exception("No external network interfaces found."); running = true; mcast_sockets = new MulticastSocket[nifs.length]; m_threads = new Listener[nifs.length]; log(Logger.LOG.INFO, "Networking interfaces:"); for (int i = 0; i < nifs.length; i++) { log(Logger.LOG.INFO, " " + nifs[i].getName()); try { mcast_sockets[i] = new MulticastSocket(SENSIX_PORT); mcast_sockets[i].setReuseAddress(true); mcast_sockets[i].setNetworkInterface(nifs[i]); mcast_sockets[i].joinGroup(InetAddress.getByName(MCAST_ADDR)); m_threads[i] = new Listener(this, marshal, mcast_sockets[i]); m_threads[i].start(); } catch (SocketException e) { throw new Exception("Socket error " + e.getMessage() + " on " + MCAST_ADDR); } catch (UnknownHostException e) { throw new Exception("Unknown host " + MCAST_ADDR + " " + e.getMessage()); } catch (IOException e) { throw new Exception("IO error " + e.getMessage()); } } } public int identifier() { return marshal.identifier(); } public byte level() { return marshal.level(); } public void log(Logger.LOG type, String msg) { logger.log(type, msg); } public void shutdown() { synchronized(this) { running = false; } try { for (int i = 0; i < m_threads.length; i++) m_threads[i].join(); } catch (InterruptedException e) {} } private NetworkInterface[] getAllInterfaces() { try { int size = 0, idx = 0; NetworkInterface[] nifs; Enumeration<NetworkInterface> ife; ife = NetworkInterface.getNetworkInterfaces(); for (NetworkInterface nif : Collections.list(ife)) { if (nif.getName().toLowerCase().startsWith("lo") == false) size++; } if (size < 1) return null; nifs = new NetworkInterface[size]; ife = NetworkInterface.getNetworkInterfaces(); for (NetworkInterface nif : Collections.list(ife)) { if (nif.getName().toLowerCase().startsWith("lo") == false) { nifs[idx] = nif; idx++; } } return nifs; } catch (SocketException e) { log(Logger.LOG.ERROR, "Socket exception on getNetworkInterfaces: " + e); return null; } } private void send(byte[] msg) { while (true) { DatagramPacket mpacket = null; try { mpacket = new DatagramPacket(msg, msg.length, InetAddress.getByName(MCAST_ADDR), SENSIX_PORT); for (int i = 0; i < mcast_sockets.length; i++) mcast_sockets[i].send(mpacket); break; } catch (IllegalArgumentException iae) { try { Thread.sleep(TX_TIMEOUT + RETRY_ITVL); } catch (InterruptedException ie) {} } catch (IOException e) { log(Logger.LOG.ERROR, "Sensix network IO exception: " + e); e.printStackTrace(System.err); break; } } } }

© 2008, Los Alamos National Security, LLC.