summaryrefslogtreecommitdiff
path: root/src/daq/flumotion-plug/s5.py
diff options
context:
space:
mode:
authorChristian Pointner <equinox@spreadspace.org>2014-10-18 20:19:22 +0200
committerChristian Pointner <equinox@spreadspace.org>2014-10-18 20:19:22 +0200
commit6f9c2349fe4c5ab92b97c85e712f0d86af862c54 (patch)
treed30593f0f45fdd46da37c4e1e85945d0ee33b385 /src/daq/flumotion-plug/s5.py
parentdat: * 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.py6
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)