kotovalexarian-likes-github/moby--moby
1
0
Fork 0
mirror of https://github.com/moby/moby.git synced 2022-11-09 12:21:53 -05:00
Code Releases Activity

Improve error reporting when following journals

Browse source 
When we set up to start following a journal, if we get error results
from sd_journal_get_fd() or sd_journal_get_events() that prevent us from
following the journal, report the error instead of just mysteriously
failing.

Signed-off-by: Nalin Dahyabhai <nalin@redhat.com> (github: nalind)
This commit is contained in:
Nalin Dahyabhai 2016-03-17 18:25:14 -04:00
parent 57575a2695
commit 8d597d25a8
1 changed files with 15 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
daemon/logger/journald/read.go
View file

@ -63,11 +63,11 @@ package journald
// fds[0].events = POLLHUP; // fds[0].events = POLLHUP;
// fds[1].fd = sd_journal_get_fd(j); // fds[1].fd = sd_journal_get_fd(j);
// if (fds[1].fd < 0) { // if (fds[1].fd < 0) {
// return -1; // return fds[1].fd;
// } // }
// jevents = sd_journal_get_events(j); // jevents = sd_journal_get_events(j);
// if (jevents < 0) { // if (jevents < 0) {
// return -1; // return jevents;
// } // }
// fds[1].events = jevents; // fds[1].events = jevents;
// sd_journal_get_timeout(j, &when); // sd_journal_get_timeout(j, &when);
@ -81,7 +81,7 @@ package journald
// i = poll(fds, 2, timeout); // i = poll(fds, 2, timeout);
// if ((i == -1) && (errno != EINTR)) { // if ((i == -1) && (errno != EINTR)) {
// /* An unexpected error. */ // /* An unexpected error. */
// return -1; // return (errno != 0) ? -errno : -EINTR;
// } // }
// if (fds[0].revents & POLLHUP) { // if (fds[0].revents & POLLHUP) {
// /* The close notification pipe was closed. */ // /* The close notification pipe was closed. */
@ -101,6 +101,7 @@ import (
"time" "time"
"unsafe" "unsafe"
"github.com/Sirupsen/logrus"
"github.com/coreos/go-systemd/journal" "github.com/coreos/go-systemd/journal"
"github.com/docker/docker/daemon/logger" "github.com/docker/docker/daemon/logger"
) )
@ -177,9 +178,18 @@ func (s *journald) followJournal(logWatcher *logger.LogWatcher, config logger.Re
s.readers.readers[logWatcher] = logWatcher s.readers.readers[logWatcher] = logWatcher
s.readers.mu.Unlock() s.readers.mu.Unlock()
go func() { go func() {
// Keep copying journal data out until we're notified to stop. // Keep copying journal data out until we're notified to stop
for C.wait_for_data_or_close(j, pfd[0]) == 1 { // or we hit an error.
status := C.wait_for_data_or_close(j, pfd[0])
for status == 1 {
cursor = s.drainJournal(logWatcher, config, j, cursor) cursor = s.drainJournal(logWatcher, config, j, cursor)
status = C.wait_for_data_or_close(j, pfd[0])
}
if status < 0 {
cerrstr := C.strerror(C.int(-status))
errstr := C.GoString(cerrstr)
fmtstr := "error %q while attempting to follow journal for container %q"
logrus.Errorf(fmtstr, errstr, s.vars["CONTAINER_ID_FULL"])
} }
// Clean up. // Clean up.
C.close(pfd[0]) C.close(pfd[0])