summaryrefslogtreecommitdiffstats
path: root/storperf/carbon/emitter.py
diff options
context:
space:
mode:
authorMark Beierl <mark.beierl@dell.com>2016-12-02 22:25:48 -0500
committermbeierl <mark.beierl@dell.com>2016-12-05 13:11:08 -0500
commit9f5b776c1b5a54d2ca5942424111f3ff55d5737c (patch)
tree56bff326b62256d1c3108453dc3ef2d33dd7ea12 /storperf/carbon/emitter.py
parentf56d13f2aac136b3b8762e06ca15688dd88ff502 (diff)
Steady state detection
Detection of steady state after 10+ samples of data Change-Id: I29368b06188c6370d17b3d567fece6486d171235 JIRA: STORPERF-72 STORPERF-73 Signed-off-by: Mark Beierl <mark.beierl@dell.com>
Diffstat (limited to 'storperf/carbon/emitter.py')
-rw-r--r--storperf/carbon/emitter.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/storperf/carbon/emitter.py b/storperf/carbon/emitter.py
index c9af8a6..e23dc79 100644
--- a/storperf/carbon/emitter.py
+++ b/storperf/carbon/emitter.py
@@ -22,9 +22,8 @@ class CarbonMetricTransmitter():
def transmit_metrics(self, metrics):
if 'timestamp' in metrics:
- timestamp = metrics.pop('timestamp')
- else:
- timestamp = str(calendar.timegm(time.gmtime()))
+ metrics.pop('timestamp')
+ timestamp = str(calendar.timegm(time.gmtime()))
carbon_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
carbon_socket.connect((self.carbon_host, self.carbon_port))