openstack/neutron-fwaas
Code Issues Proposed changes

Merge "LBaaS: update DB pool stats received from lbaas agent"

Browse Source
This commit is contained in:
Jenkins 2013-07-17 14:50:02 +00:00 committed by Gerrit Code Review
commit 7efd7957a2
3 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
neutron/db/loadbalancer/loadbalancer_db.py
View File

@ -459,7 +459,7 @@ class LoadBalancerPluginDb(LoadBalancerPluginBase,
return self._fields(res, fields)
def _update_pool_stats(self, context, pool_id, data=None):
def update_pool_stats(self, context, pool_id, data=None):
"""Update a pool with new stats structure."""
with context.session.begin(subtransactions=True):
pool_db = self._get_resource(context, Pool, pool_id)

3
neutron/services/loadbalancer/drivers/haproxy/plugin_driver.py
View File

@ -179,8 +179,7 @@ class LoadBalancerCallbacks(object):
LOG.debug(msg, port_id)
def update_pool_stats(self, context, pool_id=None, stats=None, host=None):
# TODO(markmcclain): add stats collection
pass
self.plugin.update_pool_stats(context, pool_id, data=stats)
class LoadBalancerAgentApi(proxy.RpcProxy):

6
neutron/tests/unit/db/loadbalancer/test_db_loadbalancer.py
View File

@ -931,7 +931,7 @@ class TestLoadBalancer(LoadBalancerPluginDbTestCase):
with self.pool() as pool:
pool_id = pool['pool']['id']
ctx = context.get_admin_context()
self.plugin._update_pool_stats(ctx, pool_id)
self.plugin.update_pool_stats(ctx, pool_id)
pool_obj = ctx.session.query(ldb.Pool).filter_by(id=pool_id).one()
for key in keys:
self.assertEqual(pool_obj.stats.__dict__[key], 0)
@ -948,7 +948,7 @@ class TestLoadBalancer(LoadBalancerPluginDbTestCase):
with self.pool() as pool:
pool_id = pool['pool']['id']
ctx = context.get_admin_context()
self.assertRaises(ValueError, self.plugin._update_pool_stats,
self.assertRaises(ValueError, self.plugin.update_pool_stats,
ctx, pool_id, {k: v})
def test_update_pool_stats(self):
@ -959,7 +959,7 @@ class TestLoadBalancer(LoadBalancerPluginDbTestCase):
with self.pool() as pool:
pool_id = pool['pool']['id']
ctx = context.get_admin_context()
self.plugin._update_pool_stats(ctx, pool_id, stats_data)
self.plugin.update_pool_stats(ctx, pool_id, stats_data)
pool_obj = ctx.session.query(ldb.Pool).filter_by(id=pool_id).one()
for k, v in stats_data.items():
self.assertEqual(pool_obj.stats.__dict__[k], v)