Commit f2f26f82 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Slice component: 

- Added close connection to enable load balancing in requests
parent b9d8455c

src/slice/service/SliceServiceServicerImpl.py

+13 −3
Original line number Diff line number Diff line
@@ -64,7 +64,9 @@ class SliceServiceServicerImpl(SliceServiceServicer): 
            # unable to identify the kind of slice; just update endpoints, constraints and config rules

            # update the slice in database, and return

            # pylint: disable=no-member

            return context_client.SetSlice(slice_rw)

            reply = context_client.SetSlice(slice_rw)

            context_client.close()

            return reply



        slice_with_uuids = context_client.GetSlice(slice_id_with_uuids)
@@ -82,10 +84,12 @@ class SliceServiceServicerImpl(SliceServiceServicer): 
            slice_active.CopyFrom(slice_)

            slice_active.slice_status.slice_status = SliceStatusEnum.SLICESTATUS_ACTIVE # pylint: disable=no-member

            context_client.SetSlice(slice_active)

            interdomain_client.close()

            context_client.close()

            return slice_id



        if self._slice_grouper.is_enabled:

            grouped = self._slice_grouper.group(slice_with_uuids)

            grouped = self._slice_grouper.group(slice_with_uuids) # pylint: disable=unused-variable



        # Local domain slice

        service_id = ServiceId()
@@ -159,6 +163,9 @@ class SliceServiceServicerImpl(SliceServiceServicer): 
        slice_active.CopyFrom(slice_)

        slice_active.slice_status.slice_status = SliceStatusEnum.SLICESTATUS_ACTIVE # pylint: disable=no-member

        context_client.SetSlice(slice_active)



        service_client.close()

        context_client.close()

        return slice_id



    @safe_and_metered_rpc_method(METRICS_POOL, LOGGER)
@@ -195,6 +202,7 @@ class SliceServiceServicerImpl(SliceServiceServicer): 
        try:

            _slice = context_client.GetSlice(request)

        except: # pylint: disable=bare-except

            context_client.close()

            return Empty()



        if is_multi_domain(context_client, _slice.slice_endpoint_ids):
@@ -208,7 +216,7 @@ class SliceServiceServicerImpl(SliceServiceServicer): 
            context_client.SetSlice(current_slice)



            if self._slice_grouper.is_enabled:

                ungrouped = self._slice_grouper.ungroup(current_slice)

                ungrouped = self._slice_grouper.ungroup(current_slice) # pylint: disable=unused-variable



            service_client = ServiceClient()

            for service_id in _slice.slice_service_ids:
@@ -219,6 +227,8 @@ class SliceServiceServicerImpl(SliceServiceServicer): 
                context_client.UnsetSlice(current_slice)



                service_client.DeleteService(service_id)

            service_client.close()



        context_client.RemoveSlice(request)

        context_client.close()

        return Empty()