daemon/core/session.py
def broadcast(self, src, msg):
        ''' Send Node and Link CORE API messages to all handlers connected to this session.
        '''
        self._handlerslock.acquire()
        for handler in self._handlers:
            if handler == src:
                continue
            if isinstance(msg, coreapi.CoreNodeMessage) or \
                    isinstance(msg, coreapi.CoreLinkMessage):
                try:
                    handler.sendall(msg.rawmsg)
                except Exception, e:
                    self.warn("sendall() error: %s" % e)
        self._handlerslock.release()
 Send Node and Link CORE API messages to all handlers connected to this session.
        
Send Node and Link CORE API messages to all handlers connected to this session.
Send Node and Link CORE API messages to all handlers connected to this session .
def broadcast(self, src, msg):
        self._handlerslock.acquire()
        for handler in self._handlers:
            if handler == src:
                continue
            if isinstance(msg, coreapi.CoreNodeMessage) or \
                    isinstance(msg, coreapi.CoreLinkMessage):
                try:
                    handler.sendall(msg.rawmsg)
                except Exception, e:
                    self.warn("sendall() error: %s" % e)
        self._handlerslock.release()
def broadcast ( self , src , msg ) : self . _handlerslock . acquire ( ) for handler in self . _handlers : if handler == src : continue if isinstance ( msg , coreapi . CoreNodeMessage ) or isinstance ( msg , coreapi . CoreLinkMessage ) : try : handler . sendall ( msg . rawmsg ) except Exception , e : self . warn ( "sendall() error: %s" % e ) self . _handlerslock . release ( )
Send Node and Link CORE API messages to all handlers connected to this session.
Send Node and Link CORE API messages to all handlers connected to this session .
''' Send Node and Link CORE API messages to all handlers connected to this session.
        '''
self
src
msg