sd-journal.c revision c2551e7105051f40b2bf77a5c1ecb2e720d78d77
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek/*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek This file is part of systemd.
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek Copyright 2011 Lennart Poettering
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek systemd is free software; you can redistribute it and/or modify it
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek under the terms of the GNU Lesser General Public License as published by
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek the Free Software Foundation; either version 2.1 of the License, or
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek (at your option) any later version.
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek systemd is distributed in the hope that it will be useful, but
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek WITHOUT ANY WARRANTY; without even the implied warranty of
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek Lesser General Public License for more details.
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek You should have received a copy of the GNU Lesser General Public License
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek along with systemd; If not, see <http://www.gnu.org/licenses/>.
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek#define JOURNAL_FILES_RECHECK_USEC (2 * USEC_PER_SEC)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek#define DEFAULT_DATA_THRESHOLD (64*1024)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic void remove_file_real(sd_journal *j, JournalFile *f);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic bool journal_pid_changed(sd_journal *j) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* We don't support people creating a journal object and
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * keeping it around over a fork(). Let's complain. */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return j->original_pid != getpid();
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek/* We return an error here only if we didn't manage to
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek memorize the real error. */
26687bf8a907009dedcff79346860ed41511405eOleksii Shevchukstatic int set_put_error(sd_journal *j, int r) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek k = set_ensure_allocated(&j->errors, NULL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return set_put(j->errors, INT_TO_PTR(r));
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic void detach_location(sd_journal *j) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek ORDERED_HASHMAP_FOREACH(f, j->files, i)
db91ea32aa223d1b087d99811226a9c59a1bb281Zbigniew Jędrzejewski-Szmekstatic void reset_location(sd_journal *j) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic void init_location(Location *l, LocationType type, JournalFile *f, Object *o) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(type == LOCATION_DISCRETE || type == LOCATION_SEEK);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(o->object.type == OBJECT_ENTRY);
670b110c3b59dfa335ac43065b2038400d1d04a9Zbigniew Jędrzejewski-Szmek l->seqnum = le64toh(o->entry.seqnum);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek l->seqnum_id = f->header->seqnum_id;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek l->realtime = le64toh(o->entry.realtime);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek l->monotonic = le64toh(o->entry.monotonic);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek l->xor_hash = le64toh(o->entry.xor_hash);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek l->seqnum_set = l->realtime_set = l->monotonic_set = l->xor_hash_set = true;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic void set_location(sd_journal *j, JournalFile *f, Object *o) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek init_location(&j->current_location, LOCATION_DISCRETE, f, o);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* Let f know its candidate entry was picked. */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(f->location_type == LOCATION_SEEK);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek f->location_type = LOCATION_DISCRETE;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int match_is_valid(const void *data, size_t size) {
db91ea32aa223d1b087d99811226a9c59a1bb281Zbigniew Jędrzejewski-Szmek const char *b, *p;
0371ca0dac1d70b2e5060a3c4e6fbbc2bdbd8671Florian Weimer return false;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek for (p = b; p < b + size; p++) {
348ced909724a1331b85d57aede80a102a00e428Zbigniew Jędrzejewski-Szmekstatic bool same_field(const void *_a, size_t s, const void *_b, size_t t) {
348ced909724a1331b85d57aede80a102a00e428Zbigniew Jędrzejewski-Szmek for (j = 0; j < s && j < t; j++) {
348ced909724a1331b85d57aede80a102a00e428Zbigniew Jędrzejewski-Szmek if (a[j] != b[j])
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (a[j] == '=')
670b110c3b59dfa335ac43065b2038400d1d04a9Zbigniew Jędrzejewski-Szmek assert_not_reached("\"=\" not found");
348ced909724a1331b85d57aede80a102a00e428Zbigniew Jędrzejewski-Szmekstatic Match *match_new(Match *p, MatchType t) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek LIST_PREPEND(matches, p->matches, m);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic void match_free(Match *m) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek LIST_REMOVE(matches, m->parent->matches, m);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic void match_free_if_empty(Match *m) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_add_match(sd_journal *j, const void *data, size_t size) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek Match *l3, *l4, *add_here = NULL, *m;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
23ad4dd8844c582929115a11ed2830a1371568d6Jan Alexander Steffens (heftig) assert_return(match_is_valid(data, size), -EINVAL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* level 0: AND term
23ad4dd8844c582929115a11ed2830a1371568d6Jan Alexander Steffens (heftig) * level 1: OR terms
23ad4dd8844c582929115a11ed2830a1371568d6Jan Alexander Steffens (heftig) * level 2: AND terms
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * level 3: OR terms
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * level 4: concrete matches */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->level0 = match_new(NULL, MATCH_AND_TERM);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->level1 = match_new(j->level0, MATCH_OR_TERM);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->level2 = match_new(j->level1, MATCH_AND_TERM);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(j->level0->type == MATCH_AND_TERM);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(j->level1->type == MATCH_OR_TERM);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(j->level2->type == MATCH_AND_TERM);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek le_hash = htole64(hash64(data, size));
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek LIST_FOREACH(matches, l3, j->level2->matches) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(l3->type == MATCH_OR_TERM);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek LIST_FOREACH(matches, l4, l3->matches) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(l4->type == MATCH_DISCRETE);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* Exactly the same match already? Then ignore
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * this addition */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek memcmp(l4->data, data, size) == 0)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* Same field? Then let's add this to this OR term */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (same_field(data, size, l4->data, l4->size)) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek add_here = match_new(j->level2, MATCH_OR_TERM);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek m = match_new(add_here, MATCH_DISCRETE);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_add_conjunction(sd_journal *j) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
7d73c1343be02a59b17de0cd34375deeb815d89cLennart Poettering_public_ int sd_journal_add_disjunction(sd_journal *j) {
2b98f75a63e6022bf74a7d678c47faa5208c794fZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek k = strjoin(p, m->type == MATCH_OR_TERM ? " OR " : " AND ", t, NULL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekchar *journal_make_match_string(sd_journal *j) {
348ced909724a1331b85d57aede80a102a00e428Zbigniew Jędrzejewski-Szmek return match_make_string(j->level0);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ void sd_journal_flush_matches(sd_journal *j) {
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering j->level0 = j->level1 = j->level2 = NULL;
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering_pure_ static int compare_with_location(JournalFile *af, Object *ao, Location *l) {
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering assert(l->type == LOCATION_DISCRETE || l->type == LOCATION_SEEK);
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering sd_id128_equal(ao->entry.boot_id, l->boot_id) &&
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering le64toh(ao->entry.realtime) == l->realtime &&
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering le64toh(ao->entry.xor_hash) == l->xor_hash)
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering sd_id128_equal(af->header->seqnum_id, l->seqnum_id)) {
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering sd_id128_equal(ao->entry.boot_id, l->boot_id)) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek a = le64toh(ao->entry.realtime);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek a = le64toh(ao->entry.xor_hash);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (m->type == MATCH_DISCRETE) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = journal_file_find_data_object_with_hash(f, m->data, m->size, le64toh(m->le_hash), NULL, &dp);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return journal_file_move_to_entry_by_offset_for_data(f, dp, after_offset, direction, ret, offset);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek } else if (m->type == MATCH_OR_TERM) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* Find the earliest match beyond after_offset */
26687bf8a907009dedcff79346860ed41511405eOleksii Shevchuk r = next_for_match(j, i, f, after_offset, direction, NULL, &cp);
e40ec7aec5e64cd0cfa5fc556d6a9747229b5794Zbigniew Jędrzejewski-Szmek else if (r > 0) {
e40ec7aec5e64cd0cfa5fc556d6a9747229b5794Zbigniew Jędrzejewski-Szmek if (np == 0 || (direction == DIRECTION_DOWN ? cp < np : cp > np))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek } else if (m->type == MATCH_AND_TERM) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* Always jump to the next matching entry and repeat
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * this until we find an offset that matches for all
e40ec7aec5e64cd0cfa5fc556d6a9747229b5794Zbigniew Jędrzejewski-Szmek r = next_for_match(j, m->matches, f, after_offset, direction, NULL, &np);
e40ec7aec5e64cd0cfa5fc556d6a9747229b5794Zbigniew Jędrzejewski-Szmek assert(direction == DIRECTION_DOWN ? np >= after_offset : np <= after_offset);
d07f7b9ef2835c290d6beadebd17d15308608eeaLennart Poettering LIST_LOOP_BUT_ONE(matches, i, m->matches, last_moved) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = next_for_match(j, i, f, np, direction, NULL, &cp);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert(direction == DIRECTION_DOWN ? cp >= np : cp <= np);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (direction == DIRECTION_DOWN ? cp > np : cp < np) {
d378991747d67fff1d4dc39e7fb2bc8f49f1b561Mirco Tischler r = journal_file_move_to_object(f, OBJECT_ENTRY, np, &n);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmekstatic int find_location_for_match(
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (m->type == MATCH_DISCRETE) {
ae018d9bc900d6355dea4af05119b49c67945184Lennart Poettering r = journal_file_find_data_object_with_hash(f, m->data, m->size, le64toh(m->le_hash), NULL, &dp);
c2457105d76e3daf159f554a9bafb9751b23d756Holger Hans Peter Freyther /* FIXME: missing: find by monotonic */
ae018d9bc900d6355dea4af05119b49c67945184Lennart Poettering if (j->current_location.type == LOCATION_HEAD)
c2457105d76e3daf159f554a9bafb9751b23d756Holger Hans Peter Freyther return journal_file_next_entry_for_data(f, NULL, 0, dp, DIRECTION_DOWN, ret, offset);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (j->current_location.type == LOCATION_TAIL)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return journal_file_next_entry_for_data(f, NULL, 0, dp, DIRECTION_UP, ret, offset);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (j->current_location.seqnum_set && sd_id128_equal(j->current_location.seqnum_id, f->header->seqnum_id))
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek return journal_file_move_to_entry_by_seqnum_for_data(f, dp, j->current_location.seqnum, direction, ret, offset);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (j->current_location.monotonic_set) {
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek r = journal_file_move_to_entry_by_monotonic_for_data(f, dp, j->current_location.boot_id, j->current_location.monotonic, direction, ret, offset);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (j->current_location.realtime_set)
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek return journal_file_move_to_entry_by_realtime_for_data(f, dp, j->current_location.realtime, direction, ret, offset);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek return journal_file_next_entry_for_data(f, NULL, 0, dp, direction, ret, offset);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek } else if (m->type == MATCH_OR_TERM) {
3a83211689bdf4ab617a4fb79e11980c50918123Shawn Landden /* Find the earliest match */
3a83211689bdf4ab617a4fb79e11980c50918123Shawn Landden r = find_location_for_match(j, i, f, direction, NULL, &cp);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek else if (r > 0) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (np == 0 || (direction == DIRECTION_DOWN ? np > cp : np < cp))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = journal_file_move_to_object(f, OBJECT_ENTRY, np, &n);
ae018d9bc900d6355dea4af05119b49c67945184Lennart Poettering /* First jump to the last match, and then find the
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * next one where all matches match */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek LIST_FOREACH(matches, i, m->matches) {
ae018d9bc900d6355dea4af05119b49c67945184Lennart Poettering r = find_location_for_match(j, i, f, direction, NULL, &cp);
ae018d9bc900d6355dea4af05119b49c67945184Lennart Poettering if (np == 0 || (direction == DIRECTION_DOWN ? cp > np : cp < np))
19cace379f3f680d3201cd257ab3ca6708b2d45dLennart Poettering return next_for_match(j, m, f, np, direction, ret, offset);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmekstatic int find_location_with_matches(
2d43b190901902dbd98ccea77c1d1ddc9e2a9955Dan McGee /* No matches is simple */
ef1673d16907726d83bdff2e57b5261997a85020Mirco Tischler return journal_file_next_entry(f, 0, DIRECTION_DOWN, ret, offset);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (j->current_location.type == LOCATION_TAIL)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return journal_file_next_entry(f, 0, DIRECTION_UP, ret, offset);
d682b3a7e7c7c2941a4d3e193f1e330dbc9fae89Lennart Poettering if (j->current_location.seqnum_set && sd_id128_equal(j->current_location.seqnum_id, f->header->seqnum_id))
d682b3a7e7c7c2941a4d3e193f1e330dbc9fae89Lennart Poettering return journal_file_move_to_entry_by_seqnum(f, j->current_location.seqnum, direction, ret, offset);
ae018d9bc900d6355dea4af05119b49c67945184Lennart Poettering r = journal_file_move_to_entry_by_monotonic(f, j->current_location.boot_id, j->current_location.monotonic, direction, ret, offset);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return journal_file_move_to_entry_by_realtime(f, j->current_location.realtime, direction, ret, offset);
d682b3a7e7c7c2941a4d3e193f1e330dbc9fae89Lennart Poettering return journal_file_next_entry(f, 0, direction, ret, offset);
d682b3a7e7c7c2941a4d3e193f1e330dbc9fae89Lennart Poettering return find_location_for_match(j, j->level0, f, direction, ret, offset);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek /* No matches is easy. We simple advance the file
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek * pointer by one. */
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek return journal_file_next_entry(f, cp, direction, ret, offset);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek /* If we have a match then we look for the next matching entry
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek * with an offset at least one step larger */
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek return next_for_match(j, j->level0, f, direction == DIRECTION_DOWN ? cp+1 : cp-1, direction, ret, offset);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmekstatic int next_beyond_location(sd_journal *j, JournalFile *f, direction_t direction) {
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek /* If we hit EOF before, recheck if any new entries arrived. */
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek n_entries = le64toh(f->header->n_entries);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek if (f->location_type == LOCATION_TAIL && n_entries == f->last_n_entries)
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek if (f->last_direction == direction && f->current_offset > 0) {
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek /* LOCATION_SEEK here means we did the work in a previous
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek * iteration and the current location already points to a
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek * candidate entry. */
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek if (f->location_type == LOCATION_SEEK)
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek r = next_with_matches(j, f, direction, &c, &cp);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek r = find_location_with_matches(j, f, direction, &c, &cp);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek /* OK, we found the spot, now let's advance until an entry
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek * that is actually different from what we were previously
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek * looking at. This is necessary to handle entries which exist
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek * in two (or more) journal files, and which shall all be
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek * suppressed but one. */
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek if (j->current_location.type == LOCATION_DISCRETE) {
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek k = compare_with_location(f, c, &j->current_location);
968f319679d9069af037240d0c3bcd126181cdacZbigniew Jędrzejewski-Szmek found = direction == DIRECTION_DOWN ? k > 0 : k < 0;
19cace379f3f680d3201cd257ab3ca6708b2d45dLennart Poettering journal_file_save_location(f, direction, c, cp);
19cace379f3f680d3201cd257ab3ca6708b2d45dLennart Poettering r = next_with_matches(j, f, direction, &c, &cp);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int real_journal_next(sd_journal *j, direction_t direction) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek JournalFile *f, *new_file = NULL;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering ORDERED_HASHMAP_FOREACH(f, j->files, i) {
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering r = next_beyond_location(j, f, direction);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug_errno(r, "Can't iterate through %s, ignoring: %m", f->path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek } else if (r == 0) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek f->location_type = LOCATION_TAIL;
82499507b369fea3033a74c22813bf423301aef4Lennart Poettering k = journal_file_compare_locations(f, new_file);
82499507b369fea3033a74c22813bf423301aef4Lennart Poettering found = direction == DIRECTION_DOWN ? k < 0 : k > 0;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = journal_file_move_to_object(new_file, OBJECT_ENTRY, new_file->current_offset, &o);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_next(sd_journal *j) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return real_journal_next(j, DIRECTION_DOWN);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_previous(sd_journal *j) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return real_journal_next(j, DIRECTION_UP);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int real_journal_next_skip(sd_journal *j, direction_t direction, uint64_t skip) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* If this is not a discrete skip, then at least
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * resolve the current location */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (j->current_location.type != LOCATION_DISCRETE)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return real_journal_next(j, direction);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = real_journal_next(j, direction);
7027ff61a34a12487712b382a061c654acc3a679Lennart Poettering } while (skip > 0);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_next_skip(sd_journal *j, uint64_t skip) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return real_journal_next_skip(j, DIRECTION_DOWN, skip);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_previous_skip(sd_journal *j, uint64_t skip) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek return real_journal_next_skip(j, DIRECTION_UP, skip);
2f5df74a5ec135ab2baebf26af6f088e5b4b8205Holger Hans Peter Freyther_public_ int sd_journal_get_cursor(sd_journal *j, char **cursor) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
7027ff61a34a12487712b382a061c654acc3a679Lennart Poettering if (!j->current_file || j->current_file->current_offset <= 0)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = journal_file_move_to_object(j->current_file, OBJECT_ENTRY, j->current_file->current_offset, &o);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek sd_id128_to_string(j->current_file->header->seqnum_id, sid);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek sd_id128_to_string(o->entry.boot_id, bid);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek "s=%s;i=%"PRIx64";b=%s;m=%"PRIx64";t=%"PRIx64";x=%"PRIx64,
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek bid, le64toh(o->entry.monotonic),
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek le64toh(o->entry.xor_hash)) < 0)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_seek_cursor(sd_journal *j, const char *cursor) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek unsigned long long seqnum, monotonic, realtime, xor_hash;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!isempty(cursor), -EINVAL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek FOREACH_WORD_SEPARATOR(word, l, cursor, ";", state) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek k = sd_id128_from_string(item+2, &seqnum_id);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (sscanf(item+2, "%llx", &seqnum) != 1)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek k = sd_id128_from_string(item+2, &boot_id);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (sscanf(item+2, "%llx", &monotonic) != 1)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (sscanf(item+2, "%llx", &xor_hash) != 1)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if ((!seqnum_set || !seqnum_id_set) &&
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek (!monotonic_set || !boot_id_set) &&
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.type = LOCATION_SEEK;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.realtime = (uint64_t) realtime;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.realtime_set = true;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (seqnum_set && seqnum_id_set) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.seqnum = (uint64_t) seqnum;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.seqnum_id = seqnum_id;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.seqnum_set = true;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (monotonic_set && boot_id_set) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.monotonic = (uint64_t) monotonic;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.boot_id = boot_id;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.monotonic_set = true;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.xor_hash = (uint64_t) xor_hash;
670b110c3b59dfa335ac43065b2038400d1d04a9Zbigniew Jędrzejewski-Szmek j->current_location.xor_hash_set = true;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_test_cursor(sd_journal *j, const char *cursor) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!isempty(cursor), -EINVAL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (!j->current_file || j->current_file->current_offset <= 0)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = journal_file_move_to_object(j->current_file, OBJECT_ENTRY, j->current_file->current_offset, &o);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek FOREACH_WORD_SEPARATOR(word, l, cursor, ";", state) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek _cleanup_free_ char *item = NULL;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek unsigned long long ll;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek k = sd_id128_from_string(item+2, &id);
93b73b064c663d6248bebfbbbd82989b5ca10fc5Lennart Poettering if (!sd_id128_equal(id, j->current_file->header->seqnum_id))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (sscanf(item+2, "%llx", &ll) != 1)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (ll != le64toh(o->entry.seqnum))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek k = sd_id128_from_string(item+2, &id);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (!sd_id128_equal(id, o->entry.boot_id))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (sscanf(item+2, "%llx", &ll) != 1)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (ll != le64toh(o->entry.monotonic))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (sscanf(item+2, "%llx", &ll) != 1)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (sscanf(item+2, "%llx", &ll) != 1)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (ll != le64toh(o->entry.xor_hash))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_seek_monotonic_usec(sd_journal *j, sd_id128_t boot_id, uint64_t usec) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
763c7aa288485cf5ab627fe1d25ff58e76f9dacbZbigniew Jędrzejewski-Szmek j->current_location.type = LOCATION_SEEK;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_location.boot_id = boot_id;
fbb634117d0b0ebd5b105e65b141e75ae9af7f8fLennart Poettering j->current_location.monotonic_set = true;
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering_public_ int sd_journal_seek_realtime_usec(sd_journal *j, uint64_t usec) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(!journal_pid_changed(j), -ECHILD);
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering j->current_location.type = LOCATION_SEEK;
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering_public_ int sd_journal_seek_head(sd_journal *j) {
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering assert_return(!journal_pid_changed(j), -ECHILD);
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering j->current_location.type = LOCATION_HEAD;
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering_public_ int sd_journal_seek_tail(sd_journal *j) {
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering assert_return(!journal_pid_changed(j), -ECHILD);
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering j->current_location.type = LOCATION_TAIL;
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poetteringstatic void check_network(sd_journal *j, int fd) {
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering F_TYPE_EQUAL(sfs.f_type, CIFS_MAGIC_NUMBER) ||
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering F_TYPE_EQUAL(sfs.f_type, CODA_SUPER_MAGIC) ||
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek F_TYPE_EQUAL(sfs.f_type, NCP_SUPER_MAGIC) ||
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering F_TYPE_EQUAL(sfs.f_type, NFS_SUPER_MAGIC) ||
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering F_TYPE_EQUAL(sfs.f_type, SMB_SUPER_MAGIC);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic bool file_has_type_prefix(const char *prefix, const char *filename) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek full = strappenda(prefix, ".journal");
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poetteringstatic bool file_type_wanted(int flags, const char *filename) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (!endswith(filename, ".journal") && !endswith(filename, ".journal~"))
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering /* no flags set → every type is OK */
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering if (!(flags & (SD_JOURNAL_SYSTEM | SD_JOURNAL_CURRENT_USER)))
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering if (flags & SD_JOURNAL_SYSTEM && file_has_type_prefix("system", filename))
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering char prefix[5 + DECIMAL_STR_MAX(uid_t) + 1];
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering assert_se(snprintf(prefix, sizeof(prefix), "user-"UID_FMT, getuid())
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering < (int) sizeof(prefix));
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering if (file_has_type_prefix(prefix, filename))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int add_any_file(sd_journal *j, const char *path) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (ordered_hashmap_get(j->files, path))
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering if (ordered_hashmap_size(j->files) >= JOURNAL_FILES_MAX) {
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering log_warning("Too many open journal files, not adding %s.", path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = journal_file_open(path, O_RDONLY, 0, false, false, NULL, j->mmap, NULL, &f);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* journal_file_dump(f); */
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering r = ordered_hashmap_put(j->files, f->path, f);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug("File %s added.", f->path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int add_file(sd_journal *j, const char *prefix, const char *filename) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek !file_type_wanted(j->flags, filename))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek path = strjoin(prefix, "/", filename, NULL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int remove_file(sd_journal *j, const char *prefix, const char *filename) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek path = strjoin(prefix, "/", filename, NULL);
151b9b9662a90455262ce575a8a8ae74bf4ff336Lennart Poetteringstatic void remove_file_real(sd_journal *j, JournalFile *f) {
151b9b9662a90455262ce575a8a8ae74bf4ff336Lennart Poettering ordered_hashmap_remove(j->files, f->path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* Jump to the next unique_file or NULL if that one was last */
74df0fca09b3c31ed19e14ba80f996fdff772417Lennart Poettering j->unique_file = ordered_hashmap_next(j->files, j->unique_file->path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->current_invalidate_counter ++;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int add_directory(sd_journal *j, const char *prefix, const char *dirname) {
db91ea32aa223d1b087d99811226a9c59a1bb281Zbigniew Jędrzejewski-Szmek _cleanup_free_ char *path = NULL;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek _cleanup_closedir_ DIR *d = NULL;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug("Considering %s/%s.", prefix, dirname);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if ((j->flags & SD_JOURNAL_LOCAL_ONLY) &&
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek (sd_id128_from_string(dirname, &id) < 0 ||
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek sd_id128_get_machine(&mid) < 0 ||
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek !(sd_id128_equal(id, mid) || path_startswith(prefix, "/run"))))
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek path = strjoin(prefix, "/", dirname, NULL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug_errno(errno, "Failed to open %s: %m", path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (hashmap_put(j->directories_by_path, m->path, m) < 0) {
e8e581bf256b8c0fbd430935af79fa0e8ee570a1Zbigniew Jędrzejewski-Szmek path = NULL; /* avoid freeing in cleanup */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug("Directory %s added.", m->path);
26687bf8a907009dedcff79346860ed41511405eOleksii Shevchuk m->wd = inotify_add_watch(j->inotify_fd, m->path,
26687bf8a907009dedcff79346860ed41511405eOleksii Shevchuk IN_CREATE|IN_MOVED_TO|IN_MODIFY|IN_ATTRIB|IN_DELETE|
26687bf8a907009dedcff79346860ed41511405eOleksii Shevchuk IN_DELETE_SELF|IN_MOVE_SELF|IN_UNMOUNT|IN_MOVED_FROM|
26687bf8a907009dedcff79346860ed41511405eOleksii Shevchuk if (m->wd > 0 && hashmap_put(j->directories_by_wd, INT_TO_PTR(m->wd), m) < 0)
d07f7b9ef2835c290d6beadebd17d15308608eeaLennart Poettering log_debug_errno(errno, "Failed to read directory %s: %m", m->path);
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering if (dirent_is_file_with_suffix(de, ".journal") ||
ca2670162464b98f44d3f30a1d8b47b02609784cMichał Bartoszkiewicz dirent_is_file_with_suffix(de, ".journal~")) {
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering log_debug_errno(r, "Failed to add file %s/%s: %m",
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poetteringstatic int add_root_directory(sd_journal *j, const char *p) {
26687bf8a907009dedcff79346860ed41511405eOleksii Shevchuk if ((j->flags & SD_JOURNAL_RUNTIME_ONLY) &&
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering m = hashmap_get(j->directories_by_path, p);
151b9b9662a90455262ce575a8a8ae74bf4ff336Lennart Poettering if (hashmap_put(j->directories_by_path, m->path, m) < 0) {
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering log_debug("Root directory %s added.", m->path);
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering } else if (!m->is_root)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek m->wd = inotify_add_watch(j->inotify_fd, m->path,
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek IN_CREATE|IN_MOVED_TO|IN_MODIFY|IN_ATTRIB|IN_DELETE|
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (m->wd > 0 && hashmap_put(j->directories_by_wd, INT_TO_PTR(m->wd), m) < 0)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek inotify_rm_watch(j->inotify_fd, m->wd);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug_errno(errno, "Failed to read directory %s: %m", m->path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (dirent_is_file_with_suffix(de, ".journal") ||
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek dirent_is_file_with_suffix(de, ".journal~")) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = add_file(j, m->path, de->d_name);
d288f79fb4a2fe4a93cf99f74dacd2cebd3f2440Zbigniew Jędrzejewski-Szmek log_debug_errno(r, "Failed to add file %s/%s: %m",
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek } else if ((de->d_type == DT_DIR || de->d_type == DT_LNK || de->d_type == DT_UNKNOWN) &&
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek sd_id128_from_string(de->d_name, &id) >= 0) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = add_directory(j, m->path, de->d_name);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug_errno(r, "Failed to add directory %s/%s: %m", m->path, de->d_name);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int remove_directory(sd_journal *j, Directory *d) {
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering if (d->wd > 0) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek hashmap_remove(j->directories_by_wd, INT_TO_PTR(d->wd));
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek inotify_rm_watch(j->inotify_fd, d->wd);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek hashmap_remove(j->directories_by_path, d->path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug("Root directory %s removed.", d->path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek log_debug("Directory %s removed.", d->path);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int add_search_paths(sd_journal *j) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* We ignore most errors here, since the idea is to only open
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * what's actually accessible, and ignore the rest. */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek NULSTR_FOREACH(p, search_paths) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (r < 0 && r != -ENOENT) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic int add_current_paths(sd_journal *j) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek /* Simply adds all directories for files we have open as
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * "root" directories. We don't expect errors here, so we
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek * treat them as fatal. */
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek ORDERED_HASHMAP_FOREACH(f, j->files, i) {
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poetteringstatic int allocate_inotify(sd_journal *j) {
e9174f29c7e3ee45137537b126458718913a3ec5Lennart Poettering j->inotify_fd = inotify_init1(IN_NONBLOCK|IN_CLOEXEC);
0c24bb2346b6b6232d67aacd5236b56ea4989de4Lennart Poettering j->directories_by_wd = hashmap_new(NULL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmekstatic sd_journal *journal_new(int flags, const char *path) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->data_threshold = DEFAULT_DATA_THRESHOLD;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->files = ordered_hashmap_new(&string_hash_ops);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek j->directories_by_path = hashmap_new(&string_hash_ops);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (!j->files || !j->directories_by_path || !j->mmap)
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_open(sd_journal **ret, int flags) {
f9a810bedacf1da7c505c1786a2416d592665926Lennart Poettering assert_return((flags & ~(SD_JOURNAL_LOCAL_ONLY|SD_JOURNAL_RUNTIME_ONLY|SD_JOURNAL_SYSTEM|SD_JOURNAL_CURRENT_USER)) == 0, -EINVAL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek_public_ int sd_journal_open_container(sd_journal **ret, const char *machine, int flags) {
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek _cleanup_free_ char *root = NULL, *class = NULL;
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return((flags & ~(SD_JOURNAL_LOCAL_ONLY|SD_JOURNAL_SYSTEM)) == 0, -EINVAL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek assert_return(machine_name_is_valid(machine), -EINVAL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek p = strappenda("/run/systemd/machines/", machine);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek r = parse_env_file(p, NEWLINE, "ROOT", &root, "CLASS", &class, NULL);
d025f1e4dca8fc1436aff76f9e6185fe3e728daaZbigniew Jędrzejewski-Szmek if (!streq_ptr(class, "container"))
return -ENOMEM;
r = add_search_paths(j);
goto fail;
*ret = j;
fail:
sd_journal_close(j);
sd_journal *j;
return -ENOMEM;
set_put_error(j, r);
goto fail;
*ret = j;
fail:
sd_journal_close(j);
sd_journal *j;
const char **path;
return -ENOMEM;
goto fail;
j->no_new_files = true;
*ret = j;
fail:
sd_journal_close(j);
Directory *d;
JournalFile *f;
remove_directory(j, d);
remove_directory(j, d);
if (j->mmap) {
log_debug("mmap cache statistics: %u hit, %u miss", mmap_cache_get_hit(j->mmap), mmap_cache_get_missed(j->mmap));
free(j);
Object *o;
JournalFile *f;
f = j->current_file;
return -EADDRNOTAVAIL;
if (f->current_offset <= 0)
return -EADDRNOTAVAIL;
Object *o;
JournalFile *f;
f = j->current_file;
return -EADDRNOTAVAIL;
if (f->current_offset <= 0)
return -EADDRNOTAVAIL;
if (ret_boot_id)
return -ESTALE;
if (ret)
for (p = field; *p; p++) {
_public_ int sd_journal_get_data(sd_journal *j, const char *field, const void **data, size_t *size) {
JournalFile *f;
uint64_t i, n;
Object *o;
f = j->current_file;
return -EADDRNOTAVAIL;
if (f->current_offset <= 0)
return -EADDRNOTAVAIL;
n = journal_file_entry_n_items(o);
uint64_t p, l;
size_t t;
int compression;
return -EBADMSG;
if (compression) {
j->data_threshold);
return -EPROTONOSUPPORT;
t = (size_t) l;
if ((uint64_t) t != l)
return -E2BIG;
*size = t;
return -ENOENT;
size_t t;
uint64_t l;
int compression;
t = (size_t) l;
if ((uint64_t) t != l)
return -E2BIG;
if (compression) {
return -EPROTONOSUPPORT;
*size = t;
JournalFile *f;
uint64_t p, n;
Object *o;
f = j->current_file;
return -EADDRNOTAVAIL;
if (f->current_offset <= 0)
return -EADDRNOTAVAIL;
n = journal_file_entry_n_items(o);
if (j->current_field >= n)
return -EBADMSG;
j->current_field ++;
j->current_field = 0;
if (j->inotify_fd >= 0)
return j->inotify_fd;
r = allocate_inotify(j);
if (j->no_new_files)
r = add_current_paths(j);
else if (j->path)
r = add_search_paths(j);
return j->inotify_fd;
int fd;
if (fd < 0)
return fd;
return POLLIN;
int fd;
if (fd < 0)
return fd;
if (!j->on_network) {
Directory *d;
assert(j);
assert(e);
set_put_error(j, r);
r = remove_directory(j, d);
} else if (d->is_root && (e->mask & IN_ISDIR) && e->len > 0 && sd_id128_from_string(e->name, &id) >= 0) {
assert(j);
bool got_something = false;
struct inotify_event *e;
ssize_t l;
return -errno;
got_something = true;
process_inotify_event(j, e);
uint64_t t;
if (j->inotify_fd < 0) {
r = sd_journal_get_fd(j);
return determine_change(j);
r = sd_journal_get_timeout(j, &t);
usec_t n;
timeout_usec = t;
} while (r == -EINTR);
return sd_journal_process(j);
Iterator i;
JournalFile *f;
bool first = true;
if (r == -ENOENT)
if (first) {
tmax = t;
first = false;
if (from)
if (to)
_public_ int sd_journal_get_cutoff_monotonic_usec(sd_journal *j, sd_id128_t boot_id, uint64_t *from, uint64_t *to) {
Iterator i;
JournalFile *f;
bool found = false;
if (r == -ENOENT)
if (found) {
if (from)
if (to)
if (from)
if (to)
*to = t;
found = true;
return found;
Iterator i;
JournalFile *f;
bool newline = false;
assert(j);
if (newline)
newline = true;
Iterator i;
JournalFile *f;
return -errno;
return -ENOMEM;
j->unique_field = f;
j->unique_offset = 0;
j->unique_file_lost = false;
size_t k;
if (!j->unique_file) {
if (j->unique_file_lost)
if (!j->unique_file)
j->unique_offset = 0;
Iterator i;
Object *o;
const void *odata;
bool found;
if (j->unique_offset == 0) {
if (j->unique_offset == 0) {
if (!j->unique_file)
return -EBADMSG;
if (ol <= k) {
return -EBADMSG;
j->unique_field);
return -EBADMSG;
found = false;
found = true;
if (found)
j->unique_offset = 0;
j->unique_file_lost = false;
return !j->on_network;
const void *data;
assert(j);
const void *data;
if (!cid)
return -ENOMEM;
return -ENOMEM;
*ret = t;