The-Homebrew-Cloud/cemu-DS4Windows
2
0
Fork 0
mirror of https://github.com/cemu-project/DS4Windows.git synced 2024-11-27 03:24:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'jay' into vigem-udpserver

Browse Source
This commit is contained in:
Travis Nickles 2018-10-13 02:14:25 -05:00
commit 59deafd013
1 changed files with 14 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
DS4Windows/DS4Control/UdpServer.cs
View File

@ -69,7 +69,8 @@ namespace DS4Windows
private uint serverId; private uint serverId;
private bool running; private bool running;
private byte[] recvBuffer = new byte[1024]; private byte[] recvBuffer = new byte[1024];
private Stack<SocketAsyncEventArgs> argsStack; private SocketAsyncEventArgs[] argsList;
private int listInd = 0;
public delegate void GetPadDetail(int padIdx, ref DualShockPadMeta meta); public delegate void GetPadDetail(int padIdx, ref DualShockPadMeta meta);
@ -78,12 +79,11 @@ namespace DS4Windows
public UdpServer(GetPadDetail getPadDetailDel) public UdpServer(GetPadDetail getPadDetailDel)
{ {
portInfoGet = getPadDetailDel; portInfoGet = getPadDetailDel;
argsStack = new Stack<SocketAsyncEventArgs>(20); argsList = new SocketAsyncEventArgs[20];
for (int num = 0; num <= 19; num++) for (int num = 0; num <= 19; num++)
{ {
SocketAsyncEventArgs args = new SocketAsyncEventArgs(); SocketAsyncEventArgs args = new SocketAsyncEventArgs();
args.Completed += ClearSentData; argsList[num] = args;
argsStack.Push(args);
} }
} }
@ -182,10 +182,13 @@ namespace DS4Windows
FinishPacket(packetData); FinishPacket(packetData);
//try { udpSock.SendTo(packetData, clientEP); } //try { udpSock.SendTo(packetData, clientEP); }
SocketAsyncEventArgs args = argsStack.Pop(); SocketAsyncEventArgs args = argsList[listInd];
args.RemoteEndPoint = clientEP; args.RemoteEndPoint = clientEP;
args.SetBuffer(packetData, 0, packetData.Length); args.SetBuffer(packetData, 0, packetData.Length);
try { udpSock.SendToAsync(args); } listInd = ++listInd % 20;
try {
udpSock.SendToAsync(args);
}
catch (Exception e) { } catch (Exception e) { }
} }
@ -639,10 +642,13 @@ namespace DS4Windows
foreach (var cl in clientsList) foreach (var cl in clientsList)
{ {
//try { udpSock.SendTo(outputData, cl); } //try { udpSock.SendTo(outputData, cl); }
SocketAsyncEventArgs args = argsStack.Pop(); SocketAsyncEventArgs args = argsList[listInd];
args.RemoteEndPoint = cl; args.RemoteEndPoint = cl;
args.SetBuffer(outputData, 0, outputData.Length); args.SetBuffer(outputData, 0, outputData.Length);
try { bool result = udpSock.SendToAsync(args); if (!result) argsStack.Push(args); } listInd = ++listInd % 20;
try {
udpSock.SendToAsync(args);
}
catch (SocketException ex) { } catch (SocketException ex) { }
} }
} }
@ -650,12 +656,5 @@ namespace DS4Windows
clientsList.Clear(); clientsList.Clear();
clientsList = null; clientsList = null;
} }
private void ClearSentData(object sender, SocketAsyncEventArgs args)
{
argsStack.Push(args);
//args.Dispose();
//args = null;
}
} }
} }