ITC WIP #1.

3 files changed, 144 insertions, 1 deletions

diff --git a/Makefile b/Makefile
index 906910c..75d59bb 100644
--- a/Makefile
+++ b/Makefile
@@ -9,7 +9,7 @@ PP_CC := $(PP_BOLD)$(shell tput setf 6)CC$(PP_RESET)
 PP_LD := $(PP_BOLD)$(shell tput setf 2)LD$(PP_RESET)
 PP_RM := $(PP_BOLD)$(shell tput setf 4)RM$(PP_RESET)
 
-SRC := src/main.c src/physics.c src/renderer.c src/ui.c
+SRC := src/main.c src/physics.c src/renderer.c src/ui.c src/itc.c
 OBJ := $(SRC:src/%.c=obj/%.o)
 OUT := cem
 
diff --git a/src/itc.c b/src/itc.c
new file mode 100644
index 0000000..62e6208
--- /dev/null
+++ b/src/itc.c
@@ -0,0 +1,138 @@
+#include "common.h"
+#include <unistd.h>
+
+typedef struct itc_message_s itc_message;
+struct itc_message_s {
+	int number;
+	void *data;
+
+	itc_message *older, *newer;
+};
+
+typedef struct {
+	itc_message *newest, *oldest;
+	SDL_mutex *mutex;
+
+} itc_chan;
+
+
+void itc_chan_create(itc_chan *chan)
+{
+	memset(chan, 0, sizeof(itc_chan));
+
+	chan->mutex = SDL_CreateMutex();
+	assert(chan->mutex);
+}
+
+void itc_chan_destroy(itc_chan *chan)
+{
+	// todo: free queue
+
+	SDL_DestroyMutex(chan->mutex);
+}
+
+void itc_chan_push(itc_chan *chan, int number, void *data)
+{
+	itc_message *msg;
+
+	msg = calloc(1, sizeof(itc_message));
+	assert(msg);
+
+	msg->number = number;
+	msg->data = data;
+
+	SDL_LockMutex(chan->mutex);
+	
+	if (!chan->oldest) {      
+		chan->oldest = msg;
+		chan->newest = msg;
+	} else {
+		/*
+		 *   head <---> ... <---> tail
+		 *
+		 */
+
+		chan->newest->newer = msg;
+		msg->older = chan->newest;
+		chan->newest = msg;
+	}
+
+	SDL_UnlockMutex(chan->mutex);
+}
+
+int itc_chan_pop(itc_chan *chan, int *number, void **data)
+{
+	itc_message *msg;
+
+	SDL_LockMutex(chan->mutex);
+
+	if (!chan->oldest) {
+		SDL_UnlockMutex(chan->mutex);
+		return 1;
+	}
+
+	msg = chan->oldest;
+
+	if (msg->newer) {
+		msg->newer->older = NULL;
+		chan->oldest = msg->newer;
+	} else {
+		chan->newest = NULL;
+		chan->oldest = NULL;
+	}
+
+	SDL_UnlockMutex(chan->mutex);
+
+	*number = msg->number;
+	*data = msg->data;
+	free(msg);
+
+	return 0;
+}
+
+
+
+itc_chan gulg_chan;
+
+int gulgulator(void *unused)
+{
+	int cmd_num;
+	void *cmd_data;
+
+	while (1) {
+		while (!itc_chan_pop(&gulg_chan, &cmd_num, &cmd_data)) {
+			printf("gulgulator: pop %i %p\n", cmd_num, cmd_data);
+		}
+
+		usleep(100 * 1000);
+	}
+}
+
+void itc_test(void)
+{
+	SDL_Thread *thread;
+	char line[512];
+
+	itc_chan_create(&gulg_chan);
+	thread = SDL_CreateThread(gulgulator, "gulgulator", NULL);
+
+	while (1) {
+		int cmd_num;
+
+		printf("> ");
+		fflush(stdout);
+
+		if (!fgets(line, sizeof(line), stdin))
+			break;
+
+		cmd_num = atoi(line);
+
+		printf("main: push %i %p\n", cmd_num, 0xDEADBEEF);
+		itc_chan_push(&gulg_chan, cmd_num, (void*)0xDEADBEEF);
+	}
+
+	printf("EOF\n");
+
+	SDL_WaitThread(thread, NULL);
+}
+
diff --git a/src/main.c b/src/main.c
index 65a7ab3..a313cc1 100644
--- a/src/main.c
+++ b/src/main.c
@@ -21,6 +21,8 @@ int64_t get_time(void)
 	return ts.tv_sec * 1000000000 + ts.tv_nsec;
 }
 
+void itc_test(void);
+
 int main(void)
 {
 	int rv = 0;
@@ -28,6 +30,9 @@ int main(void)
 	phy_sim sim;
 	SDL_Thread *sim_thread;
 
+	itc_test();
+	return;
+
 	if (r_init()) {
 		con_printf("fatal error: renderer initialization failed\n");
 		rv = 1;