diff options
Diffstat (limited to 'src/libsystemd-bus')
-rw-r--r-- | src/libsystemd-bus/bus-kernel.c | 5 | ||||
-rw-r--r-- | src/libsystemd-bus/bus-message.c | 13 | ||||
-rw-r--r-- | src/libsystemd-bus/bus-message.h | 1 |
3 files changed, 19 insertions, 0 deletions
diff --git a/src/libsystemd-bus/bus-kernel.c b/src/libsystemd-bus/bus-kernel.c index 3d26f16cda..1b2297fbb4 100644 --- a/src/libsystemd-bus/bus-kernel.c +++ b/src/libsystemd-bus/bus-kernel.c @@ -225,6 +225,7 @@ static int bus_kernel_make_message(sd_bus *bus, struct kdbus_msg *k, sd_bus_mess struct bus_header *h = NULL; size_t total, n_bytes = 0, idx = 0; struct kdbus_creds *creds = NULL; + uint64_t nsec = 0; int r; assert(bus); @@ -266,6 +267,8 @@ static int bus_kernel_make_message(sd_bus *bus, struct kdbus_msg *k, sd_bus_mess } else if (d->type == KDBUS_MSG_SRC_CREDS) creds = &d->creds; + else if (d->type == KDBUS_MSG_TIMESTAMP) + nsec = d->ts_ns; } if (!h) @@ -313,6 +316,8 @@ static int bus_kernel_make_message(sd_bus *bus, struct kdbus_msg *k, sd_bus_mess m->uid_valid = m->gid_valid = true; } + m->timestamp = nsec / NSEC_PER_USEC; + r = bus_message_parse_fields(m); if (r < 0) { sd_bus_message_unref(m); diff --git a/src/libsystemd-bus/bus-message.c b/src/libsystemd-bus/bus-message.c index aac49f486e..467b519039 100644 --- a/src/libsystemd-bus/bus-message.c +++ b/src/libsystemd-bus/bus-message.c @@ -709,6 +709,17 @@ const char *sd_bus_message_get_label(sd_bus_message *m) { return m->label; } +int sd_bus_message_get_timestamp(sd_bus_message *m, uint64_t *usec) { + if (!m) + return -EINVAL; + + if (m->timestamp <= 0) + return -ENOENT; + + *usec = m->timestamp; + return 0; +} + int sd_bus_message_is_signal(sd_bus_message *m, const char *interface, const char *member) { if (!m) return -EINVAL; @@ -2922,6 +2933,8 @@ int bus_message_dump(sd_bus_message *m) { printf("\tgid=%lu\n", (unsigned long) m->gid); if (m->pid_starttime != 0) printf("\tpid_starttime=%llu\n", (unsigned long long) m->pid_starttime); + if (m->timestamp) + printf("\ttimestamp=%llu\n", (unsigned long long) m->timestamp); r = sd_bus_message_rewind(m, true); if (r < 0) { diff --git a/src/libsystemd-bus/bus-message.h b/src/libsystemd-bus/bus-message.h index 079a188787..c501325b12 100644 --- a/src/libsystemd-bus/bus-message.h +++ b/src/libsystemd-bus/bus-message.h @@ -68,6 +68,7 @@ struct sd_bus_message { pid_t pid; pid_t tid; usec_t pid_starttime; + usec_t timestamp; bool sealed:1; bool dont_send:1; |