Log the entity at driver entry

(cherry picked from commit f112a6c)

Author: zhaoqin-github

f5lbaasdriver/v2/bigip/driver_v2.py

@@ -152,6 +152,9 @@ def __init__(self, driver):
         self.driver = driver
         self.api_dict = None
 
+    def _log_entity(self, entity):
+        LOG.debug("Log the entity: %s", entity.to_api_dict())
+
     def _call_rpc(self, context, loadbalancer, entity, rpc_method, **kwargs):
         '''Perform operations common to create and delete for managers.'''
 
@@ -298,6 +301,9 @@ class LoadBalancerManager(EntityManager):
     @log_helpers.log_method_call
     def create(self, context, loadbalancer):
         """Create a loadbalancer."""
+
+        self._log_entity(loadbalancer)
+
         driver = self.driver
         try:
             agent, service = self._schedule_agent_create_service(
@@ -356,6 +362,10 @@ def create(self, context, loadbalancer):
     @log_helpers.log_method_call
     def update(self, context, old_loadbalancer, loadbalancer):
         """Update a loadbalancer."""
+
+        self._log_entity(old_loadbalancer)
+        self._log_entity(loadbalancer)
+
         driver = self.driver
         try:
             agent, service = self._schedule_agent_create_service(
@@ -383,6 +393,9 @@ def update(self, context, old_loadbalancer, loadbalancer):
     @log_helpers.log_method_call
     def delete(self, context, loadbalancer):
         """Delete a loadbalancer."""
+
+        self._log_entity(loadbalancer)
+
         driver = self.driver
         try:
             agent, service = self._schedule_agent_create_service(
@@ -443,6 +456,8 @@ class ListenerManager(EntityManager):
     def create(self, context, listener):
         """Create a listener."""
 
+        self._log_entity(listener)
+
         lb = listener.loadbalancer
         self.api_dict = listener.to_dict(
             loadbalancer=False, default_pool=False)
@@ -466,6 +481,9 @@ def append_listeners(context, loadbalancer, service):
     def update(self, context, old_listener, listener):
         """Update a listener."""
 
+        self._log_entity(old_listener)
+        self._log_entity(listener)
+
         driver = self.driver
         lb = listener.loadbalancer
         try:
@@ -486,6 +504,8 @@ def update(self, context, old_listener, listener):
     def delete(self, context, listener):
         """Delete a listener."""
 
+        self._log_entity(listener)
+
         lb = listener.loadbalancer
         self.api_dict = listener.to_dict(
             loadbalancer=False, default_pool=False)
@@ -527,6 +547,8 @@ def _get_pool_dict(self, pool):
     def create(self, context, pool):
         """Create a pool."""
 
+        self._log_entity(pool)
+
         lb = pool.loadbalancer
         self.api_dict = self._get_pool_dict(pool)
 
@@ -559,6 +581,9 @@ def append_pools_monitors(context, loadbalancer, service):
     def update(self, context, old_pool, pool):
         """Update a pool."""
 
+        self._log_entity(old_pool)
+        self._log_entity(pool)
+
         driver = self.driver
         lb = pool.loadbalancer
         try:
@@ -578,6 +603,8 @@ def update(self, context, old_pool, pool):
     def delete(self, context, pool):
         """Delete a pool."""
 
+        self._log_entity(pool)
+
         lb = pool.loadbalancer
         self.api_dict = self._get_pool_dict(pool)
 
@@ -611,6 +638,8 @@ class MemberManager(EntityManager):
     def create(self, context, member):
         """Create a member."""
 
+        self._log_entity(member)
+
         lb = member.pool.loadbalancer
 
         if self.driver.unlegacy_setting_placeholder_driver_side:
@@ -719,6 +748,9 @@ def create_bulk(self, context, members):
     def update(self, context, old_member, member):
         """Update a member."""
 
+        self._log_entity(old_member)
+        self._log_entity(member)
+
         driver = self.driver
         lb = member.pool.loadbalancer
         try:
@@ -737,6 +769,9 @@ def update(self, context, old_member, member):
     @log_helpers.log_method_call
     def delete(self, context, member):
         """Delete a member."""
+
+        self._log_entity(member)
+
         lb = member.pool.loadbalancer
         driver = self.driver
         try:
@@ -794,6 +829,8 @@ class HealthMonitorManager(EntityManager):
     def create(self, context, health_monitor):
         """Create a health monitor."""
 
+        self._log_entity(health_monitor)
+
         lb = health_monitor.pool.loadbalancer
         self.api_dict = health_monitor.to_dict(pool=False)
 
@@ -816,6 +853,9 @@ def append_pools_monitors(context, loadbalancer, service):
     def update(self, context, old_health_monitor, health_monitor):
         """Update a health monitor."""
 
+        self._log_entity(old_health_monitor)
+        self._log_entity(health_monitor)
+
         driver = self.driver
         lb = health_monitor.pool.loadbalancer
         try:
@@ -835,6 +875,8 @@ def update(self, context, old_health_monitor, health_monitor):
     def delete(self, context, health_monitor):
         """Delete a health monitor."""
 
+        self._log_entity(health_monitor)
+
         lb = health_monitor.pool.loadbalancer
         self.api_dict = health_monitor.to_dict(pool=False)
 
@@ -861,6 +903,8 @@ class L7PolicyManager(EntityManager):
     def create(self, context, policy):
         """Create an L7 policy."""
 
+        self._log_entity(policy)
+
         lb = policy.listener.loadbalancer
         self.api_dict = policy.to_dict(listener=False, rules=False)
 
@@ -887,6 +931,9 @@ def append_pools_monitors(context, loadbalancer, service):
     def update(self, context, old_policy, policy):
         """Update a policy."""
 
+        self._log_entity(old_policy)
+        self._log_entity(policy)
+
         driver = self.driver
         lb = policy.listener.loadbalancer
         try:
@@ -906,6 +953,8 @@ def update(self, context, old_policy, policy):
     def delete(self, context, policy):
         """Delete a policy."""
 
+        self._log_entity(policy)
+
         lb = policy.listener.loadbalancer
         self.api_dict = policy.to_dict(listener=False, rules=False)
 
@@ -936,6 +985,8 @@ class L7RuleManager(EntityManager):
     def create(self, context, rule):
         """Create an L7 rule."""
 
+        self._log_entity(rule)
+
         lb = rule.policy.listener.loadbalancer
         self.api_dict = rule.to_dict(policy=False)
 
@@ -962,6 +1013,9 @@ def append_pools_monitors(context, loadbalancer, service):
     def update(self, context, old_rule, rule):
         """Update a rule."""
 
+        self._log_entity(old_rule)
+        self._log_entity(rule)
+
         driver = self.driver
         lb = rule.policy.listener.loadbalancer
         try:
@@ -981,6 +1035,8 @@ def update(self, context, old_rule, rule):
     def delete(self, context, rule):
         """Delete a rule."""
 
+        self._log_entity(rule)
+
         lb = rule.policy.listener.loadbalancer
         self.api_dict = rule.to_dict(policy=False)
 

f5lbaasdriver/v2/bigip/test/test_driver_v2.py

@@ -46,6 +46,9 @@ def attached_to_loadbalancer(self):
     def to_dict(self, **kwargs):
         return self.__dict__
 
+    def to_api_dict(self):
+        return self.to_dict()
+
 
 class FakeListener(FakeBaseObj):
     def __init__(self, id='test_obj_id', attached_to_lb=True):