From 677b923a90393525f8b3f7fe94db133f21a58d28 Mon Sep 17 00:00:00 2001 From: Christian Pointner Date: Tue, 14 Oct 2014 04:47:26 +0200 Subject: improved sfive plug --- src/daq/flumotion-plug/s5.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'src/daq') diff --git a/src/daq/flumotion-plug/s5.py b/src/daq/flumotion-plug/s5.py index bd26698..2ca57e9 100644 --- a/src/daq/flumotion-plug/s5.py +++ b/src/daq/flumotion-plug/s5.py @@ -147,10 +147,10 @@ class ComponentSFivePlug(base.ComponentPlug): def _socketReady(self): self.info('SFive: connection to sfive hub established') - self._old_bytes_received = -1 - self._old_bytes_sent = -1 self._sendInit() if self._sfivepoller: + self._old_bytes_received = self._component.getBytesReceived() + self._old_bytes_sent = self._component.getBytesSent() self._start_time = datetime.datetime.utcnow() self._sfivepoller.start() @@ -165,9 +165,9 @@ class ComponentSFivePlug(base.ComponentPlug): bytes_received = self._component.getBytesReceived() bytes_sent = self._component.getBytesSent() - bytes_received_diff = bytes_received - self._old_bytes_received if self._old_bytes_received > 0 else 0; + bytes_received_diff = bytes_received - self._old_bytes_received self._old_bytes_received = bytes_received - bytes_sent_diff = bytes_sent - self._old_bytes_sent if self._old_bytes_sent > 0 else 0; + bytes_sent_diff = bytes_sent - self._old_bytes_sent self._old_bytes_sent = bytes_sent data = { "start-time": self._start_time.isoformat('T'), -- cgit v1.2.3