def recv_rpc(self, context, payload):
        """Call from any thread"""
        logger.debug("Adding RPC payload to ControlBuffer queue: %s", payload)
        self.buf.put(('rpc', (context, payload)))
        with self.cv:
            self.cv.notifyAll()
def recv_rpc ( self , context , payload ) : logger . debug ( "Adding RPC payload to ControlBuffer queue: %s" , payload ) self . buf . put ( ( 'rpc' , ( context , payload ) ) ) with self . cv : self . cv . notifyAll ( )
Call from any thread