Changeset 2454 for source/ariba/Node.cpp


Ignore:
Timestamp:
Feb 18, 2009, 1:39:08 PM (15 years ago)
Author:
mies
Message:

fixed some bugs

File:
1 edited

Legend:

Unmodified
Added
Removed
  • source/ariba/Node.cpp

    r2439 r2454  
    4545#include "ariba/interface/ServiceInterface.h"
    4646#include "ariba/interface/UnderlayAbstraction.h"
    47 
     47#include "ariba/communication/EndpointDescriptor.h"
     48
     49using ariba::communication::EndpointDescriptor;
    4850using ariba::interface::UnderlayAbstraction;
    4951
     
    125127
    126128Node::Node(AribaModule& ariba_mod, const Name& node_name) :
    127         ariba_mod( ariba_mod ), name( node_name ), context( NULL ){
     129        ariba_mod(ariba_mod), name(node_name), context(NULL) {
    128130}
    129131
     
    133135void Node::join(const Name& vnetname) {
    134136        spovnetId = vnetname.toSpoVNetId();
    135         nodeId = generateNodeId( name );
     137        nodeId = generateNodeId(name);
    136138        this->context = ariba_mod.underlay_abs->joinSpoVNet(spovnetId,
    137139                        *ariba_mod.getBootstrapNode(name), nodeId);
     
    139141
    140142void Node::initiate(const Name& vnetname, const SpoVNetProperties& parm) {
    141         utility::OverlayParameterSet ovrpset =
    142                 (utility::OverlayParameterSet::_OverlayStructure) parm.getBaseOverlayType();
     143        utility::OverlayParameterSet
     144                        ovrpset =
     145                                        (utility::OverlayParameterSet::_OverlayStructure) parm.getBaseOverlayType();
    143146        spovnetId = vnetname.toSpoVNetId();
    144         nodeId = generateNodeId( name );
     147        nodeId = generateNodeId(name);
    145148        this->context = ariba_mod.underlay_abs->createSpoVNet(spovnetId, nodeId,
    146149                        ariba_mod.ip_addr, ariba_mod.tcp_port);
     150        ariba_mod.addBootstrapNode(vnetname,
     151                        new EndpointDescriptor(this->context->getBaseCommunication().getEndpointDescriptor()));
    147152}
    148153
     
    173178
    174179NodeID Node::generateNodeId(const Name& name) const {
    175         if( name == Name::UNSPECIFIED )
    176                 return Name::random().toNodeId();
    177         else
    178                 return name.toNodeId();
     180        if (name == Name::UNSPECIFIED) return Name::random().toNodeId();
     181        else return name.toNodeId();
    179182}
    180183
     
    190193seqnum_t Node::sendMessage(const DataMessage& msg, const NodeID& nid,
    191194                const ServiceID& sid, const LinkProperties& req) {
    192         return context->getOverlay().sendMessage((Message*)msg, nid, sid);
     195        return context->getOverlay().sendMessage((Message*) msg, nid, sid);
    193196}
    194197
    195198seqnum_t Node::sendMessage(const DataMessage& msg, const LinkID& lnk) {
    196         return context->getOverlay().sendMessage((Message*)msg, lnk);
     199        return context->getOverlay().sendMessage((Message*) msg, lnk);
    197200}
    198201
Note: See TracChangeset for help on using the changeset viewer.