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

Rename remote_participant to owner

Browse Source
This commit is contained in:
Pascal Serrarens 2025-03-12 15:50:24 +01:00
parent 9a13a2de12
commit 33ae03bd83
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/LocalParticipant.cs
View File

@ -168,20 +168,20 @@ namespace RoboidControl {
#region Send #region Send
public void SendThingInfo(Participant remoteParticipant, Thing thing) { public void SendThingInfo(Participant owner, Thing thing) {
Console.WriteLine("Send thing info"); Console.WriteLine("Send thing info");
this.Send(remoteParticipant, new ThingMsg(this.networkId, thing)); this.Send(owner, new ThingMsg(this.networkId, thing));
this.Send(remoteParticipant, new NameMsg(this.networkId, thing)); this.Send(owner, new NameMsg(this.networkId, thing));
this.Send(remoteParticipant, new ModelUrlMsg(this.networkId, thing)); this.Send(owner, new ModelUrlMsg(this.networkId, thing));
this.Send(remoteParticipant, new BinaryMsg(this.networkId, thing)); this.Send(owner, new BinaryMsg(this.networkId, thing));
} }
public bool Send(Participant remoteParticipant, IMessage msg) { public bool Send(Participant owner, IMessage msg) {
int bufferSize = msg.Serialize(ref this.buffer); int bufferSize = msg.Serialize(ref this.buffer);
if (bufferSize <= 0) if (bufferSize <= 0)
return true; return true;
IPEndPoint participantEndpoint = new IPEndPoint(IPAddress.Parse(remoteParticipant.ipAddress), remoteParticipant.port); IPEndPoint participantEndpoint = new IPEndPoint(IPAddress.Parse(owner.ipAddress), owner.port);
// Console.WriteLine($"msg to {participantEndpoint.Address.ToString()} {participantEndpoint.Port}"); // Console.WriteLine($"msg to {participantEndpoint.Address.ToString()} {participantEndpoint.Port}");
this.udpClient?.Send(this.buffer, bufferSize, participantEndpoint); this.udpClient?.Send(this.buffer, bufferSize, participantEndpoint);
return true; return true;