init.c

/* ************************************************************************** */
/*                                                                            */
/*                                                        :::      ::::::::   */
/*   init.c                                             :+:      :+:    :+:   */
/*                                                    +:+ +:+         +:+     */
/*   By: dporhomo <dporhomo@student.42prague.com    +#+  +:+       +#+        */
/*                                                +#+#+#+#+#+   +#+           */
/*   Created: 2026/06/08 12:16:57 by dporhomo          #+#    #+#             */
/*   Updated: 2026/06/15 13:27:26 by dporhomo         ###   ########.fr       */
/*                                                                            */
/* ************************************************************************** */

/* Allocate memory for mutexes, cond, dongle_ready_time, t_coder coders*/
/* Allocate memory for pq*/
/* Init mutexes, cond, coders and coders init data*/

#include "codexion.h"

static int	allocate_arrays(t_program *prog, t_coder **coders)
{
	prog->dongles = malloc(sizeof(pthread_mutex_t) * prog->num_coders);
	prog->coder_cond = malloc(sizeof(pthread_cond_t) * prog->num_coders);
	prog->dongle_ready_time = malloc(sizeof(long long) * prog->num_coders);
	*coders = malloc(sizeof(t_coder) * prog->num_coders);
	if (!prog->dongles || !prog->coder_cond
		|| !prog->dongle_ready_time || !*coders)
		return (0);
	return (1);
}

int	pq_init(t_pqueue *pq, int capacity, int is_edf)
{
	pq->heap = malloc(sizeof(t_request) * capacity);
	if (!pq->heap)
		return (0);
	pq->size = 0;
	pq->capacity = capacity;
	pq->is_edf = is_edf;
	return (1);
}

/* Inits mutexes and coders, sets pthread_mutex_inits, sets coders data*/
int	init_mutexes_and_coders(t_program *prog, t_coder **coders)
{
	int	i;

	if (!allocate_arrays(prog, coders))
		return (0);
	if (!pq_init(&prog->pq, prog->num_coders * 2, prog->is_edf))
		return (0);
	pthread_mutex_init(&prog->print_lock, NULL);
	pthread_mutex_init(&prog->arbitrator, NULL);
	pthread_mutex_init(&prog->state_lock, NULL);
	i = -1;
	while (++i < prog->num_coders)
	{
		pthread_mutex_init(&prog->dongles[i], NULL);
		pthread_cond_init(&prog->coder_cond[i], NULL);
		prog->dongle_ready_time[i] = 0;
		(*coders)[i].id = i + 1;
		(*coders)[i].left_dongle = i;
		(*coders)[i].right_dongle = (i + 1) % prog->num_coders;
		(*coders)[i].compiles_done = 0;
		(*coders)[i].last_compile = get_current_time();
		(*coders)[i].prog = prog;
	}
	return (1);
}