third-party-mirrors/rfoo
1
0
Fork 0
mirror of https://github.com/aaiyer/rfoo.git synced 2025-06-07 06:23:00 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

zabraneni zamknuti threadu pri cekani na accept

Browse Source
This commit is contained in:
Jiri Lunacek 2016-08-15 16:45:35 +02:00
parent 3792c1a2d8
commit 6e134d899c
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rfoo/_rfoo.py
View File

@ -53,6 +53,7 @@ import threading
import logging import logging
import inspect import inspect
import socket import socket
import select
import sys import sys
import os import os
@ -446,7 +447,7 @@ class Server(object):
self._handler_type = handler_type self._handler_type = handler_type
self._conn = conn self._conn = conn
self._ssl_context = ssl_context self._ssl_context = ssl_context
self._stop = Event() self._stop = threading.Event()
def stop(self): def stop(self):
self._stop.set() self._stop.set()
@ -475,6 +476,9 @@ class Server(object):
while True: while True:
if self.stopped(): if self.stopped():
break break
rlist,dummy,dummy = select.select([self._conn],[],[],0.1)
if len(rlist) == 0:
continue
conn, addr = self._conn.accept() conn, addr = self._conn.accept()
conn.settimeout(None) conn.settimeout(None)
if self._ssl_context != None: if self._ssl_context != None: