[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [Xen-changelog] [xen-unstable] xend: take care of dead qemu-dm process
# HG changeset patch # User Keir Fraser <keir.fraser@xxxxxxxxxx> # Date 1211788405 -3600 # Node ID eafb252f141262c8bd6ce956ed951c40e13d3495 # Parent 14f03101b61ce87d3c8274b4fac785e34c0819eb xend: take care of dead qemu-dm process This patch fix xend as when fatal error happened (e.g. qemu-dm process was killed) log error message then mark that domain as crashed, do what specified on crashed in the domain config file. Added some code in xend to check those crashed hvm DM status each 30 seconds. Signed-off-by: Xiaowei Hu <xiaowei.hu@xxxxxxxxxx> --- tools/python/xen/xend/server/SrvServer.py | 18 ++++++++++++++++-- 1 files changed, 16 insertions(+), 2 deletions(-) diff -r 14f03101b61c -r eafb252f1412 tools/python/xen/xend/server/SrvServer.py --- a/tools/python/xen/xend/server/SrvServer.py Mon May 26 08:45:59 2008 +0100 +++ b/tools/python/xen/xend/server/SrvServer.py Mon May 26 08:53:25 2008 +0100 @@ -44,6 +44,7 @@ import re import re import time import signal +import os from threading import Thread from xen.web.httpserver import HttpServer, UnixHttpServer @@ -148,14 +149,27 @@ class XendServers: # Reaching this point means we can auto start domains try: - xenddomain().autostart_domains() + dom = xenddomain() + dom.autostart_domains() except Exception, e: log.exception("Failed while autostarting domains") # loop to keep main thread alive until it receives a SIGTERM self.running = True while self.running: - time.sleep(100000000) + # loop to destroy those hvm domain that whoes DM has dead unexpectedly. + for item in dom.domains.values(): + if item.info.is_hvm(): + device_model_pid = item.gatherDom(('image/device-model-pid', str)) + dm_stat_cmd = "ps -o stat --no-headers -p"+device_model_pid + dm_stat = os.popen(dm_stat_cmd).readline().rstrip() + if dm_stat == 'Z': + log.warn("Devices Model for domain " + str(item.domid) + "was killed unexpectedly") + item.info['crashed'] = 1 + item.refreshShutdown(item.info) + else: + continue + time.sleep(30) if self.reloadingConfig: log.info("Restarting all XML-RPC and Xen-API servers...") _______________________________________________ Xen-changelog mailing list Xen-changelog@xxxxxxxxxxxxxxxxxxx http://lists.xensource.com/xen-changelog
|
Lists.xenproject.org is hosted with RackSpace, monitoring our |