Searched refs:seqnum (Results 1 - 25 of 27) sorted by relevance

12

/systemd/src/journal/
H A Dtest-journal-interleaving.c63 static void append_number(JournalFile *f, int n, uint64_t *seqnum) { argument
82 assert_ret(journal_file_append_entry(f, &ts, iovec, 1, seqnum, NULL, NULL));
213 uint64_t seqnum = 0; local
222 append_number(one, 1, &seqnum);
223 printf("seqnum=%"PRIu64"\n", seqnum);
224 assert_se(seqnum == 1);
225 append_number(one, 2, &seqnum);
226 printf("seqnum=%"PRIu64"\n", seqnum);
[all...]
H A Dtest-journal.c67 assert_se(le64toh(o->entry.seqnum) == 1);
70 assert_se(le64toh(o->entry.seqnum) == 2);
73 assert_se(le64toh(o->entry.seqnum) == 3);
78 assert_se(le64toh(o->entry.seqnum) == 1);
82 assert_se(le64toh(o->entry.seqnum) == 1);
85 assert_se(le64toh(o->entry.seqnum) == 3);
89 assert_se(le64toh(o->entry.seqnum) == 2);
92 assert_se(le64toh(o->entry.seqnum) == 2);
97 assert_se(le64toh(o->entry.seqnum) == 1);
100 assert_se(le64toh(o->entry.seqnum)
[all...]
H A Djournal-vacuum.c44 uint64_t seqnum; member in struct:vacuum_info
56 if (a->seqnum < b->seqnum)
58 else if (a->seqnum > b->seqnum)
182 unsigned long long seqnum = 0, realtime; local
229 if (sscanf(de->d_name + q-8-16-1-16, "%16llx-%16llx.journal", &seqnum, &realtime) != 2) {
301 list[n_list].seqnum = seqnum;
H A Djournal-authenticate.c60 o->tag.seqnum = htole64(journal_file_tag_seqnum(f));
64 le64toh(o->tag.seqnum),
271 gcry_md_write(f->hmac, &o->entry.seqnum, le64toh(o->object.size) - offsetof(EntryObject, seqnum));
282 gcry_md_write(f->hmac, &o->tag.seqnum, sizeof(o->tag.seqnum));
H A Djournal-def.h107 le64_t seqnum; member in struct:EntryObject
135 le64_t seqnum; member in struct:TagObject
H A Djournal-internal.h67 uint64_t seqnum; member in struct:Location
H A Djournal-file.h212 int journal_file_move_to_entry_by_seqnum(JournalFile *f, uint64_t seqnum, direction_t direction, Object **ret, uint64_t *offset);
217 int journal_file_move_to_entry_by_seqnum_for_data(JournalFile *f, uint64_t data_offset, uint64_t seqnum, direction_t direction, Object **ret, uint64_t *offset);
221 int journal_file_copy_entry(JournalFile *from, JournalFile *to, Object *o, uint64_t p, uint64_t *seqnum, Object **ret, uint64_t *offset);
H A Djournald-server.h82 uint64_t seqnum; member in struct:Server
H A Djournal-verify.c229 if (le64toh(o->entry.seqnum) <= 0) {
231 "Invalid entry seqnum: %"PRIx64,
232 le64toh(o->entry.seqnum));
956 le64toh(o->entry.seqnum) != le64toh(f->header->head_entry_seqnum)) {
963 entry_seqnum >= le64toh(o->entry.seqnum)) {
969 entry_seqnum = le64toh(o->entry.seqnum);
1056 if (le64toh(o->tag.seqnum) != n_tags + 1) {
1072 debug(p, "Checking tag %"PRIu64"...", le64toh(o->tag.seqnum));
1203 error(offsetof(Header, tail_entry_seqnum), "Invalid tail seqnum");
H A Djournal-file.c544 static uint64_t journal_file_entry_seqnum(JournalFile *f, uint64_t *seqnum) { argument
552 if (seqnum) {
553 /* If an external seqnum counter was passed, we update
557 if (*seqnum + 1 > r)
558 r = *seqnum + 1;
560 *seqnum = r;
1347 /* log_debug("=> %s seqnr=%"PRIu64" n_entries=%"PRIu64, f->path, o->entry.seqnum, f->header->n_entries); */
1373 uint64_t *seqnum,
1391 o->entry.seqnum = htole64(journal_file_entry_seqnum(f, seqnum));
1368 journal_file_append_entry_internal( JournalFile *f, const dual_timestamp *ts, uint64_t xor_hash, const EntryItem items[], unsigned n_items, uint64_t *seqnum, Object **ret, uint64_t *offset) argument
1518 journal_file_append_entry(JournalFile *f, const dual_timestamp *ts, const struct iovec iovec[], unsigned n_iovec, uint64_t *seqnum, Object **ret, uint64_t *offset) argument
2032 journal_file_move_to_entry_by_seqnum( JournalFile *f, uint64_t seqnum, direction_t direction, Object **ret, uint64_t *offset) argument
2456 journal_file_move_to_entry_by_seqnum_for_data( JournalFile *f, uint64_t data_offset, uint64_t seqnum, direction_t direction, Object **ret, uint64_t *offset) argument
3012 journal_file_copy_entry(JournalFile *from, JournalFile *to, Object *o, uint64_t p, uint64_t *seqnum, Object **ret, uint64_t *offset) argument
[all...]
H A Dsd-journal.c143 l->seqnum = le64toh(o->entry.seqnum);
468 if (f->current_seqnum < l->seqnum)
470 if (f->current_seqnum > l->seqnum)
622 return journal_file_move_to_entry_by_seqnum_for_data(f, dp, j->current_location.seqnum, direction, ret, offset);
715 return journal_file_move_to_entry_by_seqnum(f, j->current_location.seqnum, direction, ret, offset);
937 sid, le64toh(o->entry.seqnum),
949 unsigned long long seqnum, monotonic, realtime, xor_hash; local
983 if (sscanf(item+2, "%llx", &seqnum) != 1)
1032 j->current_location.seqnum
[all...]
H A Djournald-server.c546 r = journal_file_append_entry(f, NULL, iovec, n, &s->seqnum, NULL, NULL);
565 r = journal_file_append_entry(f, NULL, iovec, n, &s->seqnum, NULL, NULL);
/systemd/src/journal-remote/
H A Djournal-remote-write.h46 uint64_t seqnum; member in struct:Writer
H A Djournal-remote-write.c145 &w->seqnum, NULL, NULL);
161 &w->seqnum, NULL, NULL);
/systemd/src/libsystemd/sd-device/
H A Ddevice-private.c476 uint64_t seqnum = 0; local
508 r = safe_atou64(value, &seqnum);
511 else if (seqnum == 0)
512 /* kernel only sends seqnum > 0 */
530 if (seqnum > 0)
531 *_seqnum = seqnum;
542 static int device_verify(sd_device *device, DeviceAction action, uint64_t seqnum) { argument
545 if (!device->devpath || !device->subsystem || action == _DEVICE_ACTION_INVALID || seqnum == 0) {
546 log_debug("sd-device: device created from strv lacks devpath, subsystem, action or seqnum");
560 uint64_t seqnum; local
596 uint64_t seqnum; local
[all...]
/systemd/src/libudev/
H A Dlibudev-queue.c204 * @seqnum: sequence number
211 _public_ int udev_queue_get_seqnum_is_finished(struct udev_queue *udev_queue, unsigned long long int seqnum) argument
H A Dlibudev-device.c68 const char *seqnum; local
74 r = sd_device_get_property_value(udev_device->device, "SEQNUM", &seqnum);
82 r = safe_atollu(seqnum, &ret);
H A Dlibudev-private.h123 int udev_queue_read_seqnum(FILE *queue_file, unsigned long long int *seqnum);
H A Dlibudev.h176 int udev_queue_get_seqnum_is_finished(struct udev_queue *udev_queue, unsigned long long int seqnum) __attribute__ ((deprecated));
/systemd/src/udev/
H A Dudevd.c119 unsigned long long int seqnum; member in struct:event
609 event->seqnum = udev_device_get_seqnum(dev);
658 if (loop_event->seqnum < event->delaying_seqnum)
662 if (loop_event->seqnum == event->delaying_seqnum)
666 if (loop_event->seqnum >= event->seqnum)
679 event->delaying_seqnum = loop_event->seqnum;
697 event->delaying_seqnum = loop_event->seqnum;
703 event->delaying_seqnum = loop_event->seqnum;
709 event->delaying_seqnum = loop_event->seqnum;
[all...]
/systemd/src/libsystemd/sd-bus/
H A Dbus-dump.c121 if (m->seqnum != 0)
122 fprintf(f, " SequenceNumber=%"PRIu64, m->seqnum);
124 if (m->monotonic != 0 || m->realtime != 0 || m->seqnum != 0)
H A Dbus-message.h87 uint64_t seqnum; member in struct:sd_bus_message
H A Dkdbus.h130 * @seqnum: Global per-domain message sequence number
138 __u64 seqnum; member in struct:kdbus_timestamp
H A Dbus-kernel.c437 m->seqnum = ts->seqnum;
/systemd/src/systemd/
H A Dsd-bus.h248 int sd_bus_message_get_seqnum(sd_bus_message *m, uint64_t* seqnum);

Completed in 160 milliseconds

12