The-Homebrew-Cloud/frodo-wii
2
0
Fork 0
mirror of https://github.com/Oibaf66/frodo-wii.git synced 2024-11-10 21:55:11 +01:00
Code Issues Packages Projects Releases Wiki Activity

Handle network messages

Browse Source
This commit is contained in:
simon.kagstrom 2010-02-21 18:42:42 +00:00
parent e41dcc3c2b
commit 401784e95e
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
network-broker/network-broker
View File

@ -219,8 +219,9 @@ class TextMessagePacket(Packet):
def demarshal_from_data(self, data): def demarshal_from_data(self, data):
Packet.demarshal_from_data(self, data) Packet.demarshal_from_data(self, data)
strlen = self.size - 8 - 1
# Flags is always broadcast # Flags is always broadcast
self.message = struct.unpack(">s", data[9:])[0] self.message = struct.unpack(">%ds" % (strlen), data[9:])[0]
self.size = 8 + 1 + len(self.message) + 1 # NULL self.size = 8 + 1 + len(self.message) + 1 # NULL
def marshal(self): def marshal(self):
@ -471,7 +472,7 @@ class Peer:
self.last_ping = cur_time() self.last_ping = cur_time()
if pkt.type == TEXT_MESSAGE: if pkt.type == TEXT_MESSAGE:
self.srv.enqueue_message(pkt) self.srv.enqueue_message(self, pkt)
def seconds_since_last_ping(self): def seconds_since_last_ping(self):
now = cur_time() now = cur_time()
@ -630,12 +631,13 @@ class Broker(SocketServer.UDPServer):
return v return v
return None return None
def enqueue_message(self, message): def enqueue_message(self, sending_peer, message):
# Store last 10 messages # Store last 10 messages
self.messages = self.messages[-9:] + [message] self.messages = self.messages[-9:] + [message]
for peer in self.peers: for addr, peer in self.peers.iteritems():
peer.send_packet(message) if peer != sending_peer:
peer.send_packet(message.marshal())
def dequeue_old_messages(self): def dequeue_old_messages(self):
now = time.mktime(time.localtime()) now = time.mktime(time.localtime())