def get(self,request,node_name, process_name):
if request.session['usertype'] == 0 or request.session['usertype'] == 1:
try:
node_config = Config(CONFIG_FILE).getNodeConfig(node_name)
node = Node(node_config)
if node.connection.supervisor.stopProcess(process_name):
add_log = open(ACTIVITY_LOG, "a")
add_log.write("%s - %s stopped %s node's %s process .\n"%( timezone.localtime().ctime(), request.session['username'], node_name, process_name ))
return JsonValue(process_name, node_name, "stop").success()
except xmlrpclib.Fault as err:
add_log = open(ACTIVITY_LOG, "a")
add_log.write("%s - %s unsucces stop event %s node's %s process .\n"%( timezone.localtime().ctime(), request.session['username'], node_name, process_name ))
return JsonValue(process_name, node_name, "stop").error(err.faultCode, err.faultString)
else:
add_log = open(ACTIVITY_LOG, "a")
add_log.write("%s - %s is unauthorized user request for stop. Stop event fail for %s node's %s process .\n"%( timezone.localtime().ctime(), request.session['username'], node_name, process_name ))
return JsonResponse({'status' : "error2",
'message' : "You are not authorized this action"} )
# Node name list in the configuration file
评论列表
文章目录