github
/
jumpserver
mirror of https://github.com/jumpserver/jumpserver
1
0
Fork 0
Code Issues Releases Wiki Activity

添加删除pid条目

pull/2/head
ibuler 2014-11-04 00:22:52 +08:00
parent 06e788782b
commit 654c27490d
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
webroot/AutoSa/log_handler.py
View File

@ -48,16 +48,22 @@ def pid_exist(pid):
return False return False
def del_pid(pid_id):
pid = Pid.objects.filter(id=pid_id)
if pid:
pid[0].delete()
def get_pids(): def get_pids():
pids = [] pids = []
pids_obj = Pid.objects.all() pids_obj = Pid.objects.all()
for pid_obj in pids_obj: for pid_obj in pids_obj:
pids.append((pid_obj.ppid, pid_obj.cpid, pid_obj.logid, pid_obj.start_time)) pids.append((pid_obj.id, pid_obj.ppid, pid_obj.cpid, pid_obj.logid, pid_obj.start_time))
return pids return pids
def run(): def run():
for ppid, cpid, logid, start_time in get_pids(): for pid_id, ppid, cpid, logid, start_time in get_pids():
if pid_exist(cpid): if pid_exist(cpid):
if pid_exist(ppid): if pid_exist(ppid):
structtime_start = time.localtime() structtime_start = time.localtime()
@ -65,13 +71,16 @@ def run():
if timestamp_end - start_time > 7200: if timestamp_end - start_time > 7200:
kill_pid(ppid) kill_pid(ppid)
kill_pid(cpid) kill_pid(cpid)
del_pid(pid_id)
set_finish(logid) set_finish(logid)
log_hanler(logid) log_hanler(logid)
else: else:
kill_pid(cpid) kill_pid(cpid)
del_pid(pid_id)
set_finish(logid) set_finish(logid)
log_hanler(logid) log_hanler(logid)
else: else:
del_pid(pid_id)
set_finish(logid) set_finish(logid)
log_hanler(logid) log_hanler(logid)