X-Git-Url: https://git.stderr.nl/gitweb?a=blobdiff_plain;f=libchimara%2Fevent.c;h=4089b79eaa3205017e153642f0f54418a4105d01;hb=5b51dfd3050c65677e3d13eb7585202c8e1664ef;hp=ca5e21aac58a874dd7a28a1ebc968601e925deab;hpb=53af2af2a35b5a560d0e5c6a18b3d26e8748729b;p=rodin%2Fchimara.git diff --git a/libchimara/event.c b/libchimara/event.c index ca5e21a..4089b79 100644 --- a/libchimara/event.c +++ b/libchimara/event.c @@ -2,6 +2,7 @@ #include "magic.h" #include "glk.h" #include "window.h" +#include "input.h" #include #include "chimara-glk.h" @@ -50,6 +51,84 @@ event_throw(ChimaraGlk *glk, glui32 type, winid_t win, glui32 val1, glui32 val2) g_mutex_unlock(priv->event_lock); } +/* Helper function: Wait for an event in the event queue. If it is a forced + * input event, but no windows have an input request of that type, then wait + * for the next event and put the forced input event back on top of the queue. + */ +static void +get_appropriate_event(event_t *event) +{ + ChimaraGlkPrivate *glk_data = g_private_get(glk_data_key); + + g_mutex_lock(glk_data->event_lock); + + event_t *retrieved_event = NULL; + + /* Wait for an event */ + if( g_queue_is_empty(glk_data->event_queue) ) + g_cond_wait(glk_data->event_queue_not_empty, glk_data->event_lock); + + retrieved_event = g_queue_pop_tail(glk_data->event_queue); + + /* Signal that the event queue is no longer full */ + g_cond_signal(glk_data->event_queue_not_full); + + g_mutex_unlock(glk_data->event_lock); + + if(retrieved_event->type == evtype_ForcedCharInput) + { + /* Check for forced character input in the queue */ + winid_t win; + for(win = glk_window_iterate(NULL, NULL); win; win = glk_window_iterate(win, NULL)) + if(win->input_request_type == INPUT_REQUEST_CHARACTER || win->input_request_type == INPUT_REQUEST_CHARACTER_UNICODE) + break; + if(win) + { + force_char_input_from_queue(win, event); + g_free(retrieved_event); + } + else + { + get_appropriate_event(event); + g_mutex_lock(glk_data->event_lock); + g_queue_push_tail(glk_data->event_queue, retrieved_event); + g_cond_signal(glk_data->event_queue_not_empty); + g_mutex_unlock(glk_data->event_lock); + } + } + else if(retrieved_event->type == evtype_ForcedLineInput) + { + /* Check for forced line input in the queue */ + winid_t win; + for(win = glk_window_iterate(NULL, NULL); win; win = glk_window_iterate(win, NULL)) + if(win->input_request_type == INPUT_REQUEST_LINE || win->input_request_type == INPUT_REQUEST_LINE_UNICODE) + break; + if(win) + { + force_line_input_from_queue(win, event); + g_free(retrieved_event); + } + else + { + get_appropriate_event(event); + g_mutex_lock(glk_data->event_lock); + g_queue_push_tail(glk_data->event_queue, retrieved_event); + g_cond_signal(glk_data->event_queue_not_empty); + g_mutex_unlock(glk_data->event_lock); + } + } + else + { + if(retrieved_event == NULL) + { + WARNING("Retrieved NULL event from non-empty event queue"); + return; + } + memcpy(event, retrieved_event, sizeof(event_t)); + g_free(retrieved_event); + } +} + /** * glk_select: * @event: Pointer to an #event_t. @@ -68,29 +147,17 @@ glk_select(event_t *event) { g_return_if_fail(event != NULL); - ChimaraGlkPrivate *glk_data = g_private_get(glk_data_key); - - g_mutex_lock(glk_data->event_lock); - - /* Wait for an event */ - while( g_queue_is_empty(glk_data->event_queue) ) - g_cond_wait(glk_data->event_queue_not_empty, glk_data->event_lock); - - event_t *retrieved_event = g_queue_pop_tail(glk_data->event_queue); - if(retrieved_event == NULL) - { - g_mutex_unlock(glk_data->event_lock); - WARNING("Retrieved NULL event from non-empty event queue"); - return; + /* Flush all window buffers */ + winid_t win; + for(win = glk_window_iterate(NULL, NULL); win != NULL; win = glk_window_iterate(win, NULL)) { + if(win->type == wintype_TextBuffer || win->type == wintype_TextGrid) + flush_window_buffer(win); } - memcpy(event, retrieved_event, sizeof(event_t)); - g_free(retrieved_event); - /* Signal that the event queue is no longer full */ - g_cond_signal(glk_data->event_queue_not_full); + ChimaraGlkPrivate *glk_data = g_private_get(glk_data_key); + + get_appropriate_event(event); - g_mutex_unlock(glk_data->event_lock); - /* Check for interrupt */ glk_tick(); @@ -125,7 +192,7 @@ glk_select(event_t *event) * intended for you to test conditions which may have occurred while you are * computing, and not interfacing with the player. For example, time may pass * during slow computations; you can use glk_select_poll() to see if a - * %evtype_Timer event has occured. (See Timer Events.) * * At the moment, glk_select_poll() checks for %evtype_Timer, %evtype_Arrange, @@ -200,4 +267,4 @@ glk_select_poll(event_t *event) /* If an abort event was generated, the thread should have exited by now */ g_assert(event->type != evtype_Abort); -} \ No newline at end of file +}