diff options
| author | Christian Pointner <equinox@spreadspace.org> | 2014-10-18 20:19:22 +0200 |
|---|---|---|
| committer | Christian Pointner <equinox@spreadspace.org> | 2014-10-18 20:19:22 +0200 |
| commit | 6f9c2349fe4c5ab92b97c85e712f0d86af862c54 (patch) | |
| tree | d30593f0f45fdd46da37c4e1e85945d0ee33b385 /src/daq/flumotion-plug/s5.py | |
| parent | dat: * added sample data from accesslog importer (zipped) (diff) | |
daq: added some todo's
Diffstat (limited to 'src/daq/flumotion-plug/s5.py')
| -rw-r--r-- | src/daq/flumotion-plug/s5.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/daq/flumotion-plug/s5.py b/src/daq/flumotion-plug/s5.py index d8f7f3c..e703026 100644 --- a/src/daq/flumotion-plug/s5.py +++ b/src/daq/flumotion-plug/s5.py @@ -75,6 +75,12 @@ class SFiveProto(protocol.ConnectedDatagramProtocol): def sendDatagram(self, data): try: + ## TODO: twisted will drop messages if the write buffer is full. + ## Some batch importer work around this issue by sleeping + ## and trying again. For live importer the fix is not applicable + ## but also not as common because unlike live sources batch + ## importer produce a lot of data in a very short period of time. + ## Anyway this issue needs to be addressed! return self.transport.write(data) except socket_error as err: self._plug.warning('SFive: sending datagram failed: %s', err) |