From mboxrd@z Thu Jan 1 00:00:00 1970 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 picard.linux.it (picard.linux.it [213.254.12.146]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by smtp.lore.kernel.org (Postfix) with ESMTPS id 90972C5DF66 for ; Mon, 17 Aug 2026 15:57:32 +0000 (UTC) Received: from picard.linux.it (localhost [IPv6:::1]) by picard.linux.it (Postfix) with ESMTP id 784E43CBC32 for ; Mon, 17 Aug 2026 17:57:30 +0200 (CEST) Received: from in-3.smtp.seeweb.it (in-3.smtp.seeweb.it [217.194.8.3]) (using TLSv1.3 with cipher TLS_AES_256_GCM_SHA384 (256/256 bits) key-exchange X25519 server-signature ECDSA (secp384r1)) (No client certificate requested) by picard.linux.it (Postfix) with ESMTPS id 5D8AD3C9B32 for ; Mon, 17 Aug 2026 17:57:14 +0200 (CEST) Received: from mx0b-001b2d01.pphosted.com (mx0b-001b2d01.pphosted.com [148.163.158.5]) (using TLSv1.3 with cipher TLS_AES_256_GCM_SHA384 (256/256 bits) key-exchange X25519 server-signature RSA-PSS (2048 bits) server-digest SHA256) (No client certificate requested) by in-3.smtp.seeweb.it (Postfix) with ESMTPS id 42F011A007E8 for ; Mon, 17 Aug 2026 17:57:12 +0200 (CEST) Received: from pps.filterd (m0360072.ppops.net [127.0.0.1]) by mx0a-001b2d01.pphosted.com (8.18.1.11/8.18.1.11) with ESMTP id 67HFfhRO1851595 for ; Mon, 17 Aug 2026 15:57:10 GMT DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=ibm.com; h=cc :content-transfer-encoding:date:from:message-id:mime-version :subject:to; s=pp1; bh=rpEh2sSI0k2hSrTwNuv9oS82W5YHGL4JlybXxMGjh Ds=; b=Og383y7/lAjAhAZkrSjuLzmGa1gzPYywHUb3yosdic2V3f/uxZYJbNuiz azeUaz6ST6n2kwDwYD47gHAtxBQ32H9HaJsxU4D207FwdgXc5Wd4zfzRVbKfoqOh cj2Jqw05scUUTFz2qwRq/BrA0CA1561r3OH//YdPJ6ojqgDgmeBQ2tvzqjq04xfA JTguAjqFX3vxexvIP/Q4CXr1iVXpm9DVYpgbptVAWh+5G8ywlILFXDWIkrL+xJFC QIUjTffYrocpbpsNNDMP3LKIYSExf54piBtTO8C+s3uHwezH0nBcH+nVYZhSt9qY Q9kVhixDicObKHhUSPRb6vaqpe+dg== Received: from ppma21.wdc07v.mail.ibm.com (5b.69.3da9.ip4.static.sl-reverse.com [169.61.105.91]) by mx0a-001b2d01.pphosted.com (PPS) with ESMTPS id 4g2frt2pmf-1 (version=TLSv1.2 cipher=ECDHE-RSA-AES256-GCM-SHA384 bits=256 verify=NOT) for ; Mon, 17 Aug 2026 15:57:10 +0000 (GMT) Received: from pps.filterd (ppma21.wdc07v.mail.ibm.com [127.0.0.1]) by ppma21.wdc07v.mail.ibm.com (8.18.1.7/8.18.1.7) with ESMTP id 67HFQMr1014595 for ; Mon, 17 Aug 2026 15:57:10 GMT Received: from smtprelay02.fra02v.mail.ibm.com ([9.218.2.226]) by ppma21.wdc07v.mail.ibm.com (PPS) with ESMTPS id 4g33ejxnv6-1 (version=TLSv1.2 cipher=ECDHE-RSA-AES256-GCM-SHA384 bits=256 verify=NOT) for ; Mon, 17 Aug 2026 15:57:09 +0000 (GMT) Received: from smtpav05.fra02v.mail.ibm.com (smtpav05.fra02v.mail.ibm.com [10.20.54.104]) by smtprelay02.fra02v.mail.ibm.com (8.14.9/8.14.9/NCO v10.0) with ESMTP id 67HFv5pu45351254 (version=TLSv1/SSLv3 cipher=DHE-RSA-AES256-GCM-SHA384 bits=256 verify=OK); Mon, 17 Aug 2026 15:57:06 GMT Received: from smtpav05.fra02v.mail.ibm.com (unknown [127.0.0.1]) by IMSVA (Postfix) with ESMTP id DCCE32004B; Mon, 17 Aug 2026 15:57:05 +0000 (GMT) Received: from smtpav05.fra02v.mail.ibm.com (unknown [127.0.0.1]) by IMSVA (Postfix) with ESMTP id B6F3520043; Mon, 17 Aug 2026 15:57:04 +0000 (GMT) Received: from li-49acbccc-2994-11b2-a85c-d51b89e344f1.ibm.com.com (unknown [9.124.212.65]) by smtpav05.fra02v.mail.ibm.com (Postfix) with ESMTP; Mon, 17 Aug 2026 15:57:04 +0000 (GMT) From: Pavithra To: ltp@lists.linux.it Date: Mon, 17 Aug 2026 21:27:01 +0530 Message-ID: <20260817155701.943752-1-pavrampu@linux.ibm.com> X-Mailer: git-send-email 2.55.0 MIME-Version: 1.0 X-TM-AS-GCONF: 00 X-Authority-Analysis: v=2.4 cv=OfaoyBTY c=1 sm=1 tr=0 ts=6a832f56 cx=c_pps a=GFwsV6G8L6GxiO2Y/PsHdQ==:117 a=GFwsV6G8L6GxiO2Y/PsHdQ==:17 a=Sv0fKeRqtYgA:10 a=VkNPw1HP01LnGYTKEx00:22 a=RnoormkPH1_aCDwRdu11:22 a=RzCfie-kr_QcCd8fBx8p:22 a=VwQbUJbxAAAA:8 a=VnNF1IyMAAAA:8 a=jX24ZDNkRSSrIs4fRVcA:9 X-Proofpoint-Spam-Info: AW1haW4tMjYwODE3MDExOSBTYWx0ZWRfX++kAHKQ/k0MV LJCioCa1JjUVDqWkcFlva6mQHLhYWRnqcmCBpjwm0aVSLrKRg5YF1snTSRQQiU1zTizgFv1LkoB HFuLny3AF3Z3UyYe7VkH/XZ8+rJRfaE= X-Proofpoint-GUID: tqVSHWLvxWWE3JNKCSFoJIeaRBDQiOh1 X-Proofpoint-ORIG-GUID: tqVSHWLvxWWE3JNKCSFoJIeaRBDQiOh1 X-Proofpoint-Spam-Details-Enc: AW1haW4tMjYwODE3MDExOSBTYWx0ZWRfX5QGH+y48zCFy TLyShgWDKaU74xKVPyEGW7JPX43LKTo7vWbWFMwneetD7/DiYE4P7CniGXOQx3HsMA+AXlDbxX4 9ya7Q03ws3rZsf7h1Pse725q1oG3y2ynwWVSAmFCwUGIhH7llFBetaWZPs1R3y82e+PTogwUBda kc+RQq3Fuausr6l8IGYiKuvKL5t7cFaSbHLub/7ALDvZDif/Ss95S/0Kkpt5Z8OHVDaEWPTq07T On7fSNRpoVLdHcBIoVXmn0LzVJmnqV68D+XCM1AYCVsSmwjblYIsuBtS3X0OH6FoWnQxOIbs4n1 Z772OYEGnf24LideVrW98286AGo+U3rCO6L+cc3fZ1eUTcn58Pmp23KaOFktVcFc0EJxkRvDsWZ +HkvPChyUOg9hFupyg9SeA1l/FrlPQla52TjIzpPdgr4gYW6i1aMami3BK1NUbxYyuKNCkKn9RC Ql4oI7k73kB4TvUApOw== X-Proofpoint-Virus-Version: vendor=baseguard engine=ICAP:2.0.293,Aquarius:18.0.1176,Hydra:6.1.134,FMLib:17.12.100.49 definitions=2026-08-17_02,2026-08-12_01,2025-10-01_01 X-Proofpoint-Spam-Details: rule=outbound_notspam policy=outbound score=0 suspectscore=0 adultscore=0 clxscore=1015 lowpriorityscore=0 impostorscore=0 malwarescore=0 bulkscore=0 phishscore=0 priorityscore=1501 spamscore=0 classifier=typeunknown authscore=0 authtc= authcc= route=outbound adjust=0 reason=mlx scancount=1 engine=8.22.0-2606150000 definitions=main-2608170119 X-Virus-Scanned: clamav-milter 1.0.9 at in-3.smtp.seeweb.it X-Virus-Status: Clean Subject: [LTP] [PATCH v6] memcg/memcontrol05: add cgroup v2 task migration charge accounting test X-BeenThere: ltp@lists.linux.it X-Mailman-Version: 2.1.29 Precedence: list List-Id: Linux Test Project List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Cc: pavrampu@linux.ibm.com Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: 7bit Errors-To: ltp-bounces+ltp=archiver.kernel.org@lists.linux.it Sender: "ltp" Verify that in cgroup v2, memory charges remain pinned to the cgroup that allocated them when a task migrates, and that new allocations after migration are charged to the destination cgroup. Signed-off-by: Pavithra --- v5 -> v6: - Track worker PID and checkpoint stage to fix cleanup ordering. - Wake and reap the worker before removing cgroups in cleanup(). - Drop unused #include . Link to v5: https://lore.kernel.org/ltp/20260813195418.3083880-1-pavrampu@linux.ibm.com/ --- runtest/controllers | 1 + testcases/kernel/controllers/memcg/.gitignore | 1 + .../kernel/controllers/memcg/memcontrol05.c | 210 ++++++++++++++++++ 3 files changed, 212 insertions(+) create mode 100644 testcases/kernel/controllers/memcg/memcontrol05.c diff --git a/runtest/controllers b/runtest/controllers index 93c52c439..a9050ef0e 100644 --- a/runtest/controllers +++ b/runtest/controllers @@ -24,6 +24,7 @@ memcontrol01 memcontrol01 memcontrol02 memcontrol02 memcontrol03 memcontrol03 memcontrol04 memcontrol04 +memcontrol05 memcontrol05 cgroup_fj_function_debug cgroup_fj_function.sh debug cgroup_fj_function_cpuset cgroup_fj_function.sh cpuset diff --git a/testcases/kernel/controllers/memcg/.gitignore b/testcases/kernel/controllers/memcg/.gitignore index 3883cede6..8b9f6005c 100644 --- a/testcases/kernel/controllers/memcg/.gitignore +++ b/testcases/kernel/controllers/memcg/.gitignore @@ -9,3 +9,4 @@ memcontrol01 memcontrol02 memcontrol03 memcontrol04 +memcontrol05 diff --git a/testcases/kernel/controllers/memcg/memcontrol05.c b/testcases/kernel/controllers/memcg/memcontrol05.c new file mode 100644 index 000000000..fea451f0f --- /dev/null +++ b/testcases/kernel/controllers/memcg/memcontrol05.c @@ -0,0 +1,210 @@ +// SPDX-License-Identifier: GPL-2.0-only +/* + * Copyright (c) 2026 IBM + * Author : Pavithra + */ + +/*\ + * Origin: ``testcases/kernel/controllers/memctl/memctl_testplan.txt`` + * Verify memory controller charge accounting during task migration. + * + * Two child cgroups (``group_a``, ``group_b``) are created under the test cgroup. + * A worker process is placed in ``group_a`` and allocates a known amount of + * anonymous memory, touching every page to ensure physical allocation. + * Root is required to create cgroup subdirectories and to write a PID + * into ``cgroup.procs`` to migrate the worker between cgroups. + * + * Test 1 - No charge transfer on migration: + * The worker is migrated to ``group_b`` by writing its PID to + * ``group_b/cgroup.procs``. In cgroup v2 memory charges are never + * transferred on task migration; they remain pinned to the cgroup + * that allocated them. ``group_b/memory.current`` must not increase + * beyond its baseline after the migration. + * + * Test 2 - New allocations charged to destination cgroup: + * After migration the worker allocates an additional chunk of memory. + * This new allocation must be charged to ``group_b``, so + * ``group_b/memory.current`` must increase from the post-migration + * baseline. + */ + +#define _GNU_SOURCE + +#include +#include +#include +#include "tst_test.h" +#include "memcontrol_common.h" + +#define ALLOC_SIZE MB(60) +#define ALLOC_SIZE2 MB(20) +#define MIN_MEM_AVAIL 128 + +enum checkpoints { + WORKER_ALLOC_DONE, + WORKER_RESUME, + WORKER_ALLOC2_DONE, + WORKER_EXIT, +}; + +static struct tst_cg_group *group_a; +static struct tst_cg_group *group_b; +static pid_t worker_pid; + +enum worker_stage { + STAGE_NOT_STARTED, + STAGE_WAITING_RESUME, /* worker blocked on WORKER_RESUME */ + STAGE_WAITING_EXIT, /* worker blocked on WORKER_EXIT */ + STAGE_DONE, /* worker reaped */ +}; + +static enum worker_stage worker_stage; + +static void touch_pages(char *buf, size_t size) +{ + size_t i; + + for (i = 0; i < size; i += getpagesize()) + buf[i] = 1; +} + +static void worker(void) +{ + char *buf1, *buf2; + + SAFE_CG_PRINTF(group_a, "cgroup.procs", "%d", getpid()); + + buf1 = SAFE_MMAP(NULL, ALLOC_SIZE, PROT_READ | PROT_WRITE, + MAP_PRIVATE | MAP_ANONYMOUS, -1, 0); + touch_pages(buf1, ALLOC_SIZE); + + TST_CHECKPOINT_WAKE(WORKER_ALLOC_DONE); + + TST_CHECKPOINT_WAIT(WORKER_RESUME); + + buf2 = SAFE_MMAP(NULL, ALLOC_SIZE2, PROT_READ | PROT_WRITE, + MAP_PRIVATE | MAP_ANONYMOUS, -1, 0); + touch_pages(buf2, ALLOC_SIZE2); + + TST_CHECKPOINT_WAKE(WORKER_ALLOC2_DONE); + + TST_CHECKPOINT_WAIT(WORKER_EXIT); + + SAFE_MUNMAP(buf1, ALLOC_SIZE); + SAFE_MUNMAP(buf2, ALLOC_SIZE2); +} + +static void test_memcg_task_migration(void) +{ + long baseline_b, after_migrate, after_migrate_a, after_alloc2, current_a; + + worker_pid = 0; + worker_stage = STAGE_NOT_STARTED; + + group_a = tst_cg_group_mk(tst_cg, "group_a"); + group_b = tst_cg_group_mk(tst_cg, "group_b"); + + if (SAFE_CG_HAS(tst_cg, "memory.swap.max")) { + SAFE_CG_PRINT(group_a, "memory.swap.max", "0"); + SAFE_CG_PRINT(group_b, "memory.swap.max", "0"); + } + + SAFE_CG_SCANF(group_b, "memory.current", "%ld", &baseline_b); + tst_res(TINFO, "group_b baseline memory.current=%ld", baseline_b); + + worker_pid = SAFE_FORK(); + if (!worker_pid) { + worker(); + exit(0); + } + worker_stage = STAGE_WAITING_RESUME; + + TST_CHECKPOINT_WAIT(WORKER_ALLOC_DONE); + + SAFE_CG_SCANF(group_a, "memory.current", "%ld", ¤t_a); + tst_res(TINFO, "group_a memory.current=%ld after alloc", current_a); + if (current_a < (long)ALLOC_SIZE) { + tst_res(TFAIL, + "group_a memory.current (%ld) < ALLOC_SIZE (%ld)", + current_a, (long)ALLOC_SIZE); + goto done; + } + tst_res(TPASS, + "group_a memory.current (%ld) >= ALLOC_SIZE (%ld)", + current_a, (long)ALLOC_SIZE); + + SAFE_CG_PRINTF(group_b, "cgroup.procs", "%d", worker_pid); + tst_res(TINFO, "Migrated worker PID %d to group_b", worker_pid); + + SAFE_CG_SCANF(group_b, "memory.current", "%ld", &after_migrate); + tst_res(TINFO, + "group_b memory.current=%ld after migration (baseline=%ld)", + after_migrate, baseline_b); + + TST_EXP_EXPR(after_migrate <= baseline_b + (long)MB(4), + "group_b memory.current (%ld) not increased after migration (baseline=%ld)", + after_migrate, baseline_b); + + SAFE_CG_SCANF(group_a, "memory.current", "%ld", &after_migrate_a); + tst_res(TINFO, "group_a memory.current=%ld after migration", after_migrate_a); + TST_EXP_EXPR(after_migrate_a >= (long)ALLOC_SIZE, + "group_a memory.current (%ld) still holds pre-migration charges (>= ALLOC_SIZE %ld)", + after_migrate_a, (long)ALLOC_SIZE); + + TST_CHECKPOINT_WAKE(WORKER_RESUME); + worker_stage = STAGE_WAITING_EXIT; + TST_CHECKPOINT_WAIT(WORKER_ALLOC2_DONE); + + SAFE_CG_SCANF(group_b, "memory.current", "%ld", &after_alloc2); + tst_res(TINFO, "group_b memory.current=%ld after second alloc (baseline=%ld)", + after_alloc2, after_migrate); + + TST_EXP_EXPR(after_alloc2 >= after_migrate + (long)ALLOC_SIZE2, + "group_b memory.current (%ld) increased by >= ALLOC_SIZE2 (%ld)", + after_alloc2, (long)ALLOC_SIZE2); + +done: + if (worker_stage == STAGE_WAITING_RESUME) { + TST_CHECKPOINT_WAKE(WORKER_RESUME); + worker_stage = STAGE_WAITING_EXIT; + TST_CHECKPOINT_WAIT(WORKER_ALLOC2_DONE); + } + if (worker_stage == STAGE_WAITING_EXIT) { + TST_CHECKPOINT_WAKE(WORKER_EXIT); + tst_reap_children(); + worker_pid = 0; + worker_stage = STAGE_DONE; + } + + group_a = tst_cg_group_rm(group_a); + group_b = tst_cg_group_rm(group_b); +} + +static void cleanup(void) +{ + if (worker_stage == STAGE_WAITING_RESUME) { + TST_CHECKPOINT_WAKE(WORKER_RESUME); + worker_stage = STAGE_WAITING_EXIT; + TST_CHECKPOINT_WAIT(WORKER_ALLOC2_DONE); + } + if (worker_stage == STAGE_WAITING_EXIT) { + TST_CHECKPOINT_WAKE(WORKER_EXIT); + tst_reap_children(); + } + + if (group_a) + group_a = tst_cg_group_rm(group_a); + if (group_b) + group_b = tst_cg_group_rm(group_b); +} + +static struct tst_test test = { + .test_all = test_memcg_task_migration, + .cleanup = cleanup, + .forks_child = 1, + .needs_root = 1, + .needs_checkpoints = 1, + .needs_cgroup_ver = TST_CG_V2, + .needs_cgroup_ctrls = (const char *const []){ "memory", NULL }, + .min_mem_avail = MIN_MEM_AVAIL, +}; -- 2.55.0 -- Mailing list info: https://lists.linux.it/listinfo/ltp