[thirdparty/systemd.git] / src / libsystemd / sd-bus / bus-dump.c

/* SPDX-License-Identifier: LGPL-2.1+ */

#include <sys/time.h>

#include "alloc-util.h"
#include "bus-dump.h"
#include "bus-internal.h"
#include "bus-message.h"
#include "bus-type.h"
#include "cap-list.h"
#include "capability-util.h"
#include "fileio.h"
#include "format-util.h"
#include "locale-util.h"
#include "macro.h"
#include "string-util.h"
#include "strv.h"
#include "terminal-util.h"
#include "util.h"

static char *indent(unsigned level, unsigned flags) {
        char *p;
        unsigned n, i = 0;

        n = 0;

        if (flags & BUS_MESSAGE_DUMP_SUBTREE_ONLY && level > 0)
                level -= 1;

        if (flags & BUS_MESSAGE_DUMP_WITH_HEADER)
                n += 2;

        p = new(char, n + level*8 + 1);
        if (!p)
                return NULL;

        if (flags & BUS_MESSAGE_DUMP_WITH_HEADER) {
                p[i++] = ' ';
                p[i++] = ' ';
        }

        memset(p + i, ' ', level*8);
        p[i + level*8] = 0;

        return p;
}

int bus_message_dump(sd_bus_message *m, FILE *f, unsigned flags) {
        unsigned level = 1;
        int r;

        assert(m);

        if (!f)
                f = stdout;

        if (flags & BUS_MESSAGE_DUMP_WITH_HEADER) {
                fprintf(f,
                        "%s%s%s Type=%s%s%s  Endian=%c  Flags=%u  Version=%u  Priority=%"PRIi64,
                        m->header->type == SD_BUS_MESSAGE_METHOD_ERROR ? ansi_highlight_red() :
                        m->header->type == SD_BUS_MESSAGE_METHOD_RETURN ? ansi_highlight_green() :
                        m->header->type != SD_BUS_MESSAGE_SIGNAL ? ansi_highlight() : "",
                        special_glyph(SPECIAL_GLYPH_TRIANGULAR_BULLET),
                        ansi_normal(),

                        ansi_highlight(),
                        bus_message_type_to_string(m->header->type) ?: "(unknown)",
                        ansi_normal(),

                        m->header->endian,
                        m->header->flags,
                        m->header->version,
                        m->priority);

                /* Display synthetic message serial number in a more readable
                 * format than (uint32_t) -1 */
                if (BUS_MESSAGE_COOKIE(m) == 0xFFFFFFFFULL)
                        fprintf(f, " Cookie=-1");
                else
                        fprintf(f, " Cookie=%" PRIu64, BUS_MESSAGE_COOKIE(m));

                if (m->reply_cookie != 0)
                        fprintf(f, "  ReplyCookie=%" PRIu64, m->reply_cookie);

                fputs("\n", f);

                if (m->sender)
                        fprintf(f, "  Sender=%s%s%s", ansi_highlight(), m->sender, ansi_normal());
                if (m->destination)
                        fprintf(f, "  Destination=%s%s%s", ansi_highlight(), m->destination, ansi_normal());
                if (m->path)
                        fprintf(f, "  Path=%s%s%s", ansi_highlight(), m->path, ansi_normal());
                if (m->interface)
                        fprintf(f, "  Interface=%s%s%s", ansi_highlight(), m->interface, ansi_normal());
                if (m->member)
                        fprintf(f, "  Member=%s%s%s", ansi_highlight(), m->member, ansi_normal());

                if (m->sender || m->destination || m->path || m->interface || m->member)
                        fputs("\n", f);

                if (sd_bus_error_is_set(&m->error))
                        fprintf(f,
                                "  ErrorName=%s%s%s"
                                "  ErrorMessage=%s\"%s\"%s\n",
                                ansi_highlight_red(), strna(m->error.name), ansi_normal(),
                                ansi_highlight_red(), strna(m->error.message), ansi_normal());

                if (m->monotonic != 0)
                        fprintf(f, "  Monotonic="USEC_FMT, m->monotonic);
                if (m->realtime != 0)
                        fprintf(f, "  Realtime="USEC_FMT, m->realtime);
                if (m->seqnum != 0)
                        fprintf(f, "  SequenceNumber=%"PRIu64, m->seqnum);

                if (m->monotonic != 0 || m->realtime != 0 || m->seqnum != 0)
                        fputs("\n", f);

                bus_creds_dump(&m->creds, f, true);
        }

        r = sd_bus_message_rewind(m, !(flags & BUS_MESSAGE_DUMP_SUBTREE_ONLY));
        if (r < 0)
                return log_error_errno(r, "Failed to rewind: %m");

        if (!(flags & BUS_MESSAGE_DUMP_SUBTREE_ONLY)) {
                _cleanup_free_ char *prefix = NULL;

                prefix = indent(0, flags);
                if (!prefix)
                        return log_oom();

                fprintf(f, "%sMESSAGE \"%s\" {\n", prefix, strempty(m->root_container.signature));
        }

        for (;;) {
                _cleanup_free_ char *prefix = NULL;
                const char *contents = NULL;
                char type;
                union {
                        uint8_t u8;
                        uint16_t u16;
                        int16_t s16;
                        uint32_t u32;
                        int32_t s32;
                        uint64_t u64;
                        int64_t s64;
                        double d64;
                        const char *string;
                        int i;
                } basic;

                r = sd_bus_message_peek_type(m, &type, &contents);
                if (r < 0)
                        return log_error_errno(r, "Failed to peek type: %m");

                if (r == 0) {
                        if (level <= 1)
                                break;

                        r = sd_bus_message_exit_container(m);
                        if (r < 0)
                                return log_error_errno(r, "Failed to exit container: %m");

                        level--;

                        prefix = indent(level, flags);
                        if (!prefix)
                                return log_oom();

                        fprintf(f, "%s};\n", prefix);
                        continue;
                }

                prefix = indent(level, flags);
                if (!prefix)
                        return log_oom();

                if (bus_type_is_container(type) > 0) {
                        r = sd_bus_message_enter_container(m, type, contents);
                        if (r < 0)
                                return log_error_errno(r, "Failed to enter container: %m");

                        if (type == SD_BUS_TYPE_ARRAY)
                                fprintf(f, "%sARRAY \"%s\" {\n", prefix, contents);
                        else if (type == SD_BUS_TYPE_VARIANT)
                                fprintf(f, "%sVARIANT \"%s\" {\n", prefix, contents);
                        else if (type == SD_BUS_TYPE_STRUCT)
                                fprintf(f, "%sSTRUCT \"%s\" {\n", prefix, contents);
                        else if (type == SD_BUS_TYPE_DICT_ENTRY)
                                fprintf(f, "%sDICT_ENTRY \"%s\" {\n", prefix, contents);

                        level++;

                        continue;
                }

                r = sd_bus_message_read_basic(m, type, &basic);
                if (r < 0)
                        return log_error_errno(r, "Failed to get basic: %m");

                assert(r > 0);

                switch (type) {

                case SD_BUS_TYPE_BYTE:
                        fprintf(f, "%sBYTE %s%u%s;\n", prefix, ansi_highlight(), basic.u8, ansi_normal());
                        break;

                case SD_BUS_TYPE_BOOLEAN:
                        fprintf(f, "%sBOOLEAN %s%s%s;\n", prefix, ansi_highlight(), true_false(basic.i), ansi_normal());
                        break;

                case SD_BUS_TYPE_INT16:
                        fprintf(f, "%sINT16 %s%i%s;\n", prefix, ansi_highlight(), basic.s16, ansi_normal());
                        break;

                case SD_BUS_TYPE_UINT16:
                        fprintf(f, "%sUINT16 %s%u%s;\n", prefix, ansi_highlight(), basic.u16, ansi_normal());
                        break;

                case SD_BUS_TYPE_INT32:
                        fprintf(f, "%sINT32 %s%i%s;\n", prefix, ansi_highlight(), basic.s32, ansi_normal());
                        break;

                case SD_BUS_TYPE_UINT32:
                        fprintf(f, "%sUINT32 %s%u%s;\n", prefix, ansi_highlight(), basic.u32, ansi_normal());
                        break;

                case SD_BUS_TYPE_INT64:
                        fprintf(f, "%sINT64 %s%"PRIi64"%s;\n", prefix, ansi_highlight(), basic.s64, ansi_normal());
                        break;

                case SD_BUS_TYPE_UINT64:
                        fprintf(f, "%sUINT64 %s%"PRIu64"%s;\n", prefix, ansi_highlight(), basic.u64, ansi_normal());
                        break;

                case SD_BUS_TYPE_DOUBLE:
                        fprintf(f, "%sDOUBLE %s%g%s;\n", prefix, ansi_highlight(), basic.d64, ansi_normal());
                        break;

                case SD_BUS_TYPE_STRING:
                        fprintf(f, "%sSTRING \"%s%s%s\";\n", prefix, ansi_highlight(), basic.string, ansi_normal());
                        break;

                case SD_BUS_TYPE_OBJECT_PATH:
                        fprintf(f, "%sOBJECT_PATH \"%s%s%s\";\n", prefix, ansi_highlight(), basic.string, ansi_normal());
                        break;

                case SD_BUS_TYPE_SIGNATURE:
                        fprintf(f, "%sSIGNATURE \"%s%s%s\";\n", prefix, ansi_highlight(), basic.string, ansi_normal());
                        break;

                case SD_BUS_TYPE_UNIX_FD:
                        fprintf(f, "%sUNIX_FD %s%i%s;\n", prefix, ansi_highlight(), basic.i, ansi_normal());
                        break;

                default:
                        assert_not_reached("Unknown basic type.");
                }
        }

        if (!(flags & BUS_MESSAGE_DUMP_SUBTREE_ONLY)) {
                _cleanup_free_ char *prefix = NULL;

                prefix = indent(0, flags);
                if (!prefix)
                        return log_oom();

                fprintf(f, "%s};\n\n", prefix);
        }

        return 0;
}

