read.c

bool babeld_handle_in(struct context *ctx, int fd) {
  size_t old_len = ctx->babeld_buffer == NULL ? 0 : strlen(ctx->babeld_buffer);
  size_t new_len = old_len + CHUNKSIZE + 1;

  ctx->babeld_buffer = realloc(ctx->babeld_buffer, new_len);

  if (ctx->babeld_buffer == NULL)
    exit_errno("Cannot allocate buffer");

  ssize_t len = read(fd, ctx->babeld_buffer + old_len, CHUNKSIZE);

  if (len == 0)
    return false;

  if (len == -1 && errno == EAGAIN)
    return true;

  ctx->babeld_buffer[old_len + len] = 0;

  char *stringp, *line;

  while (1) {
    stringp = ctx->babeld_buffer;
    line = strsep(&stringp, "\n");

    if (stringp == NULL)
      break; // no line found

    babeld_parse_line(ctx, line);
    memmove(ctx->babeld_buffer, stringp, strlen(stringp) + 1);
    ctx->babeld_buffer = realloc(ctx->babeld_buffer, strlen(ctx->babeld_buffer) + 1);
  }

  return true;
}