]>
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 <systemd/sd-journal.h>
27 #include "journal-file.h"
30 int main(int argc
, char *argv
[]) {
34 static const char test
[] = "test", test2
[] = "test2";
38 log_set_max_level(LOG_DEBUG
);
40 unlink("test.journal");
42 assert_se(journal_file_open("test.journal", O_RDWR
|O_CREAT
, 0666, NULL
, &f
) == 0);
44 dual_timestamp_get(&ts
);
46 iovec
.iov_base
= (void*) test
;
47 iovec
.iov_len
= strlen(test
);
48 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
50 iovec
.iov_base
= (void*) test2
;
51 iovec
.iov_len
= strlen(test2
);
52 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
54 iovec
.iov_base
= (void*) test
;
55 iovec
.iov_len
= strlen(test
);
56 assert_se(journal_file_append_entry(f
, &ts
, &iovec
, 1, NULL
, NULL
, NULL
) == 0);
60 assert(journal_file_next_entry(f
, NULL
, 0, DIRECTION_DOWN
, &o
, &p
) == 1);
61 assert(le64toh(o
->entry
.seqnum
) == 1);
63 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 1);
64 assert(le64toh(o
->entry
.seqnum
) == 2);
66 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 1);
67 assert(le64toh(o
->entry
.seqnum
) == 3);
69 assert(journal_file_next_entry(f
, o
, p
, DIRECTION_DOWN
, &o
, &p
) == 0);
71 assert(journal_file_next_entry(f
, NULL
, 0, DIRECTION_DOWN
, &o
, &p
) == 1);
72 assert(le64toh(o
->entry
.seqnum
) == 1);
74 assert(journal_file_skip_entry(f
, o
, p
, 2, &o
, &p
) == 1);
75 assert(le64toh(o
->entry
.seqnum
) == 3);
77 assert(journal_file_skip_entry(f
, o
, p
, -2, &o
, &p
) == 1);
78 assert(le64toh(o
->entry
.seqnum
) == 1);
80 assert(journal_file_skip_entry(f
, o
, p
, -2, &o
, &p
) == 1);
81 assert(le64toh(o
->entry
.seqnum
) == 1);
83 assert(journal_file_find_data_object(f
, test
, strlen(test
), NULL
, &p
) == 1);
84 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_DOWN
, &o
, NULL
) == 1);
85 assert(le64toh(o
->entry
.seqnum
) == 1);
87 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_UP
, &o
, NULL
) == 1);
88 assert(le64toh(o
->entry
.seqnum
) == 3);
90 assert(journal_file_find_data_object(f
, test2
, strlen(test2
), NULL
, &p
) == 1);
91 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_UP
, &o
, NULL
) == 1);
92 assert(le64toh(o
->entry
.seqnum
) == 2);
94 assert(journal_file_next_entry_for_data(f
, NULL
, 0, p
, DIRECTION_DOWN
, &o
, NULL
) == 1);
95 assert(le64toh(o
->entry
.seqnum
) == 2);
97 assert(journal_file_find_data_object(f
, "quux", 4, NULL
, &p
) == 0);
99 assert(journal_file_move_to_entry_by_seqnum(f
, 1, DIRECTION_DOWN
, &o
, NULL
) == 1);
100 assert(le64toh(o
->entry
.seqnum
) == 1);
102 assert(journal_file_move_to_entry_by_seqnum(f
, 3, DIRECTION_DOWN
, &o
, NULL
) == 1);
103 assert(le64toh(o
->entry
.seqnum
) == 3);
105 assert(journal_file_move_to_entry_by_seqnum(f
, 2, DIRECTION_DOWN
, &o
, NULL
) == 1);
106 assert(le64toh(o
->entry
.seqnum
) == 2);
108 assert(journal_file_move_to_entry_by_seqnum(f
, 10, DIRECTION_DOWN
, &o
, NULL
) == 0);
110 journal_file_rotate(&f
);
111 journal_file_rotate(&f
);
113 journal_file_close(f
);
115 journal_directory_vacuum(".", 3000000, 0);
117 log_error("Exiting...");