blob: 3dba8317a0b828ebb4c06ed0c0d926da6a3034bd (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
|
#include "codexion.h"
# include <stdio.h> // 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);
}
|
