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

/home/brennan/Software/sensix/source/C^4/corba/gov/lanl/isr/sensix/test/CorbaTwoLevelTest.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 gov.lanl.isr.sensix.test; import junit.framework.*; import java.io.*; import gov.lanl.isr.sensix.*; import gov.lanl.isr.sensix.discovery.*; import gov.lanl.isr.sensix.sensing.*; public class CorbaTwoLevelTest extends TestCase { private class Runner extends Thread { private CorbaTwoLevelTest parent; private int which; private int num_levels; private byte debug_level; private boolean ready; public Runner(CorbaTwoLevelTest test, int what, int lvls, byte dl) { parent = test; which = what; num_levels = lvls; debug_level = dl; ready = false; } public void run() { String[] args = null; java.util.Properties prop = null; try { switch (which) { case 0: parent.sclient = new SenseClient(30, num_levels, args, prop, "ClientTest_2." + num_levels, debug_level); ready = true; break; case 1: parent.sserver = new SenseServer(20, num_levels - 1, args, prop, "ServerTest_2." + (num_levels - 1), debug_level, null); ready = true; parent.sserver.run(); // blocks break; } } catch (DiscoveryException de) { System.err.println("Discovery exception: " + de.description); de.printStackTrace(System.err); fail("Exception starting SENSIX Discovery service"); } catch (Exception e) { System.err.println("Miscellaneous exception"); e.printStackTrace(System.err); if (which == 0) fail("Exception starting SENSIX client: " + e.toString()); else fail("Exception starting SENSIX server: " + e.toString()); } } public void check_ready() { while (!ready) { try { Thread.sleep(10); } catch (Exception e) {} } } } public SenseClient sclient; public SenseServer sserver; protected Runner runc, runs; public static final boolean VERBOSE = true; public static final int INITIALIZATION = 500; public static final boolean MESSAGE_DUMP = false; protected void setUp() { byte dl = 0; if (VERBOSE) dl = 2; System.err.println("START TEST"); runc = new Runner(this, 0, 2, dl); runc.start(); runs = new Runner(this, 1, 2, dl); runs.start(); runc.check_ready(); runs.check_ready(); } protected void tearDown() { sclient.shutdown(); sserver.shutdown(); try { runc.join(); runs.join(); } catch (InterruptedException e) {} System.err.println("STOP TEST"); String id = java.lang.management.ManagementFactory.getRuntimeMXBean().getName(); try { FileWriter os = new FileWriter("jcorba." + id + ".msgct", true); os.write("--------------------\n"); os.close(); } catch (IOException e) {} if (MESSAGE_DUMP) { try { FileWriter os = new FileWriter("jcorba." + id + ".msgs", true); os.write("----------------------------------------\n"); os.close(); } catch (IOException e) {} } } public void testStartStop() { try { // Discovery takes a bit, about a tenth of a second Thread.sleep(INITIALIZATION); } catch (InterruptedException e) { System.err.println("Interruption"); } } public void testAddCapability() { try { Capability loc = (Capability)(new LocationImpl()); sserver.addCapability(SenseCorba.GPS, loc); Thread.sleep(INITIALIZATION); } catch (InterruptedException e) { System.err.println("Interruption"); } } public void testTwoLevelTask() { try { Capability loc = (Capability)(new LocationImpl()); sserver.addCapability(SenseCorba.GPS, loc); Thread.sleep(INITIALIZATION); System.err.println("DISCOVERY END"); String cmd = "recite(spatialseries(sense(sensor=GPS)))"; Sensory f = SenseParser.senseParser(sclient.getPoa(), cmd); if (sclient.devolve(f) < 0) fail("Unexpected Discovery exception"); System.err.println("COMMAND SENT"); Thread.sleep(100); System.err.println("DATA RECVD"); Data[] array = f.results(); if (array == null || array.length == 0 || array[0] == null) fail("NULL data"); assertEquals(array[0].fresult(), 35.8880556); assertEquals(array[1].fresult(), -106.3063889); assertEquals(array[2].fresult(), 2255.52); } catch (ParseException e) { System.err.println("Parse Exception in test: "); e.printStackTrace(System.err); } catch (org.omg.CORBA.UserException e) { System.err.println("Servant not active in test: "); e.printStackTrace(System.err); } catch (java.io.IOException e) { System.err.println("I/O Exception in test: "); e.printStackTrace(System.err); } catch (InterruptedException e) { System.err.println("Interruption"); } } }

© 2008, Los Alamos National Security, LLC.