From patchwork Tue Dec 12 19:48:07 2023 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: SeongJae Park X-Patchwork-Id: 13489826 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from kanga.kvack.org (kanga.kvack.org [205.233.56.17]) by smtp.lore.kernel.org (Postfix) with ESMTP id 6D2DEC4332F for ; Tue, 12 Dec 2023 19:48:30 +0000 (UTC) Received: by kanga.kvack.org (Postfix) id BF9096B0353; Tue, 12 Dec 2023 14:48:28 -0500 (EST) Received: by kanga.kvack.org (Postfix, from userid 40) id AEF0A6B0358; Tue, 12 Dec 2023 14:48:28 -0500 (EST) X-Delivered-To: int-list-linux-mm@kvack.org Received: by kanga.kvack.org (Postfix, from userid 63042) id 874BE6B0356; Tue, 12 Dec 2023 14:48:28 -0500 (EST) X-Delivered-To: linux-mm@kvack.org Received: from relay.hostedemail.com (smtprelay0015.hostedemail.com [216.40.44.15]) by kanga.kvack.org (Postfix) with ESMTP id 6BD416B0355 for ; Tue, 12 Dec 2023 14:48:28 -0500 (EST) Received: from smtpin05.hostedemail.com (a10.router.float.18 [10.200.18.1]) by unirelay08.hostedemail.com (Postfix) with ESMTP id 40304140ABB for ; Tue, 12 Dec 2023 19:48:28 +0000 (UTC) X-FDA: 81559203096.05.9C22DD2 Received: from dfw.source.kernel.org (dfw.source.kernel.org [139.178.84.217]) by imf20.hostedemail.com (Postfix) with ESMTP id 6B7EC1C001E for ; Tue, 12 Dec 2023 19:48:26 +0000 (UTC) Authentication-Results: imf20.hostedemail.com; dkim=pass header.d=kernel.org header.s=k20201202 header.b=HA5XbunG; dmarc=pass (policy=none) header.from=kernel.org; spf=pass (imf20.hostedemail.com: domain of sj@kernel.org designates 139.178.84.217 as permitted sender) smtp.mailfrom=sj@kernel.org ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=hostedemail.com; s=arc-20220608; t=1702410506; h=from:from:sender:reply-to:subject:subject:date:date: message-id:message-id:to:to:cc:cc:mime-version:mime-version: content-type:content-transfer-encoding:content-transfer-encoding: in-reply-to:in-reply-to:references:references:dkim-signature; bh=Llj595fCp/6fkqvOsmjH1Ip3cww+RZOnknJ+I9nFpd4=; b=kHbKUSJqmibqfJu4/w/ikjfCdAOnGeEndM1ZUzgmrdISmjMMz6MJkWw2fiQkf19Ojd5/y1 r+Ipth4YC1j/c/B9nbEuXNo+N2zA4D3NhWVyJ1Jz7Dlk9qK2P86aGBLf94+ufgKrKyMawB B0DdizRXRQwx/srI1DZAjajOmhGgSqU= ARC-Authentication-Results: i=1; imf20.hostedemail.com; dkim=pass header.d=kernel.org header.s=k20201202 header.b=HA5XbunG; dmarc=pass (policy=none) header.from=kernel.org; spf=pass (imf20.hostedemail.com: domain of sj@kernel.org designates 139.178.84.217 as permitted sender) smtp.mailfrom=sj@kernel.org ARC-Seal: i=1; s=arc-20220608; d=hostedemail.com; t=1702410506; a=rsa-sha256; cv=none; b=WcBXyUJ/WvhTglq2JtV7VHdrtKXzNQOduw+vHe1BT4l3ZhGamYz4hGWCiCm6jmt1XzOGFN bBdFO/EfwD8XyXnPiZUqTn1nwmNVFiJ6KWdDZpBsOmTMh1v9dR+m82UcbIJwhciuyk1HBh jdz11HFxOtbTWSpdZVVZAb+iNpobN5g= Received: from smtp.kernel.org (transwarp.subspace.kernel.org [100.75.92.58]) by dfw.source.kernel.org (Postfix) with ESMTP id A6A5161994; Tue, 12 Dec 2023 19:48:25 +0000 (UTC) Received: by smtp.kernel.org (Postfix) with ESMTPSA id D9C69C433C8; Tue, 12 Dec 2023 19:48:24 +0000 (UTC) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/simple; d=kernel.org; s=k20201202; t=1702410505; bh=DR2Fa3ovjeZyoem+oDl1suN899iJhJUC8UTSzsABCII=; h=From:To:Cc:Subject:Date:In-Reply-To:References:From; b=HA5XbunGmbXfx0Q2PBWZIxDGcBV5Dgvd4kTY6CbduAGZC+9muRTppO4PFe28T/5i+ CmRI1fkjAnKa1Nco2U18Ye7denvai3M3JgEXMpTQ3nSRWFQ2mPdOSy6zaHt41Skbdc 4BYfTX6VlFveLW+mcLa0DSfgORdTEKPz/j8cu8i5YSkiTKb0pcvSHH4Vkljr7mXNZi OKDjuTBDwVxNJBELhM4NX8g+i9EnR9Zv8JYdqUkmasictn2ECU353ZPspXk14NWbju 3lSWV3+4BKRlFdFjrSUVWG9gELYl9bKdP/KfdlLYVS6k1lVFspUt8MPDSgcv8aPZPC 1mpjLFnRNMFOA== From: SeongJae Park To: Andrew Morton Cc: SeongJae Park , Shuah Khan , damon@lists.linux.dev, linux-mm@kvack.org, linux-kselftest@vger.kernel.org, linux-kernel@vger.kernel.org Subject: [PATCH v2 2/5] selftests/damon/_damon_sysfs: implement kdamonds start function Date: Tue, 12 Dec 2023 19:48:07 +0000 Message-Id: <20231212194810.54457-3-sj@kernel.org> X-Mailer: git-send-email 2.34.1 In-Reply-To: <20231212194810.54457-1-sj@kernel.org> References: <20231212194810.54457-1-sj@kernel.org> MIME-Version: 1.0 X-Rspamd-Queue-Id: 6B7EC1C001E X-Rspam-User: X-Rspamd-Server: rspam05 X-Stat-Signature: nh1z9usw4rrdzebe49ydkt3nd9d9wp1k X-HE-Tag: 1702410506-463279 X-HE-Meta: U2FsdGVkX1+nZxpyWlc1N6geljODBw3Tepg+9CphyFq3xUiRn4H+xoiqzt/Fc68tYcfiIKDv8/iR/4RuQypUeOeaz+nZ8qeyF1SIfH00RCKkhxliRabbUD8iFS8xO2elWI1fUun2QlpksQwrU/+LkrQVdoPMSQSfBVki3hGILHSv5uPTfpeaThNmy5+btKWf6RSse1Uo3RwGsA2OaPjJLRyQkS01spxKCaW0CywO5r8LsYGAjVFQOl+EtcVjPuiBbFM02/m3WVzlYEI29KQYdKDK3haCIJp0DVJLHBeaZsTZ3MLTKlgiP2F+I1gR+7RLJEbEVbtIvssgu6ZBnCj/JntpaD+gX4Hcws8XzKOybhhDoDfs2YaSLN2dgIsqt7FCB8HZB+ApfbyyK97rPZBxK0OUSttW8TVQrhfHgRL4TUBVQmjF9u77PsybESmaMHwnQLyK+x7UGbxiGrNSPsEZlkDqS+RpWf3Pb3BIG66c6afqYkpi5zjAlH1bapjw1DnkUs3UeFz/u2YkAzTNLnWquyRlvuO7+eyvyVKDWkmBVwEc7dpif6P7w5h763gZRw7KbY8LrwTvwiJIMJQ++Z8VGofsI7xRLydDgh8MplsPDwUIjNpohyGGyElk7F9J+16MPDq/jlGdIAnwTj5nqarkaSsbAmsr4kAJqknTLINLR/GZUM/6gfU81rY3zlhIij2mU62FcvXTADHE6uausvEf9HV6b9BoZXjwqQmrwg1u+TWaF0b6C1deuJol4I727j5PzxATFtzyCaSE9aYJcuw1IRaPwRKeNbFXsUKPL0Fb3SehY1HMW4SLXzgJMqiw4JcbcZQOQ2pb5ssmTAwYHvBdcVm3iHqAdcVIg2g/+hXqA7HNx+0HEfKtvT6h3QJEJm0YIghSYknbWckrWGPnuXChNIPEtzD01LmzxbNWKxVtMXyBbyMftz4rhv+EJtjAhEwoE9c2aJ7ZVpDTbl4v1et CTPunT4k hFt++/ugHgktPWSmow96sYxkt3ppzaK/gKH1pTjh8i9tgDLbgRfLcgGEhR2Jqi4i7AKzedvZ0j0s+Es0QbZD06CDo8C9Dt+K+fd9NKXAQZVE95eanw4xpLExlberLaQDbDEh3OFL9Yd2x2Mp0NgXRfXBNNiS5SOO7ezYxFWk4SrzhRymOXA0nc5iAGC126r5RLIRoCurofN95DJ8GBoY3lmhieSJkIC+ypt/Iuh+CirvFLghYLp41FPmZXPiBfjP3/szEvuI5FCeWPfviPQi5MvKLlcitNMjcby/2 X-Bogosity: Ham, tests=bogofilter, spamicity=0.000000, version=1.2.4 Sender: owner-linux-mm@kvack.org Precedence: bulk X-Loop: owner-majordomo@kvack.org List-ID: List-Subscribe: List-Unsubscribe: Extend the tests-writing-purpose DAMON sysfs control module to support the kdamonds start functionality. Signed-off-by: SeongJae Park --- tools/testing/selftests/damon/_damon_sysfs.py | 206 ++++++++++++++++++ 1 file changed, 206 insertions(+) diff --git a/tools/testing/selftests/damon/_damon_sysfs.py b/tools/testing/selftests/damon/_damon_sysfs.py index 78101846ab66..6b99f87a5f1e 100644 --- a/tools/testing/selftests/damon/_damon_sysfs.py +++ b/tools/testing/selftests/damon/_damon_sysfs.py @@ -1,5 +1,28 @@ # SPDX-License-Identifier: GPL-2.0 +import os + +sysfs_root = '/sys/kernel/mm/damon/admin' + +def write_file(path, string): + "Returns error string if failed, or None otherwise" + string = '%s' % string + try: + with open(path, 'w') as f: + f.write(string) + except Exception as e: + return '%s' % e + return None + +def read_file(path): + '''Returns the read content and error string. The read content is None if + the reading failed''' + try: + with open(path, 'r') as f: + return f.read(), None + except Exception as e: + return None, '%s' % e + class DamosAccessPattern: size = None nr_accesses = None @@ -18,6 +41,35 @@ class DamosAccessPattern: if self.age == None: self.age = [0, 2**64 - 1] + def sysfs_dir(self): + return os.path.join(self.scheme.sysfs_dir(), 'access_pattern') + + def stage(self): + err = write_file( + os.path.join(self.sysfs_dir(), 'sz', 'min'), self.size[0]) + if err != None: + return err + err = write_file( + os.path.join(self.sysfs_dir(), 'sz', 'max'), self.size[1]) + if err != None: + return err + err = write_file(os.path.join(self.sysfs_dir(), 'nr_accesses', 'min'), + self.nr_accesses[0]) + if err != None: + return err + err = write_file(os.path.join(self.sysfs_dir(), 'nr_accesses', 'max'), + self.nr_accesses[1]) + if err != None: + return err + err = write_file( + os.path.join(self.sysfs_dir(), 'age', 'min'), self.age[0]) + if err != None: + return err + err = write_file( + os.path.join(self.sysfs_dir(), 'age', 'max'), self.age[1]) + if err != None: + return err + class Damos: action = None access_pattern = None @@ -30,6 +82,39 @@ class Damos: self.access_pattern = access_pattern self.access_pattern.scheme = self + def sysfs_dir(self): + return os.path.join( + self.context.sysfs_dir(), 'schemes', '%d' % self.idx) + + def stage(self): + err = write_file(os.path.join(self.sysfs_dir(), 'action'), self.action) + if err != None: + return err + err = self.access_pattern.stage() + if err != None: + return err + + # disable quotas + err = write_file(os.path.join(self.sysfs_dir(), 'quotas', 'ms'), '0') + if err != None: + return err + err = write_file( + os.path.join(self.sysfs_dir(), 'quotas', 'bytes'), '0') + if err != None: + return err + + # disable watermarks + err = write_file( + os.path.join(self.sysfs_dir(), 'watermarks', 'metric'), 'none') + if err != None: + return err + + # disable filters + err = write_file( + os.path.join(self.sysfs_dir(), 'filters', 'nr_filters'), '0') + if err != None: + return err + class DamonTarget: pid = None # todo: Support target regions if test is made @@ -39,6 +124,18 @@ class DamonTarget: def __init__(self, pid): self.pid = pid + def sysfs_dir(self): + return os.path.join( + self.context.sysfs_dir(), 'targets', '%d' % self.idx) + + def stage(self): + err = write_file( + os.path.join(self.sysfs_dir(), 'regions', 'nr_regions'), '0') + if err != None: + return err + return write_file( + os.path.join(self.sysfs_dir(), 'pid_target'), self.pid) + class DamonAttrs: sample_us = None aggr_us = None @@ -55,6 +152,40 @@ class DamonAttrs: self.min_nr_regions = min_nr_regions self.max_nr_regions = max_nr_regions + def interval_sysfs_dir(self): + return os.path.join(self.context.sysfs_dir(), 'monitoring_attrs', + 'intervals') + + def nr_regions_range_sysfs_dir(self): + return os.path.join(self.context.sysfs_dir(), 'monitoring_attrs', + 'nr_regions') + + def stage(self): + err = write_file(os.path.join(self.interval_sysfs_dir(), 'sample_us'), + self.sample_us) + if err != None: + return err + err = write_file(os.path.join(self.interval_sysfs_dir(), 'aggr_us'), + self.aggr_us) + if err != None: + return err + err = write_file(os.path.join(self.interval_sysfs_dir(), 'update_us'), + self.update_us) + if err != None: + return err + + err = write_file( + os.path.join(self.nr_regions_range_sysfs_dir(), 'min'), + self.min_nr_regions) + if err != None: + return err + + err = write_file( + os.path.join(self.nr_regions_range_sysfs_dir(), 'max'), + self.max_nr_regions) + if err != None: + return err + class DamonCtx: ops = None monitoring_attrs = None @@ -79,6 +210,46 @@ class DamonCtx: scheme.idx = idx scheme.context = self + def sysfs_dir(self): + return os.path.join(self.kdamond.sysfs_dir(), 'contexts', + '%d' % self.idx) + + def stage(self): + err = write_file( + os.path.join(self.sysfs_dir(), 'operations'), self.ops) + if err != None: + return err + err = self.monitoring_attrs.stage() + if err != None: + return err + + nr_targets_file = os.path.join( + self.sysfs_dir(), 'targets', 'nr_targets') + content, err = read_file(nr_targets_file) + if err != None: + return err + if int(content) != len(self.targets): + err = write_file(nr_targets_file, '%d' % len(self.targets)) + if err != None: + return err + for target in self.targets: + err = target.stage() + if err != None: + return err + + nr_schemes_file = os.path.join( + self.sysfs_dir(), 'schemes', 'nr_schemes') + content, err = read_file(nr_schemes_file) + if int(content) != len(self.schemes): + err = write_file(nr_schemes_file, '%d' % len(self.schemes)) + if err != None: + return err + for scheme in self.schemes: + err = scheme.stage() + if err != None: + return err + return None + class Kdamond: state = None pid = None @@ -92,6 +263,27 @@ class Kdamond: context.idx = idx context.kdamond = self + def sysfs_dir(self): + return os.path.join(self.kdamonds.sysfs_dir(), '%d' % self.idx) + + def start(self): + nr_contexts_file = os.path.join(self.sysfs_dir(), + 'contexts', 'nr_contexts') + content, err = read_file(nr_contexts_file) + if err != None: + return err + if int(content) != len(self.contexts): + err = write_file(nr_contexts_file, '%d' % len(self.contexts)) + if err != None: + return err + + for context in self.contexts: + err = context.stage() + if err != None: + return err + err = write_file(os.path.join(self.sysfs_dir(), 'state'), 'on') + return err + class Kdamonds: kdamonds = [] @@ -100,3 +292,17 @@ class Kdamonds: for idx, kdamond in enumerate(self.kdamonds): kdamond.idx = idx kdamond.kdamonds = self + + def sysfs_dir(self): + return os.path.join(sysfs_root, 'kdamonds') + + def start(self): + err = write_file(os.path.join(self.sysfs_dir(), 'nr_kdamonds'), + '%s' % len(self.kdamonds)) + if err != None: + return err + for kdamond in self.kdamonds: + err = kdamond.start() + if err != None: + return err + return None