static void dump_capabilities(
                sd_bus_creds *c,
                FILE *f,
                const char *name,
                bool terse,
                int (*has)(sd_bus_creds *c, int capability)) {

        unsigned long i, last_cap;
        unsigned n = 0;
        int r;

        assert(c);
        assert(f);
        assert(name);
        assert(has);

        i = 0;
        r = has(c, i);
        if (r < 0)
                return;

        fprintf(f, "%s%s=%s", terse ? "  " : "", name, terse ? "" : ansi_highlight());
        last_cap = cap_last_cap();

        for (;;) {
                if (r > 0) {

                        if (n > 0)
                                fputc(' ', f);
                        if (n % 4 == 3)
                                fprintf(f, terse ? "\n          " : "\n        ");

                        fprintf(f, "%s", strna(capability_to_name(i)));
                        n++;
                }

                i++;

                if (i > last_cap)
                        break;

                r = has(c, i);
        }

        fputs("\n", f);

        if (!terse)
                fputs(ansi_normal(), f);
}

int bus_creds_dump(sd_bus_creds *c, FILE *f, bool terse) {
        uid_t owner, audit_loginuid;
        uint32_t audit_sessionid;
        char **cmdline = NULL, **well_known = NULL;
        const char *prefix, *color, *suffix, *s;
        int r, q, v, w, z;

        assert(c);

        if (!f)
                f = stdout;

        if (terse) {
                prefix = "  ";
                suffix = "";
                color = "";
        } else {
                const char *off;

                prefix = "";
                color = ansi_highlight();

                off = ansi_normal();
                suffix = strjoina(off, "\n");
        }

        if (c->mask & SD_BUS_CREDS_PID)
                fprintf(f, "%sPID=%s"PID_FMT"%s", prefix, color, c->pid, suffix);
        if (c->mask & SD_BUS_CREDS_TID)
                fprintf(f, "%sTID=%s"PID_FMT"%s", prefix, color, c->tid, suffix);
        if (c->mask & SD_BUS_CREDS_PPID) {
                if (c->ppid == 0)
                        fprintf(f, "%sPPID=%sn/a%s", prefix, color, suffix);
                else
                        fprintf(f, "%sPPID=%s"PID_FMT"%s", prefix, color, c->ppid, suffix);
        }
        if (c->mask & SD_BUS_CREDS_TTY)
                fprintf(f, "%sTTY=%s%s%s", prefix, color, strna(c->tty), suffix);

        if (terse && ((c->mask & (SD_BUS_CREDS_PID|SD_BUS_CREDS_TID|SD_BUS_CREDS_PPID|SD_BUS_CREDS_TTY))))
                fputs("\n", f);

        if (c->mask & SD_BUS_CREDS_UID)
                fprintf(f, "%sUID=%s"UID_FMT"%s", prefix, color, c->uid, suffix);
        if (c->mask & SD_BUS_CREDS_EUID)
                fprintf(f, "%sEUID=%s"UID_FMT"%s", prefix, color, c->euid, suffix);
        if (c->mask & SD_BUS_CREDS_SUID)
                fprintf(f, "%sSUID=%s"UID_FMT"%s", prefix, color, c->suid, suffix);
        if (c->mask & SD_BUS_CREDS_FSUID)
                fprintf(f, "%sFSUID=%s"UID_FMT"%s", prefix, color, c->fsuid, suffix);
        r = sd_bus_creds_get_owner_uid(c, &owner);
        if (r >= 0)
                fprintf(f, "%sOwnerUID=%s"UID_FMT"%s", prefix, color, owner, suffix);
        if (c->mask & SD_BUS_CREDS_GID)
                fprintf(f, "%sGID=%s"GID_FMT"%s", prefix, color, c->gid, suffix);
        if (c->mask & SD_BUS_CREDS_EGID)
                fprintf(f, "%sEGID=%s"GID_FMT"%s", prefix, color, c->egid, suffix);
        if (c->mask & SD_BUS_CREDS_SGID)
                fprintf(f, "%sSGID=%s"GID_FMT"%s", prefix, color, c->sgid, suffix);
        if (c->mask & SD_BUS_CREDS_FSGID)
                fprintf(f, "%sFSGID=%s"GID_FMT"%s", prefix, color, c->fsgid, suffix);

        if (c->mask & SD_BUS_CREDS_SUPPLEMENTARY_GIDS) {
                unsigned i;

                fprintf(f, "%sSupplementaryGIDs=%s", prefix, color);
                for (i = 0; i < c->n_supplementary_gids; i++)
                        fprintf(f, "%s" GID_FMT, i > 0 ? " " : "", c->supplementary_gids[i]);
                fprintf(f, "%s", suffix);
        }

        if (terse && ((c->mask & (SD_BUS_CREDS_UID|SD_BUS_CREDS_EUID|SD_BUS_CREDS_SUID|SD_BUS_CREDS_FSUID|
                                  SD_BUS_CREDS_GID|SD_BUS_CREDS_EGID|SD_BUS_CREDS_SGID|SD_BUS_CREDS_FSGID|
                                  SD_BUS_CREDS_SUPPLEMENTARY_GIDS)) || r >= 0))
                fputs("\n", f);

        if (c->mask & SD_BUS_CREDS_COMM)
                fprintf(f, "%sComm=%s%s%s", prefix, color, c->comm, suffix);
        if (c->mask & SD_BUS_CREDS_TID_COMM)
                fprintf(f, "%sTIDComm=%s%s%s", prefix, color, c->tid_comm, suffix);
        if (c->mask & SD_BUS_CREDS_EXE)
                fprintf(f, "%sExe=%s%s%s", prefix, color, strna(c->exe), suffix);

        if (terse && (c->mask & (SD_BUS_CREDS_EXE|SD_BUS_CREDS_COMM|SD_BUS_CREDS_TID_COMM)))
                fputs("\n", f);

        r = sd_bus_creds_get_cmdline(c, &cmdline);
        if (r >= 0) {
                char **i;

                fprintf(f, "%sCommandLine=%s", prefix, color);
                STRV_FOREACH(i, cmdline) {
                        if (i != cmdline)
                                fputc(' ', f);

                        fputs(*i, f);
                }

                fprintf(f, "%s", suffix);
        } else if (r != -ENODATA)
                fprintf(f, "%sCommandLine=%sn/a%s", prefix, color, suffix);

        if (c->mask & SD_BUS_CREDS_SELINUX_CONTEXT)
                fprintf(f, "%sLabel=%s%s%s", prefix, color, c->label, suffix);
        if (c->mask & SD_BUS_CREDS_DESCRIPTION)
                fprintf(f, "%sDescription=%s%s%s", prefix, color, c->description, suffix);

        if (terse && (c->mask & (SD_BUS_CREDS_SELINUX_CONTEXT|SD_BUS_CREDS_DESCRIPTION)))
                fputs("\n", f);

        if (c->mask & SD_BUS_CREDS_CGROUP)
                fprintf(f, "%sCGroup=%s%s%s", prefix, color, c->cgroup, suffix);
        s = NULL;
        r = sd_bus_creds_get_unit(c, &s);
        if (r != -ENODATA)
                fprintf(f, "%sUnit=%s%s%s", prefix, color, strna(s), suffix);
        s = NULL;
        v = sd_bus_creds_get_slice(c, &s);
        if (v != -ENODATA)
                fprintf(f, "%sSlice=%s%s%s", prefix, color, strna(s), suffix);
        s = NULL;
        q = sd_bus_creds_get_user_unit(c, &s);
        if (q != -ENODATA)
                fprintf(f, "%sUserUnit=%s%s%s", prefix, color, strna(s), suffix);
        s = NULL;
        w = sd_bus_creds_get_user_slice(c, &s);
        if (w != -ENODATA)
                fprintf(f, "%sUserSlice=%s%s%s", prefix, color, strna(s), suffix);
        s = NULL;
        z = sd_bus_creds_get_session(c, &s);
        if (z != -ENODATA)
                fprintf(f, "%sSession=%s%s%s", prefix, color, strna(s), suffix);

        if (terse && ((c->mask & SD_BUS_CREDS_CGROUP) || r != -ENODATA || q != -ENODATA || v != -ENODATA || w != -ENODATA || z != -ENODATA))
                fputs("\n", f);

        r = sd_bus_creds_get_audit_login_uid(c, &audit_loginuid);
        if (r >= 0)
                fprintf(f, "%sAuditLoginUID=%s"UID_FMT"%s", prefix, color, audit_loginuid, suffix);
        else if (r != -ENODATA)
                fprintf(f, "%sAuditLoginUID=%sn/a%s", prefix, color, suffix);
        q = sd_bus_creds_get_audit_session_id(c, &audit_sessionid);
        if (q >= 0)
                fprintf(f, "%sAuditSessionID=%s%"PRIu32"%s", prefix, color, audit_sessionid, suffix);
        else if (q != -ENODATA)
                fprintf(f, "%sAuditSessionID=%sn/a%s", prefix, color, suffix);

        if (terse && (r != -ENODATA || q != -ENODATA))
                fputs("\n", f);

        if (c->mask & SD_BUS_CREDS_UNIQUE_NAME)
                fprintf(f, "%sUniqueName=%s%s%s", prefix, color, c->unique_name, suffix);

        if (sd_bus_creds_get_well_known_names(c, &well_known) >= 0) {
                char **i;

                fprintf(f, "%sWellKnownNames=%s", prefix, color);
                STRV_FOREACH(i, well_known) {
                        if (i != well_known)
                                fputc(' ', f);

                        fputs(*i, f);
                }

                fprintf(f, "%s", suffix);
        }

        if (terse && (c->mask & SD_BUS_CREDS_UNIQUE_NAME || well_known))
                fputc('\n', f);

        dump_capabilities(c, f, "EffectiveCapabilities", terse, sd_bus_creds_has_effective_cap);
        dump_capabilities(c, f, "PermittedCapabilities", terse, sd_bus_creds_has_permitted_cap);
        dump_capabilities(c, f, "InheritableCapabilities", terse, sd_bus_creds_has_inheritable_cap);
        dump_capabilities(c, f, "BoundingCapabilities", terse, sd_bus_creds_has_bounding_cap);

        return 0;
}

