Ignore:
Timestamp:
Aug 7, 2009, 12:55:13 PM (15 years ago)
Author:
mies
Message:
 
Location:
source/ariba/overlay/modules/chord
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • source/ariba/overlay/modules/chord/Chord.cpp

    r5761 r5776  
    9292
    9393        // establish link via base overlay
    94         return baseoverlay.establishLink(endp, node, OverlayInterface::OVERLAY_SERVICE_ID, remoteRelay );
     94        return baseoverlay.establishLink(endp, node, OverlayInterface::OVERLAY_SERVICE_ID,
     95                        NodeID::UNSPECIFIED );
    9596}
    9697
     
    377378                                        logging_debug("Discovery split: routing discovery message to successor "
    378379                                                        << succ_item->id.toString() );
     380                                        cmsg_s.setDestination(succ_item->id);
    379381                                        send(&cmsg_s, succ_item->info);
    380382                                }
     
    390392                                        logging_debug("Discovery split: routing discovery message to predecessor "
    391393                                                        << pred_item->id.toString() );
     394                                        cmsg_p.setDestination(pred_item->id);
    392395                                        send(&cmsg_p, pred_item->info);
    393396                                }
     
    484487                orphan_removal_counter++;
    485488                if (orphan_removal_counter <0 || orphan_removal_counter >= 4) {
    486                         back_routes.clear();
     489                        for (vector<back_route>::iterator i = back_routes.begin();
     490                                        i!=back_routes.end(); i++) {
     491                                back_route& br = *i;
     492                                if (difftime(br.lastseen,time(NULL))>5) i =
     493                                                back_routes.erase(i);
     494                        }
    487495                        logging_info("Running orphan removal");
    488496                        orphan_removal_counter = 0;
  • source/ariba/overlay/modules/chord/messages/ChordMessage.h

    r4625 r5776  
    8888        }
    8989
     90        void setSource(const NodeID& source ) {
     91                this->source = source;
     92        }
     93
    9094        const NodeID& getSource() const {
    9195                return source;
     96        }
     97
     98        void setDestination(const NodeID& destination ) {
     99                this->destination = destination;
    92100        }
    93101
Note: See TracChangeset for help on using the changeset viewer.