supported_extension_aliases = ["binding"]
servers = None
- def __init__(self, server_timeout=None):
- super(NeutronRestProxyV2Base, self).__init__()
- # This base class is not intended to be instantiated directly.
- # Extending class should set ServerPool.
- if not self.servers:
- LOG.warning(_("ServerPool not set!"))
-
def _get_all_data(self, get_ports=True, get_floating_ips=True,
get_routers=True):
admin_context = qcontext.get_admin_context()
self._aliases = aliases
return self._aliases
- def __init__(self, server_timeout=None):
+ def __init__(self):
super(NeutronRestProxyV2, self).__init__()
LOG.info(_('NeutronRestProxy: Starting plugin. Version=%s'),
version.version_string_with_vcs())
self.add_meta_server_route = cfg.CONF.RESTPROXY.add_meta_server_route
# init network ctrl connections
- self.servers = servermanager.ServerPool(server_timeout)
+ self.servers = servermanager.ServerPool()
self.servers.get_topo_function = self._get_all_data
self.servers.get_topo_function_args = {'get_ports': True,
'get_floating_ips': True,
operations to the Big Switch Controller.
"""
- def initialize(self, server_timeout=None):
+ def initialize(self):
LOG.debug(_('Initializing driver'))
# register plugin config opts
self.native_bulk_support = False
# init network ctrl connections
- self.servers = servermanager.ServerPool(server_timeout)
+ self.servers = servermanager.ServerPool()
self.servers.get_topo_function = self._get_all_data
self.servers.get_topo_function_args = {'get_ports': True,
'get_floating_ips': False,