/*
 * For details about the file format, see:
 *
 * http://wiki.wireshark.org/Development/LibpcapFileFormat
 */

typedef struct _packed_ pcap_hdr_s {
        uint32_t magic_number;   /* magic number */
        uint16_t version_major;  /* major version number */
        uint16_t version_minor;  /* minor version number */
        int32_t  thiszone;       /* GMT to local correction */
        uint32_t sigfigs;        /* accuracy of timestamps */
        uint32_t snaplen;        /* max length of captured packets, in octets */
        uint32_t network;        /* data link type */
} pcap_hdr_t ;

typedef struct  _packed_ pcaprec_hdr_s {
        uint32_t ts_sec;         /* timestamp seconds */
        uint32_t ts_usec;        /* timestamp microseconds */
        uint32_t incl_len;       /* number of octets of packet saved in file */
        uint32_t orig_len;       /* actual length of packet */
} pcaprec_hdr_t;

int bus_pcap_header(size_t snaplen, FILE *f) {

        pcap_hdr_t hdr = {
                .magic_number = 0xa1b2c3d4U,
                .version_major = 2,
                .version_minor = 4,
                .thiszone = 0, /* UTC */
                .sigfigs = 0,
                .network = 231, /* D-Bus */
        };

        if (!f)
                f = stdout;

        assert(snaplen > 0);
        assert((size_t) (uint32_t) snaplen == snaplen);

        hdr.snaplen = (uint32_t) snaplen;

        fwrite(&hdr, 1, sizeof(hdr), f);

        return fflush_and_check(f);
}

