daemon/core/emane/emane.py
def eventmonitorloop(self):
        ''' Thread target that monitors EMANE location events.
        '''
        if self.service is None:
            return
        self.info("Subscribing to EMANE location events (not generating them). " \
                  "(%s) " % threading.currentThread().getName())
        while self.doeventloop is True:
            if self.version >= self.EMANE091:
                (uuid, seq, events) = self.service.nextEvent()
                if not self.doeventloop:
                    break # this occurs with 0.9.1 event service
                for event in events:
                    (nem, eid, data) = event
                    if eid == LocationEvent.IDENTIFIER:
                        self.handlelocationevent2(nem, eid, data)
            else:
                (event, platform, nem, cmp, data) = self.service.nextEvent()
                if event == emaneeventlocation.EVENT_ID:
                    self.handlelocationevent(event, platform, nem, cmp, data)
        self.info("Unsubscribing from EMANE location events. (%s) " % \
                  threading.currentThread().getName())
 Thread target that monitors EMANE location events.
        
Thread target that monitors EMANE location events.
Thread target that monitors EMANE location events .
def eventmonitorloop(self):
        if self.service is None:
            return
        self.info("Subscribing to EMANE location events (not generating them). " \
                  "(%s) " % threading.currentThread().getName())
        while self.doeventloop is True:
            if self.version >= self.EMANE091:
                (uuid, seq, events) = self.service.nextEvent()
                if not self.doeventloop:
                    break 
                for event in events:
                    (nem, eid, data) = event
                    if eid == LocationEvent.IDENTIFIER:
                        self.handlelocationevent2(nem, eid, data)
            else:
                (event, platform, nem, cmp, data) = self.service.nextEvent()
                if event == emaneeventlocation.EVENT_ID:
                    self.handlelocationevent(event, platform, nem, cmp, data)
        self.info("Unsubscribing from EMANE location events. (%s) " % \
                  threading.currentThread().getName())
def eventmonitorloop ( self ) : if self . service is None : return self . info ( "Subscribing to EMANE location events (not generating them). " "(%s) " % threading . currentThread ( ) . getName ( ) ) while self . doeventloop is True : if self . version >= self . EMANE091 : ( uuid , seq , events ) = self . service . nextEvent ( ) if not self . doeventloop : break for event in events : ( nem , eid , data ) = event if eid == LocationEvent . IDENTIFIER : self . handlelocationevent2 ( nem , eid , data ) else : ( event , platform , nem , cmp , data ) = self . service . nextEvent ( ) if event == emaneeventlocation . EVENT_ID : self . handlelocationevent ( event , platform , nem , cmp , data ) self . info ( "Unsubscribing from EMANE location events. (%s) " % threading . currentThread ( ) . getName ( ) )
Thread target that monitors EMANE location events.
Thread target that monitors EMANE location events .
''' Thread target that monitors EMANE location events.
        ''' # this occurs with 0.9.1 event service
self