RoboidControl/RoboidControl-csharp
RoboidControl/RoboidControl-csharp
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Multiclient is working

Browse Source
This commit is contained in:
Pascal Serrarens 2024-12-09 14:02:32 +01:00
parent aebe4c0f8e
commit 2e4e4c4693
2 changed files with 28 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Client.cs
View File

@ -1,6 +1,7 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Collections.Concurrent; using System.Collections.Concurrent;
using System.Net.Sockets; using System.Net.Sockets;
using System.IO;
namespace Passer.Control { namespace Passer.Control {
@ -9,6 +10,7 @@ namespace Passer.Control {
public UdpClient udpClient; public UdpClient udpClient;
public string ipAddress; public string ipAddress;
public int port; public int port;
public Stream dataStream;
public byte networkId = 0; public byte networkId = 0;
@ -48,9 +50,15 @@ namespace Passer.Control {
this.udpClient = udpClient; this.udpClient = udpClient;
this.ipAddress = null; this.ipAddress = null;
this.port = port; this.port = port;
this.dataStream = new EchoStream();
clients.Add(this); clients.Add(this);
} }
public virtual void ProcessMessages() {
while (this.messageQueue.TryDequeue(out IMessage msg))
ProcessMessage(msg);
}
public void ProcessMessage(IMessage msg) { public void ProcessMessage(IMessage msg) {
switch (msg) { switch (msg) {
case ClientMsg clientMsg: case ClientMsg clientMsg:

20
SiteServer.cs
View File

@ -1,9 +1,29 @@
using System.Diagnostics;
using System.IO; using System.IO;
using System.Threading.Tasks; using System.Threading.Tasks;
namespace Passer.Control { namespace Passer.Control {
public static class SiteServer { public static class SiteServer {
//public static async Task ReceiveData() {
// while (true) {
// //foreach (var client in Client.clients) {
// for (int ix = 0; ix < Client.clients.Count; ix++) {
// if (ix > 0)
// UnityEngine.Debug.Log("Client2 ");
// Client client = Client.clients[ix];
// if (client == null)
// continue;
// byte packetSize = (byte)client.dataStream.ReadByte();
// if (packetSize != 0xFF)
// await ReceiveData(client.dataStream, client, packetSize);
// // else timeout
// }
// }
//}
public static async Task ReceiveData(Stream dataStream, Client client) { public static async Task ReceiveData(Stream dataStream, Client client) {
while (true) { while (true) {
byte packetSize = (byte)dataStream.ReadByte(); byte packetSize = (byte)dataStream.ReadByte();