From 256f86b76adf4b129643c4c7141dd5f06d39e3d0 Mon Sep 17 00:00:00 2001 From: mwechsler Date: Wed, 1 Sep 2021 12:24:33 +0200 Subject: [PATCH] [STCC-314] Error in start_tcp_server() in /web folder [MW] --- web/jobmonitorserver/jobmonitortcpserver.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/web/jobmonitorserver/jobmonitortcpserver.py b/web/jobmonitorserver/jobmonitortcpserver.py index 8aec9b57..64f7af92 100644 --- a/web/jobmonitorserver/jobmonitortcpserver.py +++ b/web/jobmonitorserver/jobmonitortcpserver.py @@ -309,16 +309,16 @@ def run(self): class JobMonitorTCPServer(TCPServer): def __init__(self, settings, io_loop=None, ssl_options=None): _logger.debug('Job Monitor Server started') + max_stream_buffer_size = int(settings["max_stream_buffer_size"]) if "max_stream_buffer_size" in settings else None + read_chunk_size = int(settings["read_chunk_size"]) if "read_chunk_size" in settings else None + super(JobMonitorTCPServer, self).__init__(ssl_options, max_stream_buffer_size, read_chunk_size) if not io_loop: io_loop = tornado.ioloop.IOLoop.instance() self.settings = settings self.io_loop = io_loop self.streams = {} check_zombie_interval = int(settings["check_zombie_interval"]) - self.io_loop.add_timeout(datetime.timedelta(seconds=check_zombie_interval), self.close_streams_after_timeout) - max_stream_buffer_size = int(settings["max_stream_buffer_size"]) if "max_stream_buffer_size" in settings else None - read_chunk_size = int(settings["read_chunk_size"]) if "read_chunk_size" in settings else None - super(JobMonitorTCPServer, self).__init__(io_loop, ssl_options, max_stream_buffer_size, read_chunk_size) + self.io_loop.add_timeout(datetime.timedelta(seconds=check_zombie_interval), self.close_streams_after_timeout) def stop(self): super(JobMonitorTCPServer, self).stop()