]>
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 "journal-file.h"
28 int main(int argc
, char *argv
[]) {
32 static const char test
[] = "test", test2
[] = "test2";
36 log_set_max_level(LOG_DEBUG
);
38 unlink("test.journal");
40 assert_se(journal_file_open("test.journal", O_RDWR
|O_CREAT
, 0666, NULL
, &f
) == 0);
42 dual_timestamp_get(&ts
);
44 iovec
.iov_base
= (void*) test
;
45 iovec
.iov_len
= strlen(test
);
46 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
48 iovec
.iov_base
= (void*) test2
;
49 iovec
.iov_len
= strlen(test2
);
50 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
52 iovec
.iov_base
= (void*) test
;
53 iovec
.iov_len
= strlen(test
);
54 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
58 assert(journal_file_next_entry(f
, NULL
, 0, DIRECTION_DOWN
, &o
, &p
) == 1);
59 assert(le64toh(o
->entry
.seqnum
) == 1);
61 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 1);
62 assert(le64toh(o
->entry
.seqnum
) == 2);
64 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 1);
65 assert(le64toh(o
->entry
.seqnum
) == 3);
67 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 0);
69 assert(journal_file_next_entry(f
, NULL
, 0, DIRECTION_DOWN
, &o
, &p
) == 1);
70 assert(le64toh(o
->entry
.seqnum
) == 1);
72 assert(journal_file_skip_entry(f
, o
, p
, 2, &o
, &p
) == 1);
73 assert(le64toh(o
->entry
.seqnum
) == 3);
75 assert(journal_file_skip_entry(f
, o
, p
, -2, &o
, &p
) == 1);
76 assert(le64toh(o
->entry
.seqnum
) == 1);
78 assert(journal_file_skip_entry(f
, o
, p
, -2, &o
, &p
) == 1);
79 assert(le64toh(o
->entry
.seqnum
) == 1);
81 assert(journal_file_find_data_object(f
, test
, strlen(test
), NULL
, &p
) == 1);
82 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_DOWN
, &o
, NULL
) == 1);
83 assert(le64toh(o
->entry
.seqnum
) == 1);
85 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_UP
, &o
, NULL
) == 1);
86 assert(le64toh(o
->entry
.seqnum
) == 3);
88 assert(journal_file_find_data_object(f
, test2
, strlen(test2
), NULL
, &p
) == 1);
89 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_UP
, &o
, NULL
) == 1);
90 assert(le64toh(o
->entry
.seqnum
) == 2);
92 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_DOWN
, &o
, NULL
) == 1);
93 assert(le64toh(o
->entry
.seqnum
) == 2);
95 assert(journal_file_find_data_object(f
, "quux", 4, NULL
, &p
) == 0);
97 assert(journal_file_move_to_entry_by_seqnum(f
, 1, DIRECTION_DOWN
, &o
, NULL
) == 1);
98 assert(le64toh(o
->entry
.seqnum
) == 1);
100 assert(journal_file_move_to_entry_by_seqnum(f
, 3, DIRECTION_DOWN
, &o
, NULL
) == 1);
101 assert(le64toh(o
->entry
.seqnum
) == 3);
103 assert(journal_file_move_to_entry_by_seqnum(f
, 2, DIRECTION_DOWN
, &o
, NULL
) == 1);
104 assert(le64toh(o
->entry
.seqnum
) == 2);
106 assert(journal_file_move_to_entry_by_seqnum(f
, 10, DIRECTION_DOWN
, &o
, NULL
) == 0);
108 journal_file_rotate(&f
);
109 journal_file_rotate(&f
);
111 journal_file_close(f
);
113 journal_directory_vacuum(".", 3000000, 0);