src/numa.c - master - githubmirror/strace

src/numa.c
271 строка6 KB
Dmitry V. Levin
numa: enhance printing of unknown mode and flags arguments
10 ноя 2025, 11:00
10 ноя 2025, 11:002694d55
/*
 * Copyright (c) 2003-2007 Ulrich Drepper <drepper@redhat.com>
 * Copyright (c) 2005-2016 Dmitry V. Levin <ldv@strace.io>
 * Copyright (c) 2016-2025 The strace developers.
 * All rights reserved.
 *
 * SPDX-License-Identifier: LGPL-2.1-or-later
 */

#include "defs.h"

static bool
print_node(struct tcb *tcp, void *elem_buf, size_t elem_size, void *data)
{
	if (elem_size < sizeof(kernel_ulong_t)) {
		unsigned int val = *(unsigned int *) elem_buf;
		PRINT_VAL_0X(val);
	} else {
		kernel_ulong_t val = *(kernel_ulong_t *) elem_buf;
		PRINT_VAL_0X(val);
	}

	return true;
}

static void
print_nodemask(struct tcb *const tcp, const kernel_ulong_t addr,
	       const kernel_ulong_t maxnodes)
{
	const unsigned int bits_per_long = 8 * current_wordsize;
	const kernel_ulong_t nmemb =
		(maxnodes + bits_per_long - 2) / bits_per_long;

	if (nmemb < maxnodes / bits_per_long ||
	    (maxnodes && !nmemb)) {
		printaddr(addr);
		return;
	}

	kernel_ulong_t buf;
	print_array(tcp, addr, nmemb, &buf, current_wordsize,
		    tfetch_mem, print_node, 0);
}

SYS_FUNC(migrate_pages)
{
	/* pid */
	tprints_arg_name("pid");
	printpid(tcp, tcp->u_arg[0], PT_TGID);

	/* maxnode */
	tprints_arg_next_name("maxnode");
	PRINT_VAL_U(tcp->u_arg[1]);

	/* old_nodes */
	tprints_arg_next_name("old_nodes");
	print_nodemask(tcp, tcp->u_arg[2], tcp->u_arg[1]);

	/* new_nodes */
	tprints_arg_next_name("new_nodes");
	print_nodemask(tcp, tcp->u_arg[3], tcp->u_arg[1]);

	return RVAL_DECODED;
}

#include "xlat/mpol_modes.h"
#include "xlat/mpol_mode_flags.h"
#include "xlat/mbind_flags.h"

static void
print_mode(struct tcb *const tcp, const kernel_ulong_t mode_arg)
{
	const kernel_ulong_t flags_mask = MPOL_F_STATIC_NODES |
					  MPOL_F_RELATIVE_NODES |
					  MPOL_F_NUMA_BALANCING;
	const kernel_ulong_t mode = mode_arg & ~flags_mask;
	const unsigned int flags = mode_arg & flags_mask;

	if (!flags) {
		printxval64(mpol_modes, mode, "MPOL_???");
		return;
	}

	const char *mode_str = xlookup(mpol_modes, mode);
	if (!mode_str) {
		printflags64(mpol_mode_flags, mode_arg, "MPOL_F_???");
		return;
	}

	if (xlat_verbose(xlat_verbosity) != XLAT_STYLE_ABBREV)
		PRINT_VAL_X(mode_arg);

	if (xlat_verbose(xlat_verbosity) == XLAT_STYLE_RAW)
		return;

	if (xlat_verbose(xlat_verbosity) == XLAT_STYLE_VERBOSE)
		tprint_comment_begin();

	tprint_flags_begin();
	tprints_string(mode_str);
	tprint_flags_or();
	printflags_ex(flags, NULL, XLAT_STYLE_ABBREV, mpol_mode_flags, NULL);
	tprint_flags_end();

	if (xlat_verbose(xlat_verbosity) == XLAT_STYLE_VERBOSE)
		tprint_comment_end();
}

