x
/
vmware-nsx
Code Issues Proposed changes

NSXv BGP: Use elevated context inside callbacks 

This patch makes sure that BGP callbacks will always use the elevated context
so that BGP resources can be properly accessed.

Change-Id: I633c8f52cc5b92178045360aea5d6b4a847f5b28
This commit is contained in:
Roey Chen 2017-05-21 02:43:34 -07:00
parent 38471d4ccf
commit b02f7add0c
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
vmware_nsx/services/dynamic_routing/bgp_plugin.py
View File

@ -179,7 +179,7 @@ class NSXvBgpPlugin(service_base.ServicePluginBase, bgp_db.BgpDbMixin):
# No GW network, hence no BGP speaker associated
return
context = kwargs['context']
context = kwargs['context'].elevated()
router_id = kwargs['router_id']
subnets = kwargs.get('subnets')
network_id = kwargs['network_id']
@ -203,6 +203,7 @@ class NSXvBgpPlugin(service_base.ServicePluginBase, bgp_db.BgpDbMixin):
def router_gateway_callback(self, resource, event, trigger, **kwargs):
context = kwargs.get('context') or n_context.get_admin_context()
context = context.elevated()
router_id = kwargs['router_id']
network_id = kwargs['network_id']
speakers = self._bgp_speakers_for_gateway_network(context, network_id)
@ -227,7 +228,7 @@ class NSXvBgpPlugin(service_base.ServicePluginBase, bgp_db.BgpDbMixin):
def _before_service_edge_delete_callback(self, resource, event,
trigger, **kwargs):
context = kwargs['context']
context = kwargs['context'].elevated()
router = kwargs['router']
ext_net_id = router.gw_port and router.gw_port['network_id']
gw_ip = router.gw_port and router.gw_port['fixed_ips'][0]['ip_address']
@ -244,7 +245,7 @@ class NSXvBgpPlugin(service_base.ServicePluginBase, bgp_db.BgpDbMixin):
def _after_service_edge_create_callback(self, resource, event,
trigger, **kwargs):
context = kwargs['context']
context = kwargs['context'].elevated()
router = kwargs['router']
ext_net_id = router.gw_port and router.gw_port['network_id']
speakers = self._bgp_speakers_for_gateway_network(context, ext_net_id)