From b171edf043f7c25e8b67b7bc0ea329990a9cd9cd Mon Sep 17 00:00:00 2001
From: "Semere M. Mebrahtom" <semere.meharena1@gmail.com>
Date: Thu, 26 Mar 2026 11:54:56 +0100
Subject: [PATCH] monitoring done; scheduling not implemented

---
 coders/codexion.h |  1 +
 coders/main.c     | 44 +++++++++++++++++++++++++++++++++++++++++++-
 2 files changed, 44 insertions(+), 1 deletion(-)

diff --git a/coders/codexion.h b/coders/codexion.h
index 5a37b72..c5d189a 100644
--- a/coders/codexion.h
+++ b/coders/codexion.h
@@ -49,6 +49,7 @@ typedef struct s_coder
 	long				last_compile;
 	int					compiles_done;
 	t_state				*state;
+	pthread_mutex_t		last_mutex;
 }						t_coder;
 
 typedef struct s_state
diff --git a/coders/main.c b/coders/main.c
index d473047..6816034 100644
--- a/coders/main.c
+++ b/coders/main.c
@@ -33,6 +33,16 @@ void	print(char *str, t_state *state, int coder_idx)
 	pthread_mutex_unlock(&state->print_mutex);
 }
 
+bool	is_over(t_state *state)
+{
+	bool	is_over;
+
+	pthread_mutex_lock(&state->over_mutex);
+	is_over = state->is_over;
+	pthread_mutex_unlock(&state->over_mutex);
+	return (is_over);
+}
+
 void	compile_op(t_coder *coder, t_state *state)
 {
 	t_dongle	*first;
@@ -54,7 +64,9 @@ void	compile_op(t_coder *coder, t_state *state)
 	pthread_mutex_lock(&second->lock);
 	second->last_used = now();
 	print("%ld %d has taken a dongle\n", state, coder->idx);
+	pthread_mutex_lock(&coder->last_mutex);
 	coder->last_compile = now();
+	pthread_mutex_unlock(&coder->last_mutex);
 	print("%ld %d is compiling\n", state, coder->idx);
 	usleep(state->args.time_to_compile * 1000L);
 	pthread_mutex_unlock(&first->lock);
@@ -85,8 +97,14 @@ void	*run(void *param)
 	i = 0;
 	while (i < state->args.number_of_compiles_required)
 	{
+		if (is_over(state))
+			return (NULL);
 		compile_op(coder, state);
+		if (is_over(state))
+			return (NULL);
 		debug_op(coder, state);
+		if (is_over(state))
+			return (NULL);
 		refactor_op(coder, state);
 		i++;
 	}
@@ -95,7 +113,30 @@ void	*run(void *param)
 
 void	*monitor(void *param)
 {
-	(void)param;
+	t_state	*state;
+	int		i;
+	long	last;
+
+	state = param;
+	while (!is_over(state))
+	{
+		usleep(1000);
+		i = -1;
+		while (++i < state->args.number_of_coders)
+		{
+			pthread_mutex_lock(&state->coders[i].last_mutex);
+			last = state->coders[i].last_compile;
+			pthread_mutex_unlock(&state->coders[i].last_mutex);
+			if (now() - last >= state->args.time_to_burnout)
+			{
+				pthread_mutex_lock(&state->over_mutex);
+				state->is_over = true;
+				pthread_mutex_unlock(&state->over_mutex);
+				print("%ld %d has burned out\n", state, state->coders[i].idx);
+				return (NULL);
+			}
+		}
+	}
 	return (NULL);
 }
 
@@ -158,6 +199,7 @@ t_coder	*init_coders(t_args *args, t_state *state)
 		coders[i].right_dongle = &state->dongles[(i + 1)
 			% args->number_of_coders];
 		coders[i].state = state;
+		pthread_mutex_init(&coders[i].last_mutex, NULL);
 	}
 	return (coders);
 }