openstack/neutron
Code Issues Proposed changes

Adding LOG statements to debug 1838449

Browse Source 
Adding LOG statements to debug 1838449

Change-Id: I6f9cbe2e6b4ea0f122f5f8318dbbc31fce6b61f4
Related-Bug: #1838449
This commit is contained in:
Miguel Lavalle 2019-08-18 20:27:15 -05:00
parent 88683b76ae
commit 12760c94c8
2 changed files with 19 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
neutron/api/rpc/handlers/l3_rpc.py
View File

@ -116,6 +116,9 @@ class L3RpcCallback(object):
router_ids = kwargs.get('router_ids') router_ids = kwargs.get('router_ids')
host = kwargs.get('host') host = kwargs.get('host')
context = neutron_context.get_admin_context() context = neutron_context.get_admin_context()
LOG.debug('Sync routers for ids %(router_ids)s in %(host)s',
{'router_ids': router_ids,
'host': host})
routers = self._routers_to_sync(context, router_ids, host) routers = self._routers_to_sync(context, router_ids, host)
if extensions.is_extension_supported( if extensions.is_extension_supported(
self.plugin, constants.PORT_BINDING_EXT_ALIAS): self.plugin, constants.PORT_BINDING_EXT_ALIAS):
@ -125,6 +128,10 @@ class L3RpcCallback(object):
pf_plugin = directory.get_plugin(plugin_constants.PORTFORWARDING) pf_plugin = directory.get_plugin(plugin_constants.PORTFORWARDING)
if pf_plugin: if pf_plugin:
pf_plugin.sync_port_forwarding_fip(context, routers) pf_plugin.sync_port_forwarding_fip(context, routers)
LOG.debug('The sync data for ids %(router_ids)s in %(host)s is: '
'%(routers)s', {'router_ids': router_ids,
'host': host,
'routers': routers})
return routers return routers
def _routers_to_sync(self, context, router_ids, host=None): def _routers_to_sync(self, context, router_ids, host=None):

12
neutron/db/l3_dvrscheduler_db.py
View File

@ -23,6 +23,7 @@ from neutron_lib.exceptions import l3 as l3_exc
from neutron_lib.plugins import constants as plugin_constants from neutron_lib.plugins import constants as plugin_constants
from neutron_lib.plugins import directory from neutron_lib.plugins import directory
from oslo_config import cfg from oslo_config import cfg
from oslo_log import helpers as log_helpers
from oslo_log import log as logging from oslo_log import log as logging
from sqlalchemy import or_ from sqlalchemy import or_
@ -410,6 +411,9 @@ class L3_DVRsch_db_mixin(l3agent_sch_db.L3AgentSchedulerDbMixin):
context, agent_db, router_ids, with_dvr)) context, agent_db, router_ids, with_dvr))
if not with_dvr: if not with_dvr:
return result_set return result_set
LOG.debug("Routers %(router_ids)s bound to L3 agent in host %(host)s",
{'router_ids': result_set,
'host': agent_db['host']})
router_ids = set(router_ids or []) router_ids = set(router_ids or [])
if router_ids and result_set == router_ids: if router_ids and result_set == router_ids:
# no need for extra dvr checks if requested routers are # no need for extra dvr checks if requested routers are
@ -436,13 +440,21 @@ class L3_DVRsch_db_mixin(l3agent_sch_db.L3AgentSchedulerDbMixin):
list(subnet_ids))): list(subnet_ids))):
result_set.add(router_id) result_set.add(router_id)
LOG.debug("Routers %(router_ids)s are scheduled or have "
"serviceable ports in host %(host)s",
{'router_ids': result_set,
'host': agent_db['host']})
for dvr_router in dvr_routers: for dvr_router in dvr_routers:
result_set |= set( result_set |= set(
self._get_other_dvr_router_ids_connected_router( self._get_other_dvr_router_ids_connected_router(
context, dvr_router)) context, dvr_router))
LOG.debug("Router IDs %(router_ids)s for agent in host %(host)s",
{'router_ids': result_set,
'host': agent_db['host']})
return list(result_set) return list(result_set)
@log_helpers.log_method_call
def _check_dvr_serviceable_ports_on_host(self, context, host, subnet_ids): def _check_dvr_serviceable_ports_on_host(self, context, host, subnet_ids):
"""Check for existence of dvr serviceable ports on host """Check for existence of dvr serviceable ports on host