satnode.cc

Go to the documentation of this file.

/* -*-  Mode:C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t -*- */
/*
 * Copyright (c) 1999 Regents of the University of California.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. All advertising materials mentioning features or use of this software
 *    must display the following acknowledgement:
 *      This product includes software developed by the MASH Research
 *      Group at the University of California Berkeley.
 * 4. Neither the name of the University nor of the Research Group may be
 *    used to endorse or promote products derived from this software without
 *    specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 *
 * Contributed by Tom Henderson, UCB Daedalus Research Group, June 1999
 */

#ifndef lint
static const char rcsid[] =
    "@(#) $Header: /nfs/jade/vint/CVSROOT/ns-2/satellite/satnode.cc,v 1.8 2001/11/06 06:21:47 tomh Exp $";
#endif

#include "satnode.h"
#include "satlink.h"
#include "sattrace.h"
#include "sathandoff.h"
#include "satposition.h"

static class SatNodeClass : public TclClass {
public:
    SatNodeClass() : TclClass("Node/SatNode") {}
    TclObject* create(int , const char*const* ) {
        return (new SatNode);
    }
} class_satnode;

#define MAXSATNODELIST 64 // Assume 64 nodes to start-- dynamically increases
int* SatNode::satnodelist_ = NULL;
int SatNode::maxsatnodelist_ = 0;
int SatNode::dist_routing_ = 0;

SatNode::SatNode() : ragent_(0), trace_(0), hm_(0)  
{
    bind_bool("dist_routing_", &dist_routing_);
}

int SatNode::command(int argc, const char*const* argv) {     
    Tcl& tcl = Tcl::instance();
    if (argc == 2) {
        if (strcmp(argv[1], "set_downlink") == 0) {
            if (downlink_ != NULL) {
                tcl.result(downlink_->name());
                return (TCL_OK);
            }
        } else if (strcmp(argv[1], "set_uplink") == 0) {
            if (downlink_ != NULL) {
                tcl.result(uplink_->name());
                return (TCL_OK);
            }
        } else if (strcmp(argv[1], "start_handoff") == 0) {
            if (hm_)
                hm_->start();
            else {
                printf("Error: starting non-existent ");
                printf("handoff mgr\n");
                exit(1);
            }
            return (TCL_OK);
        } else if (strcmp(argv[1], "dump_sats") == 0) {
            dumpSats();
            return (TCL_OK);
        }
    }
    if (argc == 3) {
        if (strcmp(argv[1], "set_uplink") == 0) {
            uplink_ = (SatChannel *) TclObject::lookup(argv[2]);
            if (uplink_ == 0) {
                tcl.resultf("no such object %s", argv[2]);
                return (TCL_ERROR);
            }
            return (TCL_OK);
        } else if (strcmp(argv[1], "set_downlink") == 0) {
            downlink_ = (SatChannel *) TclObject::lookup(argv[2]);
            if (downlink_ == 0) {
                tcl.resultf("no such object %s", argv[2]);
                return (TCL_ERROR);
            }
            return (TCL_OK);
        } else if (strcmp(argv[1], "set_trace") == 0) {
            trace_ = (SatTrace *) TclObject::lookup(argv[2]);
            if (trace_ == 0) {
                tcl.resultf("no such object %s", argv[2]);
                return (TCL_ERROR);
            }
            return (TCL_OK);
        } else if (strcmp(argv[1], "set_ragent") == 0) {
            ragent_ = (SatRouteAgent *) TclObject::lookup(argv[2]);
            if (ragent_ == 0) {
                tcl.resultf("no such object %s", argv[2]);
                return (TCL_ERROR);
            }
            return (TCL_OK);
        } else if(strcmp(argv[1], "addif") == 0) {
                        SatPhy* n = (SatPhy*) TclObject::lookup(argv[2]);
                        if(n == 0)
                                return TCL_ERROR; 
                        n->insertnode(&ifhead_);
                        n->setnode(this);
                        return TCL_OK;
        } else if (strcmp(argv[1], "set_position") == 0) {
            pos_ = (SatPosition*) TclObject::lookup(argv[2]);
            if (pos_ == 0) {
                tcl.resultf("no such object %s", argv[2]);
                return (TCL_ERROR);
            }
            return (TCL_OK);
        } else if (strcmp(argv[1], "set_handoff_mgr") == 0) {
            hm_ = (LinkHandoffMgr*) TclObject::lookup(argv[2]);
            if (hm_ == 0) {
                tcl.resultf("no such object %s", argv[2]);
                return (TCL_ERROR);
            }
            return (TCL_OK);
        } else if (strcmp(argv[1], "set_address") == 0) {
            addNode(atoi(argv[2]));
            return (TCL_OK);
        }
    }
    return (Node::command(argc, argv));
}

