RoboidControl/RoboidControl-python
RoboidControl/RoboidControl-python
1
0
Fork 0
Code Issues 1 Pull Requests Actions Packages Releases Activity

Send msg direct from local UDP participant

Browse Source
This commit is contained in:
Pascal Serrarens 2025-06-05 16:58:24 +02:00
parent de38566fa2
commit 932fbc1d6f
1 changed files with 3 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
RoboidControl/Participants/ParticipantUDP.py
View File

@ -115,25 +115,11 @@ class ParticipantUDP(Participant):
def UpdateMyThings(self, currentTimeMs: int):
for thing in self.things:
# if thing.hierarchyChanged and not (self.isIsolated or self.network_id == ):
# thingMsg = ThingMsg(self.network_id, thing)
# self.Send(self.remote_site, thingMsg)
# if thing.owner is not None:
# poseMsg = PoseMsg(thing.owner.network_id, thing)
# if self.remote_site is not None:
# self.remote_site.Send(poseMsg)
thing.Update(False)
if not(self.is_isolated or self.network_id == 0):
if thing.terminate:
destroyMsg = DestroyMsg.Create(self.network_id, thing)
self.remote_site.Send(destroyMsg)
# else:
# this is very inefficient
# if self.remote_site is not None and thing.owner is not None:
# # Send to remote site
# self.Send(self.remote_site, PoseMsg(thing.owner.network_id, thing))
# self.Send(self.remote_site, BinaryMsg(thing.owner.network_id, thing))
if thing.terminate:
self.Remove(thing)
@ -159,14 +145,9 @@ class ParticipantUDP(Participant):
self.Publish(PoseMsg(self.network_id, thing))
self.Publish(BinaryMsg(self.network_id, thing))
# def Send(self, owner: Participant, msg: IMessage):
# buffer_size = msg.Serialize([self.buffer])
# if buffer_size <= 0:
# return True
# # print(f'{self.name} send {self.buffer[0]} to {owner.ip_address} {owner.port}')
# self.udp_socket.sendto(self.buffer[:buffer_size], (owner.ip_address, owner.port))
# return True
def Send(self, msg):
if self.remote_site is not None:
self.remote_site.Send(msg)
def Publish(self, msg: IMessage):
buffer_size = msg.Serialize([self.buffer])