mir/kea
2
0
Fork 0
mirror of https://gitlab.isc.org/isc-projects/kea synced 2025-08-30 13:37:55 +00:00
Code Issues Releases Wiki Activity

[1858] refactoring: unify the SIGTERM/KILL cases into a single helper method.

Browse Source
This commit is contained in:
JINMEI Tatuya 2012-10-11 14:41:47 -07:00
parent 92f2cc5147
commit c9de286421
1 changed files with 23 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
src/bin/bind10/bind10_src.py.in
View File

@ -693,32 +693,35 @@ class BoB:
# from doing so
if not self.nokill:
# next try sending a SIGTERM
components_to_stop = list(self.components.values())
for component in components_to_stop:
logger.info(BIND10_SEND_SIGTERM, component.name(), component.pid())
try:
component.kill()
except OSError:
# ignore these (usually ESRCH because the child
# finally exited)
pass
# finally, send SIGKILL (unmaskable termination) until everybody dies
self.__terminate_children(False)
# finally, send SIGKILL (unmaskable termination) until everybody
# dies
while self.components:
# XXX: some delay probably useful... how much is uncertain
time.sleep(0.1)
self.reap_children()
components_to_stop = list(self.components.values())
for component in components_to_stop:
logger.info(BIND10_SEND_SIGKILL, component.name(),
component.pid())
try:
component.kill(True)
except OSError:
# ignore these (usually ESRCH because the child
# finally exited)
pass
self.__terminate_children(True)
logger.info(BIND10_SHUTDOWN_COMPLETE)
def __terminate_children(self, forceful):
'''Terminate remaining subprocesses by sending a signal.
The forceful paramter will be passed Component.kill().
This is a dedicated subroutine of shutdown(), just to unify two
similar cases.
'''
logmsg = BIND10_SEND_SIGKILL if forceful else BIND10_SEND_SIGTERM
# TODO: we should be able to skip list()
for component in list(self.components.values()):
logger.info(logmsg, component.name(), component.pid())
try:
component.kill(forceful)
except OSError:
# ignore these (usually ESRCH because the child
# finally exited)
pass
def _get_process_exit_status(self):
return os.waitpid(-1, os.WNOHANG)