From 439212b7aa408638206ae475c5c91c91cfba3a07 Mon Sep 17 00:00:00 2001
From: diazjj <jjdiaz@cttc.es>
Date: Mon, 29 Jul 2024 09:45:01 +0200
Subject: [PATCH] Debugging
---
src/dlt/connector/service/__main__.py | 2 ++
.../service/topology_abstractor/DltRecordSender.py | 4 +++-
src/interdomain/service/topology_abstractor/DltRecorder.py | 2 ++
3 files changed, 7 insertions(+), 1 deletion(-)
diff --git a/src/dlt/connector/service/__main__.py b/src/dlt/connector/service/__main__.py
index 5e0fb6f87..b13f4257b 100644
--- a/src/dlt/connector/service/__main__.py
+++ b/src/dlt/connector/service/__main__.py
@@ -53,6 +53,8 @@ def main():
event_dispatcher = DltEventDispatcher()
event_dispatcher.start()
+ # Context Event dispatcher
+
# Starting DLT connector service
grpc_service = DltConnectorService()
grpc_service.start()
diff --git a/src/interdomain/service/topology_abstractor/DltRecordSender.py b/src/interdomain/service/topology_abstractor/DltRecordSender.py
index a504fe01b..fd5bfa35a 100644
--- a/src/interdomain/service/topology_abstractor/DltRecordSender.py
+++ b/src/interdomain/service/topology_abstractor/DltRecordSender.py
@@ -21,6 +21,7 @@ from dlt.connector.client.DltConnectorClient import DltConnectorClient
from .Types import DltRecordTypes
LOGGER = logging.getLogger(__name__)
+LOGGER.setLevel(logging.DEBUG)
class DltRecordSender:
def __init__(self, context_client : ContextClient, dlt_connector_client : Optional[DltConnectorClient]) -> None:
@@ -64,7 +65,8 @@ class DltRecordSender:
for dlt_record_uuid in self.dlt_record_uuids:
topology_id,dlt_record = self.dlt_record_uuid_to_data[dlt_record_uuid]
if isinstance(dlt_record, Device):
- device_id = self.context_client.SetDevice(dlt_record)
+ device_id = self.context_client.SetDevice(dlt_record) # Se retriggerea el Evento.
+ LOGGER.debug('DEVICE ID: ({:s})'.format(str(dlt_record)))
if self.dlt_connector_client is None: continue
dlt_device_id = DltDeviceId()
dlt_device_id.topology_id.CopyFrom(topology_id) # pylint: disable=no-member
diff --git a/src/interdomain/service/topology_abstractor/DltRecorder.py b/src/interdomain/service/topology_abstractor/DltRecorder.py
index 53d2dbe31..7c48c750a 100644
--- a/src/interdomain/service/topology_abstractor/DltRecorder.py
+++ b/src/interdomain/service/topology_abstractor/DltRecorder.py
@@ -118,6 +118,7 @@ class DLTRecorder(threading.Thread):
if ((context_uuid == DEFAULT_CONTEXT_NAME) or (context_name == DEFAULT_CONTEXT_NAME)) and \
(topology_uuid not in topology_uuids) and (topology_name not in topology_uuids):
for device in topology_details.devices:
+ LOGGER.debug('DEVICE INFO({:s})'.format(grpc_message_to_json_string(device)))
dlt_record_sender.add_device(topology_id, device)
for link in topology_details.links:
@@ -149,6 +150,7 @@ class DLTRecorder(threading.Thread):
device = self.context_client.GetDevice(device_id)
topology_id = self.find_topology_for_device(device_id)
if topology_id:
+ LOGGER.debug('DEVICE INFO({:s}), DEVICE ID ({:s})'.format(grpc_message_to_json_string(device)), (str(device_id)))
dlt_record_sender.add_device(topology_id, device)
else:
LOGGER.warning(f"Topology not found for device {device_id.device_uuid.uuid}")
--
GitLab