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):
if node.connection.supervisor.startProcess(process_name):
add_log = open(ACTIVITY_LOG, "a")
add_log.write("%s - %s restarted %s node's %s process .\n"%( timezone.localtime().ctime(), request.session['username'], node_name, process_name ))
return JsonValue(process_name, node_name, "restart").success()
except xmlrpclib.Fault as err:
add_log = open(ACTIVITY_LOG, "a")
add_log.write("%s - %s unsucces restart event %s node's %s process .\n"%( timezone.localtime().ctime(), request.session['username'], node_name, process_name ))
return JsonValue(process_name, node_name, "restart").error(err.faultCode, err.faultString)
else:
add_log = open(ACTIVITY_LOG, "a")
add_log.write("%s - %s is unauthorized user request for restart. Restart event fail for %s node's %s process .\n"%( timezone.localtime().ctime(), request.session['username'], node_name, process_name ))
return jsonify(status = "error2",
message = "You are not authorized this action" )
# Process start
评论列表
文章目录