Show More
@@ -447,6 +447,7 b' class unixforkingservice(object):' | |||
|
447 | 447 | self._sock = None |
|
448 | 448 | self._oldsigchldhandler = None |
|
449 | 449 | self._workerpids = set() # updated by signal handler; do not iterate |
|
450 | self._socketunlinked = None | |
|
450 | 451 | |
|
451 | 452 | def init(self): |
|
452 | 453 | self._sock = socket.socket(socket.AF_UNIX) |
@@ -455,11 +456,17 b' class unixforkingservice(object):' | |||
|
455 | 456 | o = signal.signal(signal.SIGCHLD, self._sigchldhandler) |
|
456 | 457 | self._oldsigchldhandler = o |
|
457 | 458 | self._servicehandler.printbanner(self.address) |
|
459 | self._socketunlinked = False | |
|
460 | ||
|
461 | def _unlinksocket(self): | |
|
462 | if not self._socketunlinked: | |
|
463 | self._servicehandler.unlinksocket(self.address) | |
|
464 | self._socketunlinked = True | |
|
458 | 465 | |
|
459 | 466 | def _cleanup(self): |
|
460 | 467 | signal.signal(signal.SIGCHLD, self._oldsigchldhandler) |
|
461 | 468 | self._sock.close() |
|
462 |
self._ |
|
|
469 | self._unlinksocket() | |
|
463 | 470 | # don't kill child processes as they have active clients, just wait |
|
464 | 471 | self._reapworkers(0) |
|
465 | 472 |
General Comments 0
You need to be logged in to leave comments.
Login now