daemon/core/emane/emane.py
def handledistributed(self, msg):
        ''' Broker handler for processing CORE API messages as they are
            received. This is used to snoop the Link add messages to get NEM
            counts of NEMs that exist on other servers.
        '''
        if msg.msgtype == coreapi.CORE_API_LINK_MSG and \
           msg.flags & coreapi.CORE_API_ADD_FLAG:
            nn = msg.nodenumbers()
            # first node is always link layer node in Link add message
            if nn[0] in self.session.broker.nets:
                serverlist = self.session.broker.getserversbynode(nn[1])
                for server in serverlist:
                    self._ifccountslock.acquire()
                    if server not in self._ifccounts:
                        self._ifccounts[server] = 1
                    else:
                        self._ifccounts[server] += 1
                    self._ifccountslock.release()
 Broker handler for processing CORE API messages as they are
            received. This is used to snoop the Link add messages to get NEM
            counts of NEMs that exist on other servers.
        
Broker handler for processing CORE API messages as they are
received. This is used to snoop the Link add messages to get NEM
counts of NEMs that exist on other servers.
Broker handler for processing CORE API messages as they are received . This is used to snoop the Link add messages to get NEM counts of NEMs that exist on other servers .
def handledistributed(self, msg):
        if msg.msgtype == coreapi.CORE_API_LINK_MSG and \
           msg.flags & coreapi.CORE_API_ADD_FLAG:
            nn = msg.nodenumbers()
            if nn[0] in self.session.broker.nets:
                serverlist = self.session.broker.getserversbynode(nn[1])
                for server in serverlist:
                    self._ifccountslock.acquire()
                    if server not in self._ifccounts:
                        self._ifccounts[server] = 1
                    else:
                        self._ifccounts[server] += 1
                    self._ifccountslock.release()
def handledistributed ( self , msg ) : if msg . msgtype == coreapi . CORE_API_LINK_MSG and msg . flags & coreapi . CORE_API_ADD_FLAG : nn = msg . nodenumbers ( ) if nn [ 0 ] in self . session . broker . nets : serverlist = self . session . broker . getserversbynode ( nn [ 1 ] ) for server in serverlist : self . _ifccountslock . acquire ( ) if server not in self . _ifccounts : self . _ifccounts [ server ] = 1 else : self . _ifccounts [ server ] += 1 self . _ifccountslock . release ( )
Broker handler for processing CORE API messages as they are
received.
Broker handler for processing CORE API messages as they are received .
''' Broker handler for processing CORE API messages as they are
            received. This is used to snoop the Link add messages to get NEM
            counts of NEMs that exist on other servers.
        ''' # first node is always link layer node in Link add message
self
msg