Changeset 6919 for source/ariba/overlay


Ignore:
Timestamp:
Nov 13, 2009, 1:41:34 PM (15 years ago)
Author:
mies
Message:

Fixed tons of warnings when using CXXFLAGS="-Wall"!

Location:
source/ariba/overlay
Files:
9 edited

Legend:

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

    r6916 r6919  
    148148        static bool equals( const Data& lhs, const Data& rhs ) {
    149149                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++)
    151151                        if (lhs.getBuffer()[i] != rhs.getBuffer()[i]) return false;
    152152                return true;
     
    604604        message->setDestinationNode(remote);
    605605        message->setService(service);
    606         send( message, remote );
     606        return send( message, remote );
    607607}
    608608
     
    747747
    748748BaseOverlay::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) {
    752754        dht = new DHT();
    753755        localDHT = new DHT();
     
    11581160        sideport = _sideport;
    11591161        _sideport->configure( this );
     1162        return true;
    11601163}
    11611164
    11621165bool BaseOverlay::unregisterSidePort(SideportListener* _sideport) {
    11631166        sideport = &SideportListener::DEFAULT;
     1167        return true;
    11641168}
    11651169
     
    17891793        // erase the original descriptor
    17901794        eraseDescriptor(ld->overlayId);
     1795        return true;
    17911796}
    17921797
     
    21822187void BaseOverlay::dhtPut( const Data& key, const Data& value, int ttl, bool replace, bool no_local_refresh ) {
    21832188
    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
    21882191        );
    21892192
  • source/ariba/overlay/OverlayBootstrap.h

    r5967 r6919  
    106106                        nodeid = rhs.nodeid;
    107107                        endpoint = rhs.endpoint;
     108                        return *this;
    108109                }
    109110
  • source/ariba/overlay/messages/DHTMessage.cpp

    r6835 r6919  
    1010DHTMessage::DHTMessage() {
    1111        this->key.setLength(0);
    12         this->ttl =0 ;
     12        this->ttl = 0;
    1313        this->replace = false;
    1414}
     
    1818        this->hash = NodeID::sha1( key.getBuffer(), key.getLength() / 8 );
    1919        this->key = key.clone();
    20         this->ttl =0 ;
     20        this->ttl = 0;
    2121        this->replace = false;
    2222}
     
    2626        this->hash = NodeID::sha1( key.getBuffer(), key.getLength() / 8 );
    2727        this->key = key.clone();
    28         this->values.push_back(  value.clone() );
    29         this->ttl =0 ;
     28        this->values.push_back( value.clone() );
     29        this->ttl = 0;
    3030        this->replace = false;
    3131}
    3232
    3333DHTMessage::DHTMessage( const Data& key, const vector<Data>& values ) {
     34        this->hash = NodeID::sha1( key.getBuffer(), key.getLength() / 8 );
    3435        this->key = key.clone();
    3536        BOOST_FOREACH(const Data value, values )
    36                         this->values.push_back( value.clone() );
     37                this->values.push_back( value.clone() );
     38        this->ttl = 0;
    3739        this->replace = false;
    3840}
  • source/ariba/overlay/messages/DHTMessage.h

    r6835 r6919  
    3333
    3434        bool hasValues() const {
    35                 values.size() != 0;
     35                return values.size() != 0;
    3636        }
    3737
  • source/ariba/overlay/messages/OverlayMsg.h

    r6266 r6919  
    213213        uint8_t increaseNumHops() {
    214214                hops++;
     215                return hops;
    215216        }
    216217
  • source/ariba/overlay/modules/OverlayInterface.h

    r6854 r6919  
    179179        BaseOverlay& baseoverlay;
    180180
    181         /// The parameters of the overlay structure
    182         OverlayParameterSet parameters;
    183 
    184181        /// The node identifier to use with this overlay
    185182        const NodeID& nodeid;
     
    187184        /// The listener used to inform about overlay structure changes
    188185        OverlayStructureEvents* eventsReceiver;
     186
     187        /// The parameters of the overlay structure
     188        OverlayParameterSet parameters;
    189189
    190190        /// The service identifer of this overlay
  • source/ariba/overlay/modules/chord/Chord.cpp

    r6854 r6919  
    7979
    8080        // check if we already have a connection
    81         for (int i=0; i<table->size(); i++)
     81        for (size_t i=0; i<table->size(); i++)
    8282                if ((*table)[i]->ref_count > 0 && (*table)[i]->id == remote && !((*table)[i]->info.isUnspecified()))
    8383                        return LinkID::UNSPECIFIED;
     
    291291
    292292        // handle messages
    293         switch (m->getType()) {
     293        switch ((signalMessageTypes)m->getType()) {
    294294
    295295        // discovery request
     
    317317                        setup( dmsg->getEndpoint(), m->getSourceNode() );
    318318
    319                 // delegate discovery message
     319                // process discovery message -------------------------- switch start --
    320320                switch (dmsg->getType()) {
    321321
     
    388388                        baseoverlay.send(&omsg, omsg.getDestinationNode());
    389389                        break;
    390                 }}
     390                }
     391                case Discovery::invalid:
     392                        break;
     393
     394                default:
     395                        break;
     396                }
     397                // process discovery message ---------------------------- switch end --
     398
    391399                delete dmsg;
    392400                break;
     
    426434                // updating neighbors
    427435                logging_debug("Discover new ring neighbors");
    428                 for (int i=0; i<table->size(); i++) {
     436                for (size_t i=0; i<table->size(); i++) {
    429437                        LinkID id = (*table)[i]->info;
    430438                        if (!id.isUnspecified()) discover_neighbors(id);
  • source/ariba/overlay/modules/chord/detail/chord_routing_table.hpp

    r5902 r6919  
    9292private:
    9393        // maximum number of fingers
    94         static const int max_fingers = 32;
     94        static const size_t max_fingers = 32;
    9595
    9696        // the own node id
  • source/ariba/overlay/modules/onehop/OneHop.cpp

    r6266 r6919  
    241241        if( onemsg->isType( OneHopMessage::OneHopMessageTypeListingRequest ) ){
    242242
    243                 NodeListingRequest* request = onemsg->decapsulate<NodeListingRequest>();
     243                //NodeListingRequest* request = onemsg->decapsulate<NodeListingRequest>();
    244244
    245245                logging_info( "onehop received node listing request from node " << remote.toString() );
Note: See TracChangeset for help on using the changeset viewer.