N-sim Emulation and simulation of Wireless Sensor Networks    Home    Project Page    Download    CVS    Installation    Configuration    Plug-ins  Hosted by

/home/brennan/n-sim/OrbisQuartus/server/virtual_time.cpp Go to the documentation of this file. /* * Copyright 2007. 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. */ #include <stdio.h> #include <stdlib.h> #include <string.h> #include <avl.h> #include <daemon.h> #include <mini_mpi.h> #include <orbisquartus.h> #include <sensor_node.h> #include <mutex.h> #include "virtual_time.h" #define BIT_RATE 400 // FIXME: make this Sensor_node specific OrbisQuartus *oq; mutex_t vt_mutex; mutex_t vt_sync; AVL_tree<VT_timestamp> send_queue; AVL_tree<VT_timestamp> rcv_queue; AVL_tree<VT_timestamp> state_queue; // FIXME: paths to fs snapshots extern int my_taskid; char *VT_timestamp::_format = "%lu,%lu"; VT_timestamp VT_timestamp::_local_virtual_time = VT_timestamp(0L, 0L); VT_timestamp VT_timestamp::_global_virtual_time = VT_timestamp(0L, 0L); VT_message::VT_message(unsigned int to_whom, char *buf) : Comparable<VT_timestamp>(VT_timestamp()) { msg_queue = OUT; sender = my_taskid; _svt = key = VT_timestamp(); rcvr = to_whom; _rvt = VT_timestamp() + static_cast<int>(strlen(buf) * BIT_RATE); msg_sign = POSITIVE; content = buf; } VT_message::VT_message(char *string) : Comparable<VT_timestamp>(VT_timestamp()) { int sign; char st[VT_timestamp::_strlen + 1]; char rt[VT_timestamp::_strlen + 1]; sscanf(string, "%s::%u::%s::%u::%d::%s", st, &sender, rt, &rcvr, &sign, content); _svt = VT_timestamp(st); _rvt = key = VT_timestamp(rt); msg_queue = IN; if (sign == POSITIVE) msg_sign = POSITIVE; else msg_sign = NEGATIVE; } int checkpoint(unsigned long node_id) { int error = 0; Sensor_node *node = dynamic_cast<Sensor_node*> (oq->cfg.get_nodes()->find(node_id)->elt()); if ((error = node->pause()) < 0) return error; if ((error = node->save()) < 0) return error; error = node->unpause(); return error; } int chkpt_all(void) { int i, count, error = 0; unsigned long *assign = 0; oq->get_assignment(assign, &count); if (assign == 0) return -1; for (i = 0; i < count; i ++) { if ((error = checkpoint(assign[i])) < 0) break; } return error; } int restore(unsigned long node_id) { int error = 0; /* Sensor_node *node = dynamic_cast<Sensor_node*> (oq->cfg.get_nodes()->find(node_id)->elt()); */ return error; } void virtual_time_iterate(void) { VT_timestamp::tick(); }

© 2007, Los Alamos National Security, LLC.