From 7d36403836511ab0745791ce98498cf5112633c1 Mon Sep 17 00:00:00 2001 From: Aargh Rai Date: Fri, 24 Jul 2026 09:32:54 +0530 Subject: fixed the quit command --- src/ipc/engine_message.c | 15 +++++++++++++++ 1 file changed, 15 insertions(+) (limited to 'src/ipc') diff --git a/src/ipc/engine_message.c b/src/ipc/engine_message.c index 76814f4..c54a02e 100644 --- a/src/ipc/engine_message.c +++ b/src/ipc/engine_message.c @@ -16,6 +16,17 @@ void engine_message_handler_init(engine_message_handler_t *handle) { handle->popped_count = 0; } +void engine_message_handler_deinit(engine_message_handler_t *handle) { + engine_message_t *next, *message = handle->oldest_valid; + + int count = handle->count; + while (count-- > 0) { + next = message->next; + engine_message_deinit(message); + message = next; + } +} + void engine_message_handler_acquire(engine_message_handler_t *handle) { while (atomic_flag_test_and_set(&handler_busy)); } @@ -111,6 +122,10 @@ bool engine_message_is_ready(engine_message_t *message) { void engine_messages_deinit(engine_messages_t *messages) { assert(messages != NULL); + for (int i = 0; i < 10; i++) { + engine_message_handler_deinit(messages->data[i]); + free(messages->data[i]); + } free(messages->data); } -- cgit v1.2.3