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