commit 145749c7a2692a29e2c7fc4088e336e37a2ff7e3
author Jens Geyer <jensg@apache.org> Fri Oct 16 19:21:22 2015 +0200
committer Jens Geyer <jensg@apache.org> Fri Oct 16 19:21:22 2015 +0200
tree 46b9a486c30332be0d3b4086c42686acb445fc0c
parent a84e139215c93a2673a46fa862eb1c05d157e3d0

THRIFT-3390 Tornado server should gracefully handle closed connections
Clidnt: Python.Tornado
Patch: Christian Verkerk <christian@tubularlabs.com>

This closes #654

lib/py/src/TTornado.py

diff --git a/lib/py/src/TTornado.py b/lib/py/src/TTornado.py
index ef3e0f2..65795ab 100644
--- a/lib/py/src/TTornado.py
+++ b/lib/py/src/TTornado.py
@@ -171,7 +171,13 @@
 
         try:
             while not trans.stream.closed():
-                frame = yield trans.readFrame()
+                try:
+                    frame = yield trans.readFrame()
+                except TTransportException as e:
+                    if e.type == TTransportException.END_OF_FILE:
+                        break
+                    else:
+                        raise
                 tr = TMemoryBuffer(frame)
                 iprot = self._iprot_factory.getProtocol(tr)
                 yield self._processor.process(iprot, oprot)