int bus_message_pcap_frame(sd_bus_message *m, size_t snaplen, FILE *f) {
        struct bus_body_part *part;
        pcaprec_hdr_t hdr = {};
        struct timeval tv;
        unsigned i;
        size_t w;

        if (!f)
                f = stdout;

        assert(m);
        assert(snaplen > 0);
        assert((size_t) (uint32_t) snaplen == snaplen);

        if (m->realtime != 0)
                timeval_store(&tv, m->realtime);
        else
                assert_se(gettimeofday(&tv, NULL) >= 0);

        hdr.ts_sec = tv.tv_sec;
        hdr.ts_usec = tv.tv_usec;
        hdr.orig_len = BUS_MESSAGE_SIZE(m);
        hdr.incl_len = MIN(hdr.orig_len, snaplen);

        /* write the pcap header */
        fwrite(&hdr, 1, sizeof(hdr), f);

        /* write the dbus header */
        w = MIN(BUS_MESSAGE_BODY_BEGIN(m), snaplen);
        fwrite(m->header, 1, w, f);
        snaplen -= w;

        /* write the dbus body */
        MESSAGE_FOREACH_PART(part, i, m) {
                if (snaplen <= 0)
                        break;

                w = MIN(part->size, snaplen);
                fwrite(part->data, 1, w, f);
                snaplen -= w;
        }

        return fflush_and_check(f);
}
Commit	Line	Data
53e1b683	1	/* SPDX-License-Identifier: LGPL-2.1+ */
3db0e46b	2
ef118d00 YW	3	#include <sys/time.h>
ef118d00 YW	4
b5efdb8a	5	#include "alloc-util.h"
0d39fa9c	6	#include "bus-dump.h"
07630cea LP	7	#include "bus-internal.h"
	8	#include "bus-message.h"
	9	#include "bus-type.h"
2822da4f	10	#include "cap-list.h"
430f0182	11	#include "capability-util.h"
0d39fa9c	12	#include "fileio.h"
f97b34a6	13	#include "format-util.h"
8752c575	14	#include "locale-util.h"
07630cea LP	15	#include "macro.h"
	16	#include "string-util.h"
	17	#include "strv.h"
288a74cc	18	#include "terminal-util.h"
07630cea	19	#include "util.h"
3db0e46b	20
d55192ad	21	static char *indent(unsigned level, unsigned flags) {
f8cfb5f5	22	char *p;
d55192ad	23	unsigned n, i = 0;
f8cfb5f5	24
d55192ad LP	25	n = 0;
	26
	27	if (flags & BUS_MESSAGE_DUMP_SUBTREE_ONLY && level > 0)
	28	level -= 1;
	29
	30	if (flags & BUS_MESSAGE_DUMP_WITH_HEADER)
	31	n += 2;
	32
	33	p = new(char, n + level*8 + 1);
f8cfb5f5 LP	34	if (!p)
	35	return NULL;
	36
d55192ad LP	37	if (flags & BUS_MESSAGE_DUMP_WITH_HEADER) {
	38	p[i++] = ' ';
	39	p[i++] = ' ';
	40	}
	41
	42	memset(p + i, ' ', level*8);
	43	p[i + level*8] = 0;
f8cfb5f5 LP	44
	45	return p;
	46	}
	47
