diff options
| author | pzread <netfirewall@gmail.com> | 2013-06-03 21:40:37 +0800 |
|---|---|---|
| committer | pzread <netfirewall@gmail.com> | 2013-06-03 21:40:37 +0800 |
| commit | 9fa7badc787ec364d58f65b95355c8725ad75a9c (patch) | |
| tree | 45c37afd8ec06e093c5fb257259110fe86fd770c /src/py/netio.py | |
| parent | 13445dbeb426347354b61bd46f738f37b25ffd60 (diff) | |
| download | taiwan-online-judge-9fa7badc787ec364d58f65b95355c8725ad75a9c.tar.gz taiwan-online-judge-9fa7badc787ec364d58f65b95355c8725ad75a9c.tar.zst taiwan-online-judge-9fa7badc787ec364d58f65b95355c8725ad75a9c.zip | |
IMC framework 1.0 Alpha 1
Diffstat (limited to 'src/py/netio.py')
| -rw-r--r-- | src/py/netio.py | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/src/py/netio.py b/src/py/netio.py index e148cd6..4fe61bd 100644 --- a/src/py/netio.py +++ b/src/py/netio.py @@ -152,6 +152,10 @@ class SocketStream: iocb[1] = size break + except Exception: + self.close() + return + elif datatype == self.DATA_NOBUF: size = iocb[1] @@ -173,6 +177,10 @@ class SocketStream: iocb[1] = size break + except Exception: + self.close() + return + elif datatype == self.DATA_FILE: size = iocb[1] @@ -197,6 +205,10 @@ class SocketStream: iocb[1] = size break + except Exception: + self.close() + return + if evt & tornado.ioloop.IOLoop.WRITE: if self._conning == True: self._conning = False @@ -232,6 +244,10 @@ class SocketStream: iocb[1] = off break + except Exception: + self.close() + return + elif datatype == self.DATA_FILE: size = iocb[1] filefd = iocb[2] @@ -257,6 +273,10 @@ class SocketStream: iocb[1] = size break + except Exception: + self.close() + return + if self._closed == True: return |