Changeset 10575


Ignore:
Timestamp:
Jun 18, 2012, 5:30:53 PM (12 years ago)
Author:
Michael Tänzer
Message:

When routing do not reset source NodeID

File:
1 edited

Legend:

Unmodified
Added
Removed
  • source/ariba/overlay/BaseOverlay.cpp

    r10574 r10575  
    22032203                DHTMessage dhtmsg(dhtMsg->getKey(), vect);
    22042204                omsg.encapsulate(&dhtmsg);
    2205                 dhtSend(&omsg, omsg.getDestinationNode());
     2205                send(&omsg, omsg.getDestinationNode());
    22062206                break;
    22072207        }
     
    22482248        OverlayMsg msg( OverlayMsg::typeDHTPut );
    22492249        msg.encapsulate( &dhtmsg );
     2250        msg.setSourceNode(this->nodeId);
    22502251        dhtSend(&msg, dhtmsg.getHashedKey());
    22512252}
     
    22612262        OverlayMsg msg(OverlayMsg::typeDHTRemove);
    22622263        msg.encapsulate( &dhtmsg );
     2264        msg.setSourceNode(this->nodeId);
    22632265        dhtSend(&msg, dhtmsg.getHashedKey());
    22642266}
     
    22742276        OverlayMsg msg(OverlayMsg::typeDHTRemove);
    22752277        msg.encapsulate( &dhtmsg );
     2278        msg.setSourceNode(this->nodeId);
    22762279        dhtSend(&msg, dhtmsg.getHashedKey());
    22772280}
     
    22892292        msg.setService(service);
    22902293        msg.encapsulate( &dhtmsg );
     2294        msg.setSourceNode(this->nodeId);
    22912295        dhtSend(&msg, dhtmsg.getHashedKey());
    22922296}
     
    22952299        // log: dht send
    22962300        logging_info("DHT-Send: Sending message with key=" << dest.toString() );
    2297 
    2298         /// set source and destination
    2299         msg->setSourceNode(this->nodeId);
    23002301
    23012302        // local storage? yes-> put into DHT directly
Note: See TracChangeset for help on using the changeset viewer.