- Timestamp:
- Jun 18, 2012, 5:30:53 PM (13 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
source/ariba/overlay/BaseOverlay.cpp
r10574 r10575 2203 2203 DHTMessage dhtmsg(dhtMsg->getKey(), vect); 2204 2204 omsg.encapsulate(&dhtmsg); 2205 dhtSend(&omsg, omsg.getDestinationNode());2205 send(&omsg, omsg.getDestinationNode()); 2206 2206 break; 2207 2207 } … … 2248 2248 OverlayMsg msg( OverlayMsg::typeDHTPut ); 2249 2249 msg.encapsulate( &dhtmsg ); 2250 msg.setSourceNode(this->nodeId); 2250 2251 dhtSend(&msg, dhtmsg.getHashedKey()); 2251 2252 } … … 2261 2262 OverlayMsg msg(OverlayMsg::typeDHTRemove); 2262 2263 msg.encapsulate( &dhtmsg ); 2264 msg.setSourceNode(this->nodeId); 2263 2265 dhtSend(&msg, dhtmsg.getHashedKey()); 2264 2266 } … … 2274 2276 OverlayMsg msg(OverlayMsg::typeDHTRemove); 2275 2277 msg.encapsulate( &dhtmsg ); 2278 msg.setSourceNode(this->nodeId); 2276 2279 dhtSend(&msg, dhtmsg.getHashedKey()); 2277 2280 } … … 2289 2292 msg.setService(service); 2290 2293 msg.encapsulate( &dhtmsg ); 2294 msg.setSourceNode(this->nodeId); 2291 2295 dhtSend(&msg, dhtmsg.getHashedKey()); 2292 2296 } … … 2295 2299 // log: dht send 2296 2300 logging_info("DHT-Send: Sending message with key=" << dest.toString() ); 2297 2298 /// set source and destination2299 msg->setSourceNode(this->nodeId);2300 2301 2301 2302 // local storage? yes-> put into DHT directly
Note:
See TracChangeset
for help on using the changeset viewer.