Commit 52e49be3 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Load Generator component: 

- Added blocked counter
parent 26f9acad

src/load_generator/load_gen/RequestScheduler.py

+7 −4
Original line number Diff line number Diff line
@@ -97,6 +97,9 @@ class RequestScheduler: 


        if request is None:

            LOGGER.warning('No resources available to compose new request')

            metrics = METRICS_POOL.get_metrics_loadgen('setup', labels={'request_type': request_type})

            _, _, _, _, counter_blocked = metrics

            counter_blocked.inc()

            return



        if 'service_id' in request:
@@ -150,8 +153,8 @@ class RequestScheduler: 
    ) -> None:

        if self._parameters.dry_mode: return



        metrics = METRICS_POOL.get_metrics('setup', labels={'request_type': request_type})

        histogram_duration, counter_started, counter_completed, counter_failed = metrics

        metrics = METRICS_POOL.get_metrics_loadgen('setup', labels={'request_type': request_type})

        histogram_duration, counter_started, counter_completed, counter_failed, _ = metrics



        service_id = None

        if service is not None:
@@ -213,8 +216,8 @@ class RequestScheduler: 
    ) -> None:

        if self._parameters.dry_mode: return



        metrics = METRICS_POOL.get_metrics('teardown', labels={'request_type': request_type})

        histogram_duration, counter_started, counter_completed, counter_failed = metrics

        metrics = METRICS_POOL.get_metrics_loadgen('teardown', labels={'request_type': request_type})

        histogram_duration, counter_started, counter_completed, counter_failed, _ = metrics



        if self._parameters.record_to_dlt:

            entities_to_record = explore_entities_to_record(slice_id=slice_id, service_id=service_id)