From 4e9e36a2e25bcab1e112d84ae94e120de8dce329 Mon Sep 17 00:00:00 2001 From: Christian Pointner Date: Tue, 14 Oct 2014 03:08:29 +0200 Subject: fixed flumotion plug - start-time --- src/daq/flumotion-plug/s5.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/daq/flumotion-plug/s5.py b/src/daq/flumotion-plug/s5.py index 0f6abd5..bd26698 100644 --- a/src/daq/flumotion-plug/s5.py +++ b/src/daq/flumotion-plug/s5.py @@ -151,6 +151,7 @@ class ComponentSFivePlug(base.ComponentPlug): self._old_bytes_sent = -1 self._sendInit() if self._sfivepoller: + self._start_time = datetime.datetime.utcnow() self._sfivepoller.start() def _sendInit(self): @@ -169,7 +170,7 @@ class ComponentSFivePlug(base.ComponentPlug): bytes_sent_diff = bytes_sent - self._old_bytes_sent if self._old_bytes_sent > 0 else 0; self._old_bytes_sent = bytes_sent - data = { "start-time": datetime.datetime.utcnow().isoformat('T'), + data = { "start-time": self._start_time.isoformat('T'), "duration-ms": self._duration * 1000, "data": { "client-count": client_count, @@ -178,3 +179,4 @@ class ComponentSFivePlug(base.ComponentPlug): } } self._proto.sendDatagram('%s\n' % (json.dumps(data))); + self._start_time = datetime.datetime.utcnow() -- cgit v1.2.3