Changeset 5673 for source


Ignore:
Timestamp:
Aug 4, 2009, 5:13:50 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

    r5671 r5673  
    123123                dmsg.setSourceEndpoint(&baseoverlay.getEndpointDescriptor());
    124124                dmsg.setFollowType(Discovery::successor);
    125                 dmsg.setTTL((uint8_t)2);
     125                dmsg.setTTL((uint8_t)3);
    126126                cmsg.encapsulate(&dmsg);
    127127                send(&cmsg, lnk);
     
    133133                dmsg.setSourceEndpoint(&baseoverlay.getEndpointDescriptor());
    134134                dmsg.setFollowType(Discovery::predecessor);
    135                 dmsg.setTTL((uint8_t)2);
     135                dmsg.setTTL((uint8_t)3);
    136136                cmsg.encapsulate(&dmsg);
    137137                send(&cmsg, lnk);
     
    260260                logging_info("new orphan: " << remote.toString()
    261261                                << " with link " << lnk.toString());
     262                discover_neighbors( lnk );
    262263                table->insert_orphan(remote)->info = lnk;
    263264        }
     
    321322                // decapsulate message
    322323                Discovery* dmsg = m->decapsulate<Discovery> ();
    323                 logging_info("received discovery message with"
     324                logging_debug("received discovery message with"
    324325                            << " src=" << m->getSource().toString()
    325326                                << " dst=" << m->getDestination().toString()
     
    347348                                        cmsg_s.encapsulate(&dmsg_s);
    348349                                        route_item* succ_item = table->get(*table->get_successor());
    349                                         logging_info("Discovery split: routing discovery message to successor "
     350                                        logging_debug("Discovery split: routing discovery message to successor "
    350351                                                        << succ_item->id.toString() );
    351352                                        send(&cmsg_s, succ_item->info);
     
    360361                                        route_item* pred_item = table->get(
    361362                                                        *table->get_predesessor());
    362                                         logging_info("Discovery split: routing discovery message to predecessor "
     363                                        logging_debug("Discovery split: routing discovery message to predecessor "
    363364                                                        << pred_item->id.toString() );
    364365                                        send(&cmsg_p, pred_item->info);
     
    427428void Chord::eventFunction() {
    428429        stabilize_counter++;
    429         if (stabilize_counter < 0 || stabilize_counter == 1) {
     430        if (stabilize_counter < 0 || stabilize_counter == 3) {
    430431
    431432                // reset counter
     
    450451                const NodeID disc2 = table->get_finger_table(stabilize_finger).get_compare().get_center();
    451452                send_discovery_to(disc1);
    452 
    453                 if (table->get_successor() != NULL) {
    454                         route_item* succ_item = table->get(*table->get_successor());
    455                         if (!succ_item->info.isUnspecified()) discover_neighbors(succ_item->info);
    456                 }
    457 
    458                 // send predecessor message
    459                 if (table->get_predesessor() != NULL) {
    460                         route_item* pred_item = table->get(*table->get_predesessor());
    461                         if (!pred_item->info.isUnspecified()) discover_neighbors(pred_item->info);
    462                 }
    463 
    464453                if (disc1 != disc2)
    465454                        send_discovery_to(disc2);
     455
     456                for (int i=0; i<table->size(); i++) {
     457                        LinkID id = (*table)[i]->info;
     458                        if (!id.isUnspecified()) discover_neighbors(id);
     459                }
     460
    466461
    467462                // remove orphan links
  • source/ariba/overlay/modules/chord/detail/chord_routing_table.hpp

    r5665 r5673  
    167167public:
    168168        /// constructs the reactive chord routing table
    169         explicit chord_routing_table( const nodeid_t& id, int redundancy = 8 ) :
     169        explicit chord_routing_table( const nodeid_t& id, int redundancy = 2 ) :
    170170                id(id), succ( redundancy, succ_compare_type(this->id), *this ),
    171171                pred( redundancy, pred_compare_type(this->id), *this ) {
Note: See TracChangeset for help on using the changeset viewer.