1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
4 This file is part of systemd.
6 Copyright 2012 Lennart Poettering
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU Lesser General Public License as published by
10 the Free Software Foundation; either version 2.1 of the License, or
11 (at your option) any later version.
13 systemd is distributed in the hope that it will be useful, but
14 WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16 Lesser General Public License for more details.
18 You should have received a copy of the GNU Lesser General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
25 #include "sd-journal.h"
27 #include "alloc-util.h"
28 #include "journal-file.h"
29 #include "journal-internal.h"
32 #include "parse-util.h"
38 static void verify_contents(sd_journal
*j
, unsigned skip
) {
44 SD_JOURNAL_FOREACH(j
) {
50 assert_se(sd_journal_get_cursor(j
, &k
) >= 0);
51 printf("cursor: %s\n", k
);
54 assert_se(sd_journal_get_data(j
, "MAGIC", &d
, &l
) >= 0);
55 printf("\t%.*s\n", (int) l
, (const char*) d
);
57 assert_se(sd_journal_get_data(j
, "NUMBER", &d
, &l
) >= 0);
58 assert_se(k
= strndup(d
, l
));
62 assert_se(safe_atou(k
+ 7, &u
) >= 0);
69 assert_se(sd_journal_get_cursor(j
, &c
) >= 0);
70 assert_se(sd_journal_test_cursor(j
, c
) > 0);
75 assert_se(i
== N_ENTRIES
);
78 int main(int argc
, char *argv
[]) {
79 JournalFile
*one
, *two
, *three
;
80 char t
[] = "/tmp/journal-stream-XXXXXX";
82 _cleanup_(sd_journal_closep
) sd_journal
*j
= NULL
;
86 dual_timestamp previous_ts
= DUAL_TIMESTAMP_NULL
;
88 /* journal_file_open requires a valid machine id */
89 if (access("/etc/machine-id", F_OK
) != 0)
90 return EXIT_TEST_SKIP
;
92 log_set_max_level(LOG_DEBUG
);
94 assert_se(mkdtemp(t
));
95 assert_se(chdir(t
) >= 0);
97 assert_se(journal_file_open("one.journal", O_RDWR
|O_CREAT
, 0666, true, false, NULL
, NULL
, NULL
, &one
) == 0);
98 assert_se(journal_file_open("two.journal", O_RDWR
|O_CREAT
, 0666, true, false, NULL
, NULL
, NULL
, &two
) == 0);
99 assert_se(journal_file_open("three.journal", O_RDWR
|O_CREAT
, 0666, true, false, NULL
, NULL
, NULL
, &three
) == 0);
101 for (i
= 0; i
< N_ENTRIES
; i
++) {
104 struct iovec iovec
[2];
106 dual_timestamp_get(&ts
);
108 if (ts
.monotonic
<= previous_ts
.monotonic
)
109 ts
.monotonic
= previous_ts
.monotonic
+ 1;
111 if (ts
.realtime
<= previous_ts
.realtime
)
112 ts
.realtime
= previous_ts
.realtime
+ 1;
116 assert_se(asprintf(&p
, "NUMBER=%u", i
) >= 0);
117 iovec
[0].iov_base
= p
;
118 iovec
[0].iov_len
= strlen(p
);
120 assert_se(asprintf(&q
, "MAGIC=%s", i
% 5 == 0 ? "quux" : "waldo") >= 0);
122 iovec
[1].iov_base
= q
;
123 iovec
[1].iov_len
= strlen(q
);
126 assert_se(journal_file_append_entry(three
, &ts
, iovec
, 2, NULL
, NULL
, NULL
) == 0);
129 assert_se(journal_file_append_entry(two
, &ts
, iovec
, 2, NULL
, NULL
, NULL
) == 0);
131 assert_se(journal_file_append_entry(one
, &ts
, iovec
, 2, NULL
, NULL
, NULL
) == 0);
138 journal_file_close(one
);
139 journal_file_close(two
);
140 journal_file_close(three
);
142 assert_se(sd_journal_open_directory(&j
, t
, 0) >= 0);
144 assert_se(sd_journal_add_match(j
, "MAGIC=quux", 0) >= 0);
145 SD_JOURNAL_FOREACH_BACKWARDS(j
) {
146 _cleanup_free_
char *c
;
148 assert_se(sd_journal_get_data(j
, "NUMBER", &data
, &l
) >= 0);
149 printf("\t%.*s\n", (int) l
, (const char*) data
);
151 assert_se(sd_journal_get_cursor(j
, &c
) >= 0);
152 assert_se(sd_journal_test_cursor(j
, c
) > 0);
155 SD_JOURNAL_FOREACH(j
) {
156 _cleanup_free_
char *c
;
158 assert_se(sd_journal_get_data(j
, "NUMBER", &data
, &l
) >= 0);
159 printf("\t%.*s\n", (int) l
, (const char*) data
);
161 assert_se(sd_journal_get_cursor(j
, &c
) >= 0);
162 assert_se(sd_journal_test_cursor(j
, c
) > 0);
165 sd_journal_flush_matches(j
);
167 verify_contents(j
, 1);
169 printf("NEXT TEST\n");
170 assert_se(sd_journal_add_match(j
, "MAGIC=quux", 0) >= 0);
172 assert_se(z
= journal_make_match_string(j
));
173 printf("resulting match expression is: %s\n", z
);
176 verify_contents(j
, 5);
178 printf("NEXT TEST\n");
179 sd_journal_flush_matches(j
);
180 assert_se(sd_journal_add_match(j
, "MAGIC=waldo", 0) >= 0);
181 assert_se(sd_journal_add_match(j
, "NUMBER=10", 0) >= 0);
182 assert_se(sd_journal_add_match(j
, "NUMBER=11", 0) >= 0);
183 assert_se(sd_journal_add_match(j
, "NUMBER=12", 0) >= 0);
185 assert_se(z
= journal_make_match_string(j
));
186 printf("resulting match expression is: %s\n", z
);
189 verify_contents(j
, 0);
191 assert_se(sd_journal_query_unique(j
, "NUMBER") >= 0);
192 SD_JOURNAL_FOREACH_UNIQUE(j
, data
, l
)
193 printf("%.*s\n", (int) l
, (const char*) data
);
195 assert_se(rm_rf(t
, REMOVE_ROOT
|REMOVE_PHYSICAL
) >= 0);