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

Start parking lot. Make abnormal shutdown a bit nicer.

Browse Source 
git-svn-id: svn://bind10.isc.org/svn/bind10/branches/f2f200910@200 e5f2f494-b856-4b98-b285-d166d9295462
This commit is contained in:
Shane Kerr 2009-10-29 23:22:36 +00:00
parent c9651bb45e
commit c44cf86a43
1 changed files with 44 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
src/bin/bind10/bind10.py
View File

@ -71,10 +71,9 @@ class BoB:
stderr=dev_null, stderr=dev_null,
close_fds=True, close_fds=True,
env=c_channel_env,) env=c_channel_env,)
except OSError: except:
return "Unable to start msgq" return "Unable to start msgq"
self.processes[c_channel.pid] = c_channel self.processes[c_channel.pid] = c_channel
self.cc_process = c_channel
if self.verbose: if self.verbose:
sys.stdout.write("Started msgq with PID %d\n" % c_channel.pid) sys.stdout.write("Started msgq with PID %d\n" % c_channel.pid)
@ -109,8 +108,34 @@ class BoB:
if self.verbose: if self.verbose:
sys.stdout.write("Started bind-cfgd with PID %d\n" % bind_cfgd.pid) sys.stdout.write("Started bind-cfgd with PID %d\n" % bind_cfgd.pid)
# start the parking lot
# XXX: this must be read from the configuration manager in the future
if self.verbose:
sys.stdout.write("Starting parkinglot\n")
try:
parkinglot = subprocess.Popen("parkinglot",
stdin=dev_null,
stdout=dev_null,
stderr=dev_null,
close_fds=True,
env={},)
except:
c_channel.kill()
bind_cfgd.kill()
return "Unable to start parkinglot"
self.processes[parkinglot.pid] = parkinglot
if self.verbose:
sys.stdout.write("Started parkinglot with PID %d\n" % parkinglot.pid)
# remember our super-important process
self.cc_process = c_channel
return None return None
def stop_all_processes(self):
"""Stop all processes."""
self.cc_session.group_sendmsg({ "shutdown": True }, "Boss")
def stop_process(self, process): def stop_process(self, process):
"""Stop the given process, friendly-like.""" """Stop the given process, friendly-like."""
# XXX nothing yet # XXX nothing yet
@ -121,12 +146,14 @@ class BoB:
if self.verbose: if self.verbose:
sys.stdout.write("Stopping the server.\n") sys.stdout.write("Stopping the server.\n")
# first try using the BIND 10 request to stop # first try using the BIND 10 request to stop
unstopped_processes = [] if self.cc_session:
for process in self.processes.values(): try:
if not self.stop_process(process): self.stop_all_processes()
unstopped_processes.append(process) except:
pass
time.sleep(0.1) # XXX: some delay probably useful... how much is uncertain
# next try sending a SIGTERM # next try sending a SIGTERM
processes_to_stop = unstopped_processes processes_to_stop = list(self.processes)
unstopped_processes = [] unstopped_processes = []
for process in processes_to_stop: for process in processes_to_stop:
if self.verbose: if self.verbose:
@ -155,7 +182,6 @@ class BoB:
pass pass
if self.verbose: if self.verbose:
sys.stdout.write("All processes ended, server done.\n") sys.stdout.write("All processes ended, server done.\n")
sys.exit(0)
def reap(self, pid, exit_status): def reap(self, pid, exit_status):
"""The process specified by pid has exited with the value """The process specified by pid has exited with the value
@ -166,10 +192,12 @@ class BoB:
self.dead_processes[process.pid] = process self.dead_processes[process.pid] = process
if self.verbose: if self.verbose:
sys.stdout.write("Process %d died.\n" % pid) sys.stdout.write("Process %d died.\n" % pid)
if pid == self.cc_process.pid: if self.cc_process and (pid == self.cc_process.pid):
if self.verbose: if self.verbose:
sys.stdout.write("The msgq process died, shutting down.\n") sys.stdout.write("The msgq process died, shutting down.\n")
self.shutdown() return False
else:
return True
if __name__ == "__main__": if __name__ == "__main__":
def reaper(signal_number, stack_frame): def reaper(signal_number, stack_frame):
@ -182,7 +210,12 @@ if __name__ == "__main__":
if o.errno == errno.ECHILD: break if o.errno == errno.ECHILD: break
raise raise
if pid == 0: break if pid == 0: break
boss_of_bind.reap(pid, exit_status) if not boss_of_bind.reap(pid, exit_status):
signal.signal(signal.SIGCHLD, signal.SIG_DFL)
boss_of_bind.shutdown()
sys.exit(0)
def get_signame(signal_number): def get_signame(signal_number):
"""Return the symbolic name for a signal.""" """Return the symbolic name for a signal."""