+enum read_status
+fifo_read_one(Fifo *f, struct timespec t, char *buf)
+{
+ char c; /* Character read. */
+ int r; /* Remaining unused slots in buffer range. */
+
+ for (;;) {
+ switch (read(f->fd, &c, 1)) {
+ case -1:
+ error("Failed to read: \"%s\". errno: %d, msg: %s\n",
+ f->name, errno, strerror(errno));
+ switch (errno) {
+ case EINTR:
+ case EAGAIN:
+ return RETRY;
+ default:
+ return FAILURE;
+ }
+ case 0:
+ debug("%s: End of FILE\n", f->name);
+ f->pos_curr = f->pos_init;
+ return END_OF_FILE;
+ case 1:
+ /* TODO: Consider making msg term char a CLI option */
+ if (c == '\n' || c == '\0') {
+ r = f->pos_final - f->pos_curr;
+ if (r > 0)
+ memset(buf + f->pos_curr, ' ', r);
+ f->pos_curr = f->pos_init;
+ f->last_read = t;
+ return END_OF_MESSAGE;
+ } else {
+ if (f->pos_curr <= f->pos_final)
+ buf[f->pos_curr++] = c;
+ /* Drop beyond available range. */
+ }
+ break;
+ default:
+ assert(0);
+ }
+ }