try again to fix TWS

TWS/twsproxy/__init__.py

@@ -183,12 +183,9 @@ class TWSProxy(threading.Thread):
         logger = logging.getLogger()
         closed = False
         name = threading.current_thread().name
-        failcount=0
-        failthresh = 10
-        while not closed and failcount < failthresh:
+        while not closed:
             r,w,e = select.select([src],[],[],TWSProxy.TIMEOUT)
             if len(r) > 0:
-                failcount=0
                 buff = None
                 msglength = -1
                 try:
@@ -196,26 +193,23 @@ class TWSProxy(threading.Thread):
                     if buff is None:
                         continue
                 except ConnectionResetError as e:
-                    close = True
+                    closed = True
                     continue
                 except Exception as e:
                     import traceback
                     logger.error(traceback.format_exc())
-#                    closed = True
-                    continue
+                    closed = True
                 msglength = len(buff)
                 if msglength > 0:
                     TWSProxy.reliablesend(dest,buff,msglength)
                 if msglength == 0:
+                    #dest.send(buff)
                     dest.shutdown(shuttype)
                     initshutdown.set()
                     closed = True
-            else: 
-                failcount=failcount+1
 
-        if failcount > failthresh:
-            dest.shutdown(shuttype)
-            initshutdown.set()
+        dest.shutdown(shuttype)
+        initshutdown.set()
 
 def main():
     from . import server