From 9f13f957af9cf3691c22ff67b5dc28a588024b4d Mon Sep 17 00:00:00 2001 From: emmauss Date: Wed, 28 Oct 2020 19:52:07 +0000 Subject: [PATCH] Motion Fixes (#1589) * fix stalling when server is offline * add retry timer to fail server connections, fix alt slot number * fix alt slot key issue * fix crash when saving controller config with empty fields * code fixes * add index check in motion hid update, made HandleResponse async Co-authored-by: Emmanuel --- .../Services/Hid/HidDevices/NpadDevices.cs | 5 + Ryujinx/Motion/Client.cs | 307 +++++++++++------- Ryujinx/Motion/MotionDevice.cs | 6 +- Ryujinx/Ui/ControllerWindow.cs | 12 +- Ryujinx/Ui/ControllerWindow.glade | 23 +- Ryujinx/Ui/GLRenderer.cs | 4 +- 6 files changed, 218 insertions(+), 139 deletions(-) diff --git a/Ryujinx.HLE/HOS/Services/Hid/HidDevices/NpadDevices.cs b/Ryujinx.HLE/HOS/Services/Hid/HidDevices/NpadDevices.cs index 0decbfea9..2150f278e 100644 --- a/Ryujinx.HLE/HOS/Services/Hid/HidDevices/NpadDevices.cs +++ b/Ryujinx.HLE/HOS/Services/Hid/HidDevices/NpadDevices.cs @@ -337,6 +337,11 @@ namespace Ryujinx.HLE.HOS.Services.Hid { i++; + if (i >= states.Count) + { + return; + } + SetSixAxisState(states[i], true); } } diff --git a/Ryujinx/Motion/Client.cs b/Ryujinx/Motion/Client.cs index 07241ecd8..c1822bcda 100644 --- a/Ryujinx/Motion/Client.cs +++ b/Ryujinx/Motion/Client.cs @@ -25,6 +25,7 @@ namespace Ryujinx.Motion private readonly Dictionary _clients; private bool[] _clientErrorStatus = new bool[Enum.GetValues(typeof(PlayerIndex)).Length]; + private long[] _clientRetryTimer = new long[Enum.GetValues(typeof(PlayerIndex)).Length]; public Client() { @@ -63,18 +64,25 @@ namespace Ryujinx.Motion public void RegisterClient(int player, string host, int port) { - if (_clients.ContainsKey(player)) + if (_clients.ContainsKey(player) || !CanConnect(player)) { return; } - try + lock (_clients) { - lock (_clients) + if (_clients.ContainsKey(player) || !CanConnect(player)) + { + return; + } + + UdpClient client = null; + + try { IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse(host), port); - UdpClient client = new UdpClient(host, port); + client = new UdpClient(host, port); _clients.Add(player, client); _hosts.Add(player, endPoint); @@ -86,23 +94,39 @@ namespace Ryujinx.Motion ReceiveLoop(player); }); } - } - catch (FormatException fex) - { - if (!_clientErrorStatus[player]) + catch (FormatException fex) { - Logger.Warning?.PrintMsg(LogClass.Hid, $"Unable to connect to motion source at {host}:{port}. Error {fex.Message}"); + if (!_clientErrorStatus[player]) + { + Logger.Warning?.PrintMsg(LogClass.Hid, $"Unable to connect to motion source at {host}:{port}. Error {fex.Message}"); - _clientErrorStatus[player] = true; + _clientErrorStatus[player] = true; + } } - } - catch (SocketException ex) - { - if (!_clientErrorStatus[player]) + catch (SocketException sex) { - Logger.Warning?.PrintMsg(LogClass.Hid, $"Unable to connect to motion source at {host}:{port}. Error code {ex.ErrorCode}"); + if (!_clientErrorStatus[player]) + { + Logger.Warning?.PrintMsg(LogClass.Hid, $"Unable to connect to motion source at {host}:{port}. Error code {sex.ErrorCode}"); + _clientErrorStatus[player] = true; + } + + RemoveClient(player); + + client?.Dispose(); + + SetRetryTimer(player); + } + catch (Exception ex) + { _clientErrorStatus[player] = true; + + RemoveClient(player); + + client?.Dispose(); + + SetRetryTimer(player); } } } @@ -113,9 +137,10 @@ namespace Ryujinx.Motion { if (_motionData.ContainsKey(player)) { - input = _motionData[player][slot]; - - return true; + if (_motionData[player].TryGetValue(slot, out input)) + { + return true; + } } } @@ -124,6 +149,13 @@ namespace Ryujinx.Motion return false; } + private void RemoveClient(int clientId) + { + _clients?.Remove(clientId); + + _hosts?.Remove(clientId); + } + private void Send(byte[] data, int clientId) { if (_clients.TryGetValue(clientId, out UdpClient _client)) @@ -143,146 +175,185 @@ namespace Ryujinx.Motion _clientErrorStatus[clientId] = true; - _clients.Remove(clientId); - - _hosts.Remove(clientId); + RemoveClient(clientId); _client?.Dispose(); + + SetRetryTimer(clientId); + } + catch (ObjectDisposedException dex) + { + _clientErrorStatus[clientId] = true; + + RemoveClient(clientId); + + _client?.Dispose(); + + SetRetryTimer(clientId); } } } } - private byte[] Receive(int clientId) + private byte[] Receive(int clientId, int timeout = 0) { - if (_hosts.TryGetValue(clientId, out IPEndPoint endPoint)) + if (_hosts.TryGetValue(clientId, out IPEndPoint endPoint) && _clients.TryGetValue(clientId, out UdpClient _client)) { - if (_clients.TryGetValue(clientId, out UdpClient _client)) + if (_client != null && _client.Client != null && _client.Client.Connected) { - if (_client != null && _client.Client != null) + _client.Client.ReceiveTimeout = timeout; + + var result = _client?.Receive(ref endPoint); + + if (result.Length > 0) { - if (_client.Client.Connected) - { - try - { - var result = _client?.Receive(ref endPoint); - - if (result.Length > 0) - { - _clientErrorStatus[clientId] = false; - } - - return result; - } - catch (SocketException ex) - { - if (!_clientErrorStatus[clientId]) - { - Logger.Warning?.PrintMsg(LogClass.Hid, $"Unable to receive data from motion source at {endPoint}. Error code {ex.ErrorCode}"); - } - - _clientErrorStatus[clientId] = true; - - _clients.Remove(clientId); - - _hosts.Remove(clientId); - - _client?.Dispose(); - } - } + _clientErrorStatus[clientId] = false; } + + return result; } } - - return new byte[0]; + + throw new Exception($"Client {clientId} is not registered."); + } + + private void SetRetryTimer(int clientId) + { + var elapsedMs = PerformanceCounter.ElapsedMilliseconds; + + _clientRetryTimer[clientId] = elapsedMs; + } + + private void ResetRetryTimer(int clientId) + { + _clientRetryTimer[clientId] = 0; + } + + private bool CanConnect(int clientId) + { + return _clientRetryTimer[clientId] == 0 ? true : PerformanceCounter.ElapsedMilliseconds - 5000 > _clientRetryTimer[clientId]; } public void ReceiveLoop(int clientId) { - while (_active) + if (_hosts.TryGetValue(clientId, out IPEndPoint endPoint) && _clients.TryGetValue(clientId, out UdpClient _client)) { - byte[] data = Receive(clientId); - - if (data.Length == 0) + if (_client != null && _client.Client != null && _client.Client.Connected) { - continue; - } + try + { + while (_active) + { + byte[] data = Receive(clientId); + + if (data.Length == 0) + { + continue; + } #pragma warning disable CS4014 - HandleResponse(data, clientId); + Task.Run(() => HandleResponse(data, clientId)); #pragma warning restore CS4014 + } + } + catch (SocketException ex) + { + if (!_clientErrorStatus[clientId]) + { + Logger.Warning?.PrintMsg(LogClass.Hid, $"Unable to receive data from motion source at {endPoint}. Error code {ex.ErrorCode}"); + } + + _clientErrorStatus[clientId] = true; + + RemoveClient(clientId); + + _client?.Dispose(); + + SetRetryTimer(clientId); + } + catch (ObjectDisposedException) + { + _clientErrorStatus[clientId] = true; + + RemoveClient(clientId); + + _client?.Dispose(); + + SetRetryTimer(clientId); + } + } } } #pragma warning disable CS1998 - public async Task HandleResponse(byte[] data, int clientId) + public void HandleResponse(byte[] data, int clientId) #pragma warning restore CS1998 { + ResetRetryTimer(clientId); + MessageType type = (MessageType)BitConverter.ToUInt32(data.AsSpan().Slice(16, 4)); data = data.AsSpan().Slice(16).ToArray(); - using (MemoryStream mem = new MemoryStream(data)) + using MemoryStream mem = new MemoryStream(data); + + using BinaryReader reader = new BinaryReader(mem); + + switch (type) { - using (BinaryReader reader = new BinaryReader(mem)) - { - switch (type) + case MessageType.Protocol: + break; + case MessageType.Info: + ControllerInfoResponse contollerInfo = reader.ReadStruct(); + break; + case MessageType.Data: + ControllerDataResponse inputData = reader.ReadStruct(); + + Vector3 accelerometer = new Vector3() { - case MessageType.Protocol: - break; - case MessageType.Info: - ControllerInfoResponse contollerInfo = reader.ReadStruct(); - break; - case MessageType.Data: - ControllerDataResponse inputData = reader.ReadStruct(); + X = -inputData.AccelerometerX, + Y = inputData.AccelerometerZ, + Z = -inputData.AccelerometerY + }; - Vector3 accelerometer = new Vector3() + Vector3 gyroscrope = new Vector3() + { + X = inputData.GyroscopePitch, + Y = inputData.GyroscopeRoll, + Z = -inputData.GyroscopeYaw + }; + + ulong timestamp = inputData.MotionTimestamp; + + InputConfig config = ConfigurationState.Instance.Hid.InputConfig.Value.Find(x => x.PlayerIndex == (PlayerIndex)clientId); + + lock (_motionData) + { + int slot = inputData.Shared.Slot; + + if (_motionData.ContainsKey(clientId)) + { + if (_motionData[clientId].ContainsKey(slot)) { - X = -inputData.AccelerometerX, - Y = inputData.AccelerometerZ, - Z = -inputData.AccelerometerY - }; + var previousData = _motionData[clientId][slot]; - Vector3 gyroscrope = new Vector3() - { - X = inputData.GyroscopePitch, - Y = inputData.GyroscopeRoll, - Z = -inputData.GyroscopeYaw - }; - - ulong timestamp = inputData.MotionTimestamp; - - InputConfig config = ConfigurationState.Instance.Hid.InputConfig.Value.Find(x => x.PlayerIndex == (PlayerIndex)clientId); - - lock (_motionData) - { - int slot = inputData.Shared.Slot; - - if (_motionData.ContainsKey(clientId)) - { - if (_motionData[clientId].ContainsKey(slot)) - { - var previousData = _motionData[clientId][slot]; - - previousData.Update(accelerometer, gyroscrope, timestamp, config.Sensitivity, (float)config.GyroDeadzone); - } - else - { - MotionInput input = new MotionInput(); - input.Update(accelerometer, gyroscrope, timestamp, config.Sensitivity, (float)config.GyroDeadzone); - _motionData[clientId].Add(slot, input); - } - } - else - { - MotionInput input = new MotionInput(); - input.Update(accelerometer, gyroscrope, timestamp, config.Sensitivity, (float)config.GyroDeadzone); - _motionData.Add(clientId, new Dictionary() { { slot, input } }); - } + previousData.Update(accelerometer, gyroscrope, timestamp, config.Sensitivity, (float)config.GyroDeadzone); } - break; + else + { + MotionInput input = new MotionInput(); + input.Update(accelerometer, gyroscrope, timestamp, config.Sensitivity, (float)config.GyroDeadzone); + _motionData[clientId].Add(slot, input); + } + } + else + { + MotionInput input = new MotionInput(); + input.Update(accelerometer, gyroscrope, timestamp, config.Sensitivity, (float)config.GyroDeadzone); + _motionData.Add(clientId, new Dictionary() { { slot, input } }); + } } - } + break; } } diff --git a/Ryujinx/Motion/MotionDevice.cs b/Ryujinx/Motion/MotionDevice.cs index 82d84eb01..2e2050bcf 100644 --- a/Ryujinx/Motion/MotionDevice.cs +++ b/Ryujinx/Motion/MotionDevice.cs @@ -38,13 +38,11 @@ namespace Ryujinx.Motion } } - public void Poll(PlayerIndex player, int slot) + public void Poll(InputConfig config, int slot) { - InputConfig config = ConfigurationState.Instance.Hid.InputConfig.Value.Find(x => x.PlayerIndex == player); - Orientation = new float[9]; - if (!config.EnableMotion || !_motionSource.TryGetData((int)player, slot, out MotionInput input)) + if (!config.EnableMotion || !_motionSource.TryGetData((int)config.PlayerIndex, slot, out MotionInput input)) { Accelerometer = new Vector3(); Gyroscope = new Vector3(); diff --git a/Ryujinx/Ui/ControllerWindow.cs b/Ryujinx/Ui/ControllerWindow.cs index 406128746..77c8db0cf 100644 --- a/Ryujinx/Ui/ControllerWindow.cs +++ b/Ryujinx/Ui/ControllerWindow.cs @@ -447,6 +447,8 @@ namespace Ryujinx.Ui Enum.TryParse(_rSl.Label, out Key rButtonSl); Enum.TryParse(_rSr.Label, out Key rButtonSr); + int.TryParse(_dsuServerPort.Buffer.Text, out int port); + return new KeyboardConfig { Index = int.Parse(_inputDevice.ActiveId.Split("/")[1]), @@ -489,11 +491,11 @@ namespace Ryujinx.Ui EnableMotion = _enableMotion.Active, MirrorInput = _mirrorInput.Active, Slot = (int)_slotNumber.Value, - AltSlot = (int)_slotNumber.Value, + AltSlot = (int)_altSlotNumber.Value, Sensitivity = (int)_sensitivity.Value, GyroDeadzone = _gyroDeadzone.Value, DsuServerHost = _dsuServerHost.Buffer.Text, - DsuServerPort = int.Parse(_dsuServerPort.Buffer.Text) + DsuServerPort = port }; } @@ -525,6 +527,8 @@ namespace Ryujinx.Ui Enum.TryParse(_rSl.Label, out ControllerInputId rButtonSl); Enum.TryParse(_rSr.Label, out ControllerInputId rButtonSr); + int.TryParse(_dsuServerPort.Buffer.Text, out int port); + return new ControllerConfig { Index = int.Parse(_inputDevice.ActiveId.Split("/")[1]), @@ -570,11 +574,11 @@ namespace Ryujinx.Ui EnableMotion = _enableMotion.Active, MirrorInput = _mirrorInput.Active, Slot = (int)_slotNumber.Value, - AltSlot = (int)_slotNumber.Value, + AltSlot = (int)_altSlotNumber.Value, Sensitivity = (int)_sensitivity.Value, GyroDeadzone = _gyroDeadzone.Value, DsuServerHost = _dsuServerHost.Buffer.Text, - DsuServerPort = int.Parse(_dsuServerPort.Buffer.Text) + DsuServerPort = port }; } diff --git a/Ryujinx/Ui/ControllerWindow.glade b/Ryujinx/Ui/ControllerWindow.glade index d148cfaef..2143e9de8 100644 --- a/Ryujinx/Ui/ControllerWindow.glade +++ b/Ryujinx/Ui/ControllerWindow.glade @@ -1,5 +1,5 @@ - + @@ -9,28 +9,28 @@ 1 - 0.05 + 0.050000000000000003 0.01 - 0.1 + 0.10000000000000001 1 - 0.05 + 0.050000000000000003 0.01 - 0.1 + 0.10000000000000001 1 0.5 0.01 - 0.1 + 0.10000000000000001 100 0.01 0.01 - 0.1 - 0.1 + 0.10000000000000001 + 0.10000000000000001 1000 @@ -50,6 +50,9 @@ center 1100 600 + + + True @@ -1803,6 +1806,7 @@ True True 0 + _altSlotNumber 1 True True @@ -2030,8 +2034,5 @@ - - - diff --git a/Ryujinx/Ui/GLRenderer.cs b/Ryujinx/Ui/GLRenderer.cs index 9cf23695d..b635ad1c5 100644 --- a/Ryujinx/Ui/GLRenderer.cs +++ b/Ryujinx/Ui/GLRenderer.cs @@ -512,7 +512,7 @@ namespace Ryujinx.Ui currentButton |= _device.Hid.UpdateStickButtons(leftJoystick, rightJoystick); - motionDevice.Poll(inputConfig.PlayerIndex, inputConfig.Slot); + motionDevice.Poll(inputConfig, inputConfig.Slot); SixAxisInput sixAxisInput = new SixAxisInput() { @@ -537,7 +537,7 @@ namespace Ryujinx.Ui { if (!inputConfig.MirrorInput) { - motionDevice.Poll(inputConfig.PlayerIndex, inputConfig.AltSlot); + motionDevice.Poll(inputConfig, inputConfig.AltSlot); sixAxisInput = new SixAxisInput() {