X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Fjournal-remote%2Fjournal-remote-parse.c;h=7dd8878ca68780e5953e027c02d1e9790da7954d;hb=6357ac664c9ce8ae5b83bdb98011da24185e4efa;hp=dfb87d49af7f88a17b1de4751f751c088f09afac;hpb=92b10cbccdeef3896f45dc340eb7779c78577ede;p=elogind.git diff --git a/src/journal-remote/journal-remote-parse.c b/src/journal-remote/journal-remote-parse.c index dfb87d49a..7dd8878ca 100644 --- a/src/journal-remote/journal-remote-parse.c +++ b/src/journal-remote/journal-remote-parse.c @@ -330,7 +330,7 @@ int process_data(RemoteSource *source) { assert(line[n-1] == '\n'); if (n == 1) { - log_debug("Received empty line, event is ready"); + log_trace("Received empty line, event is ready"); return 1; } @@ -350,7 +350,7 @@ int process_data(RemoteSource *source) { else /* replace \n with = */ line[n-1] = '='; - log_debug("Received: %.*s", (int) n, line); + log_trace("Received: %.*s", (int) n, line); r = iovw_put(&source->iovw, line, n); if (r < 0) { @@ -367,7 +367,7 @@ int process_data(RemoteSource *source) { assert(source->data_size == 0); r = get_data_size(source); - log_debug("get_data_size() -> %d", r); + // log_debug("get_data_size() -> %d", r); if (r < 0) return r; if (r == 0) { @@ -386,7 +386,7 @@ int process_data(RemoteSource *source) { assert(source->data_size > 0); r = get_data_data(source, &data); - log_debug("get_data_data() -> %d", r); + // log_debug("get_data_data() -> %d", r); if (r < 0) return r; if (r == 0) { @@ -409,7 +409,7 @@ int process_data(RemoteSource *source) { case STATE_DATA_FINISH: r = get_data_newline(source); - log_debug("get_data_newline() -> %d", r); + // log_debug("get_data_newline() -> %d", r); if (r < 0) return r; if (r == 0) { @@ -438,7 +438,7 @@ int process_source(RemoteSource *source, bool compress, bool seal) { return r; /* We have a full event */ - log_debug("Received a full event from source@%p fd:%d (%s)", + log_trace("Received a full event from source@%p fd:%d (%s)", source, source->fd, source->name); if (!source->iovw.count) { @@ -478,7 +478,7 @@ int process_source(RemoteSource *source, bool compress, bool seal) { char *tmp; tmp = realloc(source->buf, target); - if (tmp) + if (!tmp) log_warning("Failed to reallocate buffer to (smaller) size %zu", target); else {