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/l4/virtual_time-l4.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 <l4/thread/thread.h> #include <virtual_time.h> #include <virtual_time-internal.h> #include <mutex.h> #include <avl.h> #include <orbisquartus.h> #include <mini_mpi.h> #include "lwip.h" extern OrbisQuartus *oq; extern mutex_t vt_mutex; extern mutex_t vt_sync; extern AVL_tree<VT_timestamp> send_queue; extern AVL_tree<VT_timestamp> rcv_queue; extern AVL_tree<VT_timestamp> state_queue; // FIXME: paths to fs snapshots char *vt_recv(struct netconn *sock, int len) { struct netbuf *inbuf; int msg_len = len + VT_message::string_len(); char msg[msg_len + 1]; VT_message *vm; inbuf = netconn_recv(sock); do { char *data; unsigned short data_len; netbuf_data(inbuf, (void**)&data, &data_len); data[data_len] = '\0'; strncat(msg, data, MPI_MSG_LEN - msg_len); msg_len += data_len; } while (netbuf_next(inbuf) >= 0); vm = new VT_message(msg); if (vm->rvt() >= global_virtual_time()) { if (vm->rvt() < local_virtual_time()) { AVL_node<VT_timestamp> *n; for (n = send_queue.find(vm->compare()); n != NULL; n = n->get_next()) { VT_message *m = dynamic_cast<VT_message *>(n->elt()); if (m != NULL) { vt_send(m->sender, sock, m->to_string(), strlen(m->to_string())); send_queue.delete_elt(m); } } // FIXME: restore checkpoint return NULL; } else { VT_message *other; if ((other = dynamic_cast<VT_message*> (rcv_queue.retrieve(vm->compare()))) != NULL) { if (other->msg_sign != vm->msg_sign) rcv_queue.delete_elt(vm); } else rcv_queue.insert_elt(vm); } } // else ignore msg return vm->content; } int vt_send(int dest, struct netconn *sock, char *buf, int len) { int error = 0; VT_message *vm = new VT_message(dest, buf); if ((error = netconn_write(sock, vm->to_string(), strlen(vm->to_string()), NETCONN_COPY)) < 0) return error; vm->msg_sign = NEGATIVE; send_queue.insert_elt(vm); return error; } static void virtual_time_client(void *unused) { while (!daemon_shuttingdown()) { while (!daemon_quitting()) { } // reset queues } } void virtual_time_init(OrbisQuartus *orbis) { oq = orbis; if ((oq->vt_thread = l4thread_create(virtual_time_client, NULL, L4THREAD_CREATE_ASYNC)) < 0) { fprintf(stderr, "ERROR-- virtual time thread: %d\n", (int)oq->vt_thread); exit(-1); } }

© 2007, Los Alamos National Security, LLC.