#include "stdafx.h" #include "cellGem.h" #include "cellCamera.h" #include "Emu/Cell/PPUModule.h" #include "Emu/Cell/timers.hpp" #include "Emu/Io/MouseHandler.h" #include "Emu/system_config.h" #include "Emu/IdManager.h" #include "Input/pad_thread.h" #include // for fmod LOG_CHANNEL(cellGem); template <> void fmt_class_string::format(std::string& out, u64 arg) { format_enum(out, arg, [](auto error) { switch (error) { STR_CASE(CELL_GEM_ERROR_RESOURCE_ALLOCATION_FAILED); STR_CASE(CELL_GEM_ERROR_ALREADY_INITIALIZED); STR_CASE(CELL_GEM_ERROR_UNINITIALIZED); STR_CASE(CELL_GEM_ERROR_INVALID_PARAMETER); STR_CASE(CELL_GEM_ERROR_INVALID_ALIGNMENT); STR_CASE(CELL_GEM_ERROR_UPDATE_NOT_FINISHED); STR_CASE(CELL_GEM_ERROR_UPDATE_NOT_STARTED); STR_CASE(CELL_GEM_ERROR_CONVERT_NOT_FINISHED); STR_CASE(CELL_GEM_ERROR_CONVERT_NOT_STARTED); STR_CASE(CELL_GEM_ERROR_WRITE_NOT_FINISHED); STR_CASE(CELL_GEM_ERROR_NOT_A_HUE); } return unknown; }); } template <> void fmt_class_string::format(std::string& out, u64 arg) { format_enum(out, arg, [](auto error) { switch (error) { STR_CASE(CELL_GEM_NOT_CONNECTED); STR_CASE(CELL_GEM_SPHERE_NOT_CALIBRATED); STR_CASE(CELL_GEM_SPHERE_CALIBRATING); STR_CASE(CELL_GEM_COMPUTING_AVAILABLE_COLORS); STR_CASE(CELL_GEM_HUE_NOT_SET); STR_CASE(CELL_GEM_NO_VIDEO); STR_CASE(CELL_GEM_TIME_OUT_OF_RANGE); STR_CASE(CELL_GEM_NOT_CALIBRATED); STR_CASE(CELL_GEM_NO_EXTERNAL_PORT_DEVICE); } return unknown; }); } // ********************** // * HLE helper structs * // ********************** struct gem_config { atomic_t state = 0; struct gem_color { float r, g, b; gem_color() : r(0.0f), g(0.0f), b(0.0f) {} gem_color(float r_, float g_, float b_) { r = std::clamp(r_, 0.0f, 1.0f); g = std::clamp(g_, 0.0f, 1.0f); b = std::clamp(b_, 0.0f, 1.0f); } }; struct gem_controller { u32 status = CELL_GEM_STATUS_DISCONNECTED; // Connection status (CELL_GEM_STATUS_DISCONNECTED or CELL_GEM_STATUS_READY) u32 ext_status = CELL_GEM_NO_EXTERNAL_PORT_DEVICE; // External port connection status u32 ext_id = 0; // External device ID (type). For example SHARP_SHOOTER_DEVICE_ID u32 port = 0; // Assigned port bool enabled_magnetometer = false; // Whether the magnetometer is enabled (probably used for additional rotational precision) bool calibrated_magnetometer = false; // Whether the magnetometer is calibrated bool enabled_filtering = false; // Whether filtering is enabled bool enabled_tracking = false; // Whether tracking is enabled bool enabled_LED = false; // Whether the LED is enabled bool hue_set = false; // Whether the hue was set u8 rumble = 0; // Rumble intensity gem_color sphere_rgb = {}; // RGB color of the sphere LED u32 hue = 0; // Tracking hue of the motion controller u32 distance{1500}; // Distance from the camera in mm u32 radius{10}; // Radius of the sphere in camera pixels static constexpr s32 diameter_mm = 45; // Physical diameter of the sphere in millimeter }; CellGemAttribute attribute = {}; CellGemVideoConvertAttribute vc_attribute = {}; u64 status_flags = 0; bool enable_pitch_correction = false; u32 inertial_counter = 0; std::array controllers; u32 connected_controllers = 0; bool video_conversion_started{}; bool update_started{}; u32 camera_frame{}; u32 memory_ptr{}; shared_mutex mtx; u64 start_timestamp = 0; // helper functions bool is_controller_ready(u32 gem_num) const { return controllers[gem_num].status == CELL_GEM_STATUS_READY; } void reset_controller(u32 gem_num) { switch (g_cfg.io.move) { case move_handler::fake: case move_handler::mouse: { connected_controllers = 1; break; } case move_handler::null: default: break; } // Assign status and port number if (gem_num < connected_controllers) { controllers[gem_num].status = CELL_GEM_STATUS_READY; controllers[gem_num].port = 7u - gem_num; } } }; /** * \brief Verifies that a Move controller id is valid * \param gem_num Move controler ID to verify * \return True if the ID is valid, false otherwise */ static bool check_gem_num(const u32 gem_num) { return gem_num < CELL_GEM_MAX_NUM; } /** * \brief Maps Move controller data (digital buttons, and analog Trigger data) to DS3 pad input. * Unavoidably buttons conflict with DS3 mappings, which is problematic for some games. * \param port_no DS3 port number to use * \param digital_buttons Bitmask filled with CELL_GEM_CTRL_* values * \param analog_t Analog value of Move's Trigger. Currently mapped to R2. * \return true on success, false if port_no controller is invalid */ static bool ds3_input_to_pad(const u32 port_no, be_t& digital_buttons, be_t& analog_t) { std::scoped_lock lock(pad::g_pad_mutex); const auto handler = pad::get_current_handler(); auto& pad = handler->GetPads()[port_no]; if (!(pad->m_port_status & CELL_PAD_STATUS_CONNECTED)) return false; for (Button& button : pad->m_buttons) { // here we check btns, and set pad accordingly if (button.m_offset == CELL_PAD_BTN_OFFSET_DIGITAL2) { if (button.m_pressed) pad->m_digital_2 |= button.m_outKeyCode; else pad->m_digital_2 &= ~button.m_outKeyCode; switch (button.m_outKeyCode) { case CELL_PAD_CTRL_SQUARE: pad->m_press_square = button.m_value; break; case CELL_PAD_CTRL_CROSS: pad->m_press_cross = button.m_value; break; case CELL_PAD_CTRL_CIRCLE: pad->m_press_circle = button.m_value; break; case CELL_PAD_CTRL_TRIANGLE: pad->m_press_triangle = button.m_value; break; case CELL_PAD_CTRL_R1: pad->m_press_R1 = button.m_value; break; case CELL_PAD_CTRL_L1: pad->m_press_L1 = button.m_value; break; case CELL_PAD_CTRL_R2: pad->m_press_R2 = button.m_value; break; case CELL_PAD_CTRL_L2: pad->m_press_L2 = button.m_value; break; default: break; } } } digital_buttons = 0; // map the Move key to R1 and the Trigger to R2 if (pad->m_press_R1) digital_buttons |= CELL_GEM_CTRL_MOVE; if (pad->m_press_R2) digital_buttons |= CELL_GEM_CTRL_T; if (pad->m_press_cross) digital_buttons |= CELL_GEM_CTRL_CROSS; if (pad->m_press_circle) digital_buttons |= CELL_GEM_CTRL_CIRCLE; if (pad->m_press_square) digital_buttons |= CELL_GEM_CTRL_SQUARE; if (pad->m_press_triangle) digital_buttons |= CELL_GEM_CTRL_TRIANGLE; if (pad->m_digital_1) digital_buttons |= CELL_GEM_CTRL_SELECT; if (pad->m_digital_2) digital_buttons |= CELL_GEM_CTRL_START; analog_t = pad->m_press_R2; return true; } /** * \brief Maps external Move controller data to DS3 input. (This can be input from any physical pad, not just the DS3) * Implementation detail: CellGemExtPortData's digital/analog fields map the same way as * libPad, so no translation is needed. * \param port_no DS3 port number to use * \param ext External data to modify * \return true on success, false if port_no controller is invalid */ static bool ds3_input_to_ext(const u32 port_no, const gem_config::gem_controller& controller, CellGemExtPortData& ext) { std::scoped_lock lock(pad::g_pad_mutex); const auto handler = pad::get_current_handler(); auto& pad = handler->GetPads()[port_no]; if (!(pad->m_port_status & CELL_PAD_STATUS_CONNECTED)) return false; ext.status = 0; // CELL_GEM_EXT_CONNECTED | CELL_GEM_EXT_EXT0 | CELL_GEM_EXT_EXT1 ext.analog_left_x = pad->m_analog_left_x; ext.analog_left_y = pad->m_analog_left_y; ext.analog_right_x = pad->m_analog_right_x; ext.analog_right_y = pad->m_analog_right_y; ext.digital1 = pad->m_digital_1; ext.digital2 = pad->m_digital_2; if (controller.ext_id == SHARP_SHOOTER_DEVICE_ID) { // TODO set custom[0] bits as follows: // 1xxxxxxx: RL reload button is pressed. // x1xxxxxx: T button trigger is pressed. // xxxxx001: Firing mode selector is in position 1. // xxxxx010: Firing mode selector is in position 2. // xxxxx100: Firing mode selector is in position 3. } return true; } /** * \brief Maps Move controller data (digital buttons, and analog Trigger data) to mouse input. * Move Button: Mouse1 * Trigger: Mouse2 * \param mouse_no Mouse index number to use * \param digital_buttons Bitmask filled with CELL_GEM_CTRL_* values * \param analog_t Analog value of Move's Trigger. * \return true on success, false if mouse_no is invalid */ static bool mouse_input_to_pad(const u32 mouse_no, be_t& digital_buttons, be_t& analog_t) { auto& handler = g_fxo->get(); std::scoped_lock lock(handler.mutex); if (mouse_no >= handler.GetMice().size()) { return false; } const auto& mouse_data = handler.GetMice().at(0); const auto is_pressed = [&mouse_data](MouseButtonCodes button) -> bool { return !!(mouse_data.buttons & button); }; digital_buttons = 0; if (is_pressed(CELL_MOUSE_BUTTON_1)) digital_buttons |= CELL_GEM_CTRL_T; if (is_pressed(CELL_MOUSE_BUTTON_2)) digital_buttons |= CELL_GEM_CTRL_MOVE; if (is_pressed(CELL_MOUSE_BUTTON_3)) digital_buttons |= CELL_GEM_CTRL_CROSS; if (is_pressed(CELL_MOUSE_BUTTON_4)) digital_buttons |= CELL_GEM_CTRL_CIRCLE; if (is_pressed(CELL_MOUSE_BUTTON_5)) digital_buttons |= CELL_GEM_CTRL_SQUARE; if (is_pressed(CELL_MOUSE_BUTTON_6) || (is_pressed(CELL_MOUSE_BUTTON_1) && is_pressed(CELL_MOUSE_BUTTON_2))) digital_buttons |= CELL_GEM_CTRL_SELECT; if (is_pressed(CELL_MOUSE_BUTTON_7) || (is_pressed(CELL_MOUSE_BUTTON_1) && is_pressed(CELL_MOUSE_BUTTON_3))) digital_buttons |= CELL_GEM_CTRL_START; if (is_pressed(CELL_MOUSE_BUTTON_8) || (is_pressed(CELL_MOUSE_BUTTON_2) && is_pressed(CELL_MOUSE_BUTTON_3))) digital_buttons |= CELL_GEM_CTRL_TRIANGLE; analog_t = (mouse_data.buttons & CELL_MOUSE_BUTTON_1) ? 0xFFFF : 0; return true; } static bool mouse_pos_to_gem_image_state(const u32 mouse_no, const gem_config::gem_controller& controller, vm::ptr& gem_image_state) { auto& handler = g_fxo->get(); std::scoped_lock lock(handler.mutex); if (!gem_image_state || mouse_no >= handler.GetMice().size()) { return false; } const auto& mouse = handler.GetMice().at(0); const auto& shared_data = g_fxo->get(); s32 mouse_width = mouse.x_max; if (mouse_width <= 0) mouse_width = shared_data.width; s32 mouse_height = mouse.y_max; if (mouse_height <= 0) mouse_height = shared_data.height; const f32 scaling_width = mouse_width / static_cast(shared_data.width); const f32 scaling_height = mouse_height / static_cast(shared_data.height); const f32 mmPerPixel = controller.diameter_mm / static_cast(controller.radius * 2); // Image coordinates in pixels const f32 image_x = static_cast(mouse.x_pos) / scaling_width; const f32 image_y = static_cast(mouse.y_pos) / scaling_height; // Centered image coordinates in pixels const f32 centered_x = image_x - (shared_data.width / 2.f); const f32 centered_y = (shared_data.height / 2.f) - image_y; // Image coordinates increase downwards, so we have to invert this // Camera coordinates in mm (centered, so it's the same as world coordinates) const f32 camera_x = centered_x * mmPerPixel; const f32 camera_y = centered_y * mmPerPixel; // Image coordinates in pixels gem_image_state->u = image_x; gem_image_state->v = image_y; // Projected camera coordinates in mm gem_image_state->projectionx = camera_x / controller.distance; gem_image_state->projectiony = camera_y / controller.distance; return true; } static bool mouse_pos_to_gem_state(const u32 mouse_no, const gem_config::gem_controller& controller, vm::ptr& gem_state) { auto& handler = g_fxo->get(); std::scoped_lock lock(handler.mutex); if (!gem_state || mouse_no >= handler.GetMice().size()) { return false; } const auto& mouse = handler.GetMice().at(0); const auto& shared_data = g_fxo->get(); s32 mouse_width = mouse.x_max; if (mouse_width <= 0) mouse_width = shared_data.width; s32 mouse_height = mouse.y_max; if (mouse_height <= 0) mouse_height = shared_data.height; const f32 scaling_width = mouse_width / static_cast(shared_data.width); const f32 scaling_height = mouse_height / static_cast(shared_data.height); const f32 mmPerPixel = controller.diameter_mm / static_cast(controller.radius * 2); // Image coordinates in pixels const f32 image_x = static_cast(mouse.x_pos) / scaling_width; const f32 image_y = static_cast(mouse.y_pos) / scaling_height; // Centered image coordinates in pixels const f32 centered_x = image_x - (shared_data.width / 2.f); const f32 centered_y = (shared_data.height / 2.f) - image_y; // Image coordinates increase downwards, so we have to invert this // Camera coordinates in mm (centered, so it's the same as world coordinates) const f32 camera_x = centered_x * mmPerPixel; const f32 camera_y = centered_y * mmPerPixel; // World coordinates in mm gem_state->pos[0] = camera_x; gem_state->pos[1] = camera_y; gem_state->pos[2] = static_cast(controller.distance); gem_state->pos[3] = 0.f; gem_state->quat[0] = 320.f - image_x; gem_state->quat[1] = (mouse.y_pos / scaling_width) - 180.f; gem_state->quat[2] = 1200.f; // TODO: calculate handle position based on our world coordinate and the angles gem_state->handle_pos[0] = camera_x; gem_state->handle_pos[1] = camera_y; gem_state->handle_pos[2] = static_cast(controller.distance + 10); gem_state->handle_pos[3] = 0.f; return true; } // ********************* // * cellGem functions * // ********************* error_code cellGemCalibrate(u32 gem_num) { cellGem.todo("cellGemCalibrate(gem_num=%d)", gem_num); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (g_cfg.io.move == move_handler::fake || g_cfg.io.move == move_handler::mouse) { gem.controllers[gem_num].calibrated_magnetometer = true; gem.controllers[gem_num].enabled_tracking = true; gem.controllers[gem_num].hue = 1; gem.status_flags = CELL_GEM_FLAG_CALIBRATION_SUCCEEDED; } return CELL_OK; } error_code cellGemClearStatusFlags(u32 gem_num, u64 mask) { cellGem.todo("cellGemClearStatusFlags(gem_num=%d, mask=0x%x)", gem_num, mask); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } gem.status_flags &= ~mask; return CELL_OK; } error_code cellGemConvertVideoFinish() { cellGem.todo("cellGemConvertVideoFinish()"); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!std::exchange(gem.video_conversion_started, false)) { return CELL_GEM_ERROR_CONVERT_NOT_STARTED; } // TODO: wait until image is converted return CELL_OK; } error_code cellGemConvertVideoStart(vm::cptr video_frame) { cellGem.todo("cellGemConvertVideoStart(video_frame=*0x%x)", video_frame); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!video_frame) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (std::exchange(gem.video_conversion_started, true)) { return CELL_GEM_ERROR_CONVERT_NOT_FINISHED; } // TODO: start image conversion of video_frame async to gem.vc_attribute.video_data_out return CELL_OK; } error_code cellGemEnableCameraPitchAngleCorrection(u32 enable_flag) { cellGem.todo("cellGemEnableCameraPitchAngleCorrection(enable_flag=%d)", enable_flag); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } gem.enable_pitch_correction = !!enable_flag; return CELL_OK; } error_code cellGemEnableMagnetometer(u32 gem_num, u32 enable) { cellGem.todo("cellGemEnableMagnetometer(gem_num=%d, enable=0x%x)", gem_num, enable); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!gem.is_controller_ready(gem_num)) { return CELL_GEM_NOT_CONNECTED; } gem.controllers[gem_num].enabled_magnetometer = !!enable; return CELL_OK; } error_code cellGemEnableMagnetometer2() { UNIMPLEMENTED_FUNC(cellGem); return CELL_OK; } error_code cellGemEnd(ppu_thread& ppu) { cellGem.warning("cellGemEnd()"); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (gem.state.compare_and_swap_test(1, 0)) { if (u32 addr = gem.memory_ptr) { sys_memory_free(ppu, addr); } return CELL_OK; } return CELL_GEM_ERROR_UNINITIALIZED; } error_code cellGemFilterState(u32 gem_num, u32 enable) { cellGem.warning("cellGemFilterState(gem_num=%d, enable=%d)", gem_num, enable); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } gem.controllers[gem_num].enabled_filtering = !!enable; return CELL_OK; } error_code cellGemForceRGB(u32 gem_num, float r, float g, float b) { cellGem.todo("cellGemForceRGB(gem_num=%d, r=%f, g=%f, b=%f)", gem_num, r, g, b); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } // TODO: Adjust brightness //if (const f32 sum = r + g + b; sum > 2.f) //{ // color = color * (2.f / sum) //} gem.controllers[gem_num].sphere_rgb = gem_config::gem_color(r, g, b); gem.controllers[gem_num].enabled_tracking = false; return CELL_OK; } error_code cellGemGetAccelerometerPositionInDevice(u32 gem_num, vm::ptr pos) { cellGem.todo("cellGemGetAccelerometerPositionInDevice(gem_num=%d, pos=*0x%x)", gem_num, pos); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || !pos) { return CELL_GEM_ERROR_INVALID_PARAMETER; } return CELL_OK; } error_code cellGemGetAllTrackableHues(vm::ptr hues) { cellGem.todo("cellGemGetAllTrackableHues(hues=*0x%x)"); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!hues) { return CELL_GEM_ERROR_INVALID_PARAMETER; } for (u32 i = 0; i < 360; i++) { hues[i] = true; } return CELL_OK; } error_code cellGemGetCameraState(vm::ptr camera_state) { cellGem.todo("cellGemGetCameraState(camera_state=0x%x)", camera_state); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!camera_state) { return CELL_GEM_ERROR_INVALID_PARAMETER; } camera_state->exposure_time = 1.0f / 60.0f; // TODO: use correct framerate camera_state->gain = 1.0; return CELL_OK; } error_code cellGemGetEnvironmentLightingColor(vm::ptr r, vm::ptr g, vm::ptr b) { cellGem.todo("cellGemGetEnvironmentLightingColor(r=*0x%x, g=*0x%x, b=*0x%x)", r, g, b); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!r || !g || !b) { return CELL_GEM_ERROR_INVALID_PARAMETER; } // default to 128 *r = 128; *g = 128; *b = 128; return CELL_OK; } error_code cellGemGetHuePixels(vm::cptr camera_frame, u32 hue, vm::ptr pixels) { cellGem.todo("cellGemGetHuePixels(camera_frame=*0x%x, hue=%d, pixels=*0x%x)", camera_frame, hue, pixels); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!camera_frame || !pixels || hue > 359) { return CELL_GEM_ERROR_INVALID_PARAMETER; } return CELL_OK; } error_code cellGemGetImageState(u32 gem_num, vm::ptr gem_image_state) { cellGem.todo("cellGemGetImageState(gem_num=%d, image_state=&0x%x)", gem_num, gem_image_state); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || !gem_image_state) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (g_cfg.io.move == move_handler::fake || g_cfg.io.move == move_handler::mouse) { auto& shared_data = g_fxo->get(); gem_image_state->frame_timestamp = shared_data.frame_timestamp.load(); gem_image_state->timestamp = gem_image_state->frame_timestamp + 10; gem_image_state->r = gem.controllers[gem_num].radius; // Radius in camera pixels gem_image_state->distance = gem.controllers[gem_num].distance; // 1.5 meters away from camera gem_image_state->visible = gem.is_controller_ready(gem_num); gem_image_state->r_valid = true; if (g_cfg.io.move == move_handler::fake) { gem_image_state->u = 0; gem_image_state->v = 0; gem_image_state->projectionx = 1; gem_image_state->projectiony = 1; } else if (g_cfg.io.move == move_handler::mouse) { mouse_pos_to_gem_image_state(gem_num, gem.controllers[gem_num], gem_image_state); } } return CELL_OK; } error_code cellGemGetInertialState(u32 gem_num, u32 state_flag, u64 timestamp, vm::ptr inertial_state) { cellGem.warning("cellGemGetInertialState(gem_num=%d, state_flag=%d, timestamp=0x%x, inertial_state=0x%x)", gem_num, state_flag, timestamp, inertial_state); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || state_flag > CELL_GEM_INERTIAL_STATE_FLAG_NEXT || !inertial_state || !gem.is_controller_ready(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (g_cfg.io.move == move_handler::fake || g_cfg.io.move == move_handler::mouse) { ds3_input_to_ext(gem_num, gem.controllers[gem_num], inertial_state->ext); inertial_state->timestamp = (get_guest_system_time() - gem.start_timestamp); inertial_state->counter = gem.inertial_counter++; inertial_state->accelerometer[0] = 10; // Current gravity in m/s² if (g_cfg.io.move == move_handler::fake) { ds3_input_to_pad(gem_num, inertial_state->pad.digitalbuttons, inertial_state->pad.analog_T); } else if (g_cfg.io.move == move_handler::mouse) { mouse_input_to_pad(gem_num, inertial_state->pad.digitalbuttons, inertial_state->pad.analog_T); } } return CELL_OK; } error_code cellGemGetInfo(vm::ptr info) { cellGem.warning("cellGemGetInfo(info=*0x%x)", info); auto& gem = g_fxo->get(); reader_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!info) { return CELL_GEM_ERROR_INVALID_PARAMETER; } // TODO: Support connecting PlayStation Move controllers info->max_connect = gem.attribute.max_connect; info->now_connect = gem.connected_controllers; for (int i = 0; i < CELL_GEM_MAX_NUM; i++) { info->status[i] = gem.controllers[i].status; info->port[i] = gem.controllers[i].port; } return CELL_OK; } u32 GemGetMemorySize(s32 max_connect) { return max_connect <= 2 ? 0x120000 : 0x140000; } error_code cellGemGetMemorySize(s32 max_connect) { cellGem.warning("cellGemGetMemorySize(max_connect=%d)", max_connect); if (max_connect > CELL_GEM_MAX_NUM || max_connect <= 0) { return CELL_GEM_ERROR_INVALID_PARAMETER; } return not_an_error(GemGetMemorySize(max_connect)); } error_code cellGemGetRGB(u32 gem_num, vm::ptr r, vm::ptr g, vm::ptr b) { cellGem.todo("cellGemGetRGB(gem_num=%d, r=*0x%x, g=*0x%x, b=*0x%x)", gem_num, r, g, b); auto& gem = g_fxo->get(); reader_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || !r || !g || !b) { return CELL_GEM_ERROR_INVALID_PARAMETER; } auto& sphere_color = gem.controllers[gem_num].sphere_rgb; *r = sphere_color.r; *g = sphere_color.g; *b = sphere_color.b; return CELL_OK; } error_code cellGemGetRumble(u32 gem_num, vm::ptr rumble) { cellGem.todo("cellGemGetRumble(gem_num=%d, rumble=*0x%x)", gem_num, rumble); auto& gem = g_fxo->get(); reader_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || !rumble) { return CELL_GEM_ERROR_INVALID_PARAMETER; } *rumble = gem.controllers[gem_num].rumble; return CELL_OK; } error_code cellGemGetState(u32 gem_num, u32 flag, u64 time_parameter, vm::ptr gem_state) { cellGem.warning("cellGemGetState(gem_num=%d, flag=0x%x, time=0x%llx, gem_state=*0x%x)", gem_num, flag, time_parameter, gem_state); auto& gem = g_fxo->get(); reader_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || flag > CELL_GEM_STATE_FLAG_TIMESTAMP || !gem_state) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (!gem.is_controller_ready(gem_num)) { return CELL_GEM_NOT_CONNECTED; } // TODO: Get the gem state at the specified time //if (flag == CELL_GEM_STATE_FLAG_CURRENT_TIME) //{ // // now + time_parameter (time_parameter in microseconds). Positive values actually allow predictions for the future state. //} //else if (flag == CELL_GEM_STATE_FLAG_LATEST_IMAGE_TIME) //{ // // When the sphere was registered during the last camera frame (time_parameter may also have an impact) //} //else // CELL_GEM_STATE_FLAG_TIMESTAMP //{ // // As specified by time_parameter. //} if (g_cfg.io.move == move_handler::fake || g_cfg.io.move == move_handler::mouse) { ds3_input_to_ext(gem_num, gem.controllers[gem_num], gem_state->ext); u32 tracking_flags = CELL_GEM_TRACKING_FLAG_VISIBLE; if (gem.controllers[gem_num].enabled_tracking) tracking_flags |= CELL_GEM_TRACKING_FLAG_POSITION_TRACKED; *gem_state = {}; gem_state->tracking_flags = tracking_flags; gem_state->timestamp = (get_guest_system_time() - gem.start_timestamp); gem_state->camera_pitch_angle = 0.f; gem_state->quat[3] = 1.f; if (g_cfg.io.move == move_handler::fake) { ds3_input_to_pad(gem_num, gem_state->pad.digitalbuttons, gem_state->pad.analog_T); } else if (g_cfg.io.move == move_handler::mouse) { mouse_input_to_pad(gem_num, gem_state->pad.digitalbuttons, gem_state->pad.analog_T); mouse_pos_to_gem_state(gem_num, gem.controllers[gem_num], gem_state); } } // TODO: verify position of this check. gem_state seems to be polled regardless (otherwise you would never be able to calibrate anyway) if (!gem.controllers[gem_num].calibrated_magnetometer) { return CELL_GEM_SPHERE_NOT_CALIBRATED; } // TODO: verify position of this check if (!gem.controllers[gem_num].hue_set) { return CELL_GEM_HUE_NOT_SET; } return CELL_OK; } error_code cellGemGetStatusFlags(u32 gem_num, vm::ptr flags) { cellGem.todo("cellGemGetStatusFlags(gem_num=%d, flags=*0x%x)", gem_num, flags); auto& gem = g_fxo->get(); reader_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || !flags) { return CELL_GEM_ERROR_INVALID_PARAMETER; } *flags = gem.status_flags; return CELL_OK; } error_code cellGemGetTrackerHue(u32 gem_num, vm::ptr hue) { cellGem.warning("cellGemGetTrackerHue(gem_num=%d, hue=*0x%x)", gem_num, hue); auto& gem = g_fxo->get(); reader_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || !hue) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (!gem.controllers[gem_num].enabled_tracking || gem.controllers[gem_num].hue > 359) { return { CELL_GEM_ERROR_NOT_A_HUE, gem.controllers[gem_num].hue }; } *hue = gem.controllers[gem_num].hue; return CELL_OK; } error_code cellGemHSVtoRGB(f32 h, f32 s, f32 v, vm::ptr r, vm::ptr g, vm::ptr b) { cellGem.warning("cellGemHSVtoRGB(h=%f, s=%f, v=%f, r=*0x%x, g=*0x%x, b=*0x%x)", h, s, v, r, g, b); if (s < 0.0f || s > 1.0f || v < 0.0f || v > 1.0f || !r || !g || !b) { return CELL_GEM_ERROR_INVALID_PARAMETER; } h = std::clamp(h, 0.0f, 360.0f); const f32 c = v * s; const f32 x = c * (1.0f - abs(fmod(h / 60.0f, 2.0f) - 1.0f)); const f32 m = v - c; f32 r_tmp{0.0}; f32 g_tmp{0.0}; f32 b_tmp{0.0}; if (h < 60.0f) { r_tmp = c; g_tmp = x; } else if (h < 120.0f) { r_tmp = x; g_tmp = c; } else if (h < 180.0f) { g_tmp = c; b_tmp = x; } else if (h < 240.0f) { g_tmp = x; b_tmp = c; } else if (h < 300.0f) { r_tmp = x; b_tmp = c; } else { r_tmp = c; b_tmp = x; } *r = (r_tmp + m) * 255.0f; *g = (g_tmp + m) * 255.0f; *b = (b_tmp + m) * 255.0f; return CELL_OK; } error_code cellGemInit(ppu_thread& ppu, vm::cptr attribute) { cellGem.warning("cellGemInit(attribute=*0x%x)", attribute); auto& gem = g_fxo->get(); if (!attribute || !attribute->spurs_addr || !attribute->max_connect || attribute->max_connect > CELL_GEM_MAX_NUM) { return CELL_GEM_ERROR_INVALID_PARAMETER; } std::scoped_lock lock(gem.mtx); if (!gem.state.compare_and_swap_test(0, 1)) { return CELL_GEM_ERROR_ALREADY_INITIALIZED; } if (!attribute->memory_ptr) { vm::var addr(0); // Decrease memory stats if (sys_memory_allocate(ppu, GemGetMemorySize(attribute->max_connect), SYS_MEMORY_PAGE_SIZE_64K, +addr) != CELL_OK) { return CELL_GEM_ERROR_RESOURCE_ALLOCATION_FAILED; } gem.memory_ptr = *addr; } else { gem.memory_ptr = 0; } gem.update_started = false; gem.camera_frame = 0; gem.status_flags = 0; gem.attribute = *attribute; if (g_cfg.io.move == move_handler::mouse) { // init mouse handler auto& handler = g_fxo->get(); handler.Init(std::min(attribute->max_connect, CELL_GEM_MAX_NUM)); } for (int gem_num = 0; gem_num < CELL_GEM_MAX_NUM; gem_num++) { gem.reset_controller(gem_num); } // TODO: is this correct? gem.start_timestamp = get_guest_system_time(); return CELL_OK; } error_code cellGemInvalidateCalibration(s32 gem_num) { cellGem.todo("cellGemInvalidateCalibration(gem_num=%d)", gem_num); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (g_cfg.io.move == move_handler::fake || g_cfg.io.move == move_handler::mouse) { gem.controllers[gem_num].calibrated_magnetometer = false; // TODO: gem.status_flags (probably not changed) } return CELL_OK; } s32 cellGemIsTrackableHue(u32 hue) { cellGem.todo("cellGemIsTrackableHue(hue=%d)", hue); auto& gem = g_fxo->get(); if (!gem.state || hue > 359) { return false; } return true; } error_code cellGemPrepareCamera(s32 max_exposure, f32 image_quality) { cellGem.todo("cellGemPrepareCamera(max_exposure=%d, image_quality=%f)", max_exposure, image_quality); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } max_exposure = std::clamp(max_exposure, static_cast(CELL_GEM_MIN_CAMERA_EXPOSURE), static_cast(CELL_GEM_MAX_CAMERA_EXPOSURE)); image_quality = std::clamp(image_quality, 0.0f, 1.0f); // TODO: prepare camera return CELL_OK; } error_code cellGemPrepareVideoConvert(vm::cptr vc_attribute) { cellGem.todo("cellGemPrepareVideoConvert(vc_attribute=*0x%x)", vc_attribute); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!vc_attribute) { return CELL_GEM_ERROR_INVALID_PARAMETER; } const auto vc = *vc_attribute; if (!vc_attribute || vc.version != CELL_GEM_VERSION) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (vc.output_format != CELL_GEM_NO_VIDEO_OUTPUT) { if (!vc.video_data_out || ((vc.conversion_flags & CELL_GEM_COMBINE_PREVIOUS_INPUT_FRAME) && !vc.buffer_memory)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } } if (!vc.video_data_out.aligned(16) || !vc.buffer_memory.aligned(128)) { return CELL_GEM_ERROR_INVALID_ALIGNMENT; } gem.vc_attribute = vc; return CELL_OK; } error_code cellGemReadExternalPortDeviceInfo(u32 gem_num, vm::ptr ext_id, vm::ptr ext_info) { cellGem.todo("cellGemReadExternalPortDeviceInfo(gem_num=%d, ext_id=*0x%x, ext_info=%s)", gem_num, ext_id, ext_info); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num) || !ext_id) { return CELL_GEM_ERROR_INVALID_PARAMETER; } if (gem.controllers[gem_num].status & CELL_GEM_STATUS_DISCONNECTED) { return CELL_GEM_NOT_CONNECTED; } if (!(gem.controllers[gem_num].ext_status & CELL_GEM_EXT_CONNECTED)) { return CELL_GEM_NO_EXTERNAL_PORT_DEVICE; } *ext_id = gem.controllers[gem_num].ext_id; return CELL_OK; } error_code cellGemReset(u32 gem_num) { cellGem.todo("cellGemReset(gem_num=%d)", gem_num); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } gem.reset_controller(gem_num); // TODO: is this correct? gem.start_timestamp = get_guest_system_time(); return CELL_OK; } error_code cellGemSetRumble(u32 gem_num, u8 rumble) { cellGem.todo("cellGemSetRumble(gem_num=%d, rumble=0x%x)", gem_num, rumble); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } gem.controllers[gem_num].rumble = rumble; return CELL_OK; } error_code cellGemSetYaw(u32 gem_num, vm::ptr z_direction) { cellGem.todo("cellGemSetYaw(gem_num=%d, z_direction=*0x%x)", gem_num, z_direction); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!z_direction) { return CELL_GEM_ERROR_INVALID_PARAMETER; } // TODO return CELL_OK; } error_code cellGemTrackHues(vm::cptr req_hues, vm::ptr res_hues) { cellGem.todo("cellGemTrackHues(req_hues=*0x%x, res_hues=*0x%x)", req_hues, res_hues); auto& gem = g_fxo->get(); std::scoped_lock lock(gem.mtx); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!req_hues) { return CELL_GEM_ERROR_INVALID_PARAMETER; } for (u32 i = 0; i < CELL_GEM_MAX_NUM; i++) { if (req_hues[i] == CELL_GEM_DONT_CARE_HUE) { gem.controllers[i].enabled_tracking = true; gem.controllers[i].enabled_LED = true; switch (i) { default: case 0: gem.controllers[i].hue = 240; // blue break; case 1: gem.controllers[i].hue = 0; // red break; case 2: gem.controllers[i].hue = 120; // green break; case 3: gem.controllers[i].hue = 300; // purple break; } if (res_hues) { res_hues[i] = gem.controllers[i].hue; } } else if (req_hues[i] == CELL_GEM_DONT_TRACK_HUE) { gem.controllers[i].enabled_tracking = false; gem.controllers[i].enabled_LED = false; if (res_hues) { res_hues[i] = CELL_GEM_DONT_TRACK_HUE; } } else { if (req_hues[i] > 359) { cellGem.warning("cellGemTrackHues: req_hues[%d]=%d -> this can lead to unexpected behavior", i, req_hues[i]); } gem.controllers[i].enabled_tracking = true; gem.controllers[i].enabled_LED = true; gem.controllers[i].hue = req_hues[i]; if (res_hues) { res_hues[i] = gem.controllers[i].hue; } } gem.controllers[i].hue_set = true; } return CELL_OK; } error_code cellGemUpdateFinish() { cellGem.warning("cellGemUpdateFinish()"); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } std::scoped_lock lock(gem.mtx); if (!std::exchange(gem.update_started, false)) { return CELL_GEM_ERROR_UPDATE_NOT_STARTED; } if (!gem.camera_frame) { return not_an_error(CELL_GEM_NO_VIDEO); } return CELL_OK; } error_code cellGemUpdateStart(vm::cptr camera_frame, u64 timestamp) { cellGem.warning("cellGemUpdateStart(camera_frame=*0x%x, timestamp=%d)", camera_frame, timestamp); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } std::scoped_lock lock(gem.mtx); // Update is starting even when camera_frame is null if (std::exchange(gem.update_started, true)) { return CELL_GEM_ERROR_UPDATE_NOT_FINISHED; } gem.camera_frame = camera_frame.addr(); if (!camera_frame) { return not_an_error(CELL_GEM_NO_VIDEO); } return CELL_OK; } error_code cellGemWriteExternalPort(u32 gem_num, vm::ptr data) { cellGem.todo("cellGemWriteExternalPort(gem_num=%d, data=%s)", gem_num, data); auto& gem = g_fxo->get(); if (!gem.state) { return CELL_GEM_ERROR_UNINITIALIZED; } if (!check_gem_num(gem_num)) { return CELL_GEM_ERROR_INVALID_PARAMETER; } return CELL_OK; } DECLARE(ppu_module_manager::cellGem)("libgem", []() { REG_FUNC(libgem, cellGemCalibrate); REG_FUNC(libgem, cellGemClearStatusFlags); REG_FUNC(libgem, cellGemConvertVideoFinish); REG_FUNC(libgem, cellGemConvertVideoStart); REG_FUNC(libgem, cellGemEnableCameraPitchAngleCorrection); REG_FUNC(libgem, cellGemEnableMagnetometer); REG_FUNC(libgem, cellGemEnableMagnetometer2); REG_FUNC(libgem, cellGemEnd); REG_FUNC(libgem, cellGemFilterState); REG_FUNC(libgem, cellGemForceRGB); REG_FUNC(libgem, cellGemGetAccelerometerPositionInDevice); REG_FUNC(libgem, cellGemGetAllTrackableHues); REG_FUNC(libgem, cellGemGetCameraState); REG_FUNC(libgem, cellGemGetEnvironmentLightingColor); REG_FUNC(libgem, cellGemGetHuePixels); REG_FUNC(libgem, cellGemGetImageState); REG_FUNC(libgem, cellGemGetInertialState); REG_FUNC(libgem, cellGemGetInfo); REG_FUNC(libgem, cellGemGetMemorySize); REG_FUNC(libgem, cellGemGetRGB); REG_FUNC(libgem, cellGemGetRumble); REG_FUNC(libgem, cellGemGetState); REG_FUNC(libgem, cellGemGetStatusFlags); REG_FUNC(libgem, cellGemGetTrackerHue); REG_FUNC(libgem, cellGemHSVtoRGB); REG_FUNC(libgem, cellGemInit); REG_FUNC(libgem, cellGemInvalidateCalibration); REG_FUNC(libgem, cellGemIsTrackableHue); REG_FUNC(libgem, cellGemPrepareCamera); REG_FUNC(libgem, cellGemPrepareVideoConvert); REG_FUNC(libgem, cellGemReadExternalPortDeviceInfo); REG_FUNC(libgem, cellGemReset); REG_FUNC(libgem, cellGemSetRumble); REG_FUNC(libgem, cellGemSetYaw); REG_FUNC(libgem, cellGemTrackHues); REG_FUNC(libgem, cellGemUpdateFinish); REG_FUNC(libgem, cellGemUpdateStart); REG_FUNC(libgem, cellGemWriteExternalPort); });