Add logging in get_ports for all plugins

This will help debug performance issues

Change-Id: I60cfc8261c7b5f78a907d54822ce9fe126f2fc0d
This commit is contained in:
asarfaty 2019-12-12 09:34:07 +02:00 committed by Adit Sarfaty
parent 50b93766ef
commit b9dcadc148
5 changed files with 12 additions and 0 deletions

View File

@ -441,6 +441,14 @@ class NsxPluginBase(db_base_plugin_v2.NeutronDbPluginV2,
sg_rule[sg_prefix.LOCAL_IP_PREFIX].startswith('::/'))):
sg_rule[sg_prefix.LOCAL_IP_PREFIX] = None
def _log_get_ports(self, ports, filters):
if len(ports) > 0:
LOG.debug("Getting %(num)s port%(plural)s with %(filters)s",
{'len': len(ports),
'plural': 's' if len(ports) > 1 else '',
'filters': ('filters ' + str(filters) if filters
else 'no filters')})
def get_housekeeper(self, context, name, fields=None):
# run the job in readonly mode and get the results
self.housekeeper.run(context, name, readonly=True)

View File

@ -603,6 +603,7 @@ class NsxDvsV2(addr_pair_db.AllowedAddressPairsMixin,
super(NsxDvsV2, self).get_ports(
context, filters, fields, sorts,
limit, marker, page_reverse))
self._log_get_ports(ports, filters)
# Add port extensions
for port in ports:
self.plugin_extend_port_dict_binding(context, port)

View File

@ -1461,6 +1461,7 @@ class NsxPolicyPlugin(nsx_plugin_common.NsxPluginV3Base):
super(NsxPolicyPlugin, self).get_ports(
context, filters, fields, sorts,
limit, marker, page_reverse))
self._log_get_ports(ports, filters)
# Add port extensions
for port in ports[:]:
self._extend_nsx_port_dict_binding(context, port)

View File

@ -2721,6 +2721,7 @@ class NsxVPluginV2(addr_pair_db.AllowedAddressPairsMixin,
super(NsxVPluginV2, self).get_ports(
context, filters, fields, sorts,
limit, marker, page_reverse))
self._log_get_ports(ports, filters)
# Add the relevant port extensions
for port in ports[:]:
self._extend_get_port_dict_qos_and_binding(context, port)

View File

@ -2055,6 +2055,7 @@ class NsxV3Plugin(nsx_plugin_common.NsxPluginV3Base,
super(NsxV3Plugin, self).get_ports(
context, filters, fields, sorts,
limit, marker, page_reverse))
self._log_get_ports(ports, filters)
# Add port extensions
for port in ports[:]:
self._extend_get_port_dict_qos_and_binding(context, port)