/* -*-	Mode:C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t -*- * * Copyright (c) 1997 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 Computer Systems *	Engineering Group at Lawrence Berkeley Laboratory. * 4. Neither the name of the University nor of the Laboratory 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. * * $Header: /nfs/jade/vint/CVSROOT/ns-2/common/node.cc,v 1.34 2002/05/30 17:44:03 haldar Exp $ * * CMU-Monarch project's Mobility extensions ported by Padma Haldar,  * 10/98. */#include <stdio.h>#include <stdarg.h>#include "address.h"#include "config.h"#ifdef HAVE_STL#include "nix/nixnode.h"#endif //HAVE_STL#include "node.h"static class LinkHeadClass : public TclClass {public:	LinkHeadClass() : TclClass("Connector/LinkHead") {}	TclObject* create(int, const char*const*) {		return (new LinkHead);	}} class_link_head;LinkHead::LinkHead() : net_if_(0), node_(0), type_(0) { }int32_t LinkHead::label() {	if (net_if_)		return net_if_->intf_label();	printf("Configuration error:  Network Interface missing\n");	exit(1);	// Make msvc happy	return 0;}int LinkHead::command(int argc, const char*const* argv){        if (argc == 3) {		if(strcmp(argv[1], "setnetinf") == 0) {			net_if_ =				(NetworkInterface*) TclObject::lookup(argv[2]);			if (net_if_ == 0)				return TCL_ERROR;			return TCL_OK;		} else if(strcmp(argv[1], "setnode") == 0) {			node_ = (Node*) TclObject::lookup(argv[2]); 			if (node_ == 0)				return TCL_ERROR;			return TCL_OK;		}	}	return (Connector::command(argc, argv));}static class NodeClass : public TclClass {public:	NodeClass() : TclClass("Node") {}	TclObject* create(int, const char*const*) {                return (new Node);        }} class_node;struct node_head Node::nodehead_ = { 0 }; // replaces LIST_INIT macrochar Node::nwrk_[NODE_NAMLOG_BUFSZ];/* Additions for NixRouting */int NixRoutingUsed = -1;Node::Node() : 	address_(-1), nodeid_ (-1), namChan_(0),	rtnotif_(NULL),#ifdef HAVE_STL	nixnode_(NULL),#endif //HAVE_STL	energy_model_(NULL), location_(NULL), index_(0) //index_ is added for prediction{	LIST_INIT(&ifhead_);	LIST_INIT(&linklisthead_);	insert(&(Node::nodehead_)); // insert self into static list of nodes#ifdef HAVE_STL	// Mods for Nix-Vector routing	if (NixRoutingUsed < 0)	{		// Find out if nix routing is in use		Tcl& tcl = Tcl::instance();		tcl.evalf("Simulator set nix-routing");		tcl.resultAs(&NixRoutingUsed);	}	if (NixRoutingUsed) {		// Create the NixNode pointer		if(0)printf("Nix routing in use, creating NixNode\n");		nixnode_ = new NixNode();	}#endif //HAVE_STL	neighbor_list_ = NULL;       //******added for prediction        for (int i=0;i<50;i++) {                neighborSignal[i].initial();        }       //******end}Node::~Node(){	LIST_REMOVE(this, entry);}intNode::command(int argc, const char*const* argv){	Tcl& tcl = Tcl::instance();	if (argc == 2) {#ifdef HAVE_STL		// Mods for Nix-Vector Routing		if(strcmp(argv[1], "populate-objects") == 0) {			if (nixnode_) {				nixnode_->PopulateObjects();			}			return TCL_OK;		}		// End mods for Nix-Vector routing#endif // HAVE_STL		if(strcmp(argv[1], "address?") == 0) {			tcl.resultf("%d", address_); 			return TCL_OK;		}					} else if (argc == 3) {#ifdef HAVE_STL		// Mods for Nix-Vector Routing		if (strcmp(argv[1], "get-nix-vector") == 0) {			if (nixnode_) {				nixnode_->GetNixVector(atol(argv[2]));			}			return TCL_OK;		}#endif //HAVE_STL		if (strcmp(argv[1], "set-neighbor") == 0) {#ifdef HAVE_STL			if (nixnode_) {				nixnode_->AddAdj(atol(argv[2]));			}#endif //HAVE_STL			return(TCL_OK);		}		if (strcmp(argv[1], "addr") == 0) {			address_ = Address::instance().str2addr(argv[2]);#ifdef HAVE_STL			if (nixnode_) {				nixnode_->Id(address_);			}#endif //HAVE_STL			return TCL_OK;		// End mods for Nix-Vector routing		} else if (strcmp(argv[1], "nodeid") == 0) {			nodeid_ = atoi(argv[2]);			return TCL_OK;		} else if(strcmp(argv[1], "addlinkhead") == 0) {			LinkHead* slhp = (LinkHead*)TclObject::lookup(argv[2]);			if (slhp == 0)				return TCL_ERROR;			slhp->insertlink(&linklisthead_);			return TCL_OK;		} else if (strcmp(argv[1], "addenergymodel") == 0) {			energy_model_=(EnergyModel*)TclObject::lookup(argv[2]);			if(!energy_model_)				return TCL_ERROR;			return TCL_OK;		} else if (strcmp(argv[1], "namattach") == 0) {                        int mode;                        namChan_ = Tcl_GetChannel(tcl.interp(), (char*)argv[2],                                                  &mode);                        if (namChan_ == 0) {                                tcl.resultf("node: can't attach %s", argv[2]);                                return (TCL_ERROR);                        }                        return (TCL_OK);		} else if (strcmp(argv[1], "add-neighbor") == 0) {			Node * node = (Node *)TclObject::lookup(argv[2]); 			if (node == 0) { 				tcl.resultf("Invalid node %s", argv[2]);                                 return (TCL_ERROR);			}			addNeighbor(node);			return TCL_OK;		}	}	return ParentNode::command(argc,argv);}void Node::route_notify(RoutingModule *rtm) {	if (rtnotif_ == NULL)		rtnotif_ = rtm;	else		rtnotif_->route_notify(rtm);}void Node::unreg_route_notify(RoutingModule *rtm) {	if (rtnotif_) {		if (rtnotif_ == rtm) {			//RoutingModule *tmp = rtnotif_;			rtnotif_= rtnotif_->next_rtm_;			//free (tmp);		}		else			rtnotif_->unreg_route_notify(rtm);	}}void Node::add_route(char *dst, NsObject *target) {	if (rtnotif_)		rtnotif_->add_route(dst, target);}void Node::delete_route(char *dst, NsObject *nullagent) {	if (rtnotif_)		rtnotif_->delete_route(dst, nullagent);}void Node::set_table_size(int nn) {	if (rtnotif_)		rtnotif_->set_table_size(nn);}void Node::set_table_size(int level, int csize) {	if (rtnotif_)		rtnotif_->set_table_size(level, csize);}void Node::addNeighbor(Node * neighbor) {	neighbor_list_node* nlistItem = (neighbor_list_node *)malloc(sizeof(neighbor_list_node));	nlistItem->nodeid = neighbor->nodeid();	nlistItem->next = neighbor_list_;	neighbor_list_=nlistItem; }void Node::namlog(const char* fmt, ...){	// Don't do anything if we don't have a log file.	if (namChan_ == 0) 		return;	va_list ap;	va_start(ap, fmt);	vsprintf(nwrk_, fmt, ap);	namdump();}void Node::namdump(){        int n = 0;        /* Otherwise nwrk_ isn't initialized */	n = strlen(nwrk_);	if (n >= NODE_NAMLOG_BUFSZ-1) {		fprintf(stderr, 			"Node::namdump() exceeds buffer size. Bail out.\n");		abort();	}	if (n > 0) {		/*		 * tack on a newline (temporarily) instead		 * of doing two writes		 */		nwrk_[n] = '\n';		nwrk_[n + 1] = 0;		(void)Tcl_Write(namChan_, nwrk_, n + 1);		nwrk_[n] = 0;	}}// Given an interface label for a NetworkInterface on this node, we return // the head of that linkNsObject* Node::intf_to_target(int32_t label){	LinkHead *lhp = linklisthead_.lh_first;	for (; lhp; lhp = lhp->nextlinkhead()) 		if (label == lhp->label())			return ((NsObject*) lhp);	return NULL;}// A class static method. Return the node instance from the static node listNode* Node::get_node_by_address (nsaddr_t id){	Node * tnode = nodehead_.lh_first;	for (; tnode; tnode = tnode->nextnode()) {		if (tnode->address_ == id ) {			return (tnode);		}	}	return NULL;}//******added for predictionint Node::getIndex(int anID){        int pos=0;        for(int i=0;i<index_;i++){                if(anID==neighborSignal[i].getNodeid()){                        pos=i;                        break;                }        }        return pos;}//add a node to the neighbor listvoid Node::addNode(int anID,double aTime,double aPower){        SignalPower aSignal;        aSignal.initial();        aSignal.nodeID=anID;        aSignal.addParameter(aPower,aTime);        neighborSignal[index_]=aSignal;        index_++;}//check if the node is in the neighborSignal arraybool Node::isRecorde(int anID){        bool result=false;        for(int i=0;i<index_;i++){                if(anID==neighborSignal[i].getNodeid()){                        result=true;                        break;                }        }        return result;}//get a node power time info by with specified IDSignalPower* Node::getNodeValue(int anID){        SignalPower* aPowerValue;        //if we found the node;        bool found=false;        for(int i=0;i<index_;i++){                if(anID==neighborSignal[i].getNodeid()){                        aPowerValue=&neighborSignal[i];                        found=true;                        break;                }        }        //if not found, return a default value        if(!found){           SignalPower aSignal;           aSignal.initial();           aPowerValue=&aSignal;        }        double theTime=aPowerValue->getPredict();        return aPowerValue;}//add signal power value to the specified node in the listvoid Node::addValue(int anID,double aTime,double aPower){        if(isRecorde(anID)){                neighborSignal[getIndex(anID)].addParameter(aPower,aTime);                        }        else{                addNode(anID,aTime,aPower);        }}//remove a node from the listbool Node::removeNode(int anID){        bool result=false;        int position =0;        for(int i=0;i<index_;i++){                if(anID==neighborSignal[i].getNodeid()){                        position=i;                        for(int j=position;j<index_;j++){                        //move forward                                neighborSignal[j]=neighborSignal[j+1];                        }                        index_--;                        result=true;                }        }        return result;}//get the predict timedouble Node::getTime(int anID){        SignalPower *aValue;        aValue=getNodeValue(anID);        double aTime=aValue->getPredict();        return aTime;}//******end