From 6e134d899ce3591b0a91ceacba530a5fbcf10a3c Mon Sep 17 00:00:00 2001 From: Jiri Lunacek Date: Mon, 15 Aug 2016 16:45:35 +0200 Subject: [PATCH] zabraneni zamknuti threadu pri cekani na accept --- rfoo/_rfoo.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/rfoo/_rfoo.py b/rfoo/_rfoo.py index fed7a46..4770a7a 100644 --- a/rfoo/_rfoo.py +++ b/rfoo/_rfoo.py @@ -53,6 +53,7 @@ import threading import logging import inspect import socket +import select import sys import os @@ -446,7 +447,7 @@ class Server(object): self._handler_type = handler_type self._conn = conn self._ssl_context = ssl_context - self._stop = Event() + self._stop = threading.Event() def stop(self): self._stop.set() @@ -475,6 +476,9 @@ class Server(object): while True: if self.stopped(): break + rlist,dummy,dummy = select.select([self._conn],[],[],0.1) + if len(rlist) == 0: + continue conn, addr = self._conn.accept() conn.settimeout(None) if self._ssl_context != None: