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

Improved ControlCore

Browse Source
This commit is contained in:
Pascal Serrarens 2024-12-11 15:23:32 +01:00
parent 1d2da54a17
commit 7e80a36027
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Client.cs
View File

@ -53,7 +53,7 @@ namespace Passer.Control {
ProcessThing(thing); ProcessThing(thing);
break; break;
case NameMsg name: case NameMsg name:
UnityEngine.Debug.Log($"Name [{name.networkId}/{name.thingId}] {name.name}"); //UnityEngine.Debug.Log($"Name [{name.networkId}/{name.thingId}] {name.name}");
ProcessName(name); ProcessName(name);
break; break;
case ModelUrlMsg modelUrl: case ModelUrlMsg modelUrl:

10
Messages.cs
View File

@ -171,6 +171,7 @@ namespace Passer.Control {
public static bool Send(Client client, byte networkId, byte thingId) { public static bool Send(Client client, byte networkId, byte thingId) {
InvestigateMsg msg = new(networkId, thingId); InvestigateMsg msg = new(networkId, thingId);
//UnityEngine.Debug.Log($"Send investigate [{msg.networkId}/{msg.thingId}]");
return SendMsg(client, msg); return SendMsg(client, msg);
} }
public static async Task<bool> Receive(Stream dataStream, Client client, byte packetSize) { public static async Task<bool> Receive(Stream dataStream, Client client, byte packetSize) {
@ -179,6 +180,8 @@ namespace Passer.Control {
byte[] buffer = await Receive(dataStream, packetSize); byte[] buffer = await Receive(dataStream, packetSize);
InvestigateMsg msg = new(buffer); InvestigateMsg msg = new(buffer);
//UnityEngine.Debug.Log($"Receive investigate [{msg.networkId}/{msg.thingId}]");
client.messageQueue.Enqueue(msg); client.messageQueue.Enqueue(msg);
return true; return true;
@ -198,6 +201,7 @@ namespace Passer.Control {
public byte parentId; public byte parentId;
public ThingMsg(byte networkId, byte thingId, byte thingType, byte parentId) { public ThingMsg(byte networkId, byte thingId, byte thingType, byte parentId) {
this.networkId = networkId;
this.thingId = thingId; this.thingId = thingId;
this.thingType = thingType; this.thingType = thingType;
this.parentId = parentId; this.parentId = parentId;
@ -222,8 +226,9 @@ namespace Passer.Control {
this.parentId = buffer[ix]; this.parentId = buffer[ix];
} }
public static bool Send(Client client, byte thingId, byte thingType, byte parentId) { public static bool Send(Client client, byte networkId, byte thingId, byte thingType, byte parentId) {
ThingMsg msg = new(client.networkId, thingId, thingType, parentId); ThingMsg msg = new(networkId, thingId, thingType, parentId);
//UnityEngine.Debug.Log($"Send thing [{msg.networkId}/{msg.thingId}]");
return SendMsg(client, msg); return SendMsg(client, msg);
} }
public static async Task<bool> Receive(Stream dataStream, Client client, byte packetSize) { public static async Task<bool> Receive(Stream dataStream, Client client, byte packetSize) {
@ -232,6 +237,7 @@ namespace Passer.Control {
byte[] buffer = await Receive(dataStream, packetSize); byte[] buffer = await Receive(dataStream, packetSize);
ThingMsg msg = new(buffer); ThingMsg msg = new(buffer);
//UnityEngine.Debug.Log($"Receive thing [{msg.networkId}/{msg.thingId}]");
// Do no process poses with nwid == 0 (== local) // Do no process poses with nwid == 0 (== local)
//if (msg.networkId == 0) //if (msg.networkId == 0)