# Signal handling
def quit(signum, frame):
print "Shuting down ..."
- loop.stop() # tell main event loop to stop
+ self.stop() # tell main event loop to stop
def reload_config(signum, frame):
print "Reloading configuration..."
# TODO iterate handlers list propagating reload action
def handle(self):
r"handle() -> None :: Handle incoming events using the dispatcher."
(msg, addr) = self.file.recvfrom(65535)
- self.dispatcher.dispatch(msg)
- #try:
- # d.dispatch(msg)
- #except dis.BadRouteError, inst:
- # sock.sendto('Bad route from : ' + inst.cmd + '\n', addr)
- #except dis.CommandNotFoundError, inst:
- # sock.sendto('Command not found : ' + inst.cmd + '\n', addr)
+ try:
+ result = self.dispatcher.dispatch(msg)
+ response = 'OK '
+ except Exception, e:
+ result = str(e)
+ response = 'ERROR '
+ if result is None:
+ response += '0'
+ else:
+ response += '%d\n%s' % (len(str(result)), result)
+ self.file.sendto(response, addr)
def run(self):
r"run() -> None :: Run the event loop (shortcut to loop())"
if __name__ == '__main__':
+ @handler
def test_handler(*args):
print 'test:', args