diff options
Diffstat (limited to 'module/remote/wsbackend/EventHandler.py')
-rw-r--r-- | module/remote/wsbackend/EventHandler.py | 32 |
1 files changed, 16 insertions, 16 deletions
diff --git a/module/remote/wsbackend/EventHandler.py b/module/remote/wsbackend/EventHandler.py index deab25a6c..2550ff2eb 100644 --- a/module/remote/wsbackend/EventHandler.py +++ b/module/remote/wsbackend/EventHandler.py @@ -16,26 +16,26 @@ # @author: RaNaN ############################################################################### -from mod_pywebsocket.msgutil import receive_message, send_message +from threading import Lock -class EventHandler: - def __init__(self, api): - self.api = api +from module.utils import lock +from AbstractHandler import AbstractHandler - def do_extra_handshake(self, req): - pass +class EventHandler(AbstractHandler): - def transfer_data(self, req): + def __init__(self, api): + AbstractHandler.__init__(self, api) + self.clients = [] + self.lock = Lock() - while True: - try: - line = receive_message(req) - except TypeError: # connection closed - return + @lock + def on_open(self, req): + self.clients.append(req) - print "Got", line - send_message(req, "You send: %s" % line) + @lock + def on_close(self, req): + self.clients.remove(req) - def passive_closing_handshake(self, req): - print "Closed", req
\ No newline at end of file + def handle_message(self, line, req): + pass
\ No newline at end of file |