int SatNode::addNode(int nodenum)
{
    if (maxsatnodelist_ == 0) {
        satnodelist_ = new int[MAXSATNODELIST];
        memset(satnodelist_, 0, MAXSATNODELIST * sizeof(satnodelist_));
        maxsatnodelist_ = MAXSATNODELIST;
    }
    assert(nodenum < 2*maxsatnodelist_);
    if (nodenum >= maxsatnodelist_) {
        // Double size of array
        int i;
        int* temp = new int[2 * maxsatnodelist_];
        memset(temp, 0, 2 * maxsatnodelist_ * sizeof(temp));
        for (i = 0; i < maxsatnodelist_; i++) {
            temp[i] = satnodelist_[i];
        }
        delete [] satnodelist_;
        satnodelist_ = temp;
        maxsatnodelist_ *= 2;
    }
    satnodelist_[nodenum] = 1;
    return 0;
}

int SatNode::IsASatNode(int nodenum)
{
    if (nodenum > maxsatnodelist_) {
        printf("Error: IsASatNode() nodenum %d greater than maxsatnodelist_ %d\n", nodenum, maxsatnodelist_);
        exit(1);
    }
    return satnodelist_[nodenum];
}

// debugging method for dumping out all of the satellite and ISL locations
// on demand from OTcl.
void SatNode::dumpSats()
{
    SatNode *snodep, *peer_snodep;
    SatPosition *sposp, *peer_sposp;
    PolarSatPosition *polar_sposp;
    SatLinkHead *slhp;
    int linktype;

        printf("\nDumping satellites at time %.2f\n\n", NOW);
        for (snodep= (SatNode*) Node::nodehead_.lh_first; snodep; 
        snodep = (SatNode*) snodep->nextnode()) {
        if (!SatNode::IsASatNode(snodep->address()))
            continue;
        sposp = snodep->position();
                printf("%d\t%.2f\t%.2f", snodep->address(), 
            RAD_TO_DEG(SatGeometry::get_latitude(sposp->coord())), 
            RAD_TO_DEG(SatGeometry::get_longitude(sposp->coord())));
        // If SatNode is polar, append plane information
        if (sposp->type()==POSITION_SAT_POLAR) {
            polar_sposp = (PolarSatPosition*) snodep->position();
            printf ("\t%d", polar_sposp->plane());
        } else if (sposp->type()==POSITION_SAT_GEO) {
            printf ("\tGEO");
        } else if (sposp->type()==POSITION_SAT_TERM) {
            printf ("\tTERM");
        }
        printf("\n");
    }
        printf("\n");
        // Dump satellite links
        // There is a static list of address classifiers //QQQ
        printf("Links:\n");
        for (snodep = (SatNode*) Node::nodehead_.lh_first; snodep; 
        snodep = (SatNode*) snodep->nextnode()) {
        if (!SatNode::IsASatNode(snodep->address()))
            continue;
        // XXX Not all links necessarily satlinks
        for (slhp = (SatLinkHead*) snodep->linklisthead_.lh_first; 
            slhp; slhp = (SatLinkHead*) slhp->nextlinkhead() ) {
            linktype = slhp->type();
                    if (linktype == LINK_GENERIC)
                            continue;
            if (!slhp->linkup_)
                continue;
                        // Link is up.
            // Print out source and dest coordinates.
            sposp = snodep->position();
            peer_snodep = hm_->get_peer(slhp);
            if (peer_snodep == 0)
                continue; // this link interface is not attached
            // need something in here for txs.
            peer_sposp = peer_snodep->position();
                        printf("%.2f\t%.2f\t%.2f\t%.2f\t%d\n", 
             RAD_TO_DEG(SatGeometry::get_latitude(sposp->coord())),
             RAD_TO_DEG(SatGeometry::get_longitude(sposp->coord())),
             RAD_TO_DEG(SatGeometry::get_latitude(peer_sposp->coord())), 
             RAD_TO_DEG(SatGeometry::get_longitude(peer_sposp->coord())),
             linktype);
        }
    }
    printf("\nDumped satellites at time %.2f\n\n", NOW);
}

---