1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
# SPDX-License-Identifier: GPL-2.0
"Control DAMON_LRU_SORT"
import argparse
import os
import time
import _damon
plrus_params_dir = '/sys/module/damon_lru_sort/parameters'
plrus_params = ['kdamond_pid', 'enabled', 'hot_thres_access_freq',
'cold_min_age', 'quota_ms', 'quota_reset_interval_ms',
'wmarks_interval', 'wmarks_high', 'wmarks_mid', 'wmarks_low',
'sample_interval', 'aggr_interval', 'min_nr_regions', 'max_nr_regions',
'monitor_region_start', 'monitor_region_end',
'nr_lru_sort_tried_hot_regions', 'nr_lru_sorted_hot_regions',
'bytes_lru_sort_tried_hot_regions', 'bytes_lru_sorted_hot_regions',
'nr_lru_sort_tried_cold_regions', 'nr_lru_sorted_cold_regions',
'bytes_lru_sort_tried_cold_regions', 'bytes_lru_sorted_cold_regions']
def chk_plrus_sysfs():
if not os.path.isdir(plrus_params_dir):
print('%s not found' % plrus_params_dir)
for param in plrus_params:
param_file = os.path.join(plrus_params_dir, param)
if not os.path.isfile(param_file):
print('%s file not found' % param_file)
exit(1)
def set_param(param, val):
if val == None:
return
path = os.path.join(plrus_params_dir, param)
with open(path, 'w') as f:
f.write('%s' % val)
def plrus_running():
with open(os.path.join(plrus_params_dir, 'kdamond_pid')) as f:
return f.read() != '-1\n'
def plrus_enable(on):
if not on:
set_param('enabled', 'N')
while plrus_running():
time.sleep(1)
return
set_param('enabled', 'N')
while plrus_running():
time.sleep(1)
set_param('enabled', 'Y')
while not plrus_running():
time.sleep(1)
return
def plrus_read_status():
for param in plrus_params:
param_file = os.path.join(plrus_params_dir, param)
if not os.path.isfile(param_file):
continue
with open(param_file, 'r') as f:
print('%s: %s' % (param, f.read().strip()))
def main(args):
_damon.ensure_root_permission()
chk_plrus_sysfs()
if args.action == 'status':
plrus_read_status()
return
set_param('hot_thres_access_freq', args.hot_thres_access_freq)
set_param('cold_min_age', args.cold_min_age)
set_param('quota_ms', args.quota[0])
set_param('quota_reset_interval_ms', args.quota[1])
set_param('wmarks_interval', args.wmarks[0])
set_param('wmarks_high', args.wmarks[1])
set_param('wmarks_mid', args.wmarks[2])
set_param('wmarks_low', args.wmarks[3])
set_param('sample_interval', args.monitor_intervals[0])
set_param('aggr_interval', args.monitor_intervals[1])
set_param('min_nr_regions', args.nr_regions[0])
set_param('max_nr_regions', args.nr_regions[1])
set_param('monitor_region_start', args.monitor_region[0])
set_param('monitor_region_end', args.monitor_region[1])
plrus_enable(args.action == 'enable')
def set_argparser(parser):
parser.add_argument('action', type=str, nargs='?',
choices=['status', 'enable', 'disable'], default='status',
help='read status, enable, or disable DAMON_RECLAIM')
parser.add_argument('--hot_thres_access_freq', type=int,
metavar='<permil>',
help='hot memory region access frequency threshold (permil)')
parser.add_argument('--cold_min_age', type=int, metavar='<microseconds>',
help='time threshold for cold memory regions identification (us)')
parser.add_argument('--quota', type=int,
metavar=('<ms>', '<ms>'), nargs=2,
default=[None] * 2,
help='time quota and quota reset interval in ms')
parser.add_argument('--wmarks', type=int,
metavar=('<us>', '<per-thousand>', '<per-thousand>',
'<per-thousand>'),
nargs=4, default=[None] * 4,
help='watermarks check interval and three watermarks')
parser.add_argument('--monitor_intervals', type=int,
metavar='<microseconds>', nargs=2, default=[None] * 2,
help='intervals for sampling and aggregation of DAMON')
parser.add_argument('--nr_regions', type=int, metavar='<number>',
nargs=2, default=[None] * 2,
help='minimum and maximum number of DAMON memory regions')
parser.add_argument('--monitor_region', type=int, metavar='<phy addr>',
nargs=2, default=[None] * 2,
help='start and end addresses of the target memory region')
|
