diff options
Diffstat (limited to 'src/daq/flumotion-rrd')
| -rwxr-xr-x | src/daq/flumotion-rrd/s5-flumotion-rrd | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/daq/flumotion-rrd/s5-flumotion-rrd b/src/daq/flumotion-rrd/s5-flumotion-rrd index c2e82eb..949456d 100755 --- a/src/daq/flumotion-rrd/s5-flumotion-rrd +++ b/src/daq/flumotion-rrd/s5-flumotion-rrd @@ -146,7 +146,7 @@ class FlumotionRRD(): def _initSocket(self): print 'SFive: trying to connect to %s...' % (self._socket) self._proto = SFiveProto(self) - self._conn = SFivePort(self._socket, self._proto, _MAX_PACKET_SIZE, 0o666, None, reactor) + self._conn = SFivePort(self._socket, self._proto, _MAX_PACKET_SIZE, 0666, None, reactor) self._conn.startListening() def _socketError(self): @@ -205,13 +205,13 @@ class FlumotionRRD(): "bytes-sent": bytes_sent } } - self._proto.sendDatagram('%s\n' % (json.dumps(data))); + self._proto.sendDatagram('%s\n' % (json.dumps(data))) def _sendInit(self): initdata = { "version": 1, "hostname": self._hostname, "streamer-id": { "content-id": self._content_id, "format": self._format, "quality": self._quality }, "tags": self._tags } - self._proto.sendDatagram('%s\n' % (json.dumps(initdata))); + self._proto.sendDatagram('%s\n' % (json.dumps(initdata))) def _sendDataset(self, timestamp, duration, client_count, bytes_sent): client_count = int(round(client_count)) if client_count else 0 @@ -223,7 +223,7 @@ class FlumotionRRD(): "bytes-sent": bytes_sent } } - self._proto.sendDatagram('%s\n' % (json.dumps(data))); + self._proto.sendDatagram('%s\n' % (json.dumps(data))) if __name__ == '__main__': |