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

print memory info at warning threshold

Browse Source
This commit is contained in:
Alexey Avramov 2020-06-26 20:21:24 +09:00
parent 01d235efda
commit ac2572190c
1 changed files with 34 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
src/nohang
View File

@ -461,6 +461,8 @@ def send_notify_warn():
""" """
log('Warning threshold exceeded') log('Warning threshold exceeded')
log_meminfo()
if check_warning_exe: if check_warning_exe:
start_thread(exe, warning_exe) start_thread(exe, warning_exe)
@ -2319,6 +2321,37 @@ def is_victim_alive(victim_id):
return 0 return 0
def log_meminfo():
"""
"""
mid = meminfo()
log('Memory info, MiB:')
log(' total={}, used={}, free={}, available={}, shared={}, buffers'
'={}, cache={},'.format(
round(mem_total / 1024),
round(mid['used'] / 1024),
round(mid['free'] / 1024),
round(mid['available'] / 1024),
round(mid['shared'] / 1024),
round(mid['buffers'] / 1024),
round(mid['cache'] / 1024)
))
log(' swap_total={}, swap_used={}, swap_free={}'.format(
round(mid['swap_total'] / 1024),
round(mid['swap_used'] / 1024),
round(mid['swap_free'] / 1024)
))
if PSI_KERNEL_OK:
mp = psi_file_mem_to_metrics('/proc/pressure/memory')
log('Memory pressure (system-wide):')
log(' some avg10={} avg60={} avg300={}'.format(
mp[0], mp[1], mp[2]
))
log(' full avg10={} avg60={} avg300={}'.format(
mp[3], mp[4], mp[5]
))
def implement_corrective_action( def implement_corrective_action(
threshold, threshold,
mem_info_list, mem_info_list,
@ -2509,32 +2542,7 @@ def implement_corrective_action(
return psi_t0 return psi_t0
mid = meminfo() log_meminfo()
log('Memory info, MiB:')
log(' total={}, used={}, free={}, available={}, shared={}, buffers'
'={}, cache={},'.format(
round(mem_total / 1024),
round(mid['used'] / 1024),
round(mid['free'] / 1024),
round(mid['available'] / 1024),
round(mid['shared'] / 1024),
round(mid['buffers'] / 1024),
round(mid['cache'] / 1024)
))
log(' swap_total={}, swap_used={}, swap_free={}'.format(
round(mid['swap_total'] / 1024),
round(mid['swap_used'] / 1024),
round(mid['swap_free'] / 1024)
))
if PSI_KERNEL_OK:
mp = psi_file_mem_to_metrics('/proc/pressure/memory')
log('Memory pressure (system-wide):')
log(' some avg10={} avg60={} avg300={}'.format(
mp[0], mp[1], mp[2]
))
log(' full avg10={} avg60={} avg300={}'.format(
mp[3], mp[4], mp[5]
))
if (threshold is SIGKILL and post_kill_exe != '') or ( if (threshold is SIGKILL and post_kill_exe != '') or (
soft_actions and threshold is SIGTERM): soft_actions and threshold is SIGTERM):