diff --git a/TWS/twsproxy/__init__.py b/TWS/twsproxy/__init__.py index f84e09aaa354e131c2262aa564ec7d93c02c365a..c5498fab9907dfdc1b8578dcce3574472d79e3b3 100644 --- a/TWS/twsproxy/__init__.py +++ b/TWS/twsproxy/__init__.py @@ -183,7 +183,6 @@ class TWSProxy(threading.Thread): logger = logging.getLogger() closed = False name = threading.current_thread().name - logger.debug('begining sock copy {} {}'.format(src,dest)) while not closed: r,w,e = select.select([src],[],[],TWSProxy.TIMEOUT) if len(r) > 0: @@ -194,24 +193,20 @@ class TWSProxy(threading.Thread): if buff is None: continue except ConnectionResetError as e: - logger.debug('connection reset closing {} {}'.format(src,dest)) closed = True continue except Exception as e: import traceback logger.error(traceback.format_exc()) - logger.debug('Exception in sockcopy {} {}'.format(src,dest)) closed = True msglength = len(buff) if msglength > 0: TWSProxy.reliablesend(dest,buff,msglength) if msglength == 0: - logger.debug('msglength 0, closing {} {}'.format(src,dest)) dest.shutdown(shuttype) initshutdown.set() closed = True - logger.debug('ending sock copy {} {}'.format(src,dest)) dest.shutdown(shuttype) initshutdown.set()