summaryrefslogtreecommitdiff
path: root/src/daq/flumotion-rrd
diff options
context:
space:
mode:
Diffstat (limited to 'src/daq/flumotion-rrd')
-rwxr-xr-xsrc/daq/flumotion-rrd/s5-flumotion-rrd8
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__':