github/nohang
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix output

Browse Source
This commit is contained in:
Alexey Avramov 2018-12-14 20:02:29 +09:00
parent 8f43c5528d
commit 748a1abc49
2 changed files with 62 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

88
nohang
View File

@ -24,6 +24,21 @@ nc = nm + 1
# function definition section # function definition section
def format_time(t):
t = int(t)
if t < 60:
return '{} sec'.format(t)
elif t >= 60 and t < 3600:
m = t // 60
s = t % 60
return '{} min {} sec'.format(m, s)
else:
h = t // 3600
s0 = t - h * 3600
m = s0 // 60
s = s0 % 60
return '{} h {} min {} sec'.format(h, m, s)
def root_notify_env(): def root_notify_env():
""" """
@ -72,7 +87,7 @@ def string_to_float_convert_test(string):
def string_to_int_convert_test(string): def string_to_int_convert_test(string):
"""Try to interpretst string values as integers.""" """Try to interpret string values as integers."""
try: try:
return int(string) return int(string)
except ValueError: except ValueError:
@ -466,50 +481,66 @@ def find_victim_and_send_signal(signal):
except ValueError: except ValueError:
pass pass
oom_score = rline1('/proc/' + pid + '/oom_score')
oom_score_adj = rline1('/proc/' + pid + '/oom_score_adj')
len_vm = len(str(vm_size))
if detailed_rss: if detailed_rss:
victim_info = ' Found the victim with highest badness:' \ victim_info = '\033[4mFound the victim with highest badness:\033[0m' \
'\n Name: \033[33m{}\033[0m' \ '\n Name: \033[33m{}\033[0m' \
'\n PID: \033[33m{}\033[0m' \ '\n PID: \033[33m{}\033[0m' \
'\n UID: \033[33m{}\033[0m' \ '\n UID: \033[33m{}\033[0m' \
'\n Badness: \033[33m{}\033[0m' \ '\n Badness: \033[33m{}\033[0m, ' \
'oom_score: \033[33m{}\033[0m, ' \
'oom_score_adj: \033[33m{}\033[0m' \
'\n VmSize: \033[33m{}\033[0m MiB' \ '\n VmSize: \033[33m{}\033[0m MiB' \
'\n VmRSS: \033[33m{}\033[0m MiB' \ '\n VmRSS: \033[33m{}\033[0m MiB (' \
'\n Anon: \033[33m{}\033[0m MiB' \ 'Anon: \033[33m{}\033[0m MiB, ' \
'\n File: \033[33m{}\033[0m MiB' \ 'File: \033[33m{}\033[0m MiB, ' \
'\n Shmem: \033[33m{}\033[0m MiB' \ 'Shmem: \033[33m{}\033[0m MiB)' \
'\n VmSwap: \033[33m{}\033[0m MiB' \ '\n VmSwap: \033[33m{}\033[0m MiB' \
'\n CmdLine: \033[33m{}\033[0m'.format( '\n CmdLine: \033[33m{}\033[0m'.format(
name, pid, uid, victim_badness, vm_size, name, pid, uid,
vm_rss, anon_rss, file_rss, shmem_rss, vm_swap, cmdline) victim_badness, oom_score, oom_score_adj,
vm_size, str(vm_rss).rjust(len_vm, ' '),
anon_rss, file_rss, shmem_rss,
str(vm_swap).rjust(len_vm, ' '), cmdline)
else: else:
victim_info = ' Found the victim with highest badness:' \ victim_info = '\033[4mFound the victim with highest badness:\033[0m' \
'\n Name: \033[33m{}\033[0m' \ '\n Name: \033[33m{}\033[0m' \
'\n PID: \033[33m{}\033[0m' \ '\n PID: \033[33m{}\033[0m' \
'\n UID: \033[33m{}\033[0m' \ '\n UID: \033[33m{}\033[0m' \
'\n Badness: \033[33m{}\033[0m' \ '\n Badness: \033[33m{}\033[0m, ' \
'oom_score: \033[33m{}\033[0m, ' \
'oom_score_adj: \033[33m{}\033[0m' \
'\n VmSize: \033[33m{}\033[0m MiB' \ '\n VmSize: \033[33m{}\033[0m MiB' \
'\n VmRSS: \033[33m{}\033[0m MiB' \ '\n VmRSS: \033[33m{}\033[0m MiB' \
'\n VmSwap: \033[33m{}\033[0m MiB' \ '\n VmSwap: \033[33m{}\033[0m MiB' \
'\n CmdLine: \033[33m{}\033[0m'.format( '\n CmdLine: \033[33m{}\033[0m'.format(
name, pid, uid, victim_badness, vm_size, name, pid, uid, victim_badness, vm_size,
vm_rss, vm_swap, cmdline) str(vm_rss).rjust(len_vm, ' '),
str(vm_swap).rjust(len_vm, ' '), cmdline)
if execute_the_command and signal is SIGTERM and name in etc_dict: if execute_the_command and signal is SIGTERM and name in etc_dict:
command = etc_dict[name] command = etc_dict[name]
exit_status = os.system(etc_dict[name]) exit_status = os.system(etc_dict[name])
if exit_status == 0:
exit_status = '\033[32m0\033[0m'
else:
exit_status = '\033[31m{}\033[0m'.format(exit_status)
response_time = time() - time0 response_time = time() - time0
# todo: display oom_score, oom_score_adj
etc_info = '{}' \ etc_info = '{}' \
'\n Execute the command: \033[4m{}\033[0m' \ '\n\033[4mImplement corrective action:\033[0m\n Execute the command: \033[4m{}\033[0m' \
'\n Exit status: {}; response time: {} ms'.format( '\n Exit status: {}; response time: {} ms'.format(
victim_info, command, exit_status, victim_info, command, exit_status,
round(response_time * 1000)) round(response_time * 1000))
# update stat_dict # update stat_dict
key = "Run the command '{}'".format(command) key = "Run the command '\033[35m{}\033[0m'".format(command)
if key not in stat_dict: if key not in stat_dict:
stat_dict.update({key: 1}) stat_dict.update({key: 1})
else: else:
@ -531,7 +562,7 @@ def find_victim_and_send_signal(signal):
round(response_time * 1000)) round(response_time * 1000))
# update stat_dict # update stat_dict
key = 'Send {} to {}'.format(sig_dict[signal], name) key = 'Send \033[35m{}\033[0m to \033[35m{}\033[0m'.format(sig_dict[signal], name)
if key not in stat_dict: if key not in stat_dict:
stat_dict.update({key: 1}) stat_dict.update({key: 1})
else: else:
@ -551,12 +582,13 @@ def find_victim_and_send_signal(signal):
round(response_time * 1000)) round(response_time * 1000))
preventing_oom_message = '{}' \ preventing_oom_message = '{}' \
'\n Sending \033[4m{}\033[0m to the victim; {}'.format( '\n\033[4mImplement corrective action:\033[0m\n ' \
'Sending \033[4m{}\033[0m to the victim; {}'.format(
victim_info, sig_dict[signal], send_result) victim_info, sig_dict[signal], send_result)
print(mem_info) print(mem_info)
print(preventing_oom_message) print(preventing_oom_message)
print('Duration of work: {} sec; number of corrective actions:'.format( print('\n\033[4mDuration of work: {}; number of corrective actions:\033[0m'.format(
round(time() - start_time))) format_time(time() - start_time)))
for key in stat_dict: for key in stat_dict:
print(' - {}: {}'.format(key, stat_dict[key])) print(' - {}: {}'.format(key, stat_dict[key]))
@ -1411,10 +1443,10 @@ while True:
# MEM SWAP KILL # MEM SWAP KILL
if mem_available <= mem_min_sigkill_kb and \ if mem_available <= mem_min_sigkill_kb and \
swap_free <= swap_min_sigkill_kb: swap_free <= swap_min_sigkill_kb:
time0 = time() time0 = time()
mem_info = '\033[4mLow memory; corrective action required!' \ mem_info = '\n\033[4mMemory status that requires corrective actions:' \
'\033[0m\n MemAvailable [{} MiB, {} %] <= mem_min_sig' \ '\033[0m\n MemAvailable [{} MiB, {} %] <= mem_min_sig' \
'kill [{} MiB, {} %]\n SwapFree [{} MiB, {} %] <= swa' \ 'kill [{} MiB, {} %]\n SwapFree [{} MiB, {} %] <= swa' \
'p_min_sigkill [{} MiB, {} %]'.format( 'p_min_sigkill [{} MiB, {} %]'.format(
@ -1433,7 +1465,7 @@ while True:
elif mem_used_zram >= zram_max_sigkill_kb: elif mem_used_zram >= zram_max_sigkill_kb:
time0 = time() time0 = time()
mem_info = '\033[4mLow memory; corrective action required!' \ mem_info = '\n\033[4mMemory status that requires corrective actions:' \
'\033[0m\n MemUsedZram [{} MiB, {} %] >= zram_max_sig' \ '\033[0m\n MemUsedZram [{} MiB, {} %] >= zram_max_sig' \
'kill [{} MiB, {} %]'.format( 'kill [{} MiB, {} %]'.format(
kib_to_mib(mem_used_zram), kib_to_mib(mem_used_zram),
@ -1445,11 +1477,11 @@ while True:
# MEM SWAP TERM # MEM SWAP TERM
elif mem_available <= mem_min_sigterm_kb and \ elif mem_available <= mem_min_sigterm_kb and \
swap_free <= swap_min_sigterm_kb: swap_free <= swap_min_sigterm_kb:
time0 = time() time0 = time()
mem_info = '\033[4mLow memory; corrective action required!' \ mem_info = '\n\033[4mMemory status that requires corrective actions:' \
'\033[0m\n MemAvailable [{} MiB, {} %] <= mem_min_sig' \ '\033[0m\n MemAvailable [{} MiB, {} %] <= mem_min_sig' \
'term [{} MiB, {} %]\n SwapFree [{} MiB, {} %] <= swa' \ 'term [{} MiB, {} %]\n SwapFree [{} MiB, {} %] <= swa' \
'p_min_sigterm [{} MiB, {} %]'.format( 'p_min_sigterm [{} MiB, {} %]'.format(
@ -1470,9 +1502,9 @@ while True:
elif mem_used_zram >= zram_max_sigterm_kb: elif mem_used_zram >= zram_max_sigterm_kb:
time0 = time() time0 = time()
mem_info = '\033[4mLow memory; corrective action ' \ mem_info = '\n\033[4mMemory status that requires corrective actions:' \
'required!\033[0m\n MemUsedZram [{} MiB, {} ' \ '\033[0m\n MemUsedZram [{} MiB, {} %] >= ' \
'%] >= zram_max_sigterm [{} M, {} %]'.format( 'zram_max_sigterm [{} M, {} %]'.format(
kib_to_mib(mem_used_zram), kib_to_mib(mem_used_zram),
percent(mem_used_zram / mem_total), percent(mem_used_zram / mem_total),
kib_to_mib(zram_max_sigterm_kb), kib_to_mib(zram_max_sigterm_kb),

4
nohang.conf
View File

@ -199,7 +199,7 @@ re_match_uid = False
Valid values are True and False. Valid values are True and False.
execute_the_command = False execute_the_command = True
The length of the process name can't exceed 15 characters. The length of the process name can't exceed 15 characters.
The syntax is as follows: lines starting with keyword $ETC are The syntax is as follows: lines starting with keyword $ETC are
@ -215,7 +215,7 @@ execute_the_command = False
$ETC mysqld /// systemctl restart mariadb.service & $ETC mysqld /// systemctl restart mariadb.service &
$ETC php-fpm7.0 /// systemctl restart php7.0-fpm.service $ETC php-fpm7.0 /// systemctl restart php7.0-fpm.service
$ETC name /// some command $ETC python3 /// exit 0
##################################################################### #####################################################################