/* Copyright 2021 The ChromiumOS Authors
 * Use of this source code is governed by a BSD-style license that can be
 * found in the LICENSE file.
 */

#include "test_util.h"

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include "util.h"

#define MAX_PIPE_CAPACITY (4096)

FILE *write_to_pipe(const std::string& content)
{
	int pipefd[2];
	if (pipe(pipefd) == -1) {
		die("pipe(pipefd) failed");
	}

	size_t len = content.length();
	if (len > MAX_PIPE_CAPACITY)
		die("write_to_pipe cannot handle >4KB content.");
	size_t i = 0;
	unsigned int attempts = 0;
	ssize_t ret;
	while (i < len) {
		ret = write(pipefd[1], content.c_str() + i, len - i);
		if (ret == -1) {
			close(pipefd[0]);
			close(pipefd[1]);
			return NULL;
		}

		/* If we write 0 bytes three times in a row, fail. */
		if (ret == 0) {
			if (++attempts >= 3) {
				close(pipefd[0]);
				close(pipefd[1]);
				warn("write() returned 0 three times in a row");
				return NULL;
			}
			continue;
		}

		attempts = 0;
		i += (size_t)ret;
	}

	close(pipefd[1]);
	return fdopen(pipefd[0], "r");
}

std::string source_path(const std::string& file) {
	std::string srcdir = getenv("SRC") ? : ".";
	return srcdir + "/" + file;
}