]> git.ipfire.org Git - thirdparty/systemd.git/blob - src/journal/test-journal.c
journal: implement parallel traversal in client
[thirdparty/systemd.git] / src / journal / test-journal.c
1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
2
3 /***
4 This file is part of systemd.
5
6 Copyright 2011 Lennart Poettering
7
8 systemd is free software; you can redistribute it and/or modify it
9 under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 2 of the License, or
11 (at your option) any later version.
12
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 General Public License for more details.
17
18 You should have received a copy of the GNU General Public License
19 along with systemd; If not, see <http://www.gnu.org/licenses/>.
20 ***/
21
22 #include <fcntl.h>
23
24 #include "journal-file.h"
25 #include "log.h"
26
27 int main(int argc, char *argv[]) {
28 dual_timestamp ts;
29 JournalFile *f;
30 struct iovec iovec;
31 static const char test[] = "test", test2[] = "test2";
32 Object *o;
33
34 log_set_max_level(LOG_DEBUG);
35
36 assert_se(journal_file_open("test", O_RDWR|O_CREAT, 0666, &f) == 0);
37
38 dual_timestamp_get(&ts);
39
40 iovec.iov_base = (void*) test;
41 iovec.iov_len = strlen(test);
42 assert_se(journal_file_append_entry(f, &ts, &iovec, 1, NULL, NULL) == 0);
43
44 iovec.iov_base = (void*) test2;
45 iovec.iov_len = strlen(test2);
46 assert_se(journal_file_append_entry(f, &ts, &iovec, 1, NULL, NULL) == 0);
47
48 iovec.iov_base = (void*) test;
49 iovec.iov_len = strlen(test);
50 assert_se(journal_file_append_entry(f, &ts, &iovec, 1, NULL, NULL) == 0);
51
52 journal_file_dump(f);
53
54 assert(journal_file_next_entry(f, NULL, &o, NULL) == 1);
55 assert(le64toh(o->entry.seqnum) == 1);
56
57 assert(journal_file_next_entry(f, o, &o, NULL) == 1);
58 assert(le64toh(o->entry.seqnum) == 2);
59
60 assert(journal_file_next_entry(f, o, &o, NULL) == 1);
61 assert(le64toh(o->entry.seqnum) == 3);
62
63 assert(journal_file_next_entry(f, o, &o, NULL) == 0);
64
65 assert(journal_file_find_first_entry(f, test, strlen(test), &o, NULL) == 1);
66 assert(le64toh(o->entry.seqnum) == 1);
67
68 assert(journal_file_find_last_entry(f, test, strlen(test), &o, NULL) == 1);
69 assert(le64toh(o->entry.seqnum) == 3);
70
71 assert(journal_file_find_last_entry(f, test2, strlen(test2), &o, NULL) == 1);
72 assert(le64toh(o->entry.seqnum) == 2);
73
74 assert(journal_file_find_first_entry(f, test2, strlen(test2), &o, NULL) == 1);
75 assert(le64toh(o->entry.seqnum) == 2);
76
77 assert(journal_file_find_first_entry(f, "quux", 4, &o, NULL) == 0);
78
79 assert(journal_file_move_to_entry(f, 1, &o, NULL) == 1);
80 assert(le64toh(o->entry.seqnum) == 1);
81
82 assert(journal_file_move_to_entry(f, 3, &o, NULL) == 1);
83 assert(le64toh(o->entry.seqnum) == 3);
84
85 assert(journal_file_move_to_entry(f, 2, &o, NULL) == 1);
86 assert(le64toh(o->entry.seqnum) == 2);
87
88 assert(journal_file_move_to_entry(f, 10, &o, NULL) == 0);
89
90 journal_file_close(f);
91
92 return 0;
93 }