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

Log from the daemon

Browse Source
This commit is contained in:
simon.kagstrom 2009-03-01 07:47:22 +00:00
parent b6010f9508
commit fa543ac596
1 changed files with 23 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
Src/network-broker/main.py
View File

@ -1,6 +1,5 @@
import socket import socket, struct, syslog
import SocketServer import SocketServer
import struct
FRODO_NETWORK_MAGIC = 0x1976 FRODO_NETWORK_MAGIC = 0x1976
@ -13,6 +12,20 @@ PING = 95 # (broker) are you alive?
ACK = 94 # Answer to broker ACK = 94 # Answer to broker
STOP = 55 # No more packets STOP = 55 # No more packets
def log(pri, msg, echo):
syslog.syslog(pri, msg)
if echo:
print msg
def log_error(msg, echo = False):
log(syslog.LOG_ERR, msg, echo)
def log_warn(msg, echo = False):
log(syslog.LOG_WARNING, msg, echo)
def log_info(msg, echo = False):
log(syslog.LOG_INFO, msg, echo)
class Packet: class Packet:
def __init__(self): def __init__(self):
"""Create a new packet""" """Create a new packet"""
@ -161,6 +174,7 @@ class Peer:
self.srv.remove_peer(self) self.srv.remove_peer(self)
def send_packet(self, data): def send_packet(self, data):
log_info("Sending data to %s:%d" % (self.addr[0], self.addr[1]))
self.srv.socket.sendto(data + StopPacket().marshal(), self.srv.socket.sendto(data + StopPacket().marshal(),
0, self.addr) 0, self.addr)
@ -187,20 +201,22 @@ class BrokerPacketHandler(SocketServer.DatagramRequestHandler):
srv = self.server srv = self.server
data = self.rfile.read() data = self.rfile.read()
print "Got packet from", self.client_address
try: try:
pkt = self.get_packet_from_data(data) pkt = self.get_packet_from_data(data)
except Exception, e: except Exception, e:
print "Broken packet: ", e log_error("Broken packet: %s" % e)
return return
log_info("Received packet %d from %s:%d" % (pkt.get_type(), self.client_address[0],
self.client_address[1]))
peer = srv.get_peer(self.client_address) peer = srv.get_peer(self.client_address)
try: try:
peer.handle_packet(pkt) peer.handle_packet(pkt)
except Exception, e: except Exception, e:
# Sends crap, let's remove it # Sends crap, let's remove it
print "Handling packet failed, removing peer:", e log_error("Handling packet failed, removing peer: %s" % e)
srv.remove_peer(peer) srv.remove_peer(peer)
class Broker(SocketServer.UDPServer): class Broker(SocketServer.UDPServer):
@ -248,6 +264,7 @@ packet_class_by_type = {
} }
if __name__ == "__main__": if __name__ == "__main__":
print "Starting Frodo network broker" syslog.openlog("frodo")
log_info("Starting Frodo network broker", True)
s = Broker( ("localhost", 46214), BrokerPacketHandler) s = Broker( ("localhost", 46214), BrokerPacketHandler)
s.serve_forever() s.serve_forever()