summaryrefslogtreecommitdiff
path: root/tools/testing/selftests/damon/damos_apply_interval.py
blob: f04d43702481c5b976f67037b1a1f5fa97af8be4 (plain)
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
#!/usr/bin/env python3
# SPDX-License-Identifier: GPL-2.0

import subprocess
import time

import _damon_sysfs

def main():
    # access two 10 MiB memory regions, 2 second per each
    sz_region = 10 * 1024 * 1024
    proc = subprocess.Popen(['./access_memory', '2', '%d' % sz_region, '2000'])

    # Set quota up to 1 MiB per 100 ms
    kdamonds = _damon_sysfs.Kdamonds([_damon_sysfs.Kdamond(
            contexts=[_damon_sysfs.DamonCtx(
                ops='vaddr',
                targets=[_damon_sysfs.DamonTarget(pid=proc.pid)],
                schemes=[
                    _damon_sysfs.Damos(
                        access_pattern=_damon_sysfs.DamosAccessPattern(
                            # >= 25% access rate, >= 200ms age
                            nr_accesses=[5, 20], age=[2, 2**64 - 1]),
                        # aggregation interval (100 ms) is used
                        apply_interval_us=0),
                    # use 10ms apply interval
                    _damon_sysfs.Damos(
                        access_pattern=_damon_sysfs.DamosAccessPattern(
                            # >= 25% access rate, >= 200ms age
                            nr_accesses=[5, 20], age=[2, 2**64 - 1]),
                        # explicitly set 10 ms apply interval
                        apply_interval_us=10 * 1000)
                    ] # schemes
                )] # contexts
            )]) # kdamonds

    err = kdamonds.start()
    if err != None:
        print('kdamond start failed: %s' % err)
        exit(1)

    wss_collected = []
    nr_quota_exceeds = 0
    while proc.poll() == None:
        time.sleep(0.1)
        err = kdamonds.kdamonds[0].update_schemes_stats()
        if err != None:
            print('stats update failed: %s' % err)
            exit(1)
    schemes = kdamonds.kdamonds[0].contexts[0].schemes
    nr_tried_stats = [s.stats.nr_tried for s in schemes]
    if nr_tried_stats[0] == 0 or nr_tried_stats[1] == 0:
        print('scheme(s) are not tried')
        exit(1)

    # Because the second scheme was having the apply interval that is ten times
    # lower than that of the first scheme, the second scheme should be tried
    # about ten times more frequently than the first scheme.  For possible
    # timing errors, check if it was at least nine times more freuqnetly tried.
    ratio = nr_tried_stats[1] / nr_tried_stats[0]
    if ratio < 9:
        print('%d / %d = %f (< 9)' %
              (nr_tried_stats[1], nr_tried_stats[0], ratio))
        exit(1)

if __name__ == '__main__':
    main()