Merge "fix haproxy_count to display the number of running processes"

Author: Zuul

octavia/amphorae/backends/agent/api_server/amphora_info.py

@@ -48,6 +48,7 @@ def compile_amphora_info(self, extend_lvs_driver=None):
         return webob.Response(json=body)
 
     def compile_amphora_details(self, extend_lvs_driver=None):
+        haproxy_loadbalancer_list = sorted(util.get_loadbalancers())
         haproxy_listener_list = sorted(util.get_listeners())
         extend_body = {}
         lvs_listener_list = []
@@ -73,7 +74,7 @@ def compile_amphora_details(self, extend_lvs_driver=None):
                 'networks': self._get_networks(),
                 'active': True,
                 'haproxy_count':
-                    self._count_haproxy_processes(haproxy_listener_list),
+                    self._count_haproxy_processes(haproxy_loadbalancer_list),
                 'cpu_count': os.cpu_count(),
                 'cpu': {
                     'total': cpu['total'],

octavia/tests/unit/amphorae/backends/agent/api_server/test_amphora_info.py

@@ -39,6 +39,7 @@ class TestAmphoraInfo(base.TestCase):
     FAKE_LISTENER_ID_3 = uuidutils.generate_uuid()
     FAKE_LISTENER_ID_4 = uuidutils.generate_uuid()
     LB_ID_1 = uuidutils.generate_uuid()
+    LB_ID_2 = uuidutils.generate_uuid()
 
     def setUp(self):
         super().setUp()
@@ -113,6 +114,8 @@ def test_compile_amphora_info_for_udp(self, mock_gethostname,
     @mock.patch('octavia.amphorae.backends.agent.api_server.util.'
                 'get_listeners', return_value=[FAKE_LISTENER_ID_1,
                                                FAKE_LISTENER_ID_2])
+    @mock.patch('octavia.amphorae.backends.agent.api_server.util.'
+                'get_loadbalancers', return_value=[LB_ID_1, LB_ID_2])
     @mock.patch('octavia.amphorae.backends.agent.api_server.'
                 'amphora_info.AmphoraInfo._get_meminfo')
     @mock.patch('octavia.amphorae.backends.agent.api_server.'
@@ -129,7 +132,8 @@ def test_compile_amphora_info_for_udp(self, mock_gethostname,
     @mock.patch('socket.gethostname', return_value='FAKE_HOST')
     def test_compile_amphora_details(self, mhostname, m_count, m_pkg_version,
                                      m_load, m_get_nets, m_os, m_cpu,
-                                     mget_mem, mget_listener):
+                                     mget_mem, mget_loadbalancers,
+                                     mget_listeners):
         mget_mem.return_value = {'SwapCached': 0, 'Buffers': 344792,
                                  'MemTotal': 21692784, 'Cached': 4271856,
                                  'Slab': 534384, 'MemFree': 12685624,
@@ -183,6 +187,7 @@ def test_compile_amphora_details(self, mhostname, m_count, m_pkg_version,
                          u'topology_status': u'OK'}
         actual = self.amp_info.compile_amphora_details()
         self.assertEqual(expected_dict, actual.json)
+        m_count.assert_called_once_with(sorted(mget_loadbalancers()))
         api_server.VERSION = original_version
 
     @mock.patch('octavia.amphorae.backends.agent.api_server.util.'

releasenotes/notes/fix-amphora-haproxy-count-b1b1df43a7150926.yaml

@@ -0,0 +1,5 @@
+---
+fixes:
+  - |
+    Fix amphora haproxy_count to return the number of
+    haproxy processes that are running.