d55192ad	48	int bus_message_dump(sd_bus_message m, FILE f, unsigned flags) {
3db0e46b LP	49	unsigned level = 1;
3db0e46b LP	50	int r;
3db0e46b LP	51
	52	assert(m);
	53
	54	if (!f)
	55	f = stdout;
	56
d55192ad	57	if (flags & BUS_MESSAGE_DUMP_WITH_HEADER) {
3db0e46b	58	fprintf(f,
1fa2f38f	59	"%s%s%s Type=%s%s%s Endian=%c Flags=%u Version=%u Priority=%"PRIi64,
f8cfb5f5 LP	60	m->header->type == SD_BUS_MESSAGE_METHOD_ERROR ? ansi_highlight_red() :
f8cfb5f5 LP	61	m->header->type == SD_BUS_MESSAGE_METHOD_RETURN ? ansi_highlight_green() :
e8fd7e4b	62	m->header->type != SD_BUS_MESSAGE_SIGNAL ? ansi_highlight() : "",
9a6f746f	63	special_glyph(SPECIAL_GLYPH_TRIANGULAR_BULLET),
e8fd7e4b ZJS	64	ansi_normal(),
	65
	66	ansi_highlight(),
	67	bus_message_type_to_string(m->header->type) ?: "(unknown)",
	68	ansi_normal(),
	69
f8cfb5f5	70	m->header->endian,
3db0e46b	71	m->header->flags,
ca7b42c8	72	m->header->version,
1fa2f38f	73	m->priority);
a009c158 LS	74
	75	/* Display synthetic message serial number in a more readable
	76	* format than (uint32_t) -1 */
693eb9a2 LP	77	if (BUS_MESSAGE_COOKIE(m) == 0xFFFFFFFFULL)
693eb9a2 LP	78	fprintf(f, " Cookie=-1");
a009c158	79	else
42c4ebcb	80	fprintf(f, " Cookie=%" PRIu64, BUS_MESSAGE_COOKIE(m));
3db0e46b	81
693eb9a2	82	if (m->reply_cookie != 0)
42c4ebcb	83	fprintf(f, " ReplyCookie=%" PRIu64, m->reply_cookie);
3db0e46b LP	84
	85	fputs("\n", f);
	86
	87	if (m->sender)
1fc464f6	88	fprintf(f, " Sender=%s%s%s", ansi_highlight(), m->sender, ansi_normal());
3db0e46b	89	if (m->destination)
1fc464f6	90	fprintf(f, " Destination=%s%s%s", ansi_highlight(), m->destination, ansi_normal());
3db0e46b	91	if (m->path)
1fc464f6	92	fprintf(f, " Path=%s%s%s", ansi_highlight(), m->path, ansi_normal());
3db0e46b	93	if (m->interface)
1fc464f6	94	fprintf(f, " Interface=%s%s%s", ansi_highlight(), m->interface, ansi_normal());
3db0e46b	95	if (m->member)
1fc464f6	96	fprintf(f, " Member=%s%s%s", ansi_highlight(), m->member, ansi_normal());
3db0e46b LP	97
	98	if (m->sender \|\| m->destination \|\| m->path \|\| m->interface \|\| m->member)
	99	fputs("\n", f);
	100
	101	if (sd_bus_error_is_set(&m->error))
	102	fprintf(f,
	103	" ErrorName=%s%s%s"
	104	" ErrorMessage=%s\"%s\"%s\n",
1fc464f6 LP	105	ansi_highlight_red(), strna(m->error.name), ansi_normal(),
1fc464f6 LP	106	ansi_highlight_red(), strna(m->error.message), ansi_normal());
3db0e46b	107
3db0e46b	108	if (m->monotonic != 0)
de0671ee	109	fprintf(f, " Monotonic="USEC_FMT, m->monotonic);
3db0e46b	110	if (m->realtime != 0)
de0671ee	111	fprintf(f, " Realtime="USEC_FMT, m->realtime);
6a0e376c	112	if (m->seqnum != 0)
de0671ee	113	fprintf(f, " SequenceNumber=%"PRIu64, m->seqnum);
3db0e46b	114
6a0e376c	115	if (m->monotonic != 0 \|\| m->realtime != 0 \|\| m->seqnum != 0)
3db0e46b LP	116	fputs("\n", f);
3db0e46b LP	117
d0b2babf	118	bus_creds_dump(&m->creds, f, true);
3db0e46b LP	119	}
3db0e46b LP	120
d55192ad	121	r = sd_bus_message_rewind(m, !(flags & BUS_MESSAGE_DUMP_SUBTREE_ONLY));
23bbb0de MS	122	if (r < 0)
23bbb0de MS	123	return log_error_errno(r, "Failed to rewind: %m");
3db0e46b	124
ee04388a LP	125	if (!(flags & BUS_MESSAGE_DUMP_SUBTREE_ONLY)) {
	126	_cleanup_free_ char *prefix = NULL;
	127
	128	prefix = indent(0, flags);
	129	if (!prefix)
	130	return log_oom();
	131
	132	fprintf(f, "%sMESSAGE \"%s\" {\n", prefix, strempty(m->root_container.signature));
	133	}
3db0e46b	134
f168c273	135	for (;;) {
3db0e46b LP	136	_cleanup_free_ char *prefix = NULL;
	137	const char *contents = NULL;
	138	char type;
	139	union {
	140	uint8_t u8;
	141	uint16_t u16;
	142	int16_t s16;
	143	uint32_t u32;
	144	int32_t s32;
	145	uint64_t u64;
	146	int64_t s64;
	147	double d64;
	148	const char *string;
	149	int i;
	150	} basic;
	151
	152	r = sd_bus_message_peek_type(m, &type, &contents);
23bbb0de MS	153	if (r < 0)
23bbb0de MS	154	return log_error_errno(r, "Failed to peek type: %m");
3db0e46b LP	155
	156	if (r == 0) {
	157	if (level <= 1)
	158	break;
	159
	160	r = sd_bus_message_exit_container(m);
23bbb0de MS	161	if (r < 0)
23bbb0de MS	162	return log_error_errno(r, "Failed to exit container: %m");
3db0e46b LP	163
	164	level--;
	165
d55192ad	166	prefix = indent(level, flags);
3db0e46b LP	167	if (!prefix)
	168	return log_oom();
	169
	170	fprintf(f, "%s};\n", prefix);
	171	continue;
	172	}
	173
d55192ad	174	prefix = indent(level, flags);
3db0e46b LP	175	if (!prefix)
	176	return log_oom();
	177
	178	if (bus_type_is_container(type) > 0) {
	179	r = sd_bus_message_enter_container(m, type, contents);
23bbb0de MS	180	if (r < 0)
23bbb0de MS	181	return log_error_errno(r, "Failed to enter container: %m");
3db0e46b LP	182
	183	if (type == SD_BUS_TYPE_ARRAY)
	184	fprintf(f, "%sARRAY \"%s\" {\n", prefix, contents);
	185	else if (type == SD_BUS_TYPE_VARIANT)
	186	fprintf(f, "%sVARIANT \"%s\" {\n", prefix, contents);
	187	else if (type == SD_BUS_TYPE_STRUCT)
	188	fprintf(f, "%sSTRUCT \"%s\" {\n", prefix, contents);
	189	else if (type == SD_BUS_TYPE_DICT_ENTRY)
	190	fprintf(f, "%sDICT_ENTRY \"%s\" {\n", prefix, contents);
	191
313cefa1	192	level++;
3db0e46b LP	193
	194	continue;
	195	}
	196
	197	r = sd_bus_message_read_basic(m, type, &basic);
23bbb0de MS	198	if (r < 0)
23bbb0de MS	199	return log_error_errno(r, "Failed to get basic: %m");
3db0e46b LP	200
	201	assert(r > 0);
	202
	203	switch (type) {
	204
	205	case SD_BUS_TYPE_BYTE:
1fc464f6	206	fprintf(f, "%sBYTE %s%u%s;\n", prefix, ansi_highlight(), basic.u8, ansi_normal());
3db0e46b LP	207	break;
	208
	209	case SD_BUS_TYPE_BOOLEAN:
1fc464f6	210	fprintf(f, "%sBOOLEAN %s%s%s;\n", prefix, ansi_highlight(), true_false(basic.i), ansi_normal());
3db0e46b LP	211	break;
	212
	213	case SD_BUS_TYPE_INT16:
1fc464f6	214	fprintf(f, "%sINT16 %s%i%s;\n", prefix, ansi_highlight(), basic.s16, ansi_normal());
3db0e46b LP	215	break;
	216
	217	case SD_BUS_TYPE_UINT16:
1fc464f6	218	fprintf(f, "%sUINT16 %s%u%s;\n", prefix, ansi_highlight(), basic.u16, ansi_normal());
3db0e46b LP	219	break;
	220
	221	case SD_BUS_TYPE_INT32:
1fc464f6	222	fprintf(f, "%sINT32 %s%i%s;\n", prefix, ansi_highlight(), basic.s32, ansi_normal());
3db0e46b LP	223	break;
	224
	225	case SD_BUS_TYPE_UINT32:
1fc464f6	226	fprintf(f, "%sUINT32 %s%u%s;\n", prefix, ansi_highlight(), basic.u32, ansi_normal());
3db0e46b LP	227	break;
	228
	229	case SD_BUS_TYPE_INT64:
1fc464f6	230	fprintf(f, "%sINT64 %s%"PRIi64"%s;\n", prefix, ansi_highlight(), basic.s64, ansi_normal());
3db0e46b LP	231	break;
	232
	233	case SD_BUS_TYPE_UINT64:
1fc464f6	234	fprintf(f, "%sUINT64 %s%"PRIu64"%s;\n", prefix, ansi_highlight(), basic.u64, ansi_normal());
3db0e46b LP	235	break;
	236
	237	case SD_BUS_TYPE_DOUBLE:
1fc464f6	238	fprintf(f, "%sDOUBLE %s%g%s;\n", prefix, ansi_highlight(), basic.d64, ansi_normal());
3db0e46b LP	239	break;
	240
	241	case SD_BUS_TYPE_STRING:
1fc464f6	242	fprintf(f, "%sSTRING \"%s%s%s\";\n", prefix, ansi_highlight(), basic.string, ansi_normal());
3db0e46b LP	243	break;
	244
	245	case SD_BUS_TYPE_OBJECT_PATH:
1fc464f6	246	fprintf(f, "%sOBJECT_PATH \"%s%s%s\";\n", prefix, ansi_highlight(), basic.string, ansi_normal());
3db0e46b LP	247	break;
	248
	249	case SD_BUS_TYPE_SIGNATURE:
1fc464f6	250	fprintf(f, "%sSIGNATURE \"%s%s%s\";\n", prefix, ansi_highlight(), basic.string, ansi_normal());
3db0e46b LP	251	break;
	252
	253	case SD_BUS_TYPE_UNIX_FD:
1fc464f6	254	fprintf(f, "%sUNIX_FD %s%i%s;\n", prefix, ansi_highlight(), basic.i, ansi_normal());
3db0e46b LP	255	break;
	256
	257	default:
	258	assert_not_reached("Unknown basic type.");
	259	}
	260	}
	261
ee04388a LP	262	if (!(flags & BUS_MESSAGE_DUMP_SUBTREE_ONLY)) {
	263	_cleanup_free_ char *prefix = NULL;
	264
	265	prefix = indent(0, flags);
	266	if (!prefix)
	267	return log_oom();
	268
	269	fprintf(f, "%s};\n\n", prefix);
	270	}
d55192ad	271
3db0e46b LP	272	return 0;
3db0e46b LP	273	}
5b12334d LP	274
	275	static void dump_capabilities(
	276	sd_bus_creds *c,
	277	FILE *f,
	278	const char *name,
d0b2babf	279	bool terse,
5b12334d LP	280	int (has)(sd_bus_creds c, int capability)) {
	281
	282	unsigned long i, last_cap;
	283	unsigned n = 0;
	284	int r;
	285
	286	assert(c);
	287	assert(f);
	288	assert(name);
	289	assert(has);
	290
	291	i = 0;
	292	r = has(c, i);
	293	if (r < 0)
	294	return;
	295
d0b2babf	296	fprintf(f, "%s%s=%s", terse ? " " : "", name, terse ? "" : ansi_highlight());
5b12334d LP	297	last_cap = cap_last_cap();
	298
	299	for (;;) {
	300	if (r > 0) {
5ce70e5b	301
5b12334d LP	302	if (n > 0)
	303	fputc(' ', f);
	304	if (n % 4 == 3)
d0b2babf	305	fprintf(f, terse ? "\n " : "\n ");
5b12334d	306
2822da4f	307	fprintf(f, "%s", strna(capability_to_name(i)));
5b12334d LP	308	n++;
	309	}
	310
	311	i++;
	312
	313	if (i > last_cap)
	314	break;
	315
	316	r = has(c, i);
	317	}
	318
	319	fputs("\n", f);
d0b2babf LP	320
d0b2babf LP	321	if (!terse)
1fc464f6	322	fputs(ansi_normal(), f);
5b12334d LP	323	}
5b12334d LP	324
d0b2babf	325	int bus_creds_dump(sd_bus_creds c, FILE f, bool terse) {
5b12334d LP	326	uid_t owner, audit_loginuid;
5b12334d LP	327	uint32_t audit_sessionid;
49b832c5	328	char cmdline = NULL, well_known = NULL;
cfeaa44a	329	const char prefix, color, suffix, s;
329ac4bc	330	int r, q, v, w, z;
5b12334d LP	331
	332	assert(c);
	333
	334	if (!f)
	335	f = stdout;
	336
d0b2babf LP	337	if (terse) {
	338	prefix = " ";
	339	suffix = "";
	340	color = "";
	341	} else {
	342	const char *off;
	343
	344	prefix = "";
	345	color = ansi_highlight();
	346
1fc464f6	347	off = ansi_normal();
63c372cb	348	suffix = strjoina(off, "\n");
d0b2babf LP	349	}
d0b2babf LP	350
5b12334d	351	if (c->mask & SD_BUS_CREDS_PID)
d0b2babf	352	fprintf(f, "%sPID=%s"PID_FMT"%s", prefix, color, c->pid, suffix);
5b12334d	353	if (c->mask & SD_BUS_CREDS_TID)
d0b2babf	354	fprintf(f, "%sTID=%s"PID_FMT"%s", prefix, color, c->tid, suffix);
cfeaa44a LP	355	if (c->mask & SD_BUS_CREDS_PPID) {
	356	if (c->ppid == 0)
	357	fprintf(f, "%sPPID=%sn/a%s", prefix, color, suffix);
	358	else
	359	fprintf(f, "%sPPID=%s"PID_FMT"%s", prefix, color, c->ppid, suffix);
	360	}
4761e880 LP	361	if (c->mask & SD_BUS_CREDS_TTY)
4761e880 LP	362	fprintf(f, "%sTTY=%s%s%s", prefix, color, strna(c->tty), suffix);
705a415f	363
4761e880	364	if (terse && ((c->mask & (SD_BUS_CREDS_PID\|SD_BUS_CREDS_TID\|SD_BUS_CREDS_PPID\|SD_BUS_CREDS_TTY))))
705a415f LP	365	fputs("\n", f);
705a415f LP	366
5b12334d	367	if (c->mask & SD_BUS_CREDS_UID)
d0b2babf	368	fprintf(f, "%sUID=%s"UID_FMT"%s", prefix, color, c->uid, suffix);
705a415f LP	369	if (c->mask & SD_BUS_CREDS_EUID)
	370	fprintf(f, "%sEUID=%s"UID_FMT"%s", prefix, color, c->euid, suffix);
	371	if (c->mask & SD_BUS_CREDS_SUID)
	372	fprintf(f, "%sSUID=%s"UID_FMT"%s", prefix, color, c->suid, suffix);
	373	if (c->mask & SD_BUS_CREDS_FSUID)
	374	fprintf(f, "%sFSUID=%s"UID_FMT"%s", prefix, color, c->fsuid, suffix);
5b12334d LP	375	r = sd_bus_creds_get_owner_uid(c, &owner);
5b12334d LP	376	if (r >= 0)
d0b2babf	377	fprintf(f, "%sOwnerUID=%s"UID_FMT"%s", prefix, color, owner, suffix);
5b12334d	378	if (c->mask & SD_BUS_CREDS_GID)
d0b2babf	379	fprintf(f, "%sGID=%s"GID_FMT"%s", prefix, color, c->gid, suffix);
705a415f LP	380	if (c->mask & SD_BUS_CREDS_EGID)
	381	fprintf(f, "%sEGID=%s"GID_FMT"%s", prefix, color, c->egid, suffix);
	382	if (c->mask & SD_BUS_CREDS_SGID)
	383	fprintf(f, "%sSGID=%s"GID_FMT"%s", prefix, color, c->sgid, suffix);
	384	if (c->mask & SD_BUS_CREDS_FSGID)
	385	fprintf(f, "%sFSGID=%s"GID_FMT"%s", prefix, color, c->fsgid, suffix);
	386
02581590 LP	387	if (c->mask & SD_BUS_CREDS_SUPPLEMENTARY_GIDS) {
	388	unsigned i;
	389
	390	fprintf(f, "%sSupplementaryGIDs=%s", prefix, color);
	391	for (i = 0; i < c->n_supplementary_gids; i++)
	392	fprintf(f, "%s" GID_FMT, i > 0 ? " " : "", c->supplementary_gids[i]);
	393	fprintf(f, "%s", suffix);
	394	}
	395
705a415f	396	if (terse && ((c->mask & (SD_BUS_CREDS_UID\|SD_BUS_CREDS_EUID\|SD_BUS_CREDS_SUID\|SD_BUS_CREDS_FSUID\|
02581590 LP	397	SD_BUS_CREDS_GID\|SD_BUS_CREDS_EGID\|SD_BUS_CREDS_SGID\|SD_BUS_CREDS_FSGID\|
02581590 LP	398	SD_BUS_CREDS_SUPPLEMENTARY_GIDS)) \|\| r >= 0))
5b12334d LP	399	fputs("\n", f);
5b12334d LP	400
5b12334d	401	if (c->mask & SD_BUS_CREDS_COMM)
d0b2babf	402	fprintf(f, "%sComm=%s%s%s", prefix, color, c->comm, suffix);
5b12334d	403	if (c->mask & SD_BUS_CREDS_TID_COMM)
d0b2babf	404	fprintf(f, "%sTIDComm=%s%s%s", prefix, color, c->tid_comm, suffix);
5cf4f2d1	405	if (c->mask & SD_BUS_CREDS_EXE)
cfeaa44a	406	fprintf(f, "%sExe=%s%s%s", prefix, color, strna(c->exe), suffix);
14008e4e	407
d0b2babf	408	if (terse && (c->mask & (SD_BUS_CREDS_EXE\|SD_BUS_CREDS_COMM\|SD_BUS_CREDS_TID_COMM)))
14008e4e LP	409	fputs("\n", f);
14008e4e LP	410
cfeaa44a LP	411	r = sd_bus_creds_get_cmdline(c, &cmdline);
cfeaa44a LP	412	if (r >= 0) {
5b12334d LP	413	char **i;
5b12334d LP	414
d0b2babf	415	fprintf(f, "%sCommandLine=%s", prefix, color);
5b12334d LP	416	STRV_FOREACH(i, cmdline) {
	417	if (i != cmdline)
	418	fputc(' ', f);
	419
	420	fputs(*i, f);
	421	}
	422
d0b2babf	423	fprintf(f, "%s", suffix);
cfeaa44a LP	424	} else if (r != -ENODATA)
cfeaa44a LP	425	fprintf(f, "%sCommandLine=%sn/a%s", prefix, color, suffix);
5b12334d	426
5cf4f2d1 LP	427	if (c->mask & SD_BUS_CREDS_SELINUX_CONTEXT)
	428	fprintf(f, "%sLabel=%s%s%s", prefix, color, c->label, suffix);
	429	if (c->mask & SD_BUS_CREDS_DESCRIPTION)
	430	fprintf(f, "%sDescription=%s%s%s", prefix, color, c->description, suffix);
	431
	432	if (terse && (c->mask & (SD_BUS_CREDS_SELINUX_CONTEXT\|SD_BUS_CREDS_DESCRIPTION)))
	433	fputs("\n", f);
	434
5b12334d	435	if (c->mask & SD_BUS_CREDS_CGROUP)
d0b2babf	436	fprintf(f, "%sCGroup=%s%s%s", prefix, color, c->cgroup, suffix);
cfeaa44a LP	437	s = NULL;
	438	r = sd_bus_creds_get_unit(c, &s);
	439	if (r != -ENODATA)
	440	fprintf(f, "%sUnit=%s%s%s", prefix, color, strna(s), suffix);
	441	s = NULL;
cfeaa44a LP	442	v = sd_bus_creds_get_slice(c, &s);
	443	if (v != -ENODATA)
	444	fprintf(f, "%sSlice=%s%s%s", prefix, color, strna(s), suffix);
	445	s = NULL;
329ac4bc LP	446	q = sd_bus_creds_get_user_unit(c, &s);
	447	if (q != -ENODATA)
	448	fprintf(f, "%sUserUnit=%s%s%s", prefix, color, strna(s), suffix);
	449	s = NULL;
	450	w = sd_bus_creds_get_user_slice(c, &s);
cfeaa44a	451	if (w != -ENODATA)
329ac4bc LP	452	fprintf(f, "%sUserSlice=%s%s%s", prefix, color, strna(s), suffix);
	453	s = NULL;
	454	z = sd_bus_creds_get_session(c, &s);
	455	if (z != -ENODATA)
cfeaa44a LP	456	fprintf(f, "%sSession=%s%s%s", prefix, color, strna(s), suffix);
cfeaa44a LP	457
329ac4bc	458	if (terse && ((c->mask & SD_BUS_CREDS_CGROUP) \|\| r != -ENODATA \|\| q != -ENODATA \|\| v != -ENODATA \|\| w != -ENODATA \|\| z != -ENODATA))
5b12334d LP	459	fputs("\n", f);
5b12334d LP	460
cfeaa44a LP	461	r = sd_bus_creds_get_audit_login_uid(c, &audit_loginuid);
cfeaa44a LP	462	if (r >= 0)
d0b2babf	463	fprintf(f, "%sAuditLoginUID=%s"UID_FMT"%s", prefix, color, audit_loginuid, suffix);
cfeaa44a LP	464	else if (r != -ENODATA)
	465	fprintf(f, "%sAuditLoginUID=%sn/a%s", prefix, color, suffix);
	466	q = sd_bus_creds_get_audit_session_id(c, &audit_sessionid);
	467	if (q >= 0)
d0b2babf	468	fprintf(f, "%sAuditSessionID=%s%"PRIu32"%s", prefix, color, audit_sessionid, suffix);
cfeaa44a LP	469	else if (q != -ENODATA)
cfeaa44a LP	470	fprintf(f, "%sAuditSessionID=%sn/a%s", prefix, color, suffix);
5b12334d	471
cfeaa44a	472	if (terse && (r != -ENODATA \|\| q != -ENODATA))
5b12334d LP	473	fputs("\n", f);
5b12334d LP	474
49b832c5	475	if (c->mask & SD_BUS_CREDS_UNIQUE_NAME)
d0b2babf	476	fprintf(f, "%sUniqueName=%s%s%s", prefix, color, c->unique_name, suffix);
49b832c5 LP	477
	478	if (sd_bus_creds_get_well_known_names(c, &well_known) >= 0) {
	479	char **i;
	480
d0b2babf	481	fprintf(f, "%sWellKnownNames=%s", prefix, color);
49b832c5 LP	482	STRV_FOREACH(i, well_known) {
	483	if (i != well_known)
	484	fputc(' ', f);
	485
	486	fputs(*i, f);
	487	}
	488
d0b2babf	489	fprintf(f, "%s", suffix);
49b832c5 LP	490	}
49b832c5 LP	491
d0b2babf	492	if (terse && (c->mask & SD_BUS_CREDS_UNIQUE_NAME \|\| well_known))
3310dfd5 LP	493	fputc('\n', f);
3310dfd5 LP	494
d0b2babf LP	495	dump_capabilities(c, f, "EffectiveCapabilities", terse, sd_bus_creds_has_effective_cap);
	496	dump_capabilities(c, f, "PermittedCapabilities", terse, sd_bus_creds_has_permitted_cap);
	497	dump_capabilities(c, f, "InheritableCapabilities", terse, sd_bus_creds_has_inheritable_cap);
	498	dump_capabilities(c, f, "BoundingCapabilities", terse, sd_bus_creds_has_bounding_cap);
5b12334d LP	499
	500	return 0;
	501	}
