Merge pull request #3033 from benoitc/fix-gthread

revert change considering connection as idle
This commit is contained in:
Benoit Chesneau 2023-07-19 13:26:28 +02:00 committed by GitHub
commit f5669f6475
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -122,13 +122,10 @@ class ThreadWorker(base.Worker):
sock, client = listener.accept()
# initialize the connection object
conn = TConn(self.cfg, sock, client, server)
# set timeout to ensure it will not be in the loop too long
conn.set_timeout()
self.nr_conns += 1
# wait until socket is readable
with self._lock:
self._keep.append(conn)
self.poller.register(conn.sock, selectors.EVENT_READ,
partial(self.on_client_socket_readable, conn))
except EnvironmentError as e: