N-archive/suyu
1
0
Fork 0
mirror of https://git.suyu.dev/suyu/suyu.git synced 2024-11-27 01:02:48 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

cleanup check access, read, and factory GetNextInput funcs. Use size rather than magic number

Browse source
This commit is contained in:
Ameer 2020-06-23 17:37:15 -04:00
parent d4e07fd95e
commit 743e1f02a0
4 changed files with 101 additions and 151 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

165
src/input_common/gcadapter/gc_adapter.cpp
View file

@ -21,57 +21,38 @@ Adapter::Adapter() {
StartScanThread();
}
GCPadStatus Adapter::CheckStatus(int port, const std::array<u8, 37>& adapter_payload) {
GCPadStatus Adapter::GetPadStatus(int port, const std::array<u8, 37>& adapter_payload) {
GCPadStatus pad = {};
bool get_origin = false;
ControllerTypes type = ControllerTypes(adapter_payload[1 + (9 * port)] >> 4);
if (type != ControllerTypes::None)
if (type != ControllerTypes::None) {
get_origin = true;
}
adapter_controllers_status[port] = type;
constexpr std::array<PadButton, 8> b1_buttons{
PAD_BUTTON_A, PAD_BUTTON_B, PAD_BUTTON_X, PAD_BUTTON_Y,
PAD_BUTTON_LEFT, PAD_BUTTON_RIGHT, PAD_BUTTON_DOWN, PAD_BUTTON_UP};
constexpr std::array<PadButton, 4> b2_buttons{PAD_BUTTON_START, PAD_TRIGGER_Z, PAD_TRIGGER_R,
PAD_TRIGGER_L};
if (adapter_controllers_status[port] != ControllerTypes::None) {
u8 b1 = adapter_payload[1 + (9 * port) + 1];
u8 b2 = adapter_payload[1 + (9 * port) + 2];
const u8 b1 = adapter_payload[1 + (9 * port) + 1];
const u8 b2 = adapter_payload[1 + (9 * port) + 2];
if (b1 & (1 << 0)) {
pad.button |= PAD_BUTTON_A;
for (int i = 0; i < b1_buttons.size(); i++) {
if (b1 & (1 << i)) {
pad.button |= b1_buttons[i];
}
if (b1 & (1 << 1)) {
pad.button |= PAD_BUTTON_B;
}
if (b1 & (1 << 2)) {
pad.button |= PAD_BUTTON_X;
}
if (b1 & (1 << 3)) {
pad.button |= PAD_BUTTON_Y;
}
if (b1 & (1 << 4)) {
pad.button |= PAD_BUTTON_LEFT;
for (int j = 0; j < b2_buttons.size(); j++) {
if (b2 & (1 << j)) {
pad.button |= b2_buttons[j];
}
if (b1 & (1 << 5)) {
pad.button |= PAD_BUTTON_RIGHT;
}
if (b1 & (1 << 6)) {
pad.button |= PAD_BUTTON_DOWN;
}
if (b1 & (1 << 7)) {
pad.button |= PAD_BUTTON_UP;
}
if (b2 & (1 << 0)) {
pad.button |= PAD_BUTTON_START;
}
if (b2 & (1 << 1)) {
pad.button |= PAD_TRIGGER_Z;
}
if (b2 & (1 << 2)) {
pad.button |= PAD_TRIGGER_R;
}
if (b2 & (1 << 3)) {
pad.button |= PAD_TRIGGER_L;
}
if (get_origin) {
@ -112,65 +93,65 @@ void Adapter::PadToState(const GCPadStatus& pad, GCState& state) {
void Adapter::Read() {
LOG_INFO(Input, "GC Adapter Read() thread started");
int payload_size_in, payload_size;
int payload_size_in, payload_size_copy;
std::array<u8, 37> adapter_payload;
std::array<u8, 37> controller_payload_copy;
std::array<GCPadStatus, 4> pad;
std::array<u8, 37> adapter_payload_copy;
std::array<GCPadStatus, 4> pads;
while (adapter_thread_running) {
libusb_interrupt_transfer(usb_adapter_handle, input_endpoint, adapter_payload.data(),
sizeof(adapter_payload), &payload_size_in, 32);
payload_size = 0;
payload_size_copy = 0;
{
std::lock_guard<std::mutex> lk(s_mutex);
std::copy(std::begin(adapter_payload), std::end(adapter_payload),
std::begin(controller_payload_copy));
payload_size = payload_size_in;
std::begin(adapter_payload_copy));
payload_size_copy = payload_size_in;
}
if (payload_size != sizeof(controller_payload_copy) ||
controller_payload_copy[0] != LIBUSB_DT_HID) {
if (payload_size_copy != sizeof(adapter_payload_copy) ||
adapter_payload_copy[0] != LIBUSB_DT_HID) {
// TODO: It might be worthwhile to Shutdown GC Adapter if we encounter errors here
LOG_ERROR(Input, "error reading payload (size: %d, type: %02x)", payload_size,
controller_payload_copy[0]);
LOG_ERROR(Input, "error reading payload (size: %d, type: %02x)", payload_size_copy,
adapter_payload_copy[0]);
} else {
for (int port = 0; port < 4; port++) {
pad[port] = CheckStatus(port, controller_payload_copy);
for (int port = 0; port < pads.size(); port++) {
pads[port] = GetPadStatus(port, adapter_payload_copy);
}
}
for (int port = 0; port < 4; port++) {
for (int port = 0; port < pads.size(); port++) {
if (DeviceConnected(port) && configuring) {
if (pad[port].button != PAD_GET_ORIGIN) {
pad_queue[port].Push(pad[port]);
if (pads[port].button != PAD_GET_ORIGIN) {
pad_queue[port].Push(pads[port]);
}
// Accounting for a threshold here because of some controller variance
if (pad[port].stick_x > pad[port].MAIN_STICK_CENTER_X + pad[port].THRESHOLD ||
pad[port].stick_x < pad[port].MAIN_STICK_CENTER_X - pad[port].THRESHOLD) {
pad[port].axis = GCAdapter::PadAxes::StickX;
pad[port].axis_value = pad[port].stick_x;
pad_queue[port].Push(pad[port]);
if (pads[port].stick_x > pads[port].MAIN_STICK_CENTER_X + pads[port].THRESHOLD ||
pads[port].stick_x < pads[port].MAIN_STICK_CENTER_X - pads[port].THRESHOLD) {
pads[port].axis = GCAdapter::PadAxes::StickX;
pads[port].axis_value = pads[port].stick_x;
pad_queue[port].Push(pads[port]);
}
if (pad[port].stick_y > pad[port].MAIN_STICK_CENTER_Y + pad[port].THRESHOLD ||
pad[port].stick_y < pad[port].MAIN_STICK_CENTER_Y - pad[port].THRESHOLD) {
pad[port].axis = GCAdapter::PadAxes::StickY;
pad[port].axis_value = pad[port].stick_y;
pad_queue[port].Push(pad[port]);
if (pads[port].stick_y > pads[port].MAIN_STICK_CENTER_Y + pads[port].THRESHOLD ||
pads[port].stick_y < pads[port].MAIN_STICK_CENTER_Y - pads[port].THRESHOLD) {
pads[port].axis = GCAdapter::PadAxes::StickY;
pads[port].axis_value = pads[port].stick_y;
pad_queue[port].Push(pads[port]);
}
if (pad[port].substick_x > pad[port].C_STICK_CENTER_X + pad[port].THRESHOLD ||
pad[port].substick_x < pad[port].C_STICK_CENTER_X - pad[port].THRESHOLD) {
pad[port].axis = GCAdapter::PadAxes::SubstickX;
pad[port].axis_value = pad[port].substick_x;
pad_queue[port].Push(pad[port]);
if (pads[port].substick_x > pads[port].C_STICK_CENTER_X + pads[port].THRESHOLD ||
pads[port].substick_x < pads[port].C_STICK_CENTER_X - pads[port].THRESHOLD) {
pads[port].axis = GCAdapter::PadAxes::SubstickX;
pads[port].axis_value = pads[port].substick_x;
pad_queue[port].Push(pads[port]);
}
if (pad[port].substick_y > pad[port].C_STICK_CENTER_Y + pad[port].THRESHOLD ||
pad[port].substick_y < pad[port].C_STICK_CENTER_Y - pad[port].THRESHOLD) {
pad[port].axis = GCAdapter::PadAxes::SubstickY;
pad[port].axis_value = pad[port].substick_y;
pad_queue[port].Push(pad[port]);
if (pads[port].substick_y > pads[port].C_STICK_CENTER_Y + pads[port].THRESHOLD ||
pads[port].substick_y < pads[port].C_STICK_CENTER_Y - pads[port].THRESHOLD) {
pads[port].axis = GCAdapter::PadAxes::SubstickY;
pads[port].axis_value = pads[port].substick_y;
pad_queue[port].Push(pads[port]);
}
}
PadToState(pad[port], state[port]);
PadToState(pads[port], state[port]);
}
std::this_thread::yield();
}
@ -215,11 +196,11 @@ void Adapter::Setup() {
libusb_device** devs; // pointer to list of connected usb devices
int cnt = libusb_get_device_list(libusb_ctx, &devs); // get the list of devices
const int cnt = libusb_get_device_list(libusb_ctx, &devs); // get the list of devices
for (int i = 0; i < cnt; i++) {
if (CheckDeviceAccess(devs[i])) {
// GC Adapter found, registering it
// GC Adapter found and accessible, registering it
GetGCEndpoint(devs[i]);
break;
}
@ -228,10 +209,11 @@ void Adapter::Setup() {
bool Adapter::CheckDeviceAccess(libusb_device* device) {
libusb_device_descriptor desc;
int ret = libusb_get_device_descriptor(device, &desc);
if (ret) {
const int get_descriptor_error = libusb_get_device_descriptor(device, &desc);
if (get_descriptor_error) {
// could not acquire the descriptor, no point in trying to use it.
LOG_ERROR(Input, "libusb_get_device_descriptor failed with error: %d", ret);
LOG_ERROR(Input, "libusb_get_device_descriptor failed with error: %d",
get_descriptor_error);
return false;
}
@ -239,35 +221,36 @@ bool Adapter::CheckDeviceAccess(libusb_device* device) {
// This isn’t the device we are looking for.
return false;
}
ret = libusb_open(device, &usb_adapter_handle);
const int open_error = libusb_open(device, &usb_adapter_handle);
if (ret == LIBUSB_ERROR_ACCESS) {
if (open_error == LIBUSB_ERROR_ACCESS) {
LOG_ERROR(Input, "Yuzu can not gain access to this device: ID %04X:%04X.", desc.idVendor,
desc.idProduct);
return false;
}
if (ret) {
LOG_ERROR(Input, "libusb_open failed to open device with error = %d", ret);
if (open_error) {
LOG_ERROR(Input, "libusb_open failed to open device with error = %d", open_error);
return false;
}
ret = libusb_kernel_driver_active(usb_adapter_handle, 0);
if (ret == 1) {
ret = libusb_detach_kernel_driver(usb_adapter_handle, 0);
if (ret != 0 && ret != LIBUSB_ERROR_NOT_SUPPORTED) {
LOG_ERROR(Input, "libusb_detach_kernel_driver failed with error = %d", ret);
int kernel_driver_error = libusb_kernel_driver_active(usb_adapter_handle, 0);
if (kernel_driver_error == 1) {
kernel_driver_error = libusb_detach_kernel_driver(usb_adapter_handle, 0);
if (kernel_driver_error != 0 && kernel_driver_error != LIBUSB_ERROR_NOT_SUPPORTED) {
LOG_ERROR(Input, "libusb_detach_kernel_driver failed with error = %d",
kernel_driver_error);
}
}
if (ret != 0 && ret != LIBUSB_ERROR_NOT_SUPPORTED) {
if (kernel_driver_error && kernel_driver_error != LIBUSB_ERROR_NOT_SUPPORTED) {
libusb_close(usb_adapter_handle);
usb_adapter_handle = nullptr;
return false;
}
ret = libusb_claim_interface(usb_adapter_handle, 0);
if (ret) {
LOG_ERROR(Input, "libusb_claim_interface failed with error = %d", ret);
const int interface_claim_error = libusb_claim_interface(usb_adapter_handle, 0);
if (interface_claim_error) {
LOG_ERROR(Input, "libusb_claim_interface failed with error = %d", interface_claim_error);
libusb_close(usb_adapter_handle);
usb_adapter_handle = nullptr;
return false;

8
src/input_common/gcadapter/gc_adapter.h
View file

@ -37,6 +37,12 @@ enum PadButton {
};
/// Used to loop through the and assign button in poller
static constexpr std::array<PadButton, 12> PadButtonArray{
PAD_BUTTON_LEFT, PAD_BUTTON_RIGHT, PAD_BUTTON_DOWN, PAD_BUTTON_UP,
PAD_TRIGGER_Z, PAD_TRIGGER_R, PAD_TRIGGER_L, PAD_BUTTON_A,
PAD_BUTTON_B, PAD_BUTTON_X, PAD_BUTTON_Y, PAD_BUTTON_START};
enum class PadAxes : u8 {
StickX,
StickY,
@ -100,7 +106,7 @@ public:
const std::array<GCState, 4>& GetPadState() const;
private:
GCPadStatus CheckStatus(int port, const std::array<u8, 37>& adapter_payload);
GCPadStatus GetPadStatus(int port, const std::array<u8, 37>& adapter_payload);
void PadToState(const GCPadStatus& pad, GCState& state);

70
src/input_common/gcadapter/gc_poller.cpp
View file

@ -58,8 +58,8 @@ GCButtonFactory::GCButtonFactory(std::shared_ptr<GCAdapter::Adapter> adapter_)
GCButton::~GCButton() = default;
std::unique_ptr<Input::ButtonDevice> GCButtonFactory::Create(const Common::ParamPackage& params) {
int button_id = params.Get("button", 0);
int port = params.Get("port", 0);
const int button_id = params.Get("button", 0);
const int port = params.Get("port", 0);
// For Axis buttons, used by the binary sticks.
if (params.Has("axis")) {
const int axis = params.Get("axis", 0);
@ -86,61 +86,22 @@ std::unique_ptr<Input::ButtonDevice> GCButtonFactory::Create(const Common::Param
Common::ParamPackage GCButtonFactory::GetNextInput() {
Common::ParamPackage params;
GCAdapter::GCPadStatus pad;
for (int i = 0; i < 4; i++) {
while (adapter->GetPadQueue()[i].Pop(pad)) {
auto& queue = adapter->GetPadQueue();
for (int port = 0; port < queue.size(); port++) {
while (queue[port].Pop(pad)) {
// This while loop will break on the earliest detected button
params.Set("engine", "gcpad");
params.Set("port", i);
params.Set("port", port);
// I was debating whether to keep these verbose for ease of reading
// or to use a while loop shifting the bits to test and set the value.
if (pad.button & GCAdapter::PAD_BUTTON_A) {
params.Set("button", GCAdapter::PAD_BUTTON_A);
for (auto button : GCAdapter::PadButtonArray) {
if (pad.button & button) {
params.Set("button", button);
break;
}
if (pad.button & GCAdapter::PAD_BUTTON_B) {
params.Set("button", GCAdapter::PAD_BUTTON_B);
break;
}
if (pad.button & GCAdapter::PAD_BUTTON_X) {
params.Set("button", GCAdapter::PAD_BUTTON_X);
break;
}
if (pad.button & GCAdapter::PAD_BUTTON_Y) {
params.Set("button", GCAdapter::PAD_BUTTON_Y);
break;
}
if (pad.button & GCAdapter::PAD_BUTTON_DOWN) {
params.Set("button", GCAdapter::PAD_BUTTON_DOWN);
break;
}
if (pad.button & GCAdapter::PAD_BUTTON_LEFT) {
params.Set("button", GCAdapter::PAD_BUTTON_LEFT);
break;
}
if (pad.button & GCAdapter::PAD_BUTTON_RIGHT) {
params.Set("button", GCAdapter::PAD_BUTTON_RIGHT);
break;
}
if (pad.button & GCAdapter::PAD_BUTTON_UP) {
params.Set("button", GCAdapter::PAD_BUTTON_UP);
break;
}
if (pad.button & GCAdapter::PAD_TRIGGER_L) {
params.Set("button", GCAdapter::PAD_TRIGGER_L);
break;
}
if (pad.button & GCAdapter::PAD_TRIGGER_R) {
params.Set("button", GCAdapter::PAD_TRIGGER_R);
break;
}
if (pad.button & GCAdapter::PAD_TRIGGER_Z) {
params.Set("button", GCAdapter::PAD_TRIGGER_Z);
break;
}
if (pad.button & GCAdapter::PAD_BUTTON_START) {
params.Set("button", GCAdapter::PAD_BUTTON_START);
break;
}
// For Axis button implementation
if (pad.axis != GCAdapter::PadAxes::Undefined) {
params.Set("axis", static_cast<u8>(pad.axis));
@ -265,8 +226,9 @@ void GCAnalogFactory::EndConfiguration() {
Common::ParamPackage GCAnalogFactory::GetNextInput() {
GCAdapter::GCPadStatus pad;
for (int i = 0; i < 4; i++) {
while (adapter->GetPadQueue()[i].Pop(pad)) {
auto& queue = adapter->GetPadQueue();
for (int port = 0; port < queue.size(); port++) {
while (queue[port].Pop(pad)) {
if (pad.axis == GCAdapter::PadAxes::Undefined ||
std::abs((pad.axis_value - 128.0f) / 128.0f) < 0.1) {
continue;
@ -276,8 +238,8 @@ Common::ParamPackage GCAnalogFactory::GetNextInput() {
const u8 axis = static_cast<u8>(pad.axis);
if (analog_x_axis == -1) {
analog_x_axis = axis;
controller_number = i;
} else if (analog_y_axis == -1 && analog_x_axis != axis && controller_number == i) {
controller_number = port;
} else if (analog_y_axis == -1 && analog_x_axis != axis && controller_number == port) {
analog_y_axis = axis;
}
}

1
src/input_common/keyboard.cpp
View file

@ -51,7 +51,6 @@ public:
for (const KeyButtonPair& pair : list) {
if (pair.key_code == key_code) {
pair.key_button->status.store(pressed);
break;
}
}
}