diff --git a/neutron/common/constants.py b/neutron/common/constants.py index 4975c013fc..cfa7cce87f 100644 --- a/neutron/common/constants.py +++ b/neutron/common/constants.py @@ -79,6 +79,7 @@ AGENT_TYPE_LOADBALANCER = 'Loadbalancer agent' AGENT_TYPE_MLNX = 'Mellanox plugin agent' AGENT_TYPE_METERING = 'Metering agent' AGENT_TYPE_METADATA = 'Metadata agent' +AGENT_TYPE_SDNVE = 'IBM SDN-VE agent' L2_AGENT_TOPIC = 'N/A' PAGINATION_INFINITE = 'infinite' diff --git a/neutron/plugins/ibm/agent/sdnve_neutron_agent.py b/neutron/plugins/ibm/agent/sdnve_neutron_agent.py index a67976e509..5221c974cf 100644 --- a/neutron/plugins/ibm/agent/sdnve_neutron_agent.py +++ b/neutron/plugins/ibm/agent/sdnve_neutron_agent.py @@ -27,11 +27,13 @@ from neutron.agent.linux import ip_lib from neutron.agent.linux import ovs_lib from neutron.agent import rpc as agent_rpc from neutron.common import config as logging_config +from neutron.common import constants as n_const from neutron.common import legacy from neutron.common import topics -from neutron.common import utils as q_utils +from neutron.common import utils as n_utils from neutron import context from neutron.openstack.common import log as logging +from neutron.openstack.common import loopingcall from neutron.openstack.common.rpc import dispatcher from neutron.plugins.ibm.common import config # noqa from neutron.plugins.ibm.common import constants @@ -76,6 +78,17 @@ class SdnveNeutronAgent(): self.reset_br = reset_br self.out_of_band = out_of_band + self.agent_state = { + 'binary': 'neutron-sdnve-agent', + 'host': cfg.CONF.host, + 'topic': n_const.L2_AGENT_TOPIC, + 'configurations': {'interface_mappings': interface_mappings, + 'reset_br': self.reset_br, + 'out_of_band': self.out_of_band, + 'controller_ip': self.controller_ip}, + 'agent_type': n_const.AGENT_TYPE_SDNVE, + 'start_flag': True} + if self.int_bridge_name: self.int_br = self.setup_integration_br(integ_br, reset_br, out_of_band, @@ -86,6 +99,14 @@ class SdnveNeutronAgent(): self.setup_rpc() + def _report_state(self): + try: + self.state_rpc.report_state(self.context, + self.agent_state) + self.agent_state.pop('start_flag', None) + except Exception: + LOG.exception(_("Failed reporting state!")) + def setup_rpc(self): if self.int_br: mac = self.int_br.get_local_port_mac() @@ -105,6 +126,10 @@ class SdnveNeutronAgent(): self.connection = agent_rpc.create_consumers(self.dispatcher, self.topic, consumers) + if self.polling_interval: + heartbeat = loopingcall.FixedIntervalLoopingCall( + self._report_state) + heartbeat.start(interval=self.polling_interval) # Plugin calls the agents through the following def info_update(self, context, **kwargs): @@ -209,7 +234,7 @@ class SdnveNeutronAgent(): def create_agent_config_map(config): - interface_mappings = q_utils.parse_mappings( + interface_mappings = n_utils.parse_mappings( config.SDNVE.interface_mappings) controller_ips = config.SDNVE.controller_ips diff --git a/neutron/plugins/ibm/sdnve_neutron_plugin.py b/neutron/plugins/ibm/sdnve_neutron_plugin.py index b8c83190ae..fda586eb7e 100644 --- a/neutron/plugins/ibm/sdnve_neutron_plugin.py +++ b/neutron/plugins/ibm/sdnve_neutron_plugin.py @@ -107,6 +107,7 @@ class SdnvePluginV2(db_base_plugin_v2.NeutronDbPluginV2, external_net_db.External_net_db_mixin, portbindings_db.PortBindingMixin, l3_gwmode_db.L3_NAT_db_mixin, + agents_db.AgentDbMixin, ): ''' @@ -117,7 +118,8 @@ class SdnvePluginV2(db_base_plugin_v2.NeutronDbPluginV2, __native_pagination_support = False __native_sorting_support = False - supported_extension_aliases = ["binding", "router", "external-net"] + supported_extension_aliases = ["binding", "router", "external-net", + "agent"] def __init__(self, configfile=None): self.base_binding_dict = {