diff options
| author | Christian Pointner <equinox@spreadspace.org> | 2015-10-16 23:31:39 +0200 |
|---|---|---|
| committer | Christian Pointner <equinox@spreadspace.org> | 2015-10-16 23:32:19 +0200 |
| commit | ff25fe32eccd388f4997a120c7f76e64645fe09a (patch) | |
| tree | 41cd3fbb31f3372fa54e1a25f9ea4fded04eb658 /src/daq/accesslog | |
| parent | removed vet and format targets from default build (diff) | |
daq: flumotion plug now also retries after EAGAIN
Diffstat (limited to 'src/daq/accesslog')
| -rwxr-xr-x | src/daq/accesslog/s5-accesslog | 8 |
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__': |