openstack/neutron
Code Issues Proposed changes

Merge "Reduce to 1 thread the processing of `IpConntrackManager` events"

Browse Source
This commit is contained in:
Zuul
2024-08-02 16:04:30 +00:00
committed by Gerrit Code Review
parent f4ab100d88 23b9077df5
commit 0666008f78
1 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
neutron/agent/linux/ip_conntrack.py
View File

@@ -27,8 +27,6 @@ CONTRACK_MGRS = {}
MAX_CONNTRACK_ZONES = 65535 MAX_CONNTRACK_ZONES = 65535
ZONE_START = 4097 ZONE_START = 4097
WORKERS = 8
class IpConntrackUpdate(object): class IpConntrackUpdate(object):
"""Encapsulates a conntrack update """Encapsulates a conntrack update
@@ -74,13 +72,8 @@ class IpConntrackManager(object):
self.zone_per_port = zone_per_port # zone per port vs per network self.zone_per_port = zone_per_port # zone per port vs per network
self._populate_initial_zone_map() self._populate_initial_zone_map()
self._queue = eventlet.queue.LightQueue() self._queue = eventlet.queue.LightQueue()
self._start_process_queue() LOG.debug('Starting the ip_conntrack _process_queue_worker() thread')
eventlet.spawn_n(self._process_queue_worker)
def _start_process_queue(self):
LOG.debug("Starting ip_conntrack _process_queue_worker() threads")
pool = eventlet.GreenPool(size=WORKERS)
for i in range(WORKERS):
pool.spawn_n(self._process_queue_worker)
def _process_queue_worker(self): def _process_queue_worker(self):
# While it's technically not necessary to have this method, the # While it's technically not necessary to have this method, the