daemon/core/broker.py
def forwardmsg(self, msg, serverlist, handle_locally):
        ''' Forward API message to all servers in serverlist; if an empty 
            host/port is encountered, set the handle_locally flag. Returns the
            value of the handle_locally flag, which may be unchanged.
        '''
        for server in serverlist:
            try:
                (host, port, sock) = self.getserver(server)
            except KeyError:
                # server not found, don't handle this message locally
                self.session.info("broker could not find server %s, message " \
                                  "with type %s dropped" % \
                                  (server, msg.msgtype))
                continue
            if host is None and port is None:
                # local emulation server, handle this locally
                handle_locally = True
            else:
                if sock is None:
                    self.session.info("server %s @ %s:%s is disconnected" % \
                                      (server, host, port))
                else:
                    sock.send(msg.rawmsg)
        return handle_locally
 Forward API message to all servers in serverlist; if an empty 
            host/port is encountered, set the handle_locally flag. Returns the
            value of the handle_locally flag, which may be unchanged.
        
Forward API message to all servers in serverlist; if an empty
host/port is encountered, set the handle_locally flag. Returns the
value of the handle_locally flag, which may be unchanged.
Forward API message to all servers in serverlist ; if an empty host / port is encountered set the handle_locally flag . Returns the value of the handle_locally flag which may be unchanged .
def forwardmsg(self, msg, serverlist, handle_locally):
        for server in serverlist:
            try:
                (host, port, sock) = self.getserver(server)
            except KeyError:
                self.session.info("broker could not find server %s, message " \
                                  "with type %s dropped" % \
                                  (server, msg.msgtype))
                continue
            if host is None and port is None:
                handle_locally = True
            else:
                if sock is None:
                    self.session.info("server %s @ %s:%s is disconnected" % \
                                      (server, host, port))
                else:
                    sock.send(msg.rawmsg)
        return handle_locally
def forwardmsg ( self , msg , serverlist , handle_locally ) : for server in serverlist : try : ( host , port , sock ) = self . getserver ( server ) except KeyError : self . session . info ( "broker could not find server %s, message " "with type %s dropped" % ( server , msg . msgtype ) ) continue if host is None and port is None : handle_locally = True else : if sock is None : self . session . info ( "server %s @ %s:%s is disconnected" % ( server , host , port ) ) else : sock . send ( msg . rawmsg ) return handle_locally
Forward API message to all servers in serverlist; if an empty
host/port is encountered, set the handle_locally flag.
Forward API message to all servers in serverlist ; if an empty host / port is encountered set the handle_locally flag .
''' Forward API message to all servers in serverlist; if an empty 
            host/port is encountered, set the handle_locally flag. Returns the
            value of the handle_locally flag, which may be unchanged.
        ''' # server not found, don't handle this message locally # local emulation server, handle this locally
self
msg
serverlist
handle_locally