X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~mdw/git/disorder/blobdiff_plain/132a5a4a47f9dbc7c52ee15234d70258c59ccf8e..16b0fea8ae1a581d568dbee2efa2932aa4e6fcce:/lib/logfd.c diff --git a/lib/logfd.c b/lib/logfd.c index a6f14c3..7175108 100644 --- a/lib/logfd.c +++ b/lib/logfd.c @@ -29,7 +29,7 @@ #include "event.h" #include "log.h" -/* called when bytes are available and at eof */ +/** @brief Called when a log FD is readable */ static int logfd_readable(ev_source attribute((unused)) *ev, ev_reader *reader, void *ptr, @@ -43,24 +43,24 @@ static int logfd_readable(ev_source attribute((unused)) *ev, while((nl = memchr(ptr, '\n', bytes))) { len = nl - (char *)ptr; ev_reader_consume(reader, len + 1); - info("%s: %.*s", tag, len, (char *)ptr); + disorder_info("%s: %.*s", tag, len, (char *)ptr); ptr = nl + 1; bytes -= len + 1; } if(eof && bytes) { - info("%s: %.*s", tag, (int)bytes, (char *)ptr); + disorder_info("%s: %.*s", tag, (int)bytes, (char *)ptr); ev_reader_consume(reader, bytes); } return 0; } -/* called when a read error occurs */ +/** @brief Called when a log FD errors */ static int logfd_error(ev_source attribute((unused)) *ev, int errno_value, void *u) { const char *tag = u; - error(errno_value, "error reading log pipe from %s", tag); + disorder_error(errno_value, "error reading log pipe from %s", tag); return 0; } @@ -74,7 +74,7 @@ static int logfd_error(ev_source attribute((unused)) *ev, * it in the parent). * * Any lines written to this fd (i.e. by the subprocess) will be logged via - * info(), with @p tag included. + * disorder_info(), with @p tag included. */ int logfd(ev_source *ev, const char *tag) { int p[2]; @@ -84,7 +84,7 @@ int logfd(ev_source *ev, const char *tag) { nonblock(p[0]); if(!ev_reader_new(ev, p[0], logfd_readable, logfd_error, (void *)tag, "logfd")) - fatal(errno, "error calling ev_reader_new"); + disorder_fatal(errno, "error calling ev_reader_new"); return p[1]; }