Show More
@@ -11,7 +11,6 b' import errno' | |||||
11 | import gc |
|
11 | import gc | |
12 | import os |
|
12 | import os | |
13 | import random |
|
13 | import random | |
14 | import select |
|
|||
15 | import signal |
|
14 | import signal | |
16 | import socket |
|
15 | import socket | |
17 | import struct |
|
16 | import struct | |
@@ -488,15 +487,15 b' class unixforkingservice(object):' | |||||
488 | # waiting for recv() will receive ECONNRESET. |
|
487 | # waiting for recv() will receive ECONNRESET. | |
489 | self._unlinksocket() |
|
488 | self._unlinksocket() | |
490 | exiting = True |
|
489 | exiting = True | |
491 | try: |
|
|||
492 |
|
|
490 | ready = selector.select(timeout=h.pollinterval) | |
493 |
|
|
491 | if not ready: | |
494 |
|
|
492 | # only exit if we completed all queued requests | |
495 |
|
|
493 | if exiting: | |
496 |
|
|
494 | break | |
497 |
|
|
495 | continue | |
|
496 | try: | |||
498 | conn, _addr = self._sock.accept() |
|
497 | conn, _addr = self._sock.accept() | |
499 |
except |
|
498 | except socket.error as inst: | |
500 | if inst.args[0] == errno.EINTR: |
|
499 | if inst.args[0] == errno.EINTR: | |
501 | continue |
|
500 | continue | |
502 | raise |
|
501 | raise |
General Comments 0
You need to be logged in to leave comments.
Login now