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

/home/brennan/Software/sensix/source/L2/sense_clients.c 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. */ #include <stdlib.h> #include <unistd.h> #include <string.h> #include <pthread.h> #include <orbit/orbit.h> #include "sensix.h" #include "sense_impl.h" #include "corba_discovery.h" #include "discovery_service.h" #include "corba_util.h" #include "sense.h" #include "parser.h" /**************************************** * Siblings use CORBA */ extern pthread_mutex_t orb_mutex; extern CORBA_ORB global_orb; pthread_mutex_t sibling_mutex = PTHREAD_MUTEX_INITIALIZER; bool_t siblings_running = false; static void siblings_run(gov_lanl_isr_sensix_SensoryRequest sensix_service, CORBA_Environment *ev) { pthread_mutex_lock(&sibling_mutex); while(siblings_running) { pthread_mutex_unlock(&sibling_mutex); { // mutex/conditional unsigned char cmd = SUMMA; // FIXME: task input from server gov_lanl_isr_sensix_Functor f = gov_lanl_isr_sensix_FunctorFactory_generate(sensix_service, cmd, ev); switch (cmd) { case (ALPHA): // FIXME: load functor break; case (BETA): // FIXME: load functor break; } gov_lanl_isr_sensix_SensoryResponse r;// = gov_lanl_isr_sensix_SensoryResponse__alloc(); // FIXME: response callback gov_lanl_isr_sensix_SensoryRequest_apply(sensix_service, f, r, ev); if (raised_exception(ev)) return; } pthread_mutex_lock(&sibling_mutex); } pthread_mutex_unlock(&sibling_mutex); } void siblings_shutdown(int sig) { pthread_mutex_lock(&sibling_mutex); siblings_running = false; pthread_mutex_unlock(&sibling_mutex); } void *siblings_client(void *arguments) { struct args *a; CORBA_Environment ev[1]; gov_lanl_isr_sensix_SensoryRequest sensix_service = CORBA_OBJECT_NIL; if (arguments == NULL) die("Siblings thread", "nil arguments"); a = (struct args*)arguments; pthread_mutex_lock(&orb_mutex); // wait for server to start pthread_mutex_unlock(&orb_mutex); siblings_running = true; CORBA_exception_init(ev); log_info("%s: SENSIX client for siblings\n", APP); sensix_service = (gov_lanl_isr_sensix_SensoryRequest) discover_object(0, global_orb, ev); // FIXME: request type if (raised_exception(ev)) { CORBA_exception_free(ev); goto cleanup; } siblings_run(sensix_service, ev); abort_if_exception(ev, "Sensix service not reachable"); cleanup: pthread_mutex_lock(&orb_mutex); CORBA_Object_release(sensix_service, ev); if (raised_exception(ev)) log_error("%s: Siblings client cleanup failed - %s\n", APP, CORBA_exception_id(ev)); pthread_mutex_unlock(&orb_mutex); // let server cleanup log_info("%s: Siblings client closing\n", APP); return NULL; } /**************************************** * Descendants use Sensix mote-sense framework */ static bool_t _desc_running = false; static pthread_mutex_t desc_mutex = PTHREAD_MUTEX_INITIALIZER; void descendants_shutdown(int sig) { pthread_mutex_lock(&desc_mutex); _desc_running = false; pthread_mutex_unlock(&desc_mutex); } void *descendants_client(void *arguments) { enum parser parser = MANTIS; char *str_parser = "Mantis"; struct args *a; if (arguments == NULL) die("", ""); a = (struct args*)arguments; if (a->argc > 2) die("too many arguments", ""); if (a->argc == 2) { str_parser = a->argv[1]; if (strcasecmp(a->argv[1], "mantis") == 0) parser = MANTIS; else if (strcasecmp(a->argv[1], "tinyos") == 0) parser = TINYOS; } log_info("%s: SENSIX client for %s motes\n", APP, str_parser); _desc_running = true; pthread_mutex_lock(&desc_mutex); while (_desc_running) { pthread_mutex_unlock(&desc_mutex); { // FIXME: await descendant server broadcasts? sleep(10); } pthread_mutex_lock(&desc_mutex); } pthread_mutex_unlock(&desc_mutex); log_info("%s: %s descendants client closing\n", APP, str_parser); return NULL; }

© 2008, Los Alamos National Security, LLC.