1f70b087 LP	502
	503	/*
	504	* For details about the file format, see:
	505	*
	506	* http://wiki.wireshark.org/Development/LibpcapFileFormat
	507	*/
	508
	509	typedef struct _packed_ pcap_hdr_s {
	510	uint32_t magic_number; /* magic number */
	511	uint16_t version_major; /* major version number */
	512	uint16_t version_minor; /* minor version number */
	513	int32_t thiszone; /* GMT to local correction */
	514	uint32_t sigfigs; /* accuracy of timestamps */
	515	uint32_t snaplen; /* max length of captured packets, in octets */
	516	uint32_t network; /* data link type */
	517	} pcap_hdr_t ;
	518
	519	typedef struct _packed_ pcaprec_hdr_s {
	520	uint32_t ts_sec; /* timestamp seconds */
	521	uint32_t ts_usec; /* timestamp microseconds */
	522	uint32_t incl_len; /* number of octets of packet saved in file */
	523	uint32_t orig_len; /* actual length of packet */
	524	} pcaprec_hdr_t;
	525
	526	int bus_pcap_header(size_t snaplen, FILE *f) {
	527
	528	pcap_hdr_t hdr = {
	529	.magic_number = 0xa1b2c3d4U,
	530	.version_major = 2,
	531	.version_minor = 4,
	532	.thiszone = 0, /* UTC */
	533	.sigfigs = 0,
	534	.network = 231, /* D-Bus */
	535	};
	536
	537	if (!f)
	538	f = stdout;
	539
	540	assert(snaplen > 0);
	541	assert((size_t) (uint32_t) snaplen == snaplen);
	542
	543	hdr.snaplen = (uint32_t) snaplen;
	544
	545	fwrite(&hdr, 1, sizeof(hdr), f);
1f70b087	546
dacd6cee	547	return fflush_and_check(f);
1f70b087 LP	548	}
	549
	550	int bus_message_pcap_frame(sd_bus_message m, size_t snaplen, FILE f) {
	551	struct bus_body_part *part;
	552	pcaprec_hdr_t hdr = {};
	553	struct timeval tv;
	554	unsigned i;
	555	size_t w;
	556
	557	if (!f)
	558	f = stdout;
	559
	560	assert(m);
	561	assert(snaplen > 0);
	562	assert((size_t) (uint32_t) snaplen == snaplen);
	563
	564	if (m->realtime != 0)
	565	timeval_store(&tv, m->realtime);
	566	else
	567	assert_se(gettimeofday(&tv, NULL) >= 0);
	568
	569	hdr.ts_sec = tv.tv_sec;
	570	hdr.ts_usec = tv.tv_usec;
	571	hdr.orig_len = BUS_MESSAGE_SIZE(m);
	572	hdr.incl_len = MIN(hdr.orig_len, snaplen);
	573
	574	/* write the pcap header */
	575	fwrite(&hdr, 1, sizeof(hdr), f);
	576
	577	/* write the dbus header */
	578	w = MIN(BUS_MESSAGE_BODY_BEGIN(m), snaplen);
	579	fwrite(m->header, 1, w, f);
	580	snaplen -= w;
	581
	582	/* write the dbus body */
	583	MESSAGE_FOREACH_PART(part, i, m) {
	584	if (snaplen <= 0)
	585	break;
	586
	587	w = MIN(part->size, snaplen);
	588	fwrite(part->data, 1, w, f);
	589	snaplen -= w;
	590	}
	591
dacd6cee	592	return fflush_and_check(f);
1f70b087	593	}