Changeset 5900 for source/ariba/overlay


Ignore:
Timestamp:
Aug 12, 2009, 5:41:11 PM (15 years ago)
Author:
mies
Message:
 
File:
1 edited

Legend:

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

    r5897 r5900  
    272272        next_link = getRelayLinkTo( destination );
    273273        if (next_link != NULL) {
    274                 next_link->setRelaying();
     274                if (message->isRelayed()) next_link->setRelaying();
    275275                return send(message, next_link);
    276276        }
     
    315315        // handle relayed link
    316316        if (ldr->relayed) {
    317                 logging_debug("send(): Resolving direct link for relayed link to "
     317                logging_debug("Resolving direct link for relayed link to "
    318318                        << ldr->remoteNode);
    319                 ld = getRelayLinkTo( ldr->remoteNode );
    320                 if (ld==NULL) {
    321                         LinkID lnk = overlayInterface->getNextLinkId(ldr->remoteNode);
    322                         if (!lnk.isUnspecified())
    323                                 ld = getDescriptor(lnk);
    324                         if (ld!=NULL && ld->relayed)
    325                                 ld = NULL;
    326                 }
    327                 if (ld==NULL) {
    328                         logging_error("Direct link not found.");
    329                         return -1;
    330                 }
    331319                message->setRelayed();
    332                 ld->setRelaying();
     320                send(message, ldr->remoteNode);
    333321        } else
    334322                ld = ldr;
     
    339327                return bc->sendMessage( ld->communicationId, message );
    340328        } else {
    341                 logging_error("send(): Could not send mesage. "
     329                logging_error("send(): Could not send message. "
    342330                                "Not a relayed link and direct link is not up.");
    343331                return -1;
Note: See TracChangeset for help on using the changeset viewer.