diff options
author | Dmitry V. Levin <ldv@strace.io> | 2021-02-03 08:00:00 +0000 |
---|---|---|
committer | Dmitry V. Levin <ldv@strace.io> | 2021-02-03 08:00:00 +0000 |
commit | ecb3ed78107c851f71696df6730a15afff91ed3d (patch) | |
tree | 0b3d2b083040fc9b08d129f80d027ff41b995059 /src/mq.c | |
parent | c47943de06204a269e16f732e7c9c71d4284b23f (diff) | |
download | strace-ecb3ed78107c851f71696df6730a15afff91ed3d.tar.gz |
Move source files into src subdirectory
* src/Makefile.am: New file.
* src/.gitignore: Likewise.
* scno.am: Move into src subdirectory.
* scno.head: Likewise.
* strace-graph: Likewise.
* strace-log-merge: Likewise.
* linux/: Likewise.
* types/: Likewise.
* xlat/: Likewise.
* *.awk: Likewise.
* *.c: Likewise.
* *.h: Likewise.
* *.sh: Likewise.
* .gitignore: Update.
* Makefile.am: Update.
* bootstrap: Update.
* configure.ac: Update.
* debian/rules: Update.
* debian/strace-udeb.install: Update.
* debian/strace.examples: Update.
* debian/strace.install: Update.
* debian/strace64.install: Update.
* m4/gen_bpf_attr_m4.sh: Update.
* m4/mpers.m4: Update.
* tests/Makefile.am: Update.
* tests/init.sh: Update.
* tests/legacy_syscall_info.test: Update.
* tests/strace-log-merge-error.test: Update.
* tests/strace-log-merge-suffix.test: Update.
Diffstat (limited to 'src/mq.c')
-rw-r--r-- | src/mq.c | 110 |
1 files changed, 110 insertions, 0 deletions
diff --git a/src/mq.c b/src/mq.c new file mode 100644 index 000000000..555e92651 --- /dev/null +++ b/src/mq.c @@ -0,0 +1,110 @@ +/* + * Copyright (c) 2004 Ulrich Drepper <drepper@redhat.com> + * Copyright (c) 2005-2015 Dmitry V. Levin <ldv@strace.io> + * Copyright (c) 2015-2019 The strace developers. + * All rights reserved. + * + * SPDX-License-Identifier: LGPL-2.1-or-later + */ + +#include "defs.h" +#include <fcntl.h> + +SYS_FUNC(mq_open) +{ + printpath(tcp, tcp->u_arg[0]); + tprints(", "); + /* flags */ + tprint_open_modes(tcp->u_arg[1]); + if (tcp->u_arg[1] & O_CREAT) { + /* mode */ + tprints(", "); + print_numeric_umode_t(tcp->u_arg[2]); + tprints(", "); + printmqattr(tcp, tcp->u_arg[3], false); + } + return RVAL_DECODED | RVAL_FD; +} + +static int +do_mq_timedsend(struct tcb *const tcp, const print_obj_by_addr_fn print_ts) +{ + printfd(tcp, tcp->u_arg[0]); + tprints(", "); + printstrn(tcp, tcp->u_arg[1], tcp->u_arg[2]); + tprintf(", %" PRI_klu ", %u, ", tcp->u_arg[2], + (unsigned int) tcp->u_arg[3]); + print_ts(tcp, tcp->u_arg[4]); + return RVAL_DECODED; +} + +#if HAVE_ARCH_TIME32_SYSCALLS +SYS_FUNC(mq_timedsend_time32) +{ + return do_mq_timedsend(tcp, print_timespec32); +} +#endif + +SYS_FUNC(mq_timedsend_time64) +{ + return do_mq_timedsend(tcp, print_timespec64); +} + +static int +do_mq_timedreceive(struct tcb *const tcp, const print_obj_by_addr_fn print_ts) +{ + if (entering(tcp)) { + printfd(tcp, tcp->u_arg[0]); + tprints(", "); + } else { + if (syserror(tcp)) + printaddr(tcp->u_arg[1]); + else + printstrn(tcp, tcp->u_arg[1], tcp->u_rval); + tprintf(", %" PRI_klu ", ", tcp->u_arg[2]); + printnum_int(tcp, tcp->u_arg[3], "%u"); + tprints(", "); + /* + * Since the timeout parameter is read by the kernel + * on entering syscall, it has to be decoded the same way + * whether the syscall has failed or not. + */ + temporarily_clear_syserror(tcp); + print_ts(tcp, tcp->u_arg[4]); + restore_cleared_syserror(tcp); + } + return 0; +} + +#if HAVE_ARCH_TIME32_SYSCALLS +SYS_FUNC(mq_timedreceive_time32) +{ + return do_mq_timedreceive(tcp, print_timespec32); +} +#endif + +SYS_FUNC(mq_timedreceive_time64) +{ + return do_mq_timedreceive(tcp, print_timespec64); +} + +SYS_FUNC(mq_notify) +{ + printfd(tcp, tcp->u_arg[0]); + tprints(", "); + print_sigevent(tcp, tcp->u_arg[1]); + return RVAL_DECODED; +} + +SYS_FUNC(mq_getsetattr) +{ + if (entering(tcp)) { + printfd(tcp, tcp->u_arg[0]); + tprints(", "); + printmqattr(tcp, tcp->u_arg[1], true); + tprints(", "); + } else { + printmqattr(tcp, tcp->u_arg[2], true); + } + return 0; +} |