Changeset 2454 for source/ariba/Node.cpp
- Timestamp:
- Feb 18, 2009, 1:39:08 PM (16 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
source/ariba/Node.cpp
r2439 r2454 45 45 #include "ariba/interface/ServiceInterface.h" 46 46 #include "ariba/interface/UnderlayAbstraction.h" 47 47 #include "ariba/communication/EndpointDescriptor.h" 48 49 using ariba::communication::EndpointDescriptor; 48 50 using ariba::interface::UnderlayAbstraction; 49 51 … … 125 127 126 128 Node::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) { 128 130 } 129 131 … … 133 135 void Node::join(const Name& vnetname) { 134 136 spovnetId = vnetname.toSpoVNetId(); 135 nodeId = generateNodeId( name);137 nodeId = generateNodeId(name); 136 138 this->context = ariba_mod.underlay_abs->joinSpoVNet(spovnetId, 137 139 *ariba_mod.getBootstrapNode(name), nodeId); … … 139 141 140 142 void 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(); 143 146 spovnetId = vnetname.toSpoVNetId(); 144 nodeId = generateNodeId( name);147 nodeId = generateNodeId(name); 145 148 this->context = ariba_mod.underlay_abs->createSpoVNet(spovnetId, nodeId, 146 149 ariba_mod.ip_addr, ariba_mod.tcp_port); 150 ariba_mod.addBootstrapNode(vnetname, 151 new EndpointDescriptor(this->context->getBaseCommunication().getEndpointDescriptor())); 147 152 } 148 153 … … 173 178 174 179 NodeID 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(); 179 182 } 180 183 … … 190 193 seqnum_t Node::sendMessage(const DataMessage& msg, const NodeID& nid, 191 194 const ServiceID& sid, const LinkProperties& req) { 192 return context->getOverlay().sendMessage((Message*) msg, nid, sid);195 return context->getOverlay().sendMessage((Message*) msg, nid, sid); 193 196 } 194 197 195 198 seqnum_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); 197 200 } 198 201
Note:
See TracChangeset
for help on using the changeset viewer.