Skip to content
Snippets Groups Projects
Commit 35b1c7fb authored by Chris Hines's avatar Chris Hines
Browse files

Revert "more debug statments"

This reverts commit aa469396.
parent da872287
No related branches found
No related tags found
4 merge requests!77Revert "disable agressive kill and restart",!35Dev,!26Dev,!25Dev
......@@ -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()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment