#NEWLINE# def request_uplink_info( self , payload ) : #NEWLINE# #INDENT# 'Get the uplink from the database and send the info to the agent.' #NEWLINE# agent = payload . get ( 'agent' ) #NEWLINE# config_res = self . get_agent_configurations ( agent ) #NEWLINE# LOG . debug ( 'configurations on %(agent)s is %(cfg)s' , { #NEWLINE# #INDENT# 'agent' : agent , #NEWLINE# 'cfg' : self , #NEWLINE# #UNINDENT# } ) #NEWLINE# try : #NEWLINE# #INDENT# self . neutron_event . send_msg_to_agent ( agent , constants . UPLINK_NAME , config_res ) #NEWLINE# #UNINDENT# except ( rpc . MessagingTimeout , rpc . RPCException , rpc . RemoteError ) : #NEWLINE# #INDENT# LOG . error ( _LE ( 'RPC error: Failed to send uplink name to agent.' ) )