| /systemd-251/src/journal/ |
| D | test-journal-interleaving.c | 51 static void append_number(ManagedJournalFile *f, int n, uint64_t *seqnum) { in append_number() argument
69 assert_ret(journal_file_append_entry(f->file, &ts, NULL, iovec, 1, seqnum, NULL, NULL)); in append_number()
213 uint64_t seqnum = 0; in TEST() local
224 append_number(one, 1, &seqnum); in TEST()
225 printf("seqnum=%"PRIu64"\n", seqnum); in TEST()
226 assert_se(seqnum == 1); in TEST()
227 append_number(one, 2, &seqnum); in TEST()
228 printf("seqnum=%"PRIu64"\n", seqnum); in TEST()
229 assert_se(seqnum == 2); in TEST()
247 append_number(two, 3, &seqnum); in TEST()
[all …]
|
| D | test-journal.c | 62 assert_se(le64toh(o->entry.seqnum) == 1); in TEST()
65 assert_se(le64toh(o->entry.seqnum) == 2); in TEST()
68 assert_se(le64toh(o->entry.seqnum) == 3); in TEST()
74 assert_se(le64toh(o->entry.seqnum) == 1); in TEST()
78 assert_se(le64toh(o->entry.seqnum) == 1); in TEST()
81 assert_se(le64toh(o->entry.seqnum) == 3); in TEST()
85 assert_se(le64toh(o->entry.seqnum) == 2); in TEST()
88 assert_se(le64toh(o->entry.seqnum) == 2); in TEST()
93 assert_se(le64toh(o->entry.seqnum) == 1); in TEST()
96 assert_se(le64toh(o->entry.seqnum) == 3); in TEST()
[all …]
|
| D | journald-server.h | 96 uint64_t seqnum; member
|
| /systemd-251/src/libsystemd/sd-journal/ |
| D | journal-vacuum.c | 29 uint64_t seqnum; member
38 return CMP(a->seqnum, b->seqnum); in vacuum_compare()
145 unsigned long long seqnum = 0, realtime; in journal_directory_vacuum() local
192 … if (sscanf(de->d_name + q-8-16-1-16, "%16llx-%16llx.journal", &seqnum, &realtime) != 2) { in journal_directory_vacuum()
269 .seqnum = seqnum, in journal_directory_vacuum()
|
| D | journal-authenticate.c | 46 o->tag.seqnum = htole64(journal_file_tag_seqnum(f)); in journal_file_append_tag()
50 le64toh(o->tag.seqnum), in journal_file_append_tag()
262 …gcry_md_write(f->hmac, &o->entry.seqnum, le64toh(o->object.size) - offsetof(Object, entry.seqnum)); in journal_file_hmac_put_object()
273 gcry_md_write(f->hmac, &o->tag.seqnum, sizeof(o->tag.seqnum)); in journal_file_hmac_put_object()
|
| D | journal-verify.c | 258 if (le64toh(o->entry.seqnum) <= 0) { in journal_file_object_verify()
261 le64toh(o->entry.seqnum)); in journal_file_object_verify()
1019 le64toh(o->entry.seqnum) != le64toh(f->header->head_entry_seqnum)) { in journal_file_verify()
1022 le64toh(o->entry.seqnum), in journal_file_verify()
1029 entry_seqnum >= le64toh(o->entry.seqnum)) { in journal_file_verify()
1033 le64toh(o->entry.seqnum)); in journal_file_verify()
1038 entry_seqnum = le64toh(o->entry.seqnum); in journal_file_verify()
1114 if (le64toh(o->tag.seqnum) != n_tags + 1) { in journal_file_verify()
1117 le64toh(o->tag.seqnum), in journal_file_verify()
1136 debug(p, "Checking tag %"PRIu64"...", le64toh(o->tag.seqnum)); in journal_file_verify()
|
| D | journal-def.h | 95 le64_t seqnum; \
127 le64_t seqnum; member
|
| D | journal-file.c | 723 if (le64toh(o->entry.seqnum) <= 0) in journal_file_check_object()
726 le64toh(o->entry.seqnum), in journal_file_check_object()
940 uint64_t *seqnum) { in journal_file_entry_seqnum() argument
951 if (seqnum) { in journal_file_entry_seqnum()
955 if (*seqnum + 1 > ret) in journal_file_entry_seqnum()
956 ret = *seqnum + 1; in journal_file_entry_seqnum()
958 *seqnum = ret; in journal_file_entry_seqnum()
1870 uint64_t *seqnum, in journal_file_append_entry_internal() argument
1888 o->entry.seqnum = htole64(journal_file_entry_seqnum(f, seqnum)); in journal_file_append_entry_internal()
2029 uint64_t *seqnum, in journal_file_append_entry() argument
[all …]
|
| D | sd-journal.c | 121 .seqnum = le64toh(o->entry.seqnum), in init_location()
448 f->current_seqnum == l->seqnum && in compare_with_location()
455 r = CMP(f->current_seqnum, l->seqnum); in compare_with_location()
617 … journal_file_move_to_entry_by_seqnum_for_data(f, d, j->current_location.seqnum, direction, ret, o… in find_location_for_match()
712 …return journal_file_move_to_entry_by_seqnum(f, j->current_location.seqnum, direction, ret, offset); in find_location_with_matches()
940 … SD_ID128_TO_STRING(j->current_file->header->seqnum_id), le64toh(o->entry.seqnum), in sd_journal_get_cursor()
950 unsigned long long seqnum, monotonic, realtime, xor_hash; in sd_journal_seek_cursor() local
986 if (sscanf(word + 2, "%llx", &seqnum) != 1) in sd_journal_seek_cursor()
1031 j->current_location.seqnum = (uint64_t) seqnum; in sd_journal_seek_cursor()
1094 if (ll != le64toh(o->entry.seqnum)) in sd_journal_test_cursor()
|
| D | journal-file.h | 221 int journal_file_move_to_entry_by_seqnum(JournalFile *f, uint64_t seqnum, direction_t direction, Ob…
226 int journal_file_move_to_entry_by_seqnum_for_data(JournalFile *f, Object *d, uint64_t seqnum, direc…
|
| D | journal-internal.h | 49 uint64_t seqnum; member
|
| /systemd-251/src/udev/ |
| D | udevd.c | 132 uint64_t seqnum; member
720 …->dev, "Worker ["PID_FMT"] processing SEQNUM=%"PRIu64" killed", event->worker->pid, event->seqnum); in on_event_timeout()
731 …["PID_FMT"] processing SEQNUM=%"PRIu64" is taking a long time", event->worker->pid, event->seqnum); in on_event_timeout_warning()
801 …g(event->dev, "Worker ["PID_FMT"] is forked for processing SEQNUM=%"PRIu64".", pid, event->seqnum); in worker_spawn()
866 assert(event->blocker_seqnum <= event->seqnum); in event_is_blocked()
879 if (event->blocker_seqnum == event->seqnum) in event_is_blocked()
887 if (loop_event->seqnum < event->blocker_seqnum) in event_is_blocked()
891 if (loop_event->seqnum == event->blocker_seqnum) in event_is_blocked()
895 if (loop_event->seqnum >= event->seqnum) in event_is_blocked()
903 assert(loop_event->seqnum > event->blocker_seqnum && in event_is_blocked()
[all …]
|
| /systemd-251/src/shared/ |
| D | loop-util.c | 153 uint64_t seqnum; in loop_configure() local
209 r = get_current_uevent_seqnum(&seqnum); in loop_configure()
272 *ret_seqnum_not_before = seqnum; in loop_configure()
281 r = get_current_uevent_seqnum(&seqnum); in loop_configure()
342 *ret_seqnum_not_before = seqnum; in loop_configure()
404 uint64_t seqnum = UINT64_MAX; in loop_device_make_internal() local
543 … r = loop_configure(loop, nr, &config, &try_loop_configure, &seqnum, ×tamp); in loop_device_make_internal()
616 .uevent_seqnum_not_before = seqnum, in loop_device_make_internal()
|
| D | udev-util.c | 343 uint64_t seqnum = 0; in log_device_uevent() local
348 (void) sd_device_get_seqnum(device, &seqnum); in log_device_uevent()
353 seqnum, strna(device_action_to_string(action)), in log_device_uevent()
|
| /systemd-251/src/journal-remote/ |
| D | journal-remote-write.c | 82 &w->seqnum, NULL, NULL); in writer_write()
100 &w->seqnum, NULL, NULL); in writer_write()
|
| D | journal-remote-write.h | 17 uint64_t seqnum; member
|
| /systemd-251/src/libsystemd/sd-device/ |
| D | device-private.c | 237 uint64_t seqnum; in device_set_seqnum() local
243 r = safe_atou64(str, &seqnum); in device_set_seqnum()
246 if (seqnum == 0) in device_set_seqnum()
253 device->seqnum = seqnum; in device_set_seqnum()
422 if (!device->devpath || !device->subsystem || device->action < 0 || device->seqnum == 0) in device_verify()
|
| D | device-internal.h | 82 uint64_t seqnum; member
|
| /systemd-251/src/libudev/ |
| D | libudev-device.c | 81 uint64_t seqnum; in udev_device_get_seqnum() local
85 if (sd_device_get_seqnum(udev_device->device, &seqnum) < 0) in udev_device_get_seqnum()
88 return seqnum; in udev_device_get_seqnum()
|
| D | libudev-queue.c | 172 …t udev_queue_get_seqnum_is_finished(struct udev_queue *udev_queue, unsigned long long int seqnum) { in udev_queue_get_seqnum_is_finished() argument
|
| D | libudev.h | 162 int udev_queue_get_seqnum_is_finished(struct udev_queue *udev_queue, unsigned long long int seqnum)…
|
| /systemd-251/src/libsystemd/sd-bus/ |
| D | bus-dump.c | 117 if (m->seqnum != 0) in sd_bus_message_dump()
118 fprintf(f, " SequenceNumber=%"PRIu64, m->seqnum); in sd_bus_message_dump()
120 if (m->monotonic != 0 || m->realtime != 0 || m->seqnum != 0) in sd_bus_message_dump()
|
| D | bus-message.h | 78 uint64_t seqnum; member
|
| D | bus-message.c | 1098 _public_ int sd_bus_message_get_seqnum(sd_bus_message *m, uint64_t *seqnum) { in sd_bus_message_get_seqnum() argument
1100 assert_return(seqnum, -EINVAL); in sd_bus_message_get_seqnum()
1102 if (m->seqnum <= 0) in sd_bus_message_get_seqnum()
1105 *seqnum = m->seqnum; in sd_bus_message_get_seqnum()
|
| /systemd-251/docs/ |
| D | JOURNAL_FILE_FORMAT.md | 467 le64_t seqnum;
479 The **seqnum** field contains the sequence number of the entry, **realtime**
586 le64_t seqnum;
597 the epoch that is written into **epoch**. The sequence number **seqnum** is
609 partially protected by the HMAC (i.e. seqnum and epoch is included, the tag
|