#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,
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;
}
* 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];
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];
}