/* See LICENSE file for copyright and license details. */
#include "common.h"


static void
process(struct algorithm *algorithm, struct global_data *global)
{
	size_t r;
	r = algorithm->hasher.process(&algorithm->hasher,
	                              &global->buffer->buf[algorithm->offset],
	                              global->buffer->length - algorithm->offset);
	algorithm->offset += r;
}


static void
finalise(struct algorithm *algorithm, struct global_data *global)
{
	if (algorithm->hasher.finalise_const(&algorithm->hasher, &global->buffer->buf[algorithm->offset],
	                                     global->buffer->length - algorithm->offset, 0))
		abort();
	format_result(algorithm, global->file, global->format);
}


int
calculate(const char *file, struct barrier_group *group, struct global_data *global)
{
	int fd, is_new_fd, r, ret = -1;
	const char *fname;

	global->nalgorithms = inithashers(global->algorithms, global->nalgorithms);
	if (!global->nalgorithms)
		return 0;

	fd = openfile(file, &is_new_fd, &fname);
	if (fd < 0)
		return -1;

	global->buffer->length = 0;
	while (!(r = feedbuffer(fd, global->buffer, fname))) {
		barriersend(group, global, &process);
		shiftbuffer(global->algorithms, global->nalgorithms, global->buffer);
	}
	if (r < 0)
		goto fail;

	barriersend(group, global, &finalise);
	ret = 0;
fail:
	destroyhashers(global->algorithms, global->nalgorithms);
	if (is_new_fd)
		close(fd);
	return ret;
}