diff options
Diffstat (limited to '')
| -rw-r--r-- | src/input_common/drivers/gc_adapter.cpp (renamed from src/input_common/gcadapter/gc_adapter.cpp) | 489 |
1 files changed, 255 insertions, 234 deletions
diff --git a/src/input_common/gcadapter/gc_adapter.cpp b/src/input_common/drivers/gc_adapter.cpp index a2f1bb67c..7ab4540a8 100644 --- a/src/input_common/gcadapter/gc_adapter.cpp +++ b/src/input_common/drivers/gc_adapter.cpp | |||
| @@ -2,47 +2,103 @@ | |||
| 2 | // Licensed under GPLv2+ | 2 | // Licensed under GPLv2+ |
| 3 | // Refer to the license.txt file included. | 3 | // Refer to the license.txt file included. |
| 4 | 4 | ||
| 5 | #include <chrono> | 5 | #include <fmt/format.h> |
| 6 | #include <thread> | ||
| 7 | |||
| 8 | #include <libusb.h> | 6 | #include <libusb.h> |
| 9 | 7 | ||
| 10 | #include "common/logging/log.h" | 8 | #include "common/logging/log.h" |
| 11 | #include "common/param_package.h" | 9 | #include "common/param_package.h" |
| 12 | #include "common/settings_input.h" | 10 | #include "common/settings_input.h" |
| 13 | #include "input_common/gcadapter/gc_adapter.h" | 11 | #include "common/thread.h" |
| 12 | #include "input_common/drivers/gc_adapter.h" | ||
| 13 | |||
| 14 | namespace InputCommon { | ||
| 15 | |||
| 16 | class LibUSBContext { | ||
| 17 | public: | ||
| 18 | explicit LibUSBContext() { | ||
| 19 | init_result = libusb_init(&ctx); | ||
| 20 | } | ||
| 21 | |||
| 22 | ~LibUSBContext() { | ||
| 23 | libusb_exit(ctx); | ||
| 24 | } | ||
| 25 | |||
| 26 | LibUSBContext& operator=(const LibUSBContext&) = delete; | ||
| 27 | LibUSBContext(const LibUSBContext&) = delete; | ||
| 28 | |||
| 29 | LibUSBContext& operator=(LibUSBContext&&) noexcept = delete; | ||
| 30 | LibUSBContext(LibUSBContext&&) noexcept = delete; | ||
| 31 | |||
| 32 | [[nodiscard]] int InitResult() const noexcept { | ||
| 33 | return init_result; | ||
| 34 | } | ||
| 35 | |||
| 36 | [[nodiscard]] libusb_context* get() noexcept { | ||
| 37 | return ctx; | ||
| 38 | } | ||
| 39 | |||
| 40 | private: | ||
| 41 | libusb_context* ctx; | ||
| 42 | int init_result{}; | ||
| 43 | }; | ||
| 44 | |||
| 45 | class LibUSBDeviceHandle { | ||
| 46 | public: | ||
| 47 | explicit LibUSBDeviceHandle(libusb_context* ctx, uint16_t vid, uint16_t pid) noexcept { | ||
| 48 | handle = libusb_open_device_with_vid_pid(ctx, vid, pid); | ||
| 49 | } | ||
| 50 | |||
| 51 | ~LibUSBDeviceHandle() noexcept { | ||
| 52 | if (handle) { | ||
| 53 | libusb_release_interface(handle, 1); | ||
| 54 | libusb_close(handle); | ||
| 55 | } | ||
| 56 | } | ||
| 14 | 57 | ||
| 15 | namespace GCAdapter { | 58 | LibUSBDeviceHandle& operator=(const LibUSBDeviceHandle&) = delete; |
| 59 | LibUSBDeviceHandle(const LibUSBDeviceHandle&) = delete; | ||
| 16 | 60 | ||
| 17 | Adapter::Adapter() { | 61 | LibUSBDeviceHandle& operator=(LibUSBDeviceHandle&&) noexcept = delete; |
| 18 | if (usb_adapter_handle != nullptr) { | 62 | LibUSBDeviceHandle(LibUSBDeviceHandle&&) noexcept = delete; |
| 63 | |||
| 64 | [[nodiscard]] libusb_device_handle* get() noexcept { | ||
| 65 | return handle; | ||
| 66 | } | ||
| 67 | |||
| 68 | private: | ||
| 69 | libusb_device_handle* handle{}; | ||
| 70 | }; | ||
| 71 | |||
| 72 | GCAdapter::GCAdapter(std::string input_engine_) : InputEngine(std::move(input_engine_)) { | ||
| 73 | if (usb_adapter_handle) { | ||
| 19 | return; | 74 | return; |
| 20 | } | 75 | } |
| 21 | LOG_INFO(Input, "GC Adapter Initialization started"); | 76 | LOG_DEBUG(Input, "Initialization started"); |
| 22 | 77 | ||
| 23 | const int init_res = libusb_init(&libusb_ctx); | 78 | libusb_ctx = std::make_unique<LibUSBContext>(); |
| 79 | const int init_res = libusb_ctx->InitResult(); | ||
| 24 | if (init_res == LIBUSB_SUCCESS) { | 80 | if (init_res == LIBUSB_SUCCESS) { |
| 25 | adapter_scan_thread = std::thread(&Adapter::AdapterScanThread, this); | 81 | adapter_scan_thread = |
| 82 | std::jthread([this](std::stop_token stop_token) { AdapterScanThread(stop_token); }); | ||
| 26 | } else { | 83 | } else { |
| 27 | LOG_ERROR(Input, "libusb could not be initialized. failed with error = {}", init_res); | 84 | LOG_ERROR(Input, "libusb could not be initialized. failed with error = {}", init_res); |
| 28 | } | 85 | } |
| 29 | } | 86 | } |
| 30 | 87 | ||
| 31 | Adapter::~Adapter() { | 88 | GCAdapter::~GCAdapter() { |
| 32 | Reset(); | 89 | Reset(); |
| 33 | } | 90 | } |
| 34 | 91 | ||
| 35 | void Adapter::AdapterInputThread() { | 92 | void GCAdapter::AdapterInputThread(std::stop_token stop_token) { |
| 36 | LOG_DEBUG(Input, "GC Adapter input thread started"); | 93 | LOG_DEBUG(Input, "Input thread started"); |
| 94 | Common::SetCurrentThreadName("yuzu:input:GCAdapter"); | ||
| 37 | s32 payload_size{}; | 95 | s32 payload_size{}; |
| 38 | AdapterPayload adapter_payload{}; | 96 | AdapterPayload adapter_payload{}; |
| 39 | 97 | ||
| 40 | if (adapter_scan_thread.joinable()) { | 98 | adapter_scan_thread = {}; |
| 41 | adapter_scan_thread.join(); | ||
| 42 | } | ||
| 43 | 99 | ||
| 44 | while (adapter_input_thread_running) { | 100 | while (!stop_token.stop_requested()) { |
| 45 | libusb_interrupt_transfer(usb_adapter_handle, input_endpoint, adapter_payload.data(), | 101 | libusb_interrupt_transfer(usb_adapter_handle->get(), input_endpoint, adapter_payload.data(), |
| 46 | static_cast<s32>(adapter_payload.size()), &payload_size, 16); | 102 | static_cast<s32>(adapter_payload.size()), &payload_size, 16); |
| 47 | if (IsPayloadCorrect(adapter_payload, payload_size)) { | 103 | if (IsPayloadCorrect(adapter_payload, payload_size)) { |
| 48 | UpdateControllers(adapter_payload); | 104 | UpdateControllers(adapter_payload); |
| @@ -52,19 +108,20 @@ void Adapter::AdapterInputThread() { | |||
| 52 | } | 108 | } |
| 53 | 109 | ||
| 54 | if (restart_scan_thread) { | 110 | if (restart_scan_thread) { |
| 55 | adapter_scan_thread = std::thread(&Adapter::AdapterScanThread, this); | 111 | adapter_scan_thread = |
| 112 | std::jthread([this](std::stop_token token) { AdapterScanThread(token); }); | ||
| 56 | restart_scan_thread = false; | 113 | restart_scan_thread = false; |
| 57 | } | 114 | } |
| 58 | } | 115 | } |
| 59 | 116 | ||
| 60 | bool Adapter::IsPayloadCorrect(const AdapterPayload& adapter_payload, s32 payload_size) { | 117 | bool GCAdapter::IsPayloadCorrect(const AdapterPayload& adapter_payload, s32 payload_size) { |
| 61 | if (payload_size != static_cast<s32>(adapter_payload.size()) || | 118 | if (payload_size != static_cast<s32>(adapter_payload.size()) || |
| 62 | adapter_payload[0] != LIBUSB_DT_HID) { | 119 | adapter_payload[0] != LIBUSB_DT_HID) { |
| 63 | LOG_DEBUG(Input, "Error reading payload (size: {}, type: {:02x})", payload_size, | 120 | LOG_DEBUG(Input, "Error reading payload (size: {}, type: {:02x})", payload_size, |
| 64 | adapter_payload[0]); | 121 | adapter_payload[0]); |
| 65 | if (input_error_counter++ > 20) { | 122 | if (input_error_counter++ > 20) { |
| 66 | LOG_ERROR(Input, "GC adapter timeout, Is the adapter connected?"); | 123 | LOG_ERROR(Input, "Timeout, Is the adapter connected?"); |
| 67 | adapter_input_thread_running = false; | 124 | adapter_input_thread.request_stop(); |
| 68 | restart_scan_thread = true; | 125 | restart_scan_thread = true; |
| 69 | } | 126 | } |
| 70 | return false; | 127 | return false; |
| @@ -74,7 +131,7 @@ bool Adapter::IsPayloadCorrect(const AdapterPayload& adapter_payload, s32 payloa | |||
| 74 | return true; | 131 | return true; |
| 75 | } | 132 | } |
| 76 | 133 | ||
| 77 | void Adapter::UpdateControllers(const AdapterPayload& adapter_payload) { | 134 | void GCAdapter::UpdateControllers(const AdapterPayload& adapter_payload) { |
| 78 | for (std::size_t port = 0; port < pads.size(); ++port) { | 135 | for (std::size_t port = 0; port < pads.size(); ++port) { |
| 79 | const std::size_t offset = 1 + (9 * port); | 136 | const std::size_t offset = 1 + (9 * port); |
| 80 | const auto type = static_cast<ControllerTypes>(adapter_payload[offset] >> 4); | 137 | const auto type = static_cast<ControllerTypes>(adapter_payload[offset] >> 4); |
| @@ -84,23 +141,24 @@ void Adapter::UpdateControllers(const AdapterPayload& adapter_payload) { | |||
| 84 | const u8 b2 = adapter_payload[offset + 2]; | 141 | const u8 b2 = adapter_payload[offset + 2]; |
| 85 | UpdateStateButtons(port, b1, b2); | 142 | UpdateStateButtons(port, b1, b2); |
| 86 | UpdateStateAxes(port, adapter_payload); | 143 | UpdateStateAxes(port, adapter_payload); |
| 87 | if (configuring) { | ||
| 88 | UpdateYuzuSettings(port); | ||
| 89 | } | ||
| 90 | } | 144 | } |
| 91 | } | 145 | } |
| 92 | } | 146 | } |
| 93 | 147 | ||
| 94 | void Adapter::UpdatePadType(std::size_t port, ControllerTypes pad_type) { | 148 | void GCAdapter::UpdatePadType(std::size_t port, ControllerTypes pad_type) { |
| 95 | if (pads[port].type == pad_type) { | 149 | if (pads[port].type == pad_type) { |
| 96 | return; | 150 | return; |
| 97 | } | 151 | } |
| 98 | // Device changed reset device and set new type | 152 | // Device changed reset device and set new type |
| 99 | ResetDevice(port); | 153 | pads[port].axis_origin = {}; |
| 154 | pads[port].reset_origin_counter = {}; | ||
| 155 | pads[port].enable_vibration = {}; | ||
| 156 | pads[port].rumble_amplitude = {}; | ||
| 100 | pads[port].type = pad_type; | 157 | pads[port].type = pad_type; |
| 101 | } | 158 | } |
| 102 | 159 | ||
| 103 | void Adapter::UpdateStateButtons(std::size_t port, u8 b1, u8 b2) { | 160 | void GCAdapter::UpdateStateButtons(std::size_t port, [[maybe_unused]] u8 b1, |
| 161 | [[maybe_unused]] u8 b2) { | ||
| 104 | if (port >= pads.size()) { | 162 | if (port >= pads.size()) { |
| 105 | return; | 163 | return; |
| 106 | } | 164 | } |
| @@ -116,25 +174,21 @@ void Adapter::UpdateStateButtons(std::size_t port, u8 b1, u8 b2) { | |||
| 116 | PadButton::TriggerR, | 174 | PadButton::TriggerR, |
| 117 | PadButton::TriggerL, | 175 | PadButton::TriggerL, |
| 118 | }; | 176 | }; |
| 119 | pads[port].buttons = 0; | 177 | |
| 120 | for (std::size_t i = 0; i < b1_buttons.size(); ++i) { | 178 | for (std::size_t i = 0; i < b1_buttons.size(); ++i) { |
| 121 | if ((b1 & (1U << i)) != 0) { | 179 | const bool button_status = (b1 & (1U << i)) != 0; |
| 122 | pads[port].buttons = | 180 | const int button = static_cast<int>(b1_buttons[i]); |
| 123 | static_cast<u16>(pads[port].buttons | static_cast<u16>(b1_buttons[i])); | 181 | SetButton(pads[port].identifier, button, button_status); |
| 124 | pads[port].last_button = b1_buttons[i]; | ||
| 125 | } | ||
| 126 | } | 182 | } |
| 127 | 183 | ||
| 128 | for (std::size_t j = 0; j < b2_buttons.size(); ++j) { | 184 | for (std::size_t j = 0; j < b2_buttons.size(); ++j) { |
| 129 | if ((b2 & (1U << j)) != 0) { | 185 | const bool button_status = (b2 & (1U << j)) != 0; |
| 130 | pads[port].buttons = | 186 | const int button = static_cast<int>(b2_buttons[j]); |
| 131 | static_cast<u16>(pads[port].buttons | static_cast<u16>(b2_buttons[j])); | 187 | SetButton(pads[port].identifier, button, button_status); |
| 132 | pads[port].last_button = b2_buttons[j]; | ||
| 133 | } | ||
| 134 | } | 188 | } |
| 135 | } | 189 | } |
| 136 | 190 | ||
| 137 | void Adapter::UpdateStateAxes(std::size_t port, const AdapterPayload& adapter_payload) { | 191 | void GCAdapter::UpdateStateAxes(std::size_t port, const AdapterPayload& adapter_payload) { |
| 138 | if (port >= pads.size()) { | 192 | if (port >= pads.size()) { |
| 139 | return; | 193 | return; |
| 140 | } | 194 | } |
| @@ -155,134 +209,63 @@ void Adapter::UpdateStateAxes(std::size_t port, const AdapterPayload& adapter_pa | |||
| 155 | pads[port].axis_origin[index] = axis_value; | 209 | pads[port].axis_origin[index] = axis_value; |
| 156 | pads[port].reset_origin_counter++; | 210 | pads[port].reset_origin_counter++; |
| 157 | } | 211 | } |
| 158 | pads[port].axis_values[index] = | 212 | const f32 axis_status = (axis_value - pads[port].axis_origin[index]) / 100.0f; |
| 159 | static_cast<s16>(axis_value - pads[port].axis_origin[index]); | 213 | SetAxis(pads[port].identifier, static_cast<int>(index), axis_status); |
| 160 | } | ||
| 161 | } | ||
| 162 | |||
| 163 | void Adapter::UpdateYuzuSettings(std::size_t port) { | ||
| 164 | if (port >= pads.size()) { | ||
| 165 | return; | ||
| 166 | } | ||
| 167 | |||
| 168 | constexpr u8 axis_threshold = 50; | ||
| 169 | GCPadStatus pad_status = {.port = port}; | ||
| 170 | |||
| 171 | if (pads[port].buttons != 0) { | ||
| 172 | pad_status.button = pads[port].last_button; | ||
| 173 | pad_queue.Push(pad_status); | ||
| 174 | } | ||
| 175 | |||
| 176 | // Accounting for a threshold here to ensure an intentional press | ||
| 177 | for (std::size_t i = 0; i < pads[port].axis_values.size(); ++i) { | ||
| 178 | const s16 value = pads[port].axis_values[i]; | ||
| 179 | |||
| 180 | if (value > axis_threshold || value < -axis_threshold) { | ||
| 181 | pad_status.axis = static_cast<PadAxes>(i); | ||
| 182 | pad_status.axis_value = value; | ||
| 183 | pad_status.axis_threshold = axis_threshold; | ||
| 184 | pad_queue.Push(pad_status); | ||
| 185 | } | ||
| 186 | } | ||
| 187 | } | ||
| 188 | |||
| 189 | void Adapter::UpdateVibrations() { | ||
| 190 | // Use 8 states to keep the switching between on/off fast enough for | ||
| 191 | // a human to not notice the difference between switching from on/off | ||
| 192 | // More states = more rumble strengths = slower update time | ||
| 193 | constexpr u8 vibration_states = 8; | ||
| 194 | |||
| 195 | vibration_counter = (vibration_counter + 1) % vibration_states; | ||
| 196 | |||
| 197 | for (GCController& pad : pads) { | ||
| 198 | const bool vibrate = pad.rumble_amplitude > vibration_counter; | ||
| 199 | vibration_changed |= vibrate != pad.enable_vibration; | ||
| 200 | pad.enable_vibration = vibrate; | ||
| 201 | } | ||
| 202 | SendVibrations(); | ||
| 203 | } | ||
| 204 | |||
| 205 | void Adapter::SendVibrations() { | ||
| 206 | if (!rumble_enabled || !vibration_changed) { | ||
| 207 | return; | ||
| 208 | } | ||
| 209 | s32 size{}; | ||
| 210 | constexpr u8 rumble_command = 0x11; | ||
| 211 | const u8 p1 = pads[0].enable_vibration; | ||
| 212 | const u8 p2 = pads[1].enable_vibration; | ||
| 213 | const u8 p3 = pads[2].enable_vibration; | ||
| 214 | const u8 p4 = pads[3].enable_vibration; | ||
| 215 | std::array<u8, 5> payload = {rumble_command, p1, p2, p3, p4}; | ||
| 216 | const int err = libusb_interrupt_transfer(usb_adapter_handle, output_endpoint, payload.data(), | ||
| 217 | static_cast<s32>(payload.size()), &size, 16); | ||
| 218 | if (err) { | ||
| 219 | LOG_DEBUG(Input, "Adapter libusb write failed: {}", libusb_error_name(err)); | ||
| 220 | if (output_error_counter++ > 5) { | ||
| 221 | LOG_ERROR(Input, "GC adapter output timeout, Rumble disabled"); | ||
| 222 | rumble_enabled = false; | ||
| 223 | } | ||
| 224 | return; | ||
| 225 | } | 214 | } |
| 226 | output_error_counter = 0; | ||
| 227 | vibration_changed = false; | ||
| 228 | } | 215 | } |
| 229 | 216 | ||
| 230 | bool Adapter::RumblePlay(std::size_t port, u8 amplitude) { | 217 | void GCAdapter::AdapterScanThread(std::stop_token stop_token) { |
| 231 | pads[port].rumble_amplitude = amplitude; | 218 | Common::SetCurrentThreadName("yuzu:input:ScanGCAdapter"); |
| 232 | 219 | usb_adapter_handle = nullptr; | |
| 233 | return rumble_enabled; | 220 | pads = {}; |
| 234 | } | 221 | while (!stop_token.stop_requested() && !Setup()) { |
| 235 | 222 | std::this_thread::sleep_for(std::chrono::seconds(2)); | |
| 236 | void Adapter::AdapterScanThread() { | ||
| 237 | adapter_scan_thread_running = true; | ||
| 238 | adapter_input_thread_running = false; | ||
| 239 | if (adapter_input_thread.joinable()) { | ||
| 240 | adapter_input_thread.join(); | ||
| 241 | } | ||
| 242 | ClearLibusbHandle(); | ||
| 243 | ResetDevices(); | ||
| 244 | while (adapter_scan_thread_running && !adapter_input_thread_running) { | ||
| 245 | Setup(); | ||
| 246 | std::this_thread::sleep_for(std::chrono::seconds(1)); | ||
| 247 | } | 223 | } |
| 248 | } | 224 | } |
| 249 | 225 | ||
| 250 | void Adapter::Setup() { | 226 | bool GCAdapter::Setup() { |
| 251 | usb_adapter_handle = libusb_open_device_with_vid_pid(libusb_ctx, 0x057e, 0x0337); | 227 | constexpr u16 nintendo_vid = 0x057e; |
| 252 | 228 | constexpr u16 gc_adapter_pid = 0x0337; | |
| 253 | if (usb_adapter_handle == NULL) { | 229 | usb_adapter_handle = |
| 254 | return; | 230 | std::make_unique<LibUSBDeviceHandle>(libusb_ctx->get(), nintendo_vid, gc_adapter_pid); |
| 231 | if (!usb_adapter_handle->get()) { | ||
| 232 | return false; | ||
| 255 | } | 233 | } |
| 256 | if (!CheckDeviceAccess()) { | 234 | if (!CheckDeviceAccess()) { |
| 257 | ClearLibusbHandle(); | 235 | usb_adapter_handle = nullptr; |
| 258 | return; | 236 | return false; |
| 259 | } | 237 | } |
| 260 | 238 | ||
| 261 | libusb_device* device = libusb_get_device(usb_adapter_handle); | 239 | libusb_device* const device = libusb_get_device(usb_adapter_handle->get()); |
| 262 | 240 | ||
| 263 | LOG_INFO(Input, "GC adapter is now connected"); | 241 | LOG_INFO(Input, "GC adapter is now connected"); |
| 264 | // GC Adapter found and accessible, registering it | 242 | // GC Adapter found and accessible, registering it |
| 265 | if (GetGCEndpoint(device)) { | 243 | if (GetGCEndpoint(device)) { |
| 266 | adapter_scan_thread_running = false; | ||
| 267 | adapter_input_thread_running = true; | ||
| 268 | rumble_enabled = true; | 244 | rumble_enabled = true; |
| 269 | input_error_counter = 0; | 245 | input_error_counter = 0; |
| 270 | output_error_counter = 0; | 246 | output_error_counter = 0; |
| 271 | adapter_input_thread = std::thread(&Adapter::AdapterInputThread, this); | ||
| 272 | } | ||
| 273 | } | ||
| 274 | 247 | ||
| 275 | bool Adapter::CheckDeviceAccess() { | 248 | std::size_t port = 0; |
| 276 | // This fixes payload problems from offbrand GCAdapters | 249 | for (GCController& pad : pads) { |
| 277 | const s32 control_transfer_error = | 250 | pad.identifier = { |
| 278 | libusb_control_transfer(usb_adapter_handle, 0x21, 11, 0x0001, 0, nullptr, 0, 1000); | 251 | .guid = Common::UUID{Common::INVALID_UUID}, |
| 279 | if (control_transfer_error < 0) { | 252 | .port = port++, |
| 280 | LOG_ERROR(Input, "libusb_control_transfer failed with error= {}", control_transfer_error); | 253 | .pad = 0, |
| 254 | }; | ||
| 255 | PreSetController(pad.identifier); | ||
| 256 | } | ||
| 257 | |||
| 258 | adapter_input_thread = | ||
| 259 | std::jthread([this](std::stop_token stop_token) { AdapterInputThread(stop_token); }); | ||
| 260 | return true; | ||
| 281 | } | 261 | } |
| 262 | return false; | ||
| 263 | } | ||
| 282 | 264 | ||
| 283 | s32 kernel_driver_error = libusb_kernel_driver_active(usb_adapter_handle, 0); | 265 | bool GCAdapter::CheckDeviceAccess() { |
| 266 | s32 kernel_driver_error = libusb_kernel_driver_active(usb_adapter_handle->get(), 0); | ||
| 284 | if (kernel_driver_error == 1) { | 267 | if (kernel_driver_error == 1) { |
| 285 | kernel_driver_error = libusb_detach_kernel_driver(usb_adapter_handle, 0); | 268 | kernel_driver_error = libusb_detach_kernel_driver(usb_adapter_handle->get(), 0); |
| 286 | if (kernel_driver_error != 0 && kernel_driver_error != LIBUSB_ERROR_NOT_SUPPORTED) { | 269 | if (kernel_driver_error != 0 && kernel_driver_error != LIBUSB_ERROR_NOT_SUPPORTED) { |
| 287 | LOG_ERROR(Input, "libusb_detach_kernel_driver failed with error = {}", | 270 | LOG_ERROR(Input, "libusb_detach_kernel_driver failed with error = {}", |
| 288 | kernel_driver_error); | 271 | kernel_driver_error); |
| @@ -290,23 +273,28 @@ bool Adapter::CheckDeviceAccess() { | |||
| 290 | } | 273 | } |
| 291 | 274 | ||
| 292 | if (kernel_driver_error && kernel_driver_error != LIBUSB_ERROR_NOT_SUPPORTED) { | 275 | if (kernel_driver_error && kernel_driver_error != LIBUSB_ERROR_NOT_SUPPORTED) { |
| 293 | libusb_close(usb_adapter_handle); | ||
| 294 | usb_adapter_handle = nullptr; | 276 | usb_adapter_handle = nullptr; |
| 295 | return false; | 277 | return false; |
| 296 | } | 278 | } |
| 297 | 279 | ||
| 298 | const int interface_claim_error = libusb_claim_interface(usb_adapter_handle, 0); | 280 | const int interface_claim_error = libusb_claim_interface(usb_adapter_handle->get(), 0); |
| 299 | if (interface_claim_error) { | 281 | if (interface_claim_error) { |
| 300 | LOG_ERROR(Input, "libusb_claim_interface failed with error = {}", interface_claim_error); | 282 | LOG_ERROR(Input, "libusb_claim_interface failed with error = {}", interface_claim_error); |
| 301 | libusb_close(usb_adapter_handle); | ||
| 302 | usb_adapter_handle = nullptr; | 283 | usb_adapter_handle = nullptr; |
| 303 | return false; | 284 | return false; |
| 304 | } | 285 | } |
| 305 | 286 | ||
| 287 | // This fixes payload problems from offbrand GCAdapters | ||
| 288 | const s32 control_transfer_error = | ||
| 289 | libusb_control_transfer(usb_adapter_handle->get(), 0x21, 11, 0x0001, 0, nullptr, 0, 1000); | ||
| 290 | if (control_transfer_error < 0) { | ||
| 291 | LOG_ERROR(Input, "libusb_control_transfer failed with error= {}", control_transfer_error); | ||
| 292 | } | ||
| 293 | |||
| 306 | return true; | 294 | return true; |
| 307 | } | 295 | } |
| 308 | 296 | ||
| 309 | bool Adapter::GetGCEndpoint(libusb_device* device) { | 297 | bool GCAdapter::GetGCEndpoint(libusb_device* device) { |
| 310 | libusb_config_descriptor* config = nullptr; | 298 | libusb_config_descriptor* config = nullptr; |
| 311 | const int config_descriptor_return = libusb_get_config_descriptor(device, 0, &config); | 299 | const int config_descriptor_return = libusb_get_config_descriptor(device, 0, &config); |
| 312 | if (config_descriptor_return != LIBUSB_SUCCESS) { | 300 | if (config_descriptor_return != LIBUSB_SUCCESS) { |
| @@ -332,77 +320,95 @@ bool Adapter::GetGCEndpoint(libusb_device* device) { | |||
| 332 | // This transfer seems to be responsible for clearing the state of the adapter | 320 | // This transfer seems to be responsible for clearing the state of the adapter |
| 333 | // Used to clear the "busy" state of when the device is unexpectedly unplugged | 321 | // Used to clear the "busy" state of when the device is unexpectedly unplugged |
| 334 | unsigned char clear_payload = 0x13; | 322 | unsigned char clear_payload = 0x13; |
| 335 | libusb_interrupt_transfer(usb_adapter_handle, output_endpoint, &clear_payload, | 323 | libusb_interrupt_transfer(usb_adapter_handle->get(), output_endpoint, &clear_payload, |
| 336 | sizeof(clear_payload), nullptr, 16); | 324 | sizeof(clear_payload), nullptr, 16); |
| 337 | return true; | 325 | return true; |
| 338 | } | 326 | } |
| 339 | 327 | ||
| 340 | void Adapter::JoinThreads() { | 328 | Common::Input::VibrationError GCAdapter::SetRumble( |
| 341 | restart_scan_thread = false; | 329 | const PadIdentifier& identifier, const Common::Input::VibrationStatus& vibration) { |
| 342 | adapter_input_thread_running = false; | 330 | const auto mean_amplitude = (vibration.low_amplitude + vibration.high_amplitude) * 0.5f; |
| 343 | adapter_scan_thread_running = false; | 331 | const auto processed_amplitude = |
| 332 | static_cast<u8>((mean_amplitude + std::pow(mean_amplitude, 0.3f)) * 0.5f * 0x8); | ||
| 344 | 333 | ||
| 345 | if (adapter_scan_thread.joinable()) { | 334 | pads[identifier.port].rumble_amplitude = processed_amplitude; |
| 346 | adapter_scan_thread.join(); | ||
| 347 | } | ||
| 348 | 335 | ||
| 349 | if (adapter_input_thread.joinable()) { | 336 | if (!rumble_enabled) { |
| 350 | adapter_input_thread.join(); | 337 | return Common::Input::VibrationError::Disabled; |
| 351 | } | 338 | } |
| 339 | return Common::Input::VibrationError::None; | ||
| 352 | } | 340 | } |
| 353 | 341 | ||
| 354 | void Adapter::ClearLibusbHandle() { | 342 | void GCAdapter::UpdateVibrations() { |
| 355 | if (usb_adapter_handle) { | 343 | // Use 8 states to keep the switching between on/off fast enough for |
| 356 | libusb_release_interface(usb_adapter_handle, 1); | 344 | // a human to feel different vibration strenght |
| 357 | libusb_close(usb_adapter_handle); | 345 | // More states == more rumble strengths == slower update time |
| 358 | usb_adapter_handle = nullptr; | 346 | constexpr u8 vibration_states = 8; |
| 347 | |||
| 348 | vibration_counter = (vibration_counter + 1) % vibration_states; | ||
| 349 | |||
| 350 | for (GCController& pad : pads) { | ||
| 351 | const bool vibrate = pad.rumble_amplitude > vibration_counter; | ||
| 352 | vibration_changed |= vibrate != pad.enable_vibration; | ||
| 353 | pad.enable_vibration = vibrate; | ||
| 359 | } | 354 | } |
| 355 | SendVibrations(); | ||
| 360 | } | 356 | } |
| 361 | 357 | ||
| 362 | void Adapter::ResetDevices() { | 358 | void GCAdapter::SendVibrations() { |
| 363 | for (std::size_t i = 0; i < pads.size(); ++i) { | 359 | if (!rumble_enabled || !vibration_changed) { |
| 364 | ResetDevice(i); | 360 | return; |
| 361 | } | ||
| 362 | s32 size{}; | ||
| 363 | constexpr u8 rumble_command = 0x11; | ||
| 364 | const u8 p1 = pads[0].enable_vibration; | ||
| 365 | const u8 p2 = pads[1].enable_vibration; | ||
| 366 | const u8 p3 = pads[2].enable_vibration; | ||
| 367 | const u8 p4 = pads[3].enable_vibration; | ||
| 368 | std::array<u8, 5> payload = {rumble_command, p1, p2, p3, p4}; | ||
| 369 | const int err = | ||
| 370 | libusb_interrupt_transfer(usb_adapter_handle->get(), output_endpoint, payload.data(), | ||
| 371 | static_cast<s32>(payload.size()), &size, 16); | ||
| 372 | if (err) { | ||
| 373 | LOG_DEBUG(Input, "Libusb write failed: {}", libusb_error_name(err)); | ||
| 374 | if (output_error_counter++ > 5) { | ||
| 375 | LOG_ERROR(Input, "Output timeout, Rumble disabled"); | ||
| 376 | rumble_enabled = false; | ||
| 377 | } | ||
| 378 | return; | ||
| 365 | } | 379 | } |
| 380 | output_error_counter = 0; | ||
| 381 | vibration_changed = false; | ||
| 366 | } | 382 | } |
| 367 | 383 | ||
| 368 | void Adapter::ResetDevice(std::size_t port) { | 384 | bool GCAdapter::DeviceConnected(std::size_t port) const { |
| 369 | pads[port].type = ControllerTypes::None; | 385 | return pads[port].type != ControllerTypes::None; |
| 370 | pads[port].enable_vibration = false; | ||
| 371 | pads[port].rumble_amplitude = 0; | ||
| 372 | pads[port].buttons = 0; | ||
| 373 | pads[port].last_button = PadButton::Undefined; | ||
| 374 | pads[port].axis_values.fill(0); | ||
| 375 | pads[port].reset_origin_counter = 0; | ||
| 376 | } | 386 | } |
| 377 | 387 | ||
| 378 | void Adapter::Reset() { | 388 | void GCAdapter::Reset() { |
| 379 | JoinThreads(); | 389 | adapter_scan_thread = {}; |
| 380 | ClearLibusbHandle(); | 390 | adapter_input_thread = {}; |
| 381 | ResetDevices(); | 391 | usb_adapter_handle = nullptr; |
| 382 | 392 | pads = {}; | |
| 383 | if (libusb_ctx) { | 393 | libusb_ctx = nullptr; |
| 384 | libusb_exit(libusb_ctx); | ||
| 385 | } | ||
| 386 | } | 394 | } |
| 387 | 395 | ||
| 388 | std::vector<Common::ParamPackage> Adapter::GetInputDevices() const { | 396 | std::vector<Common::ParamPackage> GCAdapter::GetInputDevices() const { |
| 389 | std::vector<Common::ParamPackage> devices; | 397 | std::vector<Common::ParamPackage> devices; |
| 390 | for (std::size_t port = 0; port < pads.size(); ++port) { | 398 | for (std::size_t port = 0; port < pads.size(); ++port) { |
| 391 | if (!DeviceConnected(port)) { | 399 | if (!DeviceConnected(port)) { |
| 392 | continue; | 400 | continue; |
| 393 | } | 401 | } |
| 394 | std::string name = fmt::format("Gamecube Controller {}", port + 1); | 402 | Common::ParamPackage identifier{}; |
| 395 | devices.emplace_back(Common::ParamPackage{ | 403 | identifier.Set("engine", GetEngineName()); |
| 396 | {"class", "gcpad"}, | 404 | identifier.Set("display", fmt::format("Gamecube Controller {}", port + 1)); |
| 397 | {"display", std::move(name)}, | 405 | identifier.Set("port", static_cast<int>(port)); |
| 398 | {"port", std::to_string(port)}, | 406 | devices.emplace_back(identifier); |
| 399 | }); | ||
| 400 | } | 407 | } |
| 401 | return devices; | 408 | return devices; |
| 402 | } | 409 | } |
| 403 | 410 | ||
| 404 | InputCommon::ButtonMapping Adapter::GetButtonMappingForDevice( | 411 | ButtonMapping GCAdapter::GetButtonMappingForDevice(const Common::ParamPackage& params) { |
| 405 | const Common::ParamPackage& params) const { | ||
| 406 | // This list is missing ZL/ZR since those are not considered buttons. | 412 | // This list is missing ZL/ZR since those are not considered buttons. |
| 407 | // We will add those afterwards | 413 | // We will add those afterwards |
| 408 | // This list also excludes any button that can't be really mapped | 414 | // This list also excludes any button that can't be really mapped |
| @@ -425,47 +431,49 @@ InputCommon::ButtonMapping Adapter::GetButtonMappingForDevice( | |||
| 425 | return {}; | 431 | return {}; |
| 426 | } | 432 | } |
| 427 | 433 | ||
| 428 | InputCommon::ButtonMapping mapping{}; | 434 | ButtonMapping mapping{}; |
| 429 | for (const auto& [switch_button, gcadapter_button] : switch_to_gcadapter_button) { | 435 | for (const auto& [switch_button, gcadapter_button] : switch_to_gcadapter_button) { |
| 430 | Common::ParamPackage button_params({{"engine", "gcpad"}}); | 436 | Common::ParamPackage button_params{}; |
| 437 | button_params.Set("engine", GetEngineName()); | ||
| 431 | button_params.Set("port", params.Get("port", 0)); | 438 | button_params.Set("port", params.Get("port", 0)); |
| 432 | button_params.Set("button", static_cast<int>(gcadapter_button)); | 439 | button_params.Set("button", static_cast<int>(gcadapter_button)); |
| 433 | mapping.insert_or_assign(switch_button, std::move(button_params)); | 440 | mapping.insert_or_assign(switch_button, std::move(button_params)); |
| 434 | } | 441 | } |
| 435 | 442 | ||
| 436 | // Add the missing bindings for ZL/ZR | 443 | // Add the missing bindings for ZL/ZR |
| 437 | static constexpr std::array<std::pair<Settings::NativeButton::Values, PadAxes>, 2> | 444 | static constexpr std::array<std::tuple<Settings::NativeButton::Values, PadButton, PadAxes>, 2> |
| 438 | switch_to_gcadapter_axis = { | 445 | switch_to_gcadapter_axis = { |
| 439 | std::pair{Settings::NativeButton::ZL, PadAxes::TriggerLeft}, | 446 | std::tuple{Settings::NativeButton::ZL, PadButton::TriggerL, PadAxes::TriggerLeft}, |
| 440 | {Settings::NativeButton::ZR, PadAxes::TriggerRight}, | 447 | {Settings::NativeButton::ZR, PadButton::TriggerR, PadAxes::TriggerRight}, |
| 441 | }; | 448 | }; |
| 442 | for (const auto& [switch_button, gcadapter_axis] : switch_to_gcadapter_axis) { | 449 | for (const auto& [switch_button, gcadapter_buton, gcadapter_axis] : switch_to_gcadapter_axis) { |
| 443 | Common::ParamPackage button_params({{"engine", "gcpad"}}); | 450 | Common::ParamPackage button_params{}; |
| 451 | button_params.Set("engine", GetEngineName()); | ||
| 444 | button_params.Set("port", params.Get("port", 0)); | 452 | button_params.Set("port", params.Get("port", 0)); |
| 445 | button_params.Set("button", static_cast<s32>(PadButton::Stick)); | 453 | button_params.Set("button", static_cast<s32>(gcadapter_buton)); |
| 446 | button_params.Set("axis", static_cast<s32>(gcadapter_axis)); | 454 | button_params.Set("axis", static_cast<s32>(gcadapter_axis)); |
| 447 | button_params.Set("threshold", 0.5f); | 455 | button_params.Set("threshold", 0.5f); |
| 456 | button_params.Set("range", 1.9f); | ||
| 448 | button_params.Set("direction", "+"); | 457 | button_params.Set("direction", "+"); |
| 449 | mapping.insert_or_assign(switch_button, std::move(button_params)); | 458 | mapping.insert_or_assign(switch_button, std::move(button_params)); |
| 450 | } | 459 | } |
| 451 | return mapping; | 460 | return mapping; |
| 452 | } | 461 | } |
| 453 | 462 | ||
| 454 | InputCommon::AnalogMapping Adapter::GetAnalogMappingForDevice( | 463 | AnalogMapping GCAdapter::GetAnalogMappingForDevice(const Common::ParamPackage& params) { |
| 455 | const Common::ParamPackage& params) const { | ||
| 456 | if (!params.Has("port")) { | 464 | if (!params.Has("port")) { |
| 457 | return {}; | 465 | return {}; |
| 458 | } | 466 | } |
| 459 | 467 | ||
| 460 | InputCommon::AnalogMapping mapping = {}; | 468 | AnalogMapping mapping = {}; |
| 461 | Common::ParamPackage left_analog_params; | 469 | Common::ParamPackage left_analog_params; |
| 462 | left_analog_params.Set("engine", "gcpad"); | 470 | left_analog_params.Set("engine", GetEngineName()); |
| 463 | left_analog_params.Set("port", params.Get("port", 0)); | 471 | left_analog_params.Set("port", params.Get("port", 0)); |
| 464 | left_analog_params.Set("axis_x", static_cast<int>(PadAxes::StickX)); | 472 | left_analog_params.Set("axis_x", static_cast<int>(PadAxes::StickX)); |
| 465 | left_analog_params.Set("axis_y", static_cast<int>(PadAxes::StickY)); | 473 | left_analog_params.Set("axis_y", static_cast<int>(PadAxes::StickY)); |
| 466 | mapping.insert_or_assign(Settings::NativeAnalog::LStick, std::move(left_analog_params)); | 474 | mapping.insert_or_assign(Settings::NativeAnalog::LStick, std::move(left_analog_params)); |
| 467 | Common::ParamPackage right_analog_params; | 475 | Common::ParamPackage right_analog_params; |
| 468 | right_analog_params.Set("engine", "gcpad"); | 476 | right_analog_params.Set("engine", GetEngineName()); |
| 469 | right_analog_params.Set("port", params.Get("port", 0)); | 477 | right_analog_params.Set("port", params.Get("port", 0)); |
| 470 | right_analog_params.Set("axis_x", static_cast<int>(PadAxes::SubstickX)); | 478 | right_analog_params.Set("axis_x", static_cast<int>(PadAxes::SubstickX)); |
| 471 | right_analog_params.Set("axis_y", static_cast<int>(PadAxes::SubstickY)); | 479 | right_analog_params.Set("axis_y", static_cast<int>(PadAxes::SubstickY)); |
| @@ -473,34 +481,47 @@ InputCommon::AnalogMapping Adapter::GetAnalogMappingForDevice( | |||
| 473 | return mapping; | 481 | return mapping; |
| 474 | } | 482 | } |
| 475 | 483 | ||
| 476 | bool Adapter::DeviceConnected(std::size_t port) const { | 484 | Common::Input::ButtonNames GCAdapter::GetUIButtonName(const Common::ParamPackage& params) const { |
| 477 | return pads[port].type != ControllerTypes::None; | 485 | PadButton button = static_cast<PadButton>(params.Get("button", 0)); |
| 478 | } | 486 | switch (button) { |
| 479 | 487 | case PadButton::ButtonLeft: | |
| 480 | void Adapter::BeginConfiguration() { | 488 | return Common::Input::ButtonNames::ButtonLeft; |
| 481 | pad_queue.Clear(); | 489 | case PadButton::ButtonRight: |
| 482 | configuring = true; | 490 | return Common::Input::ButtonNames::ButtonRight; |
| 483 | } | 491 | case PadButton::ButtonDown: |
| 484 | 492 | return Common::Input::ButtonNames::ButtonDown; | |
| 485 | void Adapter::EndConfiguration() { | 493 | case PadButton::ButtonUp: |
| 486 | pad_queue.Clear(); | 494 | return Common::Input::ButtonNames::ButtonUp; |
| 487 | configuring = false; | 495 | case PadButton::TriggerZ: |
| 488 | } | 496 | return Common::Input::ButtonNames::TriggerZ; |
| 489 | 497 | case PadButton::TriggerR: | |
| 490 | Common::SPSCQueue<GCPadStatus>& Adapter::GetPadQueue() { | 498 | return Common::Input::ButtonNames::TriggerR; |
| 491 | return pad_queue; | 499 | case PadButton::TriggerL: |
| 492 | } | 500 | return Common::Input::ButtonNames::TriggerL; |
| 493 | 501 | case PadButton::ButtonA: | |
| 494 | const Common::SPSCQueue<GCPadStatus>& Adapter::GetPadQueue() const { | 502 | return Common::Input::ButtonNames::ButtonA; |
| 495 | return pad_queue; | 503 | case PadButton::ButtonB: |
| 504 | return Common::Input::ButtonNames::ButtonB; | ||
| 505 | case PadButton::ButtonX: | ||
| 506 | return Common::Input::ButtonNames::ButtonX; | ||
| 507 | case PadButton::ButtonY: | ||
| 508 | return Common::Input::ButtonNames::ButtonY; | ||
| 509 | case PadButton::ButtonStart: | ||
| 510 | return Common::Input::ButtonNames::ButtonStart; | ||
| 511 | default: | ||
| 512 | return Common::Input::ButtonNames::Undefined; | ||
| 513 | } | ||
| 496 | } | 514 | } |
| 497 | 515 | ||
| 498 | GCController& Adapter::GetPadState(std::size_t port) { | 516 | Common::Input::ButtonNames GCAdapter::GetUIName(const Common::ParamPackage& params) const { |
| 499 | return pads.at(port); | 517 | if (params.Has("button")) { |
| 500 | } | 518 | return GetUIButtonName(params); |
| 519 | } | ||
| 520 | if (params.Has("axis")) { | ||
| 521 | return Common::Input::ButtonNames::Value; | ||
| 522 | } | ||
| 501 | 523 | ||
| 502 | const GCController& Adapter::GetPadState(std::size_t port) const { | 524 | return Common::Input::ButtonNames::Invalid; |
| 503 | return pads.at(port); | ||
| 504 | } | 525 | } |
| 505 | 526 | ||
| 506 | } // namespace GCAdapter | 527 | } // namespace InputCommon |