]>
git.ipfire.org Git - thirdparty/systemd.git/blob - src/journal/test-journal.c
1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
4 This file is part of systemd.
6 Copyright 2011 Lennart Poettering
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.
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.
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/>.
25 #include "sd-journal.h"
26 #include "journal-file.h"
29 int main(int argc
, char *argv
[]) {
33 static const char test
[] = "test", test2
[] = "test2";
37 log_set_max_level(LOG_DEBUG
);
39 unlink("test.journal");
41 assert_se(journal_file_open("test.journal", O_RDWR
|O_CREAT
, 0666, NULL
, &f
) == 0);
43 dual_timestamp_get(&ts
);
45 iovec
.iov_base
= (void*) test
;
46 iovec
.iov_len
= strlen(test
);
47 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
49 iovec
.iov_base
= (void*) test2
;
50 iovec
.iov_len
= strlen(test2
);
51 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
53 iovec
.iov_base
= (void*) test
;
54 iovec
.iov_len
= strlen(test
);
55 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
59 assert(journal_file_next_entry(f
, NULL
, 0, DIRECTION_DOWN
, &o
, &p
) == 1);
60 assert(le64toh(o
->entry
.seqnum
) == 1);
62 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 1);
63 assert(le64toh(o
->entry
.seqnum
) == 2);
65 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 1);
66 assert(le64toh(o
->entry
.seqnum
) == 3);
68 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 0);
70 assert(journal_file_next_entry(f
, NULL
, 0, DIRECTION_DOWN
, &o
, &p
) == 1);
71 assert(le64toh(o
->entry
.seqnum
) == 1);
73 assert(journal_file_skip_entry(f
, o
, p
, 2, &o
, &p
) == 1);
74 assert(le64toh(o
->entry
.seqnum
) == 3);
76 assert(journal_file_skip_entry(f
, o
, p
, -2, &o
, &p
) == 1);
77 assert(le64toh(o
->entry
.seqnum
) == 1);
79 assert(journal_file_skip_entry(f
, o
, p
, -2, &o
, &p
) == 1);
80 assert(le64toh(o
->entry
.seqnum
) == 1);
82 assert(journal_file_find_data_object(f
, test
, strlen(test
), NULL
, &p
) == 1);
83 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_DOWN
, &o
, NULL
) == 1);
84 assert(le64toh(o
->entry
.seqnum
) == 1);
86 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_UP
, &o
, NULL
) == 1);
87 assert(le64toh(o
->entry
.seqnum
) == 3);
89 assert(journal_file_find_data_object(f
, test2
, strlen(test2
), NULL
, &p
) == 1);
90 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_UP
, &o
, NULL
) == 1);
91 assert(le64toh(o
->entry
.seqnum
) == 2);
93 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_DOWN
, &o
, NULL
) == 1);
94 assert(le64toh(o
->entry
.seqnum
) == 2);
96 assert(journal_file_find_data_object(f
, "quux", 4, NULL
, &p
) == 0);
98 assert(journal_file_move_to_entry_by_seqnum(f
, 1, DIRECTION_DOWN
, &o
, NULL
) == 1);
99 assert(le64toh(o
->entry
.seqnum
) == 1);
101 assert(journal_file_move_to_entry_by_seqnum(f
, 3, DIRECTION_DOWN
, &o
, NULL
) == 1);
102 assert(le64toh(o
->entry
.seqnum
) == 3);
104 assert(journal_file_move_to_entry_by_seqnum(f
, 2, DIRECTION_DOWN
, &o
, NULL
) == 1);
105 assert(le64toh(o
->entry
.seqnum
) == 2);
107 assert(journal_file_move_to_entry_by_seqnum(f
, 10, DIRECTION_DOWN
, &o
, NULL
) == 0);
109 journal_file_rotate(&f
);
110 journal_file_rotate(&f
);
112 journal_file_close(f
);
114 journal_directory_vacuum(".", 3000000, 0);
116 log_error("Exiting...");