Changeset 6919 for source/ariba/overlay/BaseOverlay.cpp
- Timestamp:
- Nov 13, 2009, 1:41:34 PM (15 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
source/ariba/overlay/BaseOverlay.cpp
r6916 r6919 148 148 static bool equals( const Data& lhs, const Data& rhs ) { 149 149 if (rhs.getLength()!=lhs.getLength()) return false; 150 for ( int i=0; i<lhs.getLength()/8; i++)150 for (size_t i=0; i<lhs.getLength()/8; i++) 151 151 if (lhs.getBuffer()[i] != rhs.getBuffer()[i]) return false; 152 152 return true; … … 604 604 message->setDestinationNode(remote); 605 605 message->setService(service); 606 send( message, remote );606 return send( message, remote ); 607 607 } 608 608 … … 747 747 748 748 BaseOverlay::BaseOverlay() : 749 bc(NULL), overlayInterface(NULL), nodeId(NodeID::UNSPECIFIED), 750 spovnetId(SpoVNetID::UNSPECIFIED), state(BaseOverlayStateInvalid), 751 sideport(&SideportListener::DEFAULT), started(false), counter(0) { 749 started(false),state(BaseOverlayStateInvalid), 750 bc(NULL), 751 nodeId(NodeID::UNSPECIFIED), spovnetId(SpoVNetID::UNSPECIFIED), 752 sideport(&SideportListener::DEFAULT), overlayInterface(NULL), 753 counter(0) { 752 754 dht = new DHT(); 753 755 localDHT = new DHT(); … … 1158 1160 sideport = _sideport; 1159 1161 _sideport->configure( this ); 1162 return true; 1160 1163 } 1161 1164 1162 1165 bool BaseOverlay::unregisterSidePort(SideportListener* _sideport) { 1163 1166 sideport = &SideportListener::DEFAULT; 1167 return true; 1164 1168 } 1165 1169 … … 1789 1793 // erase the original descriptor 1790 1794 eraseDescriptor(ld->overlayId); 1795 return true; 1791 1796 } 1792 1797 … … 2182 2187 void BaseOverlay::dhtPut( const Data& key, const Data& value, int ttl, bool replace, bool no_local_refresh ) { 2183 2188 2184 logging_info("DHT: putting key=" << key 2185 << " value=" << value 2186 << " ttl=" << ttl 2187 << " replace=" << replace 2189 logging_info("DHT: putting key=" << key << " value=" << value 2190 << " ttl=" << ttl << " replace=" << replace 2188 2191 ); 2189 2192
Note:
See TracChangeset
for help on using the changeset viewer.