diff --git a/src/dlt/connector/service/__main__.py b/src/dlt/connector/service/__main__.py index 5e0fb6f878dca4e244274632e8931bc25a4f1319..b13f4257b77f6b4596b0397e62d7a736f09c4ce8 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 a504fe01b4e5755b880b76114c60d28f186f3f6f..fd5bfa35ae28a6e0beafe96d0a09a9e6008d067c 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 53d2dbe316f63ebffba92470415539cf4c1662f8..7c48c750acfd4bd9da63a78ad4fee424b1fc0e7b 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}")