diff options
Diffstat (limited to 'include/codexion.h')
| -rw-r--r-- | include/codexion.h | 142 |
1 files changed, 142 insertions, 0 deletions
diff --git a/include/codexion.h b/include/codexion.h new file mode 100644 index 0000000..51c606f --- /dev/null +++ b/include/codexion.h @@ -0,0 +1,142 @@ +#ifndef CODEXION_H + +# define CODEXION_H + +# include <pthread.h> // for pthread_* +//# include <stdio.h> // for printf() +//# include <stdlib.h> // for atoi(), malloc() +//# include <string.h> // for strlen() +//# include <sys/time.h> // for getimeofday() +//# include <unistd.h> // for usleep() +# define MAX 2 + +typedef struct s_sim t_sim; +typedef struct s_queue t_queue; +typedef struct s_fork t_fork; + +typedef struct s_philo +{ + int id; + int ticket; + pthread_t thread_id; + t_fork *left_fork; + t_fork *right_fork; + long beginning_last_eat_time; + t_sim *sim; + int number_of_eats_done; + pthread_mutex_t mutex_number_of_eats_done; + pthread_mutex_t mutex_beginning_last_eat_time; + pthread_mutex_t mutex_ticket; + pthread_mutex_t mutex_id; + pthread_mutex_t mutex_sim; +} t_philo; + +typedef struct s_ticket +{ + int num; +} t_ticket; + +typedef struct s_queue +{ + t_ticket items[MAX]; + int size; +} t_queue; + +typedef struct s_fork +{ + int id; + size_t ticket_next; + int last_released; + t_philo *left_philo; + t_philo *right_philo; + t_sim *sim; + pthread_mutex_t mutex; + pthread_mutex_t mutex_left_philo; + pthread_mutex_t mutex_right_philo; + pthread_mutex_t mutex_ticket_next; + pthread_mutex_t mutex_cond; + pthread_mutex_t mutex_sim; + pthread_mutex_t mutex_last_released; + pthread_cond_t cond_signal; + t_queue pq; + pthread_mutex_t mutex_pq; + +} t_fork; + +typedef struct s_sim +{ + int number_of_philos; + int time_to_starve; + int time_to_eat; + int time_to_reflect; + int time_to_think; + int number_of_eat_required; + int fork_cooldown; + char *scheduler; + t_fork **forks; + t_philo **philos; + long start_time; + pthread_t monitor_thread; + int philo_starved; + int number_of_forks_actual; + int number_of_philos_actual; + pthread_mutex_t mutex_philo_starved; + pthread_mutex_t mutex_print_log; + pthread_mutex_t mutex_cooldown; + pthread_mutex_t mutex_start_time; + pthread_mutex_t mutex_number_of_eat_done; + pthread_mutex_t mutex_philos; + pthread_mutex_t mutex_number_of_philos; + pthread_mutex_t mutex_number_of_eat_required; + pthread_mutex_t mutex_time_to_starve; + pthread_mutex_t mutex_time_to_think; + pthread_mutex_t mutex_time_to_reflect; + pthread_mutex_t mutex_time_to_eat; + pthread_mutex_t mutex_scheduler; + pthread_mutex_t mutex_forks; + +} t_sim; + +long time_ms(void); +int check_if_philo_starved(t_sim *sim); +void print_log(t_philo *philo, char *msg, int flag); +int check_for_starves(t_sim *sim); +void print_usage(void); +void free_philos(t_sim *sim); +void free_forks(t_sim *sim); +t_fork *create_fork(t_sim *sim); +t_fork **create_arr_forks(t_sim *sim); +t_philo *create_philo(t_sim *sim); +t_philo **create_arr_philos(t_sim *sim); +void start_timer(t_sim *sim); +t_philo *who_is_near(t_philo *philo, t_fork *fork); +void *routine(void *arg); +void *monitoring_routine(void *arg); +void init_mutex(t_sim *sim); +void destroy_mutex(t_sim *sim); +int run_threads(t_sim *sim); +t_philo **assign_forks(t_sim *sim); +t_fork **assign_philos(t_sim *sim); +t_sim *create_sim(char **argv); +int valid_params(char **argv); +int main(int argc, char **argv); +int philo_routine(t_philo *philo, + t_fork *left_fork, t_fork *right_fork); +void swap(t_ticket a, t_ticket b); +int time_until_starve(t_philo *philo); +int get_id(t_philo *philo); +void eat(t_philo *philo); +void reflect_and_think(t_philo *philo); +int wait_for_fork(t_philo *philo, t_fork *fork); +void wait_for_longest_cooldown(t_philo *philo, + t_fork *left_fork, t_fork *right_fork); +void update_last_released(t_sim *sim, + t_fork *fork1, t_fork *fork2); +int get_rel_time(t_sim *sim); +void dequeue(t_fork *fork); +int queue_routine(t_philo *philo, + t_fork *f1, t_fork *f2); +void enqueue(t_fork *fork, t_ticket ticket); +void heapify(t_fork *fork); + +#endif |