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

Temporary change to UDP server

Browse Source 
Don't want to lose these changes but more has to be done
This commit is contained in:
Travis Nickles 2018-11-27 04:30:42 -06:00
parent 84558f805f
commit 773a7a0423
1 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
DS4Windows/DS4Control/UdpServer.cs
View File

@ -85,6 +85,8 @@ namespace DS4Windows
for (int num = 0; num <= 19; num++) for (int num = 0; num <= 19; num++)
{ {
SocketAsyncEventArgs args = new SocketAsyncEventArgs(); SocketAsyncEventArgs args = new SocketAsyncEventArgs();
args.Completed += CompletedBuffer;
args.SetBuffer(new byte[100], 0, 100);
argsList[num] = args; argsList[num] = args;
} }
} }
@ -186,15 +188,17 @@ namespace DS4Windows
//try { udpSock.SendTo(packetData, clientEP); } //try { udpSock.SendTo(packetData, clientEP); }
int temp = 0; int temp = 0;
poolLock.EnterWriteLock(); poolLock.EnterWriteLock();
listInd = ++listInd % 20;
temp = listInd; temp = listInd;
listInd = (listInd + 1) % 20;
SocketAsyncEventArgs args = argsList[temp];
poolLock.ExitWriteLock(); poolLock.ExitWriteLock();
SocketAsyncEventArgs args = argsList[temp];
args.RemoteEndPoint = clientEP; args.RemoteEndPoint = clientEP;
args.SetBuffer(packetData, 0, packetData.Length); Array.Copy(packetData, args.Buffer, packetData.Length);
//args.SetBuffer(packetData, 0, packetData.Length);
try { try {
udpSock.SendToAsync(args); udpSock.SendToAsync(args);
//udpSock.BeginSendTo(packetData, 0, packetData.Length, SocketFlags.Broadcast, clientEP, null, null);
} }
catch (Exception e) { } catch (Exception e) { }
} }
@ -651,15 +655,17 @@ namespace DS4Windows
//try { udpSock.SendTo(outputData, cl); } //try { udpSock.SendTo(outputData, cl); }
int temp = 0; int temp = 0;
poolLock.EnterWriteLock(); poolLock.EnterWriteLock();
listInd = ++listInd % 20;
temp = listInd; temp = listInd;
listInd = (listInd + 1) % 20;
SocketAsyncEventArgs args = argsList[temp];
poolLock.ExitWriteLock(); poolLock.ExitWriteLock();
SocketAsyncEventArgs args = argsList[temp];
args.RemoteEndPoint = cl; args.RemoteEndPoint = cl;
args.SetBuffer(outputData, 0, outputData.Length); //args.SetBuffer(outputData, 0, outputData.Length);
Array.Copy(outputData, args.Buffer, outputData.Length);
try { try {
udpSock.SendToAsync(args); udpSock.SendToAsync(args);
//udpSock.BeginSendTo(outputData, 0, outputData.Length, SocketFlags.Broadcast, cl, null, null);
} }
catch (SocketException ex) { } catch (SocketException ex) { }
} }
@ -668,5 +674,11 @@ namespace DS4Windows
clientsList.Clear(); clientsList.Clear();
clientsList = null; clientsList = null;
} }
public void CompletedBuffer(object sender, SocketAsyncEventArgs args)
{
//args.SetBuffer(null, 0, 0);
//args.RemoteEndPoint = null;
}
} }
} }