X-Git-Url: https://git.llucax.com/software/pymin.git/blobdiff_plain/f2571fe7b62abfa67f4b805c266869058647afff..9c443d159056e112ed23af07afa38022882583b3:/pymin/pymindaemon.py?ds=sidebyside diff --git a/pymin/pymindaemon.py b/pymin/pymindaemon.py index ee5f805..8ed3f15 100644 --- a/pymin/pymindaemon.py +++ b/pymin/pymindaemon.py @@ -37,7 +37,7 @@ class PyminDaemon(eventloop.EventLoop): >>> PyminDaemon(Root(), ('', 9999)).run() """ - def __init__(self, root, bind_addr=('', 9999)): + def __init__(self, root, bind_addr=('', 9999), timer=1): r"""Initialize the PyminDaemon object. See PyminDaemon class documentation for more info. @@ -47,8 +47,9 @@ class PyminDaemon(eventloop.EventLoop): sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) sock.bind(bind_addr) # Create EventLoop - eventloop.EventLoop.__init__(self, sock) + eventloop.EventLoop.__init__(self, sock, timer=timer) # Create Dispatcher + #TODO root.pymin = PyminHandler() self.dispatcher = dispatcher.Dispatcher(root) # Signal handling def quit(signum, frame): @@ -65,7 +66,7 @@ class PyminDaemon(eventloop.EventLoop): r"handle() -> None :: Handle incoming events using the dispatcher." (msg, addr) = self.file.recvfrom(65535) try: - result = self.dispatcher.dispatch(msg) + result = self.dispatcher.dispatch(unicode(msg, 'utf-8')) if result is not None: result = serializer.serialize(result) response = u'OK ' @@ -81,7 +82,11 @@ class PyminDaemon(eventloop.EventLoop): response += u'0\n' else: response += u'%d\n%s' % (len(result), result) - self.file.sendto(response, addr) + self.file.sendto(response.encode('utf-8'), addr) + + def handle_timer(self): + r"handle_timer() -> None :: Call handle_timer() on handlers." + self.dispatcher.root.handle_timer() def run(self): r"run() -> None :: Run the event loop (shortcut to loop())"