From add27e2682349675eea253d08b1eccd36425a71b Mon Sep 17 00:00:00 2001 From: Alvaro Vega Date: Mon, 23 Jan 2017 16:35:17 +0100 Subject: [PATCH] add header size to metrics --- src/orchestrator/common/util.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/orchestrator/common/util.py b/src/orchestrator/common/util.py index 7f63d8b9..33b40309 100644 --- a/src/orchestrator/common/util.py +++ b/src/orchestrator/common/util.py @@ -172,7 +172,7 @@ def rest_request(self, url, method, user=None, password=None, res.code = 500 res.msg = self.ENDPOINT_NAME + " endpoint ERROR: " + res.args[0][1] - self.collectOutgoingMetrics(service_start, request.data, res) + self.collectOutgoingMetrics(service_start, request.data, request.headers, res) return res @@ -255,11 +255,11 @@ def rest_request2(self, url, method, user=None, password=None, except Exception, e: print e - self.collectOutgoingMetrics(service_start, rdata, res) + self.collectOutgoingMetrics(service_start, rdata, headers, res) return res - def collectOutgoingMetrics(self, service_start, data_request, response): + def collectOutgoingMetrics(self, service_start, data_request, headers_request, response): try: service_stop = time.time() transactionError = False @@ -270,8 +270,8 @@ def collectOutgoingMetrics(self, service_start, data_request, response): self.sum["outgoingTransactions"] += 1 else: self.sum["outgoingTransactionErrors"] += 1 - self.sum["outgoingTransactionRequestSize"] += len(json.dumps(data_request)) - self.sum["outgoingTransactionResponseSize"] += len(json.dumps(data_response)) + self.sum["outgoingTransactionRequestSize"] += len(json.dumps(data_request)) + len(str(headers_request)) + self.sum["outgoingTransactionResponseSize"] += len(json.dumps(data_response)) + len(str(response.headers.headers)) self.sum["serviceTimeTotal"] += (service_stop - service_start) except Exception, ex: self.logger.error("ERROR collecting outgoing metrics %s", ex)