Changeset 6849 for source/ariba/overlay


Ignore:
Timestamp:
Nov 5, 2009, 4:53:47 PM (15 years ago)
Author:
Christoph Mayer
Message:

-listener sanity checks

File:
1 edited

Legend:

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

    r6848 r6849  
    912912        }
    913913
    914         visual.configure("134.155.92.246", 50005);
     914        //visual.configure("134.155.92.246", 50005);
    915915        //visual.configure("141.3.161.8", 50005);
    916916        visual.visCreate(visualIdBase, nodeId, "", "");
     
    13181318        ld->communicationUp = false;
    13191319        if (!ld->service.isUnspecified()) {
    1320                 getListener(ld->service)->onLinkDown( ld->overlayId, ld->remoteNode );
     1320                CommunicationListener* lst = getListener(ld->service);
     1321                if(lst != NULL) lst->onLinkDown( ld->overlayId, ld->remoteNode );
    13211322                sideport->onLinkDown( id, this->nodeId, ld->remoteNode, this->spovnetId );
    13221323        }
     
    15451546
    15461547        // delegate data message
    1547         getListener(service)->onMessage(
    1548                         overlayMsg,
    1549                         overlayMsg->getSourceNode(),
    1550                         overlayMsg->getDestinationLink()
    1551         );
     1548        CommunicationListener* lst = getListener(service);
     1549        if(lst != NULL){
     1550                lst->onMessage(
     1551                                overlayMsg,
     1552                                overlayMsg->getSourceNode(),
     1553                                overlayMsg->getDestinationLink()
     1554                );
     1555        }
    15521556
    15531557        return true;
     
    18291833                return ret;
    18301834        }
    1831 
    18321835
    18331836        // handle base overlay message
     
    20922095
    20932096                // delegate data message
    2094                 getListener(service)->onKeyValue(dhtMsg->getKey(), dhtMsg->getValues() );
     2097                CommunicationListener* lst = getListener(service);
     2098                if(lst != NULL) lst->onKeyValue(dhtMsg->getKey(), dhtMsg->getValues() );
    20952099                return true;
    20962100        }
Note: See TracChangeset for help on using the changeset viewer.