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

/home/brennan/Software/sensix/source/L3/sense_clients.cpp 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 <string.h> #include <pthread.h> #include "sensingC.h" #include "sensix.h" #include "sense_discover.h" #include "sense_impl.h" #include "discovery_service.h" #include "corba_discovery.h" using namespace sensix; extern pthread_mutex_t orb_mutex; extern CORBA::ORB_var global_orb; pthread_mutex_t sibling_mutex = PTHREAD_MUTEX_INITIALIZER; bool_t siblings_running = false; static void _run(Request_var sensix_service) { pthread_mutex_lock(&sibling_mutex); while(siblings_running) { pthread_mutex_unlock(&sibling_mutex); // mutex/conditional //unsigned char cmd = SUMMA; /* // FIXME: task input from server Functor_var f = FunctorFactory::generate(sensix_service, cmd, ev); switch (cmd) { case (ALPHA): // FIXME: load functor break; case (BETA): // FIXME: load functor break; } Response_var r;// = new Response(); // FIXME: response callback Request::apply(sensix_service, f, r, ev); */ pthread_mutex_lock(&sibling_mutex); } pthread_mutex_unlock(&sibling_mutex); } static void _shutdown(int sig) { pthread_mutex_lock(&sibling_mutex); siblings_running = false; pthread_mutex_unlock(&sibling_mutex); } static void _client(unsigned char which, void *arguments) { Request_var sensix_service; struct args *a; 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; log_info("%s: SENSIX client for siblings\n", APP); try { CORBA::Object_var tmp = discover_object(0, a->level, global_orb);// FIXME: request type sensix_service = Request::_narrow(tmp.in()); _run(sensix_service); pthread_mutex_lock(&orb_mutex); // stop service } catch (CORBA::Exception &ex) { log_error("%s: Clients CORBA exception - %s\n", APP, ex._info().c_str()); } pthread_mutex_unlock(&orb_mutex); // let server cleanup log_info("%s: Siblings client closing\n", APP); } void siblings_shutdown(int sig) { _shutdown(sig); } void *siblings_client(void *arguments) { _client(SIBLINGS, arguments); return NULL; } void descendants_shutdown(int sig) { _shutdown(sig); } void *descendants_client(void *arguments) { _client(DESCENDANTS, arguments); return NULL; }

© 2008, Los Alamos National Security, LLC.