githubmirror/strace

src/futex2.c
201 строка4 KB
Dmitry V. Levin
Update copyright headers
05 авг 2025, 11:00
05 авг 2025, 11:007db24b3
/*
 * Copyright (c) 2021-2025 The strace developers.
 * Copyright (c) 2021 André Almeida <andrealmeid@collabora.com>
 * All rights reserved.
 *
 * SPDX-License-Identifier: LGPL-2.1-or-later
 */

#include "defs.h"
#include <linux/futex.h>
#include "xlat/futex2_sizes.h"
#include "xlat/futex2_flags.h"

static void
print_futex2_flags(unsigned int flags)
{
	if (xlat_verbose(xlat_verbosity) != XLAT_STYLE_ABBREV)
		PRINT_VAL_X(flags);

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

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

	tprint_flags_begin();

	printxvals_ex(flags & FUTEX2_SIZE_MASK, NULL, XLAT_STYLE_ABBREV,
		      futex2_sizes, NULL);
	flags &= ~FUTEX2_SIZE_MASK;

	if (flags) {
		tprint_flags_or();
		printflags_ex(flags, NULL, XLAT_STYLE_ABBREV,
			      futex2_flags, NULL);
	}

	tprint_flags_end();

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

struct print_waiter_data {
	unsigned int count;
};

static bool
print_waiter(struct tcb * const tcp, void * const elem_buf,
	     const size_t elem_size, void * const data)
{
	struct futex_waitv *waiter = elem_buf;
	struct print_waiter_data *p = data;

	if (p->count++ >= FUTEX_WAITV_MAX) {
		tprint_more_data_follows();
		return false;
	}

	tprint_struct_begin();
	PRINT_FIELD_X(*waiter, val);

	tprint_struct_next();
	PRINT_FIELD_ADDR64(*waiter, uaddr);

	tprint_struct_next();
	PRINT_FIELD_OBJ_VAL(*waiter, flags, print_futex2_flags);

	if (waiter->__reserved) {
		tprint_struct_next();
		PRINT_FIELD_X(*waiter, __reserved);
	}

	tprint_struct_end();
	return true;
}

static void
print_waiter_array(struct tcb * const tcp, const kernel_ulong_t waiters,
		   const unsigned int nr_futexes)
{
	struct futex_waitv buf;
	struct print_waiter_data data = {};

	print_array(tcp, waiters, nr_futexes, &buf, sizeof(buf),
		    tfetch_mem, print_waiter, &data);
}

SYS_FUNC(futex_waitv)
{
	const kernel_ulong_t waiters = tcp->u_arg[0];
	const unsigned int nr_futexes = tcp->u_arg[1];
	const unsigned int flags = tcp->u_arg[2];
	const kernel_ulong_t timeout = tcp->u_arg[3];
	const unsigned int clockid = tcp->u_arg[4];

	tprints_arg_name("waiters");
	print_waiter_array(tcp, waiters, nr_futexes);

	tprints_arg_next_name("nr_futexes");
	PRINT_VAL_U(nr_futexes);

	tprints_arg_next_name("flags");
	PRINT_VAL_X(flags);

	tprints_arg_next_name("timeout");
	print_timespec64(tcp, timeout);

	tprints_arg_next_name("clockid");
	printxval(clocknames, clockid, "CLOCK_???");

	return RVAL_DECODED;
}

SYS_FUNC(futex_wake)
{
	const kernel_ulong_t uaddr = tcp->u_arg[0];
	const kernel_ulong_t mask = tcp->u_arg[1];
	const int nr = tcp->u_arg[2];
	const unsigned int flags = tcp->u_arg[3];

	/* uaddr */
	tprints_arg_name("uaddr");
	printaddr(uaddr);

	/* mask */
	tprints_arg_next_name("mask");
	printxval64(futexbitset, mask, NULL);

	/* nr */
	tprints_arg_next_name("nr");
	PRINT_VAL_D(nr);

	/* flags */
	tprints_arg_next_name("flags");
	print_futex2_flags(flags);

	return RVAL_DECODED;
}

SYS_FUNC(futex_wait)
{
	const kernel_ulong_t uaddr = tcp->u_arg[0];
	const kernel_ulong_t val = tcp->u_arg[1];
	const kernel_ulong_t mask = tcp->u_arg[2];
	const unsigned int flags = tcp->u_arg[3];
	const kernel_ulong_t timeout = tcp->u_arg[4];
	const unsigned int clockid = tcp->u_arg[5];

	/* uaddr */
	tprints_arg_name("uaddr");
	printaddr(uaddr);

	/* val */
	tprints_arg_next_name("val");
	PRINT_VAL_U(val);

	/* mask */
	tprints_arg_next_name("mask");
	printxval64(futexbitset, mask, NULL);

	/* flags */
	tprints_arg_next_name("flags");
	print_futex2_flags(flags);

	/* timeout */
	tprints_arg_next_name("timeout");
	print_timespec64(tcp, timeout);

	/* clockid */
	tprints_arg_next_name("clockid");
	printxval(clocknames, clockid, "CLOCK_???");

	return RVAL_DECODED;
}

SYS_FUNC(futex_requeue)
{
	const kernel_ulong_t waiters = tcp->u_arg[0];
	const unsigned int flags = tcp->u_arg[1];
	const int nr_wake = tcp->u_arg[2];
	const int nr_requeue = tcp->u_arg[3];

	/* waiters */
	tprints_arg_name("waiters");
	print_waiter_array(tcp, waiters, 2);

	/* flags */
	tprints_arg_next_name("flags");
	PRINT_VAL_X(flags);

	/* nr_wake */
	tprints_arg_next_name("nr_wake");
	PRINT_VAL_D(nr_wake);

	/* nr_requeue */
	tprints_arg_next_name("nr_requeue");
	PRINT_VAL_D(nr_requeue);

	return RVAL_DECODED;
}