SYS_FUNC(mbind)
{
	/* addr */
	tprints_arg_name("addr");
	printaddr(tcp->u_arg[0]);

	/* len */
	tprints_arg_next_name("len");
	PRINT_VAL_U(tcp->u_arg[1]);

	/* mode */
	tprints_arg_next_name("mode");
	print_mode(tcp, tcp->u_arg[2]);

	/* nodemask */
	tprints_arg_next_name("nodemask");
	print_nodemask(tcp, tcp->u_arg[3], tcp->u_arg[4]);

	/* maxnode */
	tprints_arg_next_name("maxnode");
	PRINT_VAL_U(tcp->u_arg[4]);

	/* flags */
	tprints_arg_next_name("flags");
	printflags(mbind_flags, tcp->u_arg[5], "MPOL_MF_???");

	return RVAL_DECODED;
}

SYS_FUNC(set_mempolicy)
{
	/* mode */
	tprints_arg_name("mode");
	print_mode(tcp, (unsigned int) tcp->u_arg[0]);

	/* nodemask */
	tprints_arg_next_name("nodemask");
	print_nodemask(tcp, tcp->u_arg[1], tcp->u_arg[2]);

	/* maxnode */
	tprints_arg_next_name("maxnode");
	PRINT_VAL_U(tcp->u_arg[2]);

	return RVAL_DECODED;
}

#include "xlat/get_mempolicy_flags.h"

SYS_FUNC(get_mempolicy)
{
	if (exiting(tcp)) {
		/* mode */
		tprints_arg_name("mode");
		int pol;
		if (!umove_or_printaddr(tcp, tcp->u_arg[0], &pol)) {
			tprint_indirect_begin();
			printxval(mpol_modes, pol, "MPOL_???");
			tprint_indirect_end();
		}

		/* nodemask */
		tprints_arg_next_name("nodemask");
		print_nodemask(tcp, tcp->u_arg[1], tcp->u_arg[2]);

		/* maxnode */
		tprints_arg_next_name("maxnode");
		PRINT_VAL_U(tcp->u_arg[2]);

		/* addr */
		tprints_arg_next_name("addr");
		printaddr(tcp->u_arg[3]);

		/* flags */
		tprints_arg_next_name("flags");
		printflags64(get_mempolicy_flags, tcp->u_arg[4], "MPOL_F_???");
	}
	return 0;
}

SYS_FUNC(set_mempolicy_home_node)
{
	/* start */
	tprints_arg_name("start");
	printaddr(tcp->u_arg[0]);

	/* len */
	tprints_arg_next_name("len");
	PRINT_VAL_U(tcp->u_arg[1]);

	/* home_node */
	tprints_arg_next_name("home_node");
	PRINT_VAL_U(tcp->u_arg[2]);

	/* flags */
	tprints_arg_next_name("flags");
	PRINT_VAL_X(tcp->u_arg[3]);

	return RVAL_DECODED;
}

#include "xlat/move_pages_flags.h"

static bool
print_addr(struct tcb *tcp, void *elem_buf, size_t elem_size, void *data)
{
	kernel_ulong_t addr;

	if (elem_size < sizeof(addr)) {
		addr = *(unsigned int *) elem_buf;
	} else {
		addr = *(kernel_ulong_t *) elem_buf;
	}

	printaddr(addr);

	return true;
}

static bool
print_status(struct tcb *tcp, void *elem_buf, size_t elem_size, void *data)
{
	const int status = *(int *) elem_buf;

	print_err(status, true);

	return true;
}

SYS_FUNC(move_pages)
{
	const kernel_ulong_t npages = tcp->u_arg[1];
	kernel_ulong_t buf;

	if (entering(tcp)) {
		/* pid */
		tprints_arg_name("pid");
		printpid(tcp, tcp->u_arg[0], PT_TGID);

		/* count */
		tprints_arg_next_name("count");
		PRINT_VAL_U(npages);

		/* pages */
		tprints_arg_next_name("pages");
		print_array(tcp, tcp->u_arg[2], npages, &buf, current_wordsize,
			    tfetch_mem, print_addr, 0);

		/* nodes */
		tprints_arg_next_name("nodes");
		print_array(tcp, tcp->u_arg[3], npages, &buf, sizeof(int),
			    tfetch_mem, print_int_array_member, 0);
	} else {
		/* status */
		tprints_arg_next_name("status");
		print_array(tcp, tcp->u_arg[4], npages, &buf, sizeof(int),
			    tfetch_mem, print_status, 0);

		/* flags */
		tprints_arg_next_name("flags");
		printflags(move_pages_flags, tcp->u_arg[5], "MPOL_MF_???");
	}
	return 0;
}