Skip to content
Snippets Groups Projects
Commit ecf1f4cc authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Interdomain component:

- Added filter to skip undesired device events
- Corrected close of DLT connector client
parent 7137a540
No related branches found
No related tags found
2 merge requests!142Release TeraFlowSDN 2.1,!119Migration of Interdomain component and OECC/PSC'22 test to Release 2
...@@ -69,6 +69,7 @@ class RemoteDomainClients(threading.Thread): ...@@ -69,6 +69,7 @@ class RemoteDomainClients(threading.Thread):
if not isinstance(event, DeviceEvent): continue if not isinstance(event, DeviceEvent): continue
LOGGER.info('Processing Event({:s})...'.format(grpc_message_to_json_string(event))) LOGGER.info('Processing Event({:s})...'.format(grpc_message_to_json_string(event)))
domain_data = get_domain_data(self.context_client, event) domain_data = get_domain_data(self.context_client, event)
if domain_data is None: continue
domain_name, domain_address, domain_port = domain_data domain_name, domain_address, domain_port = domain_data
try: try:
self.add_peer(domain_name, domain_address, domain_port) self.add_peer(domain_name, domain_address, domain_port)
......
...@@ -295,4 +295,4 @@ class TopologyAbstractor(threading.Thread): ...@@ -295,4 +295,4 @@ class TopologyAbstractor(threading.Thread):
LOGGER.warning('Unsupported Event({:s})'.format(grpc_message_to_json_string(event))) LOGGER.warning('Unsupported Event({:s})'.format(grpc_message_to_json_string(event)))
dlt_record_sender.commit() dlt_record_sender.commit()
dlt_connector_client.close() if dlt_connector_client is not None: dlt_connector_client.close()
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment