openstack/neutron
Code Issues Proposed changes

Merge "Add extra logs to the ip_monitor class"

Browse Source
This commit is contained in:
Zuul 2022-03-25 12:49:49 +00:00 committed by Gerrit Code Review
commit f09ff28ef2
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
neutron/agent/linux/ip_lib.py
View File

@ -1474,6 +1474,8 @@ def ip_monitor(namespace, queue, event_stop, event_started):
while True: while True:
ip_addresses = _ip.get() ip_addresses = _ip.get()
for ip_address in ip_addresses: for ip_address in ip_addresses:
LOG.debug("IP monitor %s; Adding IP address: %s "
"to the queue.", namespace, ip_address)
_queue.put(ip_address) _queue.put(ip_address)
except EOFError: except EOFError:
pass pass
@ -1493,6 +1495,8 @@ def ip_monitor(namespace, queue, event_stop, event_started):
while not event_stop.is_set(): while not event_stop.is_set():
try: try:
ip_address = _queue.get(timeout=1) ip_address = _queue.get(timeout=1)
LOG.debug("IP monitor %s; IP address to process: %s",
namespace, ip_address)
except eventlet.queue.Empty: except eventlet.queue.Empty:
continue continue
if 'index' in ip_address and 'prefixlen' in ip_address: if 'index' in ip_address and 'prefixlen' in ip_address:
@ -1502,6 +1506,8 @@ def ip_monitor(namespace, queue, event_stop, event_started):
if not name: if not name:
continue continue
LOG.debug("IP monitor %s; Queueing IP address: %s; device: %s",
namespace, ip_address, name)
cache_devices[index] = name cache_devices[index] = name
queue.put(_parse_ip_address(ip_address, name)) queue.put(_parse_ip_address(ip_address, name))