summaryrefslogtreecommitdiffstats
path: root/module/remote/wsbackend/EventHandler.py
diff options
context:
space:
mode:
authorGravatar RaNaN <Mast3rRaNaN@hotmail.de> 2012-10-11 20:55:48 +0200
committerGravatar RaNaN <Mast3rRaNaN@hotmail.de> 2012-10-11 20:55:48 +0200
commit582b8eb777a86a157f4825e3d9d68e8655e8f092 (patch)
tree2c96b04e167135101c57d2ef2d387380f60c1370 /module/remote/wsbackend/EventHandler.py
parentlast test commit (diff)
downloadpyload-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.py32
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