Commit 34374c82 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Common Context Query tools: 

- reduced log level of InterDomain-related methods to DEBUG
parent 9df866a8

src/common/tools/context_queries/InterDomain.py

+16 −16
Original line number Diff line number Diff line
@@ -34,11 +34,11 @@ DATACENTER_DEVICE_TYPES = {DeviceTypeEnum.DATACENTER, DeviceTypeEnum.EMULATED_DA 
def get_local_device_uuids(context_client : ContextClient) -> Set[str]:

    topologies = context_client.ListTopologies(ADMIN_CONTEXT_ID)

    topologies = {topology.topology_id.topology_uuid.uuid : topology for topology in topologies.topologies}

    LOGGER.info('[get_local_device_uuids] topologies.keys()={:s}'.format(str(topologies.keys())))

    LOGGER.debug('[get_local_device_uuids] topologies.keys()={:s}'.format(str(topologies.keys())))



    local_topology_uuids = set(topologies.keys())

    local_topology_uuids.discard(INTERDOMAIN_TOPOLOGY_NAME)

    LOGGER.info('[get_local_device_uuids] local_topology_uuids={:s}'.format(str(local_topology_uuids)))

    LOGGER.debug('[get_local_device_uuids] local_topology_uuids={:s}'.format(str(local_topology_uuids)))



    local_device_uuids = set()
@@ -52,11 +52,11 @@ def get_local_device_uuids(context_client : ContextClient) -> Set[str]: 
    for local_topology_uuid in local_topology_uuids:

        topology_device_ids = topologies[local_topology_uuid].device_ids

        topology_device_uuids = {device_id.device_uuid.uuid for device_id in topology_device_ids}

        LOGGER.info('[get_local_device_uuids] [loop] local_topology_uuid={:s} topology_device_uuids={:s}'.format(

        LOGGER.debug('[get_local_device_uuids] [loop] local_topology_uuid={:s} topology_device_uuids={:s}'.format(

            str(local_topology_uuid), str(topology_device_uuids)))

        local_device_uuids.update(topology_device_uuids)



    LOGGER.info('[get_local_device_uuids] local_device_uuids={:s}'.format(str(local_device_uuids)))

    LOGGER.debug('[get_local_device_uuids] local_device_uuids={:s}'.format(str(local_device_uuids)))

    return local_device_uuids



def get_interdomain_device_uuids(context_client : ContextClient) -> Set[str]:
@@ -71,7 +71,7 @@ def get_interdomain_device_uuids(context_client : ContextClient) -> Set[str]: 
    # add abstracted devices in the interdomain topology

    interdomain_device_ids = interdomain_topology.device_ids

    interdomain_device_uuids = {device_id.device_uuid.uuid for device_id in interdomain_device_ids}

    LOGGER.info('[get_interdomain_device_uuids] interdomain_device_uuids={:s}'.format(str(interdomain_device_uuids)))

    LOGGER.debug('[get_interdomain_device_uuids] interdomain_device_uuids={:s}'.format(str(interdomain_device_uuids)))

    return interdomain_device_uuids



def get_local_domain_devices(context_client : ContextClient) -> List[Device]:
@@ -87,7 +87,7 @@ def get_local_domain_devices(context_client : ContextClient) -> List[Device]: 


def is_inter_domain(context_client : ContextClient, endpoint_ids : List[EndPointId]) -> bool:

    interdomain_device_uuids = get_interdomain_device_uuids(context_client)

    LOGGER.info('[is_inter_domain] interdomain_device_uuids={:s}'.format(str(interdomain_device_uuids)))

    LOGGER.debug('[is_inter_domain] interdomain_device_uuids={:s}'.format(str(interdomain_device_uuids)))

    non_interdomain_endpoint_ids = [

        endpoint_id

        for endpoint_id in endpoint_ids
@@ -97,14 +97,14 @@ def is_inter_domain(context_client : ContextClient, endpoint_ids : List[EndPoint 
        (endpoint_id.device_id.device_uuid.uuid, endpoint_id.endpoint_uuid.uuid)

        for endpoint_id in non_interdomain_endpoint_ids

    ]

    LOGGER.info('[is_inter_domain] non_interdomain_endpoint_ids={:s}'.format(str(str_non_interdomain_endpoint_ids)))

    LOGGER.debug('[is_inter_domain] non_interdomain_endpoint_ids={:s}'.format(str(str_non_interdomain_endpoint_ids)))

    is_inter_domain_ = len(non_interdomain_endpoint_ids) == 0

    LOGGER.info('[is_inter_domain] is_inter_domain={:s}'.format(str(is_inter_domain_)))

    LOGGER.debug('[is_inter_domain] is_inter_domain={:s}'.format(str(is_inter_domain_)))

    return is_inter_domain_



def is_multi_domain(context_client : ContextClient, endpoint_ids : List[EndPointId]) -> bool:

    local_device_uuids = get_local_device_uuids(context_client)

    LOGGER.info('[is_multi_domain] local_device_uuids={:s}'.format(str(local_device_uuids)))

    LOGGER.debug('[is_multi_domain] local_device_uuids={:s}'.format(str(local_device_uuids)))

    remote_endpoint_ids = [

        endpoint_id

        for endpoint_id in endpoint_ids
@@ -114,9 +114,9 @@ def is_multi_domain(context_client : ContextClient, endpoint_ids : List[EndPoint 
        (endpoint_id.device_id.device_uuid.uuid, endpoint_id.endpoint_uuid.uuid)

        for endpoint_id in remote_endpoint_ids

    ]

    LOGGER.info('[is_multi_domain] remote_endpoint_ids={:s}'.format(str(str_remote_endpoint_ids)))

    LOGGER.debug('[is_multi_domain] remote_endpoint_ids={:s}'.format(str(str_remote_endpoint_ids)))

    is_multi_domain_ = len(remote_endpoint_ids) > 0

    LOGGER.info('[is_multi_domain] is_multi_domain={:s}'.format(str(is_multi_domain_)))

    LOGGER.debug('[is_multi_domain] is_multi_domain={:s}'.format(str(is_multi_domain_)))

    return is_multi_domain_



def compute_interdomain_path(
@@ -144,9 +144,9 @@ def compute_interdomain_path( 
    constraint_lat.custom.constraint_type = 'latency[ms]'

    constraint_lat.custom.constraint_value = '100.0'



    LOGGER.info('pathcomp_req = {:s}'.format(grpc_message_to_json_string(pathcomp_req)))

    LOGGER.debug('pathcomp_req = {:s}'.format(grpc_message_to_json_string(pathcomp_req)))

    pathcomp_rep = pathcomp_client.Compute(pathcomp_req)

    LOGGER.info('pathcomp_rep = {:s}'.format(grpc_message_to_json_string(pathcomp_rep)))

    LOGGER.debug('pathcomp_rep = {:s}'.format(grpc_message_to_json_string(pathcomp_rep)))



    service = next(iter([

        service
@@ -222,7 +222,7 @@ def compute_traversed_domains( 
) -> List[Tuple[str, bool, List[EndPointId]]]:



    local_device_uuids = get_local_device_uuids(context_client)

    LOGGER.info('[compute_traversed_domains] local_device_uuids={:s}'.format(str(local_device_uuids)))

    LOGGER.debug('[compute_traversed_domains] local_device_uuids={:s}'.format(str(local_device_uuids)))



    interdomain_devices = get_devices_in_topology(context_client, ADMIN_CONTEXT_ID, INTERDOMAIN_TOPOLOGY_NAME)

    interdomain_devices = {
@@ -231,7 +231,7 @@ def compute_traversed_domains( 
    }



    devices_to_domains = get_device_to_domain_map(context_client)

    LOGGER.info('[compute_traversed_domains] devices_to_domains={:s}'.format(str(devices_to_domains)))

    LOGGER.debug('[compute_traversed_domains] devices_to_domains={:s}'.format(str(devices_to_domains)))



    traversed_domains : List[Tuple[str, bool, List[EndPointId]]] = list()

    domains_dict : Dict[str, Tuple[str, bool, List[EndPointId]]] = dict()
@@ -252,5 +252,5 @@ def compute_traversed_domains( 
        ])

        for domain_uuid,is_local_domain,endpoint_ids in traversed_domains

    ]

    LOGGER.info('[compute_traversed_domains] devices_to_domains={:s}'.format(str(str_traversed_domains)))

    LOGGER.debug('[compute_traversed_domains] devices_to_domains={:s}'.format(str(str_traversed_domains)))

    return traversed_domains