From 52e49be3b3dbc7d8bff4660c8071a09e40650029 Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Wed, 26 Apr 2023 17:10:12 +0000
Subject: [PATCH] Load Generator component:
- Added blocked counter
---
src/load_generator/load_gen/RequestScheduler.py | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git a/src/load_generator/load_gen/RequestScheduler.py b/src/load_generator/load_gen/RequestScheduler.py
index 080e607d7..08876e29f 100644
--- a/src/load_generator/load_gen/RequestScheduler.py
+++ b/src/load_generator/load_gen/RequestScheduler.py
@@ -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)
--
GitLab