From ecf1f4ccf58dc6f9fead8b096688eb0001814a4e Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Fri, 23 Jun 2023 16:36:09 +0000
Subject: [PATCH] Interdomain component:
- Added filter to skip undesired device events
- Corrected close of DLT connector client
---
src/interdomain/service/RemoteDomainClients.py | 1 +
.../service/topology_abstractor/TopologyAbstractor.py | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/src/interdomain/service/RemoteDomainClients.py b/src/interdomain/service/RemoteDomainClients.py
index e28176ef4..d60450a18 100644
--- a/src/interdomain/service/RemoteDomainClients.py
+++ b/src/interdomain/service/RemoteDomainClients.py
@@ -69,6 +69,7 @@ class RemoteDomainClients(threading.Thread):
if not isinstance(event, DeviceEvent): continue
LOGGER.info('Processing Event({:s})...'.format(grpc_message_to_json_string(event)))
domain_data = get_domain_data(self.context_client, event)
+ if domain_data is None: continue
domain_name, domain_address, domain_port = domain_data
try:
self.add_peer(domain_name, domain_address, domain_port)
diff --git a/src/interdomain/service/topology_abstractor/TopologyAbstractor.py b/src/interdomain/service/topology_abstractor/TopologyAbstractor.py
index 20b186f30..40b40ac66 100644
--- a/src/interdomain/service/topology_abstractor/TopologyAbstractor.py
+++ b/src/interdomain/service/topology_abstractor/TopologyAbstractor.py
@@ -295,4 +295,4 @@ class TopologyAbstractor(threading.Thread):
LOGGER.warning('Unsupported Event({:s})'.format(grpc_message_to_json_string(event)))
dlt_record_sender.commit()
- dlt_connector_client.close()
+ if dlt_connector_client is not None: dlt_connector_client.close()
--
GitLab