openstack
/
octavia
Code Issues Proposed changes

Merge "Fix compile_amphora_details when using UDP listeners" into stable/train

This commit is contained in:
Zuul 2022-06-29 17:21:58 +00:00 committed by Gerrit Code Review
parent 5be32ed740 3637fe83fb
commit ff38e3b57d
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
octavia/amphorae/backends/agent/api_server/amphora_info.py
View File

@ -111,7 +111,7 @@ class AmphoraInfo(object):
def _count_udp_listener_processes(self, udp_driver, listener_list):
num = 0
for listener_id in listener_list:
if udp_driver.is_listener_running(listener_id):
if util.is_udp_listener_running(listener_id):
# optional check if it's still running
num += 1
return num

13
octavia/tests/unit/amphorae/backends/agent/api_server/test_amphora_info.py
View File

@ -183,6 +183,8 @@ class TestAmphoraInfo(base.TestCase):
self.assertEqual(expected_dict, actual.json)
api_server.VERSION = original_version
@mock.patch('octavia.amphorae.backends.agent.api_server.util.'
'is_udp_listener_running')
@mock.patch('octavia.amphorae.backends.agent.api_server.util.'
'get_udp_listeners',
return_value=[FAKE_LISTENER_ID_3, FAKE_LISTENER_ID_4])
@ -205,7 +207,8 @@ class TestAmphoraInfo(base.TestCase):
def test_compile_amphora_details_for_udp(self, mhostname, m_count,
m_pkg_version, m_load, m_get_nets,
m_os, m_cpu, mget_mem,
mock_get_lb, mget_udp_listener):
mock_get_lb, mget_udp_listener,
mock_is_udp_listener_running):
mget_mem.return_value = {'SwapCached': 0, 'Buffers': 344792,
'MemTotal': 21692784, 'Cached': 4271856,
'Slab': 534384, 'MemFree': 12685624,
@ -227,7 +230,7 @@ class TestAmphoraInfo(base.TestCase):
m_count.return_value = 5
self.udp_driver.get_subscribed_amp_compile_info.return_value = [
'keepalived', 'ipvsadm']
self.udp_driver.is_listener_running.side_effect = [True, False]
mock_is_udp_listener_running.side_effect = [True, False]
mock_get_lb.return_value = [self.LB_ID_1]
original_version = api_server.VERSION
api_server.VERSION = self.API_VERSION
@ -282,8 +285,10 @@ class TestAmphoraInfo(base.TestCase):
[uuidutils.generate_uuid(), uuidutils.generate_uuid()])
self.assertEqual(1, result)
def test__count_udp_listener_processes(self):
self.udp_driver.is_listener_running.side_effect = [True, False, True]
@mock.patch('octavia.amphorae.backends.agent.api_server.util.'
'is_udp_listener_running')
def test__count_udp_listener_processes(self, mock_is_udp_listener_running):
mock_is_udp_listener_running.side_effect = [True, False, True]
expected = 2
actual = self.amp_info._count_udp_listener_processes(
self.udp_driver, [self.FAKE_LISTENER_ID_1,