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 <systemd/sd-journal.h>
27 #include "journal-file.h"
28 #include "journal-internal.h"
34 static void verify_contents(sd_journal *j, unsigned skip) {
40 SD_JOURNAL_FOREACH(j) {
46 assert_se(sd_journal_get_cursor(j, &k) >= 0);
47 printf("cursor: %s\n", k);
50 assert_se(sd_journal_get_data(j, "MAGIC", &d, &l) >= 0);
51 printf("\t%.*s\n", (int) l, (const char*) d);
53 assert_se(sd_journal_get_data(j, "NUMBER", &d, &l) >= 0);
54 assert_se(k = strndup(d, l));
58 assert_se(safe_atou(k + 7, &u) >= 0);
67 assert_se(i == N_ENTRIES);
70 int main(int argc, char *argv[]) {
71 JournalFile *one, *two, *three;
72 char t[] = "/tmp/journal-stream-XXXXXX";
77 log_set_max_level(LOG_DEBUG);
79 assert_se(mkdtemp(t));
80 assert_se(chdir(t) >= 0);
82 assert_se(journal_file_open("one.journal", O_RDWR|O_CREAT, 0666, true, false, NULL, NULL, NULL, &one) == 0);
83 assert_se(journal_file_open("two.journal", O_RDWR|O_CREAT, 0666, true, false, NULL, NULL, NULL, &two) == 0);
84 assert_se(journal_file_open("three.journal", O_RDWR|O_CREAT, 0666, true, false, NULL, NULL, NULL, &three) == 0);
86 for (i = 0; i < N_ENTRIES; i++) {
89 struct iovec iovec[2];
91 dual_timestamp_get(&ts);
93 assert_se(asprintf(&p, "NUMBER=%u", i) >= 0);
94 iovec[0].iov_base = p;
95 iovec[0].iov_len = strlen(p);
97 assert_se(asprintf(&q, "MAGIC=%s", i % 5 == 0 ? "quux" : "waldo") >= 0);
99 iovec[1].iov_base = q;
100 iovec[1].iov_len = strlen(q);
103 assert_se(journal_file_append_entry(three, &ts, iovec, 2, NULL, NULL, NULL) == 0);
106 assert_se(journal_file_append_entry(two, &ts, iovec, 2, NULL, NULL, NULL) == 0);
108 assert_se(journal_file_append_entry(one, &ts, iovec, 2, NULL, NULL, NULL) == 0);
115 journal_file_close(one);
116 journal_file_close(two);
117 journal_file_close(three);
119 assert_se(sd_journal_open_directory(&j, t, 0) >= 0);
121 assert_se(sd_journal_add_match(j, "MAGIC=quux", 0) >= 0);
122 SD_JOURNAL_FOREACH_BACKWARDS(j) {
126 assert_se(sd_journal_get_data(j, "NUMBER", &d, &l) >= 0);
127 printf("\t%.*s\n", (int) l, (const char*) d);
130 SD_JOURNAL_FOREACH(j) {
134 assert_se(sd_journal_get_data(j, "NUMBER", &d, &l) >= 0);
135 printf("\t%.*s\n", (int) l, (const char*) d);
138 sd_journal_flush_matches(j);
140 verify_contents(j, 1);
142 printf("NEXT TEST\n");
143 assert_se(sd_journal_add_match(j, "MAGIC=quux", 0) >= 0);
145 assert_se(z = journal_make_match_string(j));
146 printf("resulting match expression is: %s\n", z);
149 verify_contents(j, 5);
151 printf("NEXT TEST\n");
152 sd_journal_flush_matches(j);
153 assert_se(sd_journal_add_match(j, "MAGIC=waldo", 0) >= 0);
154 assert_se(sd_journal_add_match(j, "NUMBER=10", 0) >= 0);
155 assert_se(sd_journal_add_match(j, "NUMBER=11", 0) >= 0);
156 assert_se(sd_journal_add_match(j, "NUMBER=12", 0) >= 0);
158 assert_se(z = journal_make_match_string(j));
159 printf("resulting match expression is: %s\n", z);
162 verify_contents(j, 0);
166 assert_se(rm_rf_dangerous(t, false, true, false) >= 0);