summaryrefslogtreecommitdiff
path: root/src/daq/accesslog
diff options
context:
space:
mode:
authorChristian Pointner <equinox@spreadspace.org>2015-10-16 23:31:39 +0200
committerChristian Pointner <equinox@spreadspace.org>2015-10-16 23:32:19 +0200
commitff25fe32eccd388f4997a120c7f76e64645fe09a (patch)
tree41cd3fbb31f3372fa54e1a25f9ea4fded04eb658 /src/daq/accesslog
parentremoved vet and format targets from default build (diff)
daq: flumotion plug now also retries after EAGAIN
Diffstat (limited to 'src/daq/accesslog')
-rwxr-xr-xsrc/daq/accesslog/s5-accesslog8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/daq/accesslog/s5-accesslog b/src/daq/accesslog/s5-accesslog
index 5026575..b89db22 100755
--- a/src/daq/accesslog/s5-accesslog
+++ b/src/daq/accesslog/s5-accesslog
@@ -321,7 +321,7 @@ class AccessLog():
print 'SFive: trying to connect to %s...' % (self._socket)
self._connected = False
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 socketReady(self):
@@ -359,7 +359,7 @@ class AccessLog():
"bytes-sent": clients.getBytesSent()
}
}
- 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,
@@ -374,7 +374,7 @@ class AccessLog():
if len(initdata["streamer-id"].keys()) == 0:
del initdata["streamer-id"]
- self._proto.sendDatagram('%s\n' % (json.dumps(initdata)));
+ self._proto.sendDatagram('%s\n' % (json.dumps(initdata)))
def _sendDataset(self, timestamp, duration, content_id, format, quality):
clients = self._streamer[content_id][format][quality]
@@ -396,7 +396,7 @@ class AccessLog():
if len(data["streamer-id"].keys()) == 0:
del data["streamer-id"]
- self._proto.sendDatagram('%s\n' % (json.dumps(data)));
+ self._proto.sendDatagram('%s\n' % (json.dumps(data)))
if __name__ == '__main__':