#NEWLINE# def save_uplink( self , context , msg ) : #NEWLINE# #INDENT# args = jsonutils . loads ( msg ) #NEWLINE# agent = args . get ( 'agent' ) #NEWLINE# uplink = args . get ( 'uplink' ) #NEWLINE# veth_intf = args . get ( 'veth_intf' ) #NEWLINE# configs = self . obj . get_agent_configurations ( agent ) #NEWLINE# if configs : #NEWLINE# #INDENT# new_config = jsonutils . loads ( configs ) #NEWLINE# new_config . update ( { #NEWLINE# #INDENT# 'uplink' : uplink , #NEWLINE# 'veth_intf' : msg , #NEWLINE# #UNINDENT# } ) #NEWLINE# if self . obj . update_agent_configurations ( agent , jsonutils . dumps ( new_config ) ) : #NEWLINE# #INDENT# LOG . debug ( 'Saved %(uplink)s %(veth)s for %(agent)s in DB.' , { #NEWLINE# #INDENT# 'uplink' : uplink , #NEWLINE# 'veth' : veth_intf , #NEWLINE# 'agent' : agent , #NEWLINE# #UNINDENT# } ) #NEWLINE# if uplink : #NEWLINE# #INDENT# self . request_vms_info ( context , agent ) #NEWLINE# #UNINDENT# return True #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# return False