x/vmware-nsx
Code Issues Proposed changes

Add logging for NSX status sync cache

Browse Source 
This patch simply adds some log statements with debug
severity for tracking events related to the NSX object
cache kept by the operational status synchronization
thread.

This will  be helpful when debugging error conditions.

Change-Id: Ieb7b44b1117048c126d275dea2b8503b85eaba04
Related-Bug: 1329560
This commit is contained in:
Salvatore Orlando 2014-06-12 16:38:43 -07:00
parent c27e29a6ca
commit f86a5fce0d
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
neutron/plugins/vmware/common/sync.py
View File

@ -78,6 +78,7 @@ class NsxCache(object):
# The item is not anymore in NSX, so delete it # The item is not anymore in NSX, so delete it
del resources[uuid] del resources[uuid]
del self._uuid_dict_mappings[uuid] del self._uuid_dict_mappings[uuid]
LOG.debug("Removed item %s from NSX object cache", uuid)
def do_hash(item): def do_hash(item):
return hash(jsonutils.dumps(item)) return hash(jsonutils.dumps(item))
@ -95,6 +96,7 @@ class NsxCache(object):
resources[item_id]['data'] = item resources[item_id]['data'] = item
# Mark the item as hit in any case # Mark the item as hit in any case
resources[item_id]['hit'] = True resources[item_id]['hit'] = True
LOG.debug("Updating item %s in NSX object cache", item_id)
else: else:
resources[item_id] = {'hash': do_hash(item)} resources[item_id] = {'hash': do_hash(item)}
resources[item_id]['hit'] = True resources[item_id]['hit'] = True
@ -103,6 +105,7 @@ class NsxCache(object):
# add a uuid to dict mapping for easy retrieval # add a uuid to dict mapping for easy retrieval
# with __getitem__ # with __getitem__
self._uuid_dict_mappings[item_id] = resources self._uuid_dict_mappings[item_id] = resources
LOG.debug("Added item %s to NSX object cache", item_id)
def _delete_resources(self, resources): def _delete_resources(self, resources):
# Mark for removal all the elements which have not been visited. # Mark for removal all the elements which have not been visited.
@ -622,12 +625,14 @@ class NsxSynchronizer():
LOG.debug(_("Number of chunks: %d"), num_chunks) LOG.debug(_("Number of chunks: %d"), num_chunks)
# Find objects which have changed on NSX side and need # Find objects which have changed on NSX side and need
# to be synchronized # to be synchronized
LOG.debug("Processing NSX cache for updated objects")
(ls_uuids, lr_uuids, lp_uuids) = self._nsx_cache.process_updates( (ls_uuids, lr_uuids, lp_uuids) = self._nsx_cache.process_updates(
lswitches, lrouters, lswitchports) lswitches, lrouters, lswitchports)
# Process removed objects only at the last chunk # Process removed objects only at the last chunk
scan_missing = (sp.current_chunk == num_chunks - 1 and scan_missing = (sp.current_chunk == num_chunks - 1 and
not sp.init_sync_performed) not sp.init_sync_performed)
if sp.current_chunk == num_chunks - 1: if sp.current_chunk == num_chunks - 1:
LOG.debug("Processing NSX cache for deleted objects")
self._nsx_cache.process_deletes() self._nsx_cache.process_deletes()
ls_uuids = self._nsx_cache.get_lswitches( ls_uuids = self._nsx_cache.get_lswitches(
changed_only=not scan_missing) changed_only=not scan_missing)