Commit 185aecae authored by Javier Diaz's avatar Javier Diaz
Browse files

Debugging

parent edd4b3c2

src/interdomain/service/topology_abstractor/DltRecordSender.py

+8 −4
Original line number Diff line number Diff line
@@ -66,7 +66,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) # Se retriggerea el Evento.

                #device_id = self.context_client.SetDevice(dlt_record) # This causes events to be triggered infinitely.

                device_id = dlt_record.device_id.device_uuid.uuid

                #LOGGER.debug('DEVICE_ID: ({:s})'.format(grpc_message_to_json_string(device_id)))

                if self.dlt_connector_client is None: continue

                dlt_device_id = DltDeviceId()
@@ -74,21 +75,24 @@ class DltRecordSender: 
                dlt_device_id.device_id.CopyFrom(device_id)         # pylint: disable=no-member

                self.dlt_connector_client.RecordDevice(dlt_device_id)

            elif isinstance(dlt_record, Link):

                link_id = self.context_client.SetLink(dlt_record)

                #link_id = self.context_client.SetLink(dlt_record)

                link_id = dlt_record.link_id.link_uuid.uuid

                if self.dlt_connector_client is None: continue

                dlt_link_id = DltLinkId()

                dlt_link_id.topology_id.CopyFrom(topology_id)       # pylint: disable=no-member

                dlt_link_id.link_id.CopyFrom(link_id)               # pylint: disable=no-member

                self.dlt_connector_client.RecordLink(dlt_link_id)

            elif isinstance(dlt_record, Service):

                service_id = self.context_client.SetService(dlt_record)

                #service_id = self.context_client.SetService(dlt_record)

                service_id = dlt_record.service_id.service_uuid.uuid

                if self.dlt_connector_client is None: continue

                dlt_service_id = DltServiceId()

                dlt_service_id.topology_id.CopyFrom(topology_id)    # pylint: disable=no-member

                dlt_service_id.service_id.CopyFrom(service_id)      # pylint: disable=no-member

                self.dlt_connector_client.RecordService(dlt_service_id)

            elif isinstance(dlt_record, Slice):

                slice_id = self.context_client.SetSlice(dlt_record)

                #slice_id = self.context_client.SetSlice(dlt_record)

                slice_id = dlt_record.slice_id.slice_uuid.uuid

                if self.dlt_connector_client is None: continue

                dlt_slice_id = DltSliceId()

                dlt_slice_id.topology_id.CopyFrom(topology_id)      # pylint: disable=no-member