/* RetroArch - A frontend for libretro. * Copyright (C) 2010-2014 - Hans-Kristian Arntzen * Copyright (C) 2011-2017 - Daniel De Matteis * * RetroArch is free software: you can redistribute it and/or modify it under the terms * of the GNU General Public License as published by the Free Software Found- * ation, either version 3 of the License, or (at your option) any later version. * * RetroArch is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR * PURPOSE. See the GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along with RetroArch. * If not, see . */ #include #include #include #include #include #include #include #include "video_thread_wrapper.h" #include "font_driver.h" #include "../retroarch.h" #include "../verbosity.h" enum thread_cmd { CMD_VIDEO_NONE = 0, CMD_INIT, CMD_SET_SHADER, CMD_FREE, CMD_ALIVE, /* Blocking alive check. Used when paused. */ CMD_SET_VIEWPORT, CMD_SET_ROTATION, CMD_READ_VIEWPORT, CMD_OVERLAY_ENABLE, CMD_OVERLAY_LOAD, CMD_OVERLAY_TEX_GEOM, CMD_OVERLAY_VERTEX_GEOM, CMD_OVERLAY_FULL_SCREEN, CMD_POKE_SET_VIDEO_MODE, CMD_POKE_SET_FILTERING, CMD_POKE_GET_VIDEO_OUTPUT_SIZE, CMD_POKE_GET_VIDEO_OUTPUT_PREV, CMD_POKE_GET_VIDEO_OUTPUT_NEXT, CMD_POKE_SET_FBO_STATE, CMD_POKE_GET_FBO_STATE, CMD_POKE_SET_ASPECT_RATIO, CMD_POKE_SET_OSD_MSG, CMD_FONT_INIT, CMD_CUSTOM_COMMAND, CMD_DUMMY = INT_MAX }; struct thread_packet { enum thread_cmd type; union { bool b; int i; float f; const char *str; void *v; struct { enum rarch_shader_type type; const char *path; } set_shader; struct { unsigned width; unsigned height; bool force_full; bool allow_rotate; } set_viewport; struct { unsigned index; float x, y, w, h; } rect; struct { const struct texture_image *data; unsigned num; } image; struct { unsigned width; unsigned height; } output; struct { unsigned width; unsigned height; bool fullscreen; } new_mode; struct { unsigned index; bool smooth; } filtering; struct { char msg[255]; struct font_params params; } osd_message; struct { custom_command_method_t method; void* data; int return_value; } custom_command; struct { custom_font_command_method_t method; const void **font_driver; void **font_handle; void *video_data; const char *font_path; float font_size; bool return_value; bool is_threaded; enum font_driver_render_api api; } font_init; } data; }; struct thread_video { slock_t *lock; scond_t *cond_cmd; scond_t *cond_thread; sthread_t *thread; video_info_t info; const video_driver_t *driver; #ifdef HAVE_OVERLAY const video_overlay_interface_t *overlay; #endif const video_poke_interface_t *poke; void *driver_data; const input_driver_t **input; void **input_data; #if defined(HAVE_MENU) struct { void *frame; size_t frame_cap; unsigned width; unsigned height; float alpha; bool frame_updated; bool rgb32; bool enable; bool full_screen; } texture; #endif bool apply_state_changes; bool alive; bool focus; bool suppress_screensaver; bool has_windowed; bool nonblock; bool is_idle; retro_time_t last_time; unsigned hit_count; unsigned miss_count; float *alpha_mod; unsigned alpha_mods; bool alpha_update; slock_t *alpha_lock; void (*send_and_wait)(struct thread_video *, thread_packet_t*); enum thread_cmd send_cmd; enum thread_cmd reply_cmd; thread_packet_t cmd_data; struct video_viewport vp; struct video_viewport read_vp; /* Last viewport reported to caller. */ struct { slock_t *lock; uint8_t *buffer; unsigned width; unsigned height; unsigned pitch; bool updated; bool within_thread; uint64_t count; char msg[255]; } frame; video_driver_t video_thread; }; static void *video_thread_init_never_call(const video_info_t *video, const input_driver_t **input, void **input_data) { (void)video; (void)input; (void)input_data; RARCH_ERR("Sanity check fail! Threaded mustn't be reinit.\n"); abort(); return NULL; } /* thread -> user */ static void video_thread_reply(thread_video_t *thr, const thread_packet_t *pkt) { slock_lock(thr->lock); thr->cmd_data = *pkt; thr->reply_cmd = pkt->type; thr->send_cmd = CMD_VIDEO_NONE; scond_signal(thr->cond_cmd); slock_unlock(thr->lock); } /* user -> thread */ static void video_thread_send_packet(thread_video_t *thr, const thread_packet_t *pkt) { slock_lock(thr->lock); thr->cmd_data = *pkt; thr->send_cmd = pkt->type; thr->reply_cmd = CMD_VIDEO_NONE; scond_signal(thr->cond_thread); slock_unlock(thr->lock); } /* user -> thread */ static void video_thread_wait_reply(thread_video_t *thr, thread_packet_t *pkt) { slock_lock(thr->lock); while (pkt->type != thr->reply_cmd) scond_wait(thr->cond_cmd, thr->lock); *pkt = thr->cmd_data; thr->cmd_data.type = CMD_VIDEO_NONE; slock_unlock(thr->lock); } /* user -> thread */ static void video_thread_send_and_wait_user_to_thread(thread_video_t *thr, thread_packet_t *pkt) { video_thread_send_packet(thr, pkt); video_thread_wait_reply(thr, pkt); } static void thread_update_driver_state(thread_video_t *thr) { #if defined(HAVE_MENU) if (thr->texture.frame_updated) { if (thr->poke && thr->poke->set_texture_frame) thr->poke->set_texture_frame(thr->driver_data, thr->texture.frame, thr->texture.rgb32, thr->texture.width, thr->texture.height, thr->texture.alpha); thr->texture.frame_updated = false; } if (thr->poke && thr->poke->set_texture_enable) thr->poke->set_texture_enable(thr->driver_data, thr->texture.enable, thr->texture.full_screen); #endif #if defined(HAVE_OVERLAY) slock_lock(thr->alpha_lock); if (thr->alpha_update) { unsigned i; for (i = 0; i < thr->alpha_mods; i++) { if (thr->overlay && thr->overlay->set_alpha) thr->overlay->set_alpha(thr->driver_data, i, thr->alpha_mod[i]); } thr->alpha_update = false; } slock_unlock(thr->alpha_lock); #endif if (thr->apply_state_changes) { if (thr->poke && thr->poke->apply_state_changes) thr->poke->apply_state_changes(thr->driver_data); thr->apply_state_changes = false; } } /* returns true when video_thread_loop should quit */ static bool video_thread_handle_packet( thread_video_t *thr, const thread_packet_t *incoming) { #ifdef HAVE_OVERLAY unsigned i; #endif thread_packet_t pkt = *incoming; bool ret = false; switch (pkt.type) { case CMD_INIT: thr->driver_data = thr->driver->init(&thr->info, thr->input, thr->input_data); pkt.data.b = thr->driver_data; thr->driver->viewport_info(thr->driver_data, &thr->vp); video_thread_reply(thr, &pkt); break; case CMD_FREE: if (thr->driver_data) { if (thr->driver && thr->driver->free) thr->driver->free(thr->driver_data); } thr->driver_data = NULL; video_thread_reply(thr, &pkt); return true; case CMD_SET_ROTATION: if (thr->driver && thr->driver->set_rotation) thr->driver->set_rotation(thr->driver_data, pkt.data.i); video_thread_reply(thr, &pkt); break; case CMD_READ_VIEWPORT: { struct video_viewport vp; vp.x = 0; vp.y = 0; vp.width = 0; vp.height = 0; vp.full_width = 0; vp.full_height = 0; thr->driver->viewport_info(thr->driver_data, &vp); if (string_is_equal_fast(&vp, &thr->read_vp, sizeof(vp))) { /* We can read safely * * read_viewport() in GL driver calls * 'cached frame render' to be able to read from * back buffer. * * This means frame() callback in threaded wrapper will * be called from this thread, causing a timeout, and * no frame to be rendered. * * To avoid this, set a flag so wrapper can see if * it's called in this "special" way. */ thr->frame.within_thread = true; if (thr->driver->read_viewport) ret = thr->driver->read_viewport(thr->driver_data, (uint8_t*)pkt.data.v, thr->is_idle); pkt.data.b = ret; thr->frame.within_thread = false; } else { /* Viewport dimensions changed right after main * thread read the async value. Cannot read safely. */ pkt.data.b = false; } video_thread_reply(thr, &pkt); break; } case CMD_SET_SHADER: if (thr->driver && thr->driver->set_shader) ret = thr->driver->set_shader(thr->driver_data, pkt.data.set_shader.type, pkt.data.set_shader.path); pkt.data.b = ret; video_thread_reply(thr, &pkt); break; case CMD_ALIVE: if (thr->driver && thr->driver->alive) ret = thr->driver->alive(thr->driver_data); pkt.data.b = ret; video_thread_reply(thr, &pkt); break; #ifdef HAVE_OVERLAY case CMD_OVERLAY_ENABLE: if (thr->overlay && thr->overlay->enable) thr->overlay->enable(thr->driver_data, pkt.data.b); video_thread_reply(thr, &pkt); break; case CMD_OVERLAY_LOAD: if (thr->overlay && thr->overlay->load) ret = thr->overlay->load(thr->driver_data, pkt.data.image.data, pkt.data.image.num); pkt.data.b = ret; thr->alpha_mods = pkt.data.image.num; thr->alpha_mod = (float*)realloc(thr->alpha_mod, thr->alpha_mods * sizeof(float)); for (i = 0; i < thr->alpha_mods; i++) { /* Avoid temporary garbage data. */ thr->alpha_mod[i] = 1.0f; } video_thread_reply(thr, &pkt); break; case CMD_OVERLAY_TEX_GEOM: if (thr->overlay && thr->overlay->tex_geom) thr->overlay->tex_geom(thr->driver_data, pkt.data.rect.index, pkt.data.rect.x, pkt.data.rect.y, pkt.data.rect.w, pkt.data.rect.h); video_thread_reply(thr, &pkt); break; case CMD_OVERLAY_VERTEX_GEOM: if (thr->overlay && thr->overlay->vertex_geom) thr->overlay->vertex_geom(thr->driver_data, pkt.data.rect.index, pkt.data.rect.x, pkt.data.rect.y, pkt.data.rect.w, pkt.data.rect.h); video_thread_reply(thr, &pkt); break; case CMD_OVERLAY_FULL_SCREEN: if (thr->overlay && thr->overlay->full_screen) thr->overlay->full_screen(thr->driver_data, pkt.data.b); video_thread_reply(thr, &pkt); break; #endif case CMD_POKE_SET_VIDEO_MODE: if (thr->poke && thr->poke->set_video_mode) thr->poke->set_video_mode(thr->driver_data, pkt.data.new_mode.width, pkt.data.new_mode.height, pkt.data.new_mode.fullscreen); video_thread_reply(thr, &pkt); break; case CMD_POKE_SET_FILTERING: if (thr->poke && thr->poke->set_filtering) thr->poke->set_filtering(thr->driver_data, pkt.data.filtering.index, pkt.data.filtering.smooth); video_thread_reply(thr, &pkt); break; case CMD_POKE_GET_VIDEO_OUTPUT_SIZE: if (thr->poke && thr->poke->get_video_output_size) thr->poke->get_video_output_size(thr->driver_data, &pkt.data.output.width, &pkt.data.output.height); video_thread_reply(thr, &pkt); break; case CMD_POKE_GET_VIDEO_OUTPUT_PREV: if (thr->poke && thr->poke->get_video_output_prev) thr->poke->get_video_output_prev(thr->driver_data); video_thread_reply(thr, &pkt); break; case CMD_POKE_GET_VIDEO_OUTPUT_NEXT: if (thr->poke && thr->poke->get_video_output_next) thr->poke->get_video_output_next(thr->driver_data); video_thread_reply(thr, &pkt); break; case CMD_POKE_SET_ASPECT_RATIO: if (thr->poke && thr->poke->set_aspect_ratio) thr->poke->set_aspect_ratio(thr->driver_data, pkt.data.i); video_thread_reply(thr, &pkt); break; case CMD_POKE_SET_OSD_MSG: { video_frame_info_t video_info; video_driver_build_info(&video_info); if (thr->poke && thr->poke->set_osd_msg) thr->poke->set_osd_msg(thr->driver_data, &video_info, pkt.data.osd_message.msg, &pkt.data.osd_message.params, NULL); } video_thread_reply(thr, &pkt); break; case CMD_FONT_INIT: if (pkt.data.font_init.method) pkt.data.font_init.return_value = pkt.data.font_init.method (pkt.data.font_init.font_driver, pkt.data.font_init.font_handle, pkt.data.font_init.video_data, pkt.data.font_init.font_path, pkt.data.font_init.font_size, pkt.data.font_init.api, pkt.data.font_init.is_threaded); video_thread_reply(thr, &pkt); break; case CMD_CUSTOM_COMMAND: if (pkt.data.custom_command.method) pkt.data.custom_command.return_value = pkt.data.custom_command.method (pkt.data.custom_command.data); video_thread_reply(thr, &pkt); break; case CMD_VIDEO_NONE: /* Never reply on no command. Possible deadlock if * thread sends command right after frame update. */ break; default: video_thread_reply(thr, &pkt); break; } return false; } static void video_thread_loop(void *data) { thread_video_t *thr = (thread_video_t*)data; for (;;) { thread_packet_t pkt; bool updated = false; slock_lock(thr->lock); while (thr->send_cmd == CMD_VIDEO_NONE && !thr->frame.updated) scond_wait(thr->cond_thread, thr->lock); if (thr->frame.updated) updated = true; /* To avoid race condition where send_cmd is updated * right after the switch is checked. */ pkt = thr->cmd_data; slock_unlock(thr->lock); if (video_thread_handle_packet(thr, &pkt)) return; if (updated) { struct video_viewport vp; bool ret = false; bool alive = false; bool focus = false; bool has_windowed = true; vp.x = 0; vp.y = 0; vp.width = 0; vp.height = 0; vp.full_width = 0; vp.full_height = 0; slock_lock(thr->frame.lock); thread_update_driver_state(thr); if (thr->driver && thr->driver->frame) { video_frame_info_t video_info; video_driver_build_info(&video_info); ret = thr->driver->frame(thr->driver_data, thr->frame.buffer, thr->frame.width, thr->frame.height, thr->frame.count, thr->frame.pitch, *thr->frame.msg ? thr->frame.msg : NULL, &video_info); } slock_unlock(thr->frame.lock); if (thr->driver && thr->driver->alive) alive = ret && thr->driver->alive(thr->driver_data); if (thr->driver && thr->driver->focus) focus = ret && thr->driver->focus(thr->driver_data); if (thr->driver && thr->driver->has_windowed) has_windowed = ret && thr->driver->has_windowed(thr->driver_data); if (thr->driver && thr->driver->viewport_info) thr->driver->viewport_info(thr->driver_data, &vp); slock_lock(thr->lock); thr->alive = alive; thr->focus = focus; thr->has_windowed = has_windowed; thr->frame.updated = false; thr->vp = vp; scond_signal(thr->cond_cmd); slock_unlock(thr->lock); } } } static bool video_thread_alive(void *data) { bool ret; thread_video_t *thr = (thread_video_t*)data; if (rarch_ctl(RARCH_CTL_IS_PAUSED, NULL)) { thread_packet_t pkt = { CMD_ALIVE }; video_thread_send_and_wait_user_to_thread(thr, &pkt); return pkt.data.b; } slock_lock(thr->lock); ret = thr->alive; slock_unlock(thr->lock); return ret; } static bool video_thread_focus(void *data) { bool ret; thread_video_t *thr = (thread_video_t*)data; slock_lock(thr->lock); ret = thr->focus; slock_unlock(thr->lock); return ret; } static bool video_thread_suppress_screensaver(void *data, bool enable) { bool ret; thread_video_t *thr = (thread_video_t*)data; slock_lock(thr->lock); ret = thr->suppress_screensaver; slock_unlock(thr->lock); return ret; } static bool video_thread_has_windowed(void *data) { bool ret; thread_video_t *thr = (thread_video_t*)data; slock_lock(thr->lock); ret = thr->has_windowed; slock_unlock(thr->lock); return ret; } static bool video_thread_frame(void *data, const void *frame_, unsigned width, unsigned height, uint64_t frame_count, unsigned pitch, const char *msg, video_frame_info_t *video_info) { unsigned copy_stride; const uint8_t *src = NULL; uint8_t *dst = NULL; thread_video_t *thr = (thread_video_t*)data; /* If called from within read_viewport, we're actually in the * driver thread, so just render directly. */ if (thr->frame.within_thread) { thread_update_driver_state(thr); if (thr->driver && thr->driver->frame) return thr->driver->frame(thr->driver_data, frame_, width, height, frame_count, pitch, msg, video_info); return false; } copy_stride = width * (thr->info.rgb32 ? sizeof(uint32_t) : sizeof(uint16_t)); src = (const uint8_t*)frame_; dst = thr->frame.buffer; slock_lock(thr->lock); if (!thr->nonblock) { retro_time_t target_frame_time = (retro_time_t) roundf(1000000 / video_info->refresh_rate); retro_time_t target = thr->last_time + target_frame_time; /* Ideally, use absolute time, but that is only a good idea on POSIX. */ while (thr->frame.updated) { retro_time_t current = cpu_features_get_time_usec(); retro_time_t delta = target - current; if (delta <= 0) break; if (!scond_wait_timeout(thr->cond_cmd, thr->lock, delta)) break; } } /* Drop frame if updated flag is still set, as thread is * still working on last frame. */ if (!thr->frame.updated) { if (src) { unsigned h; for (h = 0; h < height; h++, src += pitch, dst += copy_stride) memcpy(dst, src, copy_stride); } thr->frame.updated = true; thr->frame.width = width; thr->frame.height = height; thr->frame.count = frame_count; thr->frame.pitch = copy_stride; if (msg) strlcpy(thr->frame.msg, msg, sizeof(thr->frame.msg)); else *thr->frame.msg = '\0'; scond_signal(thr->cond_thread); #if defined(HAVE_MENU) if (thr->texture.enable) { while (thr->frame.updated) scond_wait(thr->cond_cmd, thr->lock); } #endif thr->hit_count++; } else thr->miss_count++; slock_unlock(thr->lock); thr->last_time = cpu_features_get_time_usec(); return true; } static void video_thread_set_nonblock_state(void *data, bool state) { thread_video_t *thr = (thread_video_t*)data; if (thr) thr->nonblock = state; } static bool video_thread_init(thread_video_t *thr, const video_info_t info, const input_driver_t **input, void **input_data) { size_t max_size; thread_packet_t pkt = {CMD_INIT}; thr->lock = slock_new(); thr->alpha_lock = slock_new(); thr->frame.lock = slock_new(); thr->cond_cmd = scond_new(); thr->cond_thread = scond_new(); thr->input = input; thr->input_data = input_data; thr->info = info; thr->alive = true; thr->focus = true; thr->has_windowed = true; thr->suppress_screensaver = true; max_size = info.input_scale * RARCH_SCALE_BASE; max_size *= max_size; max_size *= info.rgb32 ? sizeof(uint32_t) : sizeof(uint16_t); thr->frame.buffer = (uint8_t*)malloc(max_size); if (!thr->frame.buffer) return false; memset(thr->frame.buffer, 0x80, max_size); thr->last_time = cpu_features_get_time_usec(); thr->thread = sthread_create(video_thread_loop, thr); if (!thr->thread) return false; video_thread_send_and_wait_user_to_thread(thr, &pkt); thr->send_and_wait = video_thread_send_and_wait_user_to_thread; return pkt.data.b; } static bool video_thread_set_shader(void *data, enum rarch_shader_type type, const char *path) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = {CMD_SET_SHADER}; if (!thr) return false; pkt.data.set_shader.type = type; pkt.data.set_shader.path = path; video_thread_send_and_wait_user_to_thread(thr, &pkt); return pkt.data.b; } static void video_thread_set_viewport(void *data, unsigned width, unsigned height, bool force_full, bool allow_rotate) { thread_video_t *thr = (thread_video_t*)data; if (!thr) return; slock_lock(thr->lock); if (thr->driver && thr->driver->set_viewport) thr->driver->set_viewport(thr->driver_data, width, height, force_full, allow_rotate); slock_unlock(thr->lock); } static void video_thread_set_rotation(void *data, unsigned rotation) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_SET_ROTATION }; if (!thr) return; pkt.data.i = rotation; video_thread_send_and_wait_user_to_thread(thr, &pkt); } /* This value is set async as stalling on the video driver for * every query is too slow. * * This means this value might not be correct, so viewport * reads are not supported for now. */ static void video_thread_viewport_info(void *data, struct video_viewport *vp) { thread_video_t *thr = (thread_video_t*)data; if (!thr) return; slock_lock(thr->lock); *vp = thr->vp; /* Explicitly mem-copied so we can use memcmp correctly later. */ memcpy(&thr->read_vp, &thr->vp, sizeof(thr->vp)); slock_unlock(thr->lock); } static bool video_thread_read_viewport(void *data, uint8_t *buffer, bool is_idle) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_READ_VIEWPORT }; if (!thr) return false; pkt.data.v = buffer; thr->is_idle = is_idle; video_thread_send_and_wait_user_to_thread(thr, &pkt); return pkt.data.b; } static void video_thread_free(void *data) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_FREE }; if (!thr) return; video_thread_send_and_wait_user_to_thread(thr, &pkt); sthread_join(thr->thread); #if defined(HAVE_MENU) free(thr->texture.frame); #endif free(thr->frame.buffer); slock_free(thr->frame.lock); slock_free(thr->lock); scond_free(thr->cond_cmd); scond_free(thr->cond_thread); free(thr->alpha_mod); slock_free(thr->alpha_lock); RARCH_LOG("Threaded video stats: Frames pushed: %u, Frames dropped: %u.\n", thr->hit_count, thr->miss_count); free(thr); } #ifdef HAVE_OVERLAY static void thread_overlay_enable(void *data, bool state) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_OVERLAY_ENABLE }; if (!thr) return; pkt.data.b = state; video_thread_send_and_wait_user_to_thread(thr, &pkt); } static bool thread_overlay_load(void *data, const void *image_data, unsigned num_images) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_OVERLAY_LOAD }; const struct texture_image *images = (const struct texture_image*)image_data; if (!thr) return false; pkt.data.image.data = images; pkt.data.image.num = num_images; video_thread_send_and_wait_user_to_thread(thr, &pkt); return pkt.data.b; } static void thread_overlay_tex_geom(void *data, unsigned idx, float x, float y, float w, float h) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_OVERLAY_TEX_GEOM }; if (!thr) return; pkt.data.rect.index = idx; pkt.data.rect.x = x; pkt.data.rect.y = y; pkt.data.rect.w = w; pkt.data.rect.h = h; video_thread_send_and_wait_user_to_thread(thr, &pkt); } static void thread_overlay_vertex_geom(void *data, unsigned idx, float x, float y, float w, float h) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_OVERLAY_VERTEX_GEOM }; if (!thr) return; pkt.data.rect.index = idx; pkt.data.rect.x = x; pkt.data.rect.y = y; pkt.data.rect.w = w; pkt.data.rect.h = h; video_thread_send_and_wait_user_to_thread(thr, &pkt); } static void thread_overlay_full_screen(void *data, bool enable) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_OVERLAY_FULL_SCREEN }; pkt.data.b = enable; video_thread_send_and_wait_user_to_thread(thr, &pkt); } /* We cannot wait for this to complete. Totally blocks the main thread. */ static void thread_overlay_set_alpha(void *data, unsigned idx, float mod) { thread_video_t *thr = (thread_video_t*)data; if (!thr) return; slock_lock(thr->alpha_lock); thr->alpha_mod[idx] = mod; thr->alpha_update = true; slock_unlock(thr->alpha_lock); } static const video_overlay_interface_t thread_overlay = { thread_overlay_enable, thread_overlay_load, thread_overlay_tex_geom, thread_overlay_vertex_geom, thread_overlay_full_screen, thread_overlay_set_alpha, }; static void video_thread_get_overlay_interface(void *data, const video_overlay_interface_t **iface) { thread_video_t *thr = (thread_video_t*)data; if (!thr) return; *iface = &thread_overlay; thr->driver->overlay_interface(thr->driver_data, &thr->overlay); } #endif static void thread_set_video_mode(void *data, unsigned width, unsigned height, bool fullscreen) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_POKE_SET_VIDEO_MODE }; if (!thr) return; pkt.data.new_mode.width = width; pkt.data.new_mode.height = height; pkt.data.new_mode.fullscreen = fullscreen; video_thread_send_and_wait_user_to_thread(thr, &pkt); } static void thread_set_filtering(void *data, unsigned idx, bool smooth) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_POKE_SET_FILTERING }; if (!thr) return; pkt.data.filtering.index = idx; pkt.data.filtering.smooth = smooth; video_thread_send_and_wait_user_to_thread(thr, &pkt); } static void thread_get_video_output_size(void *data, unsigned *width, unsigned *height) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_POKE_GET_VIDEO_OUTPUT_SIZE }; if (!thr) return; video_thread_send_and_wait_user_to_thread(thr, &pkt); *width = pkt.data.output.width; *height = pkt.data.output.height; } static void thread_get_video_output_prev(void *data) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_POKE_GET_VIDEO_OUTPUT_PREV }; if (!thr) return; video_thread_send_and_wait_user_to_thread(thr, &pkt); } static void thread_get_video_output_next(void *data) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_POKE_GET_VIDEO_OUTPUT_NEXT }; if (!thr) return; video_thread_send_and_wait_user_to_thread(thr, &pkt); } static void thread_set_aspect_ratio(void *data, unsigned aspectratio_idx) { thread_video_t *thr = (thread_video_t*)data; thread_packet_t pkt = { CMD_POKE_SET_ASPECT_RATIO }; if (!thr) return; pkt.data.i = aspectratio_idx; video_thread_send_and_wait_user_to_thread(thr, &pkt); } #if defined(HAVE_MENU) static void thread_set_texture_frame(void *data, const void *frame, bool rgb32, unsigned width, unsigned height, float alpha) { size_t required; thread_video_t *thr = (thread_video_t*)data; slock_lock(thr->frame.lock); required = width * height * (rgb32 ? sizeof(uint32_t) : sizeof(uint16_t)); if (required > thr->texture.frame_cap) { thr->texture.frame = realloc(thr->texture.frame, required); thr->texture.frame_cap = required; } if (thr->texture.frame) { memcpy(thr->texture.frame, frame, required); thr->texture.frame_updated = true; thr->texture.rgb32 = rgb32; thr->texture.width = width; thr->texture.height = height; thr->texture.alpha = alpha; } slock_unlock(thr->frame.lock); } static void thread_set_texture_enable(void *data, bool state, bool full_screen) { thread_video_t *thr = (thread_video_t*)data; if (!thr) return; slock_lock(thr->frame.lock); thr->texture.enable = state; thr->texture.full_screen = full_screen; slock_unlock(thr->frame.lock); } static void thread_set_osd_msg(void *data, video_frame_info_t *video_info, const char *msg, const void *params, void *font) { thread_video_t *thr = (thread_video_t*)data; if (!thr) return; /* TODO : find a way to determine if the calling * thread is the driver thread or not. */ if (thr->poke && thr->poke->set_osd_msg) thr->poke->set_osd_msg(thr->driver_data, video_info, msg, params, font); } #endif static uintptr_t thread_load_texture(void *video_data, void *data, bool threaded, enum texture_filter_type filter_type) { thread_video_t *thr = (thread_video_t*)video_data; if (!thr || !thr->poke || !thr->poke->load_texture) return 0; return thr->poke->load_texture(thr->driver_data, data, threaded, filter_type); } static void thread_unload_texture(void *video_data, uintptr_t id) { thread_video_t *thr = (thread_video_t*)video_data; if (!thr) return; if (thr->poke && thr->poke->unload_texture) thr->poke->unload_texture(thr->driver_data, id); } static void thread_apply_state_changes(void *data) { thread_video_t *thr = (thread_video_t*)data; if (!thr) return; slock_lock(thr->frame.lock); thr->apply_state_changes = true; slock_unlock(thr->frame.lock); } /* This is read-only state which should not * have any kind of race condition. */ static struct video_shader *thread_get_current_shader(void *data) { thread_video_t *thr = (thread_video_t*)data; if (!thr || !thr->poke) return NULL; return thr->poke->get_current_shader(thr->driver_data); } static const video_poke_interface_t thread_poke = { thread_load_texture, thread_unload_texture, thread_set_video_mode, thread_set_filtering, thread_get_video_output_size, thread_get_video_output_prev, thread_get_video_output_next, NULL, /* get_current_framebuffer */ NULL, /* get_proc_address */ thread_set_aspect_ratio, thread_apply_state_changes, #if defined(HAVE_MENU) thread_set_texture_frame, thread_set_texture_enable, thread_set_osd_msg, #else NULL, NULL, #endif NULL, NULL, thread_get_current_shader, }; static void video_thread_get_poke_interface( void *data, const video_poke_interface_t **iface) { thread_video_t *thr = (thread_video_t*)data; if (thr->driver->poke_interface) { *iface = &thread_poke; thr->driver->poke_interface(thr->driver_data, &thr->poke); } else *iface = NULL; } static const video_driver_t video_thread = { video_thread_init_never_call, /* Should never be called directly. */ video_thread_frame, video_thread_set_nonblock_state, video_thread_alive, video_thread_focus, video_thread_suppress_screensaver, video_thread_has_windowed, video_thread_set_shader, video_thread_free, "Thread wrapper", video_thread_set_viewport, video_thread_set_rotation, video_thread_viewport_info, video_thread_read_viewport, NULL, /* read_frame_raw */ #ifdef HAVE_OVERLAY video_thread_get_overlay_interface, /* get_overlay_interface */ #endif video_thread_get_poke_interface, }; static void video_thread_set_callbacks( thread_video_t *thr, const video_driver_t *drv) { thr->video_thread = video_thread; /* Disable optional features if not present. */ if (!drv->read_viewport) thr->video_thread.read_viewport = NULL; if (!drv->set_viewport) thr->video_thread.set_viewport = NULL; if (!drv->set_rotation) thr->video_thread.set_rotation = NULL; if (!drv->set_shader) thr->video_thread.set_shader = NULL; #ifdef HAVE_OVERLAY if (!drv->overlay_interface) thr->video_thread.overlay_interface = NULL; #endif /* Might have to optionally disable poke_interface features as well. */ if (!thr->video_thread.poke_interface) thr->video_thread.poke_interface = NULL; } /** * video_init_thread: * @out_driver : Output video driver * @out_data : Output video data * @input : Input input driver * @input_data : Input input data * @driver : Input Video driver * @info : Video info handle. * * Creates, initializes and starts a video driver in a new thread. * Access to video driver will be mediated through this driver. * * Returns: true (1) if successful, otherwise false (0). **/ bool video_init_thread(const video_driver_t **out_driver, void **out_data, const input_driver_t **input, void **input_data, const video_driver_t *drv, const video_info_t info) { thread_video_t *thr = (thread_video_t*)calloc(1, sizeof(*thr)); if (!thr) return false; video_thread_set_callbacks(thr, drv); thr->driver = drv; *out_driver = &thr->video_thread; *out_data = thr; return video_thread_init(thr, info, input, input_data); } /** * video_thread_get_ptr: * @drv : Found driver. * * Gets the underlying video driver associated with the * threaded video wrapper. Sets @drv to the found * video driver. * * Returns: Video driver data of the video driver associated * with the threaded wrapper (if successful). If not successful, * NULL. **/ void *video_thread_get_ptr(const video_driver_t **drv) { const thread_video_t *thr = (const thread_video_t*) video_driver_get_ptr(true); if (drv) *drv = thr->driver; if (!thr) return NULL; return thr->driver_data; } const char *video_thread_get_ident(void) { const thread_video_t *thr = (const thread_video_t*) video_driver_get_ptr(true); if (!thr || !thr->driver) return NULL; return thr->driver->ident; } static void video_thread_send_and_wait(thread_video_t *thr, thread_packet_t *pkt) { if (!thr || !pkt) return; thr->send_and_wait(thr, pkt); } bool video_thread_font_init(const void **font_driver, void **font_handle, void *data, const char *font_path, float font_size, enum font_driver_render_api api, custom_font_command_method_t func, bool is_threaded) { thread_packet_t pkt; thread_video_t *thr = (thread_video_t*)video_driver_get_ptr(true); if (!thr) return false; pkt.type = CMD_FONT_INIT; pkt.data.font_init.method = func; pkt.data.font_init.font_driver = font_driver; pkt.data.font_init.font_handle = font_handle; pkt.data.font_init.video_data = data; pkt.data.font_init.font_path = font_path; pkt.data.font_init.font_size = font_size; pkt.data.font_init.is_threaded = is_threaded; pkt.data.font_init.api = api; video_thread_send_and_wait(thr, &pkt); return pkt.data.font_init.return_value; } unsigned video_thread_texture_load(void *data, custom_command_method_t func) { thread_video_t *thr = (thread_video_t*)video_driver_get_ptr(true); thread_packet_t pkt = { CMD_CUSTOM_COMMAND }; if (!thr) return 0; pkt.data.custom_command.method = func; pkt.data.custom_command.data = (void*)data; video_thread_send_and_wait(thr, &pkt); return pkt.data.custom_command.return_value; }