summaryrefslogtreecommitdiff
path: root/src/mq.c
diff options
context:
space:
mode:
authorDmitry V. Levin <ldv@strace.io>2021-02-03 08:00:00 +0000
committerDmitry V. Levin <ldv@strace.io>2021-02-03 08:00:00 +0000
commitecb3ed78107c851f71696df6730a15afff91ed3d (patch)
tree0b3d2b083040fc9b08d129f80d027ff41b995059 /src/mq.c
parentc47943de06204a269e16f732e7c9c71d4284b23f (diff)
downloadstrace-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.c110
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;
+}