#NEWLINE# def _process_floating_ips_dvr( self , context , routers_dict , floating_ips , host , agent ) : #NEWLINE# #INDENT# fip_sync_interfaces = None #NEWLINE# LOG . debug ( 'FIP Agent : %s ' , agent . id ) #NEWLINE# for floating_ip in floating_ips : #NEWLINE# #INDENT# router = routers_dict . get ( floating_ip [ 'router_id' ] ) #NEWLINE# if router : #NEWLINE# #INDENT# router_floatingips = router . get ( const . FLOATINGIP_KEY , [ ] ) #NEWLINE# if router [ 'distributed' ] : #NEWLINE# #INDENT# if ( ( floating_ip . get ( 'host' , None ) != host ) and ( floating_ip . get ( 'dest_host' ) is None ) ) : #NEWLINE# #INDENT# continue #NEWLINE# #UNINDENT# LOG . debug ( 'Floating IP host: %s' , floating_ip [ 'host' ] ) #NEWLINE# #UNINDENT# router_floatingips . append ( floating_ip ) #NEWLINE# router [ const . FLOATINGIP_KEY ] = router_floatingips #NEWLINE# if ( not fip_sync_interfaces ) : #NEWLINE# #INDENT# fip_sync_interfaces = self . _get_fip_sync_interfaces ( context , router . id ) #NEWLINE# LOG . debug ( 'FIP Agent ports: %s' , fip_sync_interfaces ) #NEWLINE# #UNINDENT# router [ l3_const . FLOATINGIP_AGENT_INTF_KEY ] = fip_sync_interfaces