From 47beba686ff9d2aab63738fba7176a5235703d05 Mon Sep 17 00:00:00 2001 From: yctct Date: Sun, 13 Sep 2026 18:58:14 +0200 Subject: Add all files, first commit --- src/starve.c | 84 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 84 insertions(+) create mode 100644 src/starve.c (limited to 'src/starve.c') diff --git a/src/starve.c b/src/starve.c new file mode 100644 index 0000000..3dba831 --- /dev/null +++ b/src/starve.c @@ -0,0 +1,84 @@ +#include "codexion.h" +# include // for printf() + +static void broadcast_signals(t_sim *sim) +{ + t_fork **forks; + t_fork *fork; + int number_of_philos; + + (void)pthread_mutex_lock(&sim->mutex_forks); + forks = sim->forks; + (void)pthread_mutex_unlock(&sim->mutex_forks); + (void)pthread_mutex_lock(&sim->mutex_number_of_philos); + number_of_philos = sim->number_of_philos; + (void)pthread_mutex_unlock(&sim->mutex_number_of_philos); + while (number_of_philos-- > 0) + { + fork = *forks++; + (void)pthread_mutex_lock(&fork->mutex_cond); + pthread_cond_broadcast(&fork->cond_signal); + (void)pthread_mutex_unlock(&fork->mutex_cond); + } +} + +/* Computes a philo's time until he/she burns out */ +int time_until_starve(t_philo *philo) +{ + int time_until_starve; + int time_to_starve; + int beginning_last_eat_time; + t_sim *sim; + + (void)pthread_mutex_lock(&philo->mutex_sim); + sim = philo->sim; + (void)pthread_mutex_unlock(&philo->mutex_sim); + (void)pthread_mutex_lock(&sim->mutex_time_to_starve); + time_to_starve = sim->time_to_starve; + (void)pthread_mutex_unlock(&sim->mutex_time_to_starve); + (void)pthread_mutex_lock(&philo->mutex_beginning_last_eat_time); + beginning_last_eat_time = philo->beginning_last_eat_time; + (void)pthread_mutex_unlock(&philo->mutex_beginning_last_eat_time); + time_until_starve = time_to_starve - (get_rel_time(sim) + - beginning_last_eat_time); + return (time_until_starve); +} + +int check_if_philo_starved(t_sim *sim) +{ + int starved_status; + + (void)pthread_mutex_lock(&sim->mutex_philo_starved); + starved_status = sim->philo_starved; + (void)pthread_mutex_unlock(&sim->mutex_philo_starved); + return (starved_status); +} + +int check_for_starves(t_sim *sim) +{ + t_philo **philos; + t_philo *philo; + int number_of_philos; + + (void)pthread_mutex_lock(&sim->mutex_philos); + philos = sim->philos; + (void)pthread_mutex_unlock(&sim->mutex_philos); + philo = *philos; + (void)pthread_mutex_lock(&sim->mutex_number_of_philos); + number_of_philos = sim->number_of_philos; + (void)pthread_mutex_unlock(&sim->mutex_number_of_philos); + while (number_of_philos-- > 0) + { + philo = *philos++; + if (time_until_starve(philo) == 0) + { + (void)pthread_mutex_lock(&sim->mutex_philo_starved); + sim->philo_starved = 1; + (void)pthread_mutex_unlock(&sim->mutex_philo_starved); + print_log(philo, "starved", 1); + broadcast_signals(sim); + return (1); + } + } + return (0); +} -- cgit v1.2.3