1 /* SPDX-License-Identifier: LGPL-2.1+ */
3 Copyright © 2013 Marius Vollmer
9 #include "sd-journal.h"
11 #include "alloc-util.h"
12 #include "journal-file.h"
13 #include "journal-vacuum.h"
15 #include "parse-util.h"
20 /* This program tests skipping around in a multi-file journal. */
22 static bool arg_keep
= false;
24 _noreturn_
static void log_assert_errno(const char *text
, int error
, const char *file
, int line
, const char *func
) {
25 log_internal(LOG_CRIT
, error
, file
, line
, func
,
26 "'%s' failed at %s:%u (%s): %m", text
, file
, line
, func
);
30 #define assert_ret(expr) \
33 if (_unlikely_(_r_ < 0)) \
34 log_assert_errno(#expr, -_r_, __FILE__, __LINE__, __PRETTY_FUNCTION__); \
37 static JournalFile
*test_open(const char *name
) {
39 assert_ret(journal_file_open(-1, name
, O_RDWR
|O_CREAT
, 0644, true, (uint64_t) -1, false, NULL
, NULL
, NULL
, NULL
, &f
));
43 static void test_close(JournalFile
*f
) {
44 (void) journal_file_close (f
);
47 static void append_number(JournalFile
*f
, int n
, uint64_t *seqnum
) {
50 static dual_timestamp previous_ts
= {};
51 struct iovec iovec
[1];
53 dual_timestamp_get(&ts
);
55 if (ts
.monotonic
<= previous_ts
.monotonic
)
56 ts
.monotonic
= previous_ts
.monotonic
+ 1;
58 if (ts
.realtime
<= previous_ts
.realtime
)
59 ts
.realtime
= previous_ts
.realtime
+ 1;
63 assert_se(asprintf(&p
, "NUMBER=%d", n
) >= 0);
64 iovec
[0].iov_base
= p
;
65 iovec
[0].iov_len
= strlen(p
);
66 assert_ret(journal_file_append_entry(f
, &ts
, NULL
, iovec
, 1, seqnum
, NULL
, NULL
));
70 static void test_check_number (sd_journal
*j
, int n
) {
72 _cleanup_free_
char *k
;
76 assert_ret(sd_journal_get_data(j
, "NUMBER", &d
, &l
));
77 assert_se(k
= strndup(d
, l
));
80 assert_se(safe_atoi(k
+ 7, &x
) >= 0);
84 static void test_check_numbers_down (sd_journal
*j
, int count
) {
87 for (i
= 1; i
<= count
; i
++) {
89 test_check_number(j
, i
);
90 assert_ret(r
= sd_journal_next(j
));
99 static void test_check_numbers_up (sd_journal
*j
, int count
) {
100 for (int i
= count
; i
>= 1; i
--) {
102 test_check_number(j
, i
);
103 assert_ret(r
= sd_journal_previous(j
));
112 static void setup_sequential(void) {
113 JournalFile
*one
, *two
;
114 one
= test_open("one.journal");
115 two
= test_open("two.journal");
116 append_number(one
, 1, NULL
);
117 append_number(one
, 2, NULL
);
118 append_number(two
, 3, NULL
);
119 append_number(two
, 4, NULL
);
124 static void setup_interleaved(void) {
125 JournalFile
*one
, *two
;
126 one
= test_open("one.journal");
127 two
= test_open("two.journal");
128 append_number(one
, 1, NULL
);
129 append_number(two
, 2, NULL
);
130 append_number(one
, 3, NULL
);
131 append_number(two
, 4, NULL
);
136 static void test_skip(void (*setup
)(void)) {
137 char t
[] = "/tmp/journal-skip-XXXXXX";
141 assert_se(mkdtemp(t
));
142 assert_se(chdir(t
) >= 0);
146 /* Seek to head, iterate down.
148 assert_ret(sd_journal_open_directory(&j
, t
, 0));
149 assert_ret(sd_journal_seek_head(j
));
150 assert_ret(sd_journal_next(j
));
151 test_check_numbers_down(j
, 4);
154 /* Seek to tail, iterate up.
156 assert_ret(sd_journal_open_directory(&j
, t
, 0));
157 assert_ret(sd_journal_seek_tail(j
));
158 assert_ret(sd_journal_previous(j
));
159 test_check_numbers_up(j
, 4);
162 /* Seek to tail, skip to head, iterate down.
164 assert_ret(sd_journal_open_directory(&j
, t
, 0));
165 assert_ret(sd_journal_seek_tail(j
));
166 assert_ret(r
= sd_journal_previous_skip(j
, 4));
168 test_check_numbers_down(j
, 4);
171 /* Seek to head, skip to tail, iterate up.
173 assert_ret(sd_journal_open_directory(&j
, t
, 0));
174 assert_ret(sd_journal_seek_head(j
));
175 assert_ret(r
= sd_journal_next_skip(j
, 4));
177 test_check_numbers_up(j
, 4);
183 log_info("Not removing %s", t
);
185 journal_directory_vacuum(".", 3000000, 0, 0, NULL
, true);
187 assert_se(rm_rf(t
, REMOVE_ROOT
|REMOVE_PHYSICAL
) >= 0);
190 puts("------------------------------------------------------------");
193 static void test_sequence_numbers(void) {
195 char t
[] = "/tmp/journal-seq-XXXXXX";
196 JournalFile
*one
, *two
;
198 sd_id128_t seqnum_id
;
200 assert_se(mkdtemp(t
));
201 assert_se(chdir(t
) >= 0);
203 assert_se(journal_file_open(-1, "one.journal", O_RDWR
|O_CREAT
, 0644,
204 true, (uint64_t) -1, false, NULL
, NULL
, NULL
, NULL
, &one
) == 0);
206 append_number(one
, 1, &seqnum
);
207 printf("seqnum=%"PRIu64
"\n", seqnum
);
208 assert_se(seqnum
== 1);
209 append_number(one
, 2, &seqnum
);
210 printf("seqnum=%"PRIu64
"\n", seqnum
);
211 assert_se(seqnum
== 2);
213 assert_se(one
->header
->state
== STATE_ONLINE
);
214 assert_se(!sd_id128_equal(one
->header
->file_id
, one
->header
->machine_id
));
215 assert_se(!sd_id128_equal(one
->header
->file_id
, one
->header
->boot_id
));
216 assert_se(sd_id128_equal(one
->header
->file_id
, one
->header
->seqnum_id
));
218 memcpy(&seqnum_id
, &one
->header
->seqnum_id
, sizeof(sd_id128_t
));
220 assert_se(journal_file_open(-1, "two.journal", O_RDWR
|O_CREAT
, 0644,
221 true, (uint64_t) -1, false, NULL
, NULL
, NULL
, one
, &two
) == 0);
223 assert_se(two
->header
->state
== STATE_ONLINE
);
224 assert_se(!sd_id128_equal(two
->header
->file_id
, one
->header
->file_id
));
225 assert_se(sd_id128_equal(one
->header
->machine_id
, one
->header
->machine_id
));
226 assert_se(sd_id128_equal(one
->header
->boot_id
, one
->header
->boot_id
));
227 assert_se(sd_id128_equal(one
->header
->seqnum_id
, one
->header
->seqnum_id
));
229 append_number(two
, 3, &seqnum
);
230 printf("seqnum=%"PRIu64
"\n", seqnum
);
231 assert_se(seqnum
== 3);
232 append_number(two
, 4, &seqnum
);
233 printf("seqnum=%"PRIu64
"\n", seqnum
);
234 assert_se(seqnum
== 4);
238 append_number(one
, 5, &seqnum
);
239 printf("seqnum=%"PRIu64
"\n", seqnum
);
240 assert_se(seqnum
== 5);
242 append_number(one
, 6, &seqnum
);
243 printf("seqnum=%"PRIu64
"\n", seqnum
);
244 assert_se(seqnum
== 6);
251 assert_se(journal_file_open(-1, "two.journal", O_RDWR
, 0,
252 true, (uint64_t) -1, false, NULL
, NULL
, NULL
, NULL
, &two
) == 0);
254 assert_se(sd_id128_equal(two
->header
->seqnum_id
, seqnum_id
));
256 append_number(two
, 7, &seqnum
);
257 printf("seqnum=%"PRIu64
"\n", seqnum
);
258 assert_se(seqnum
== 5);
260 /* So..., here we have the same seqnum in two files with the
268 log_info("Not removing %s", t
);
270 journal_directory_vacuum(".", 3000000, 0, 0, NULL
, true);
272 assert_se(rm_rf(t
, REMOVE_ROOT
|REMOVE_PHYSICAL
) >= 0);
276 int main(int argc
, char *argv
[]) {
277 test_setup_logging(LOG_DEBUG
);
279 /* journal_file_open requires a valid machine id */
280 if (access("/etc/machine-id", F_OK
) != 0)
281 return log_tests_skipped("/etc/machine-id not found");
285 test_skip(setup_sequential
);
286 test_skip(setup_interleaved
);
288 test_sequence_numbers();