diff options
author | RaNaN <Mast3rRaNaN@hotmail.de> | 2012-10-11 20:55:48 +0200 |
---|---|---|
committer | RaNaN <Mast3rRaNaN@hotmail.de> | 2012-10-11 20:55:48 +0200 |
commit | 582b8eb777a86a157f4825e3d9d68e8655e8f092 (patch) | |
tree | 2c96b04e167135101c57d2ef2d387380f60c1370 /module/remote/wsbackend/EventHandler.py | |
parent | last test commit (diff) | |
download | pyload-582b8eb777a86a157f4825e3d9d68e8655e8f092.tar.xz |
refactored ws handler, generate debug information for ttypes
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 |