Octavia driver: agent implementation
The driver is loaded, then terminated whenever a request is issued.
This behavior causes termination of the Octavia listener which is
responsible to the processing of the driver status updates and
statistics processing.
The following change implements an agent which will execute the
listener.
Change-Id: I566aaa65df4ba7455577a539aa9eebb6cc36a099
(cherry picked from commit 24e93461d0
)
This commit is contained in:
parent
ec56cf9765
commit
e7840c8d7c
|
@ -155,6 +155,9 @@ Add octavia and python-octaviaclient repos as external repositories and configur
|
||||||
[controller_worker]
|
[controller_worker]
|
||||||
network_driver = allowed_address_pairs_driver
|
network_driver = allowed_address_pairs_driver
|
||||||
|
|
||||||
|
[driver_agent]
|
||||||
|
enabled_provider_agents=vmwareagent
|
||||||
|
|
||||||
NSX-T
|
NSX-T
|
||||||
-----
|
-----
|
||||||
|
|
||||||
|
@ -279,6 +282,8 @@ Add octavia and python-octaviaclient repos as external repositories and configur
|
||||||
[controller_worker]
|
[controller_worker]
|
||||||
network_driver = allowed_address_pairs_driver
|
network_driver = allowed_address_pairs_driver
|
||||||
|
|
||||||
|
[driver_agent]
|
||||||
|
enabled_provider_agents=vmwareagent
|
||||||
|
|
||||||
NSX-P
|
NSX-P
|
||||||
-----
|
-----
|
||||||
|
@ -360,6 +365,9 @@ Add octavia and python-octaviaclient repos as external repositories and configur
|
||||||
[controller_worker]
|
[controller_worker]
|
||||||
network_driver = allowed_address_pairs_driver
|
network_driver = allowed_address_pairs_driver
|
||||||
|
|
||||||
|
[driver_agent]
|
||||||
|
enabled_provider_agents=vmwareagent
|
||||||
|
|
||||||
Trunk Driver
|
Trunk Driver
|
||||||
~~~~~~~~~~~~
|
~~~~~~~~~~~~
|
||||||
|
|
||||||
|
|
|
@ -95,6 +95,8 @@ vmware_nsx.neutron.nsxv3.housekeeper.jobs =
|
||||||
mismatch_logical_port = vmware_nsx.plugins.nsx_v3.housekeeper.mismatch_logical_port:MismatchLogicalportJob
|
mismatch_logical_port = vmware_nsx.plugins.nsx_v3.housekeeper.mismatch_logical_port:MismatchLogicalportJob
|
||||||
octavia.api.drivers =
|
octavia.api.drivers =
|
||||||
vmwareedge = vmware_nsx.services.lbaas.octavia.octavia_driver:NSXOctaviaDriver
|
vmwareedge = vmware_nsx.services.lbaas.octavia.octavia_driver:NSXOctaviaDriver
|
||||||
|
octavia.driver_agent.provider_agents =
|
||||||
|
vmwareagent = vmware_nsx.services.lbaas.octavia.octavia_driver:vmware_nsx_provider_agent
|
||||||
[build_sphinx]
|
[build_sphinx]
|
||||||
source-dir = doc/source
|
source-dir = doc/source
|
||||||
build-dir = doc/build
|
build-dir = doc/build
|
||||||
|
|
|
@ -15,6 +15,7 @@
|
||||||
|
|
||||||
import copy
|
import copy
|
||||||
import socket
|
import socket
|
||||||
|
import time
|
||||||
|
|
||||||
from oslo_config import cfg
|
from oslo_config import cfg
|
||||||
from oslo_log import helpers as log_helpers
|
from oslo_log import helpers as log_helpers
|
||||||
|
@ -75,7 +76,6 @@ class NSXOctaviaDriver(driver_base.ProviderDriver):
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
super(NSXOctaviaDriver, self).__init__()
|
super(NSXOctaviaDriver, self).__init__()
|
||||||
self._init_rpc_messaging()
|
self._init_rpc_messaging()
|
||||||
self._init_rpc_listener()
|
|
||||||
self._init_cert_manager()
|
self._init_cert_manager()
|
||||||
self.repositories = repositories.Repositories()
|
self.repositories = repositories.Repositories()
|
||||||
|
|
||||||
|
@ -88,20 +88,6 @@ class NSXOctaviaDriver(driver_base.ProviderDriver):
|
||||||
version='1.0')
|
version='1.0')
|
||||||
self.client = messaging.RPCClient(transport, target)
|
self.client = messaging.RPCClient(transport, target)
|
||||||
|
|
||||||
@log_helpers.log_method_call
|
|
||||||
def _init_rpc_listener(self):
|
|
||||||
# Initialize RPC listener
|
|
||||||
topic = d_const.DRIVER_TO_OCTAVIA_TOPIC
|
|
||||||
server = socket.gethostname()
|
|
||||||
target = messaging.Target(topic=topic, server=server,
|
|
||||||
exchange="common", fanout=False)
|
|
||||||
endpoints = [NSXOctaviaDriverEndpoint()]
|
|
||||||
access_policy = dispatcher.DefaultRPCAccessPolicy
|
|
||||||
|
|
||||||
self.octavia_server = get_rpc_server(target, endpoints,
|
|
||||||
access_policy)
|
|
||||||
self.octavia_server.start()
|
|
||||||
|
|
||||||
@log_helpers.log_method_call
|
@log_helpers.log_method_call
|
||||||
def _init_cert_manager(self):
|
def _init_cert_manager(self):
|
||||||
self.cert_manager = stevedore_driver.DriverManager(
|
self.cert_manager = stevedore_driver.DriverManager(
|
||||||
|
@ -589,3 +575,22 @@ class NSXOctaviaDriverEndpoint(driver_lib.DriverLibrary):
|
||||||
except exceptions.UpdateStatisticsError as e:
|
except exceptions.UpdateStatisticsError as e:
|
||||||
LOG.error("Failed to update Octavia listener statistics. "
|
LOG.error("Failed to update Octavia listener statistics. "
|
||||||
"Stats %s, Error %s", statistics, e.fault_string)
|
"Stats %s, Error %s", statistics, e.fault_string)
|
||||||
|
|
||||||
|
|
||||||
|
@log_helpers.log_method_call
|
||||||
|
def vmware_nsx_provider_agent(exit_event):
|
||||||
|
# Initialize RPC listener
|
||||||
|
topic = d_const.DRIVER_TO_OCTAVIA_TOPIC
|
||||||
|
server = socket.gethostname()
|
||||||
|
target = messaging.Target(topic=topic, server=server,
|
||||||
|
exchange="common", fanout=False)
|
||||||
|
endpoints = [NSXOctaviaDriverEndpoint()]
|
||||||
|
access_policy = dispatcher.DefaultRPCAccessPolicy
|
||||||
|
get_transport()
|
||||||
|
octavia_server = get_rpc_server(target, endpoints, access_policy)
|
||||||
|
octavia_server.start()
|
||||||
|
|
||||||
|
LOG.info('VMware NSX Octavia provider agent has started.')
|
||||||
|
while not exit_event.is_set():
|
||||||
|
time.sleep(1)
|
||||||
|
LOG.info('VMware NSX Octavia provider agent is exiting.')
|
||||||
|
|
Loading…
Reference in New Issue