diff --git a/RoboidControl/Participants/ParticipantUDP.py b/RoboidControl/Participants/ParticipantUDP.py index 3919e28..d9c1403 100644 --- a/RoboidControl/Participants/ParticipantUDP.py +++ b/RoboidControl/Participants/ParticipantUDP.py @@ -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])