summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPeter Åstrand (astrand) <astrand@cendio.se>2013-11-28 13:23:50 +0100
committerPeter Åstrand (astrand) <astrand@cendio.se>2013-11-28 13:23:50 +0100
commit558402848e9fc5b9ec7136144149dd71e3c0c32a (patch)
tree518b9ac61c727cf8b13d583edd6efe276e8f88f6
parent34a1b68d79a13c03aa63b5c4194796341c9383fe (diff)
downloadwebsockify-558402848e9fc5b9ec7136144149dd71e3c0c32a.tar.gz
Rename self.client to self.request, in preparation for merging pull
request #72. The standard Python SocketServer/BaseRequestHandler requires this name.
-rwxr-xr-xtests/echo.py8
-rwxr-xr-xtests/load.py2
-rw-r--r--websockify/websocket.py16
-rwxr-xr-xwebsockify/websocketproxy.py8
4 files changed, 17 insertions, 17 deletions
diff --git a/tests/echo.py b/tests/echo.py
index 1d46d50..6ad0651 100755
--- a/tests/echo.py
+++ b/tests/echo.py
@@ -28,21 +28,21 @@ class WebSocketEcho(WebSocketServer):
cqueue = []
c_pend = 0
cpartial = ""
- rlist = [self.client]
+ rlist = [self.request]
while True:
wlist = []
- if cqueue or c_pend: wlist.append(self.client)
+ if cqueue or c_pend: wlist.append(self.request)
ins, outs, excepts = select.select(rlist, wlist, [], 1)
if excepts: raise Exception("Socket exception")
- if self.client in outs:
+ if self.request in outs:
# Send queued target data to the client
c_pend = self.send_frames(cqueue)
cqueue = []
- if self.client in ins:
+ if self.request in ins:
# Receive client data, decode it, and send it back
frames, closed = self.recv_frames()
cqueue.extend(frames)
diff --git a/tests/load.py b/tests/load.py
index e1354c9..f142fa1 100755
--- a/tests/load.py
+++ b/tests/load.py
@@ -34,7 +34,7 @@ class WebSocketLoad(WebSocketServer):
self.recv_cnt = 0
try:
- self.responder(self.client)
+ self.responder(self.request)
except:
print "accumulated errors:", self.errors
self.errors = 0
diff --git a/websockify/websocket.py b/websockify/websocket.py
index d5ea96b..eb89a1f 100644
--- a/websockify/websocket.py
+++ b/websockify/websocket.py
@@ -477,7 +477,7 @@ Sec-WebSocket-Accept: %s\r
while self.send_parts:
# Send pending frames
buf = self.send_parts.pop(0)
- sent = self.client.send(buf)
+ sent = self.request.send(buf)
if sent == len(buf):
self.print_traffic("<")
@@ -499,7 +499,7 @@ Sec-WebSocket-Accept: %s\r
bufs = []
tdelta = int(time.time()*1000) - self.start_time
- buf = self.client.recv(self.buffer_size)
+ buf = self.request.recv(self.buffer_size)
if len(buf) == 0:
closed = {'code': 1000, 'reason': "Client closed abruptly"}
return bufs, closed
@@ -555,7 +555,7 @@ Sec-WebSocket-Accept: %s\r
msg = pack(">H%ds" % len(reason), code, reason)
buf, h, t = self.encode_hybi(msg, opcode=0x08, base64=False)
- self.client.send(buf)
+ self.request.send(buf)
def do_websocket_handshake(self, headers, path):
h = self.headers = headers
@@ -755,7 +755,7 @@ Sec-WebSocket-Accept: %s\r
# handler process
try:
try:
- self.client = self.do_handshake(startsock, address)
+ self.request = self.do_handshake(startsock, address)
if self.record:
# Record raw frame data as JavaScript array
@@ -774,7 +774,7 @@ Sec-WebSocket-Accept: %s\r
except self.CClose:
# Close the client
_, exc, _ = sys.exc_info()
- if self.client:
+ if self.request:
self.send_close(exc.args[0], exc.args[1])
except self.EClose:
_, exc, _ = sys.exc_info()
@@ -792,10 +792,10 @@ Sec-WebSocket-Accept: %s\r
self.rec.write("'EOF'];\n")
self.rec.close()
- if self.client and self.client != startsock:
+ if self.request and self.request != startsock:
# Close the SSL wrapped socket
# Original socket closed by caller
- self.client.close()
+ self.request.close()
def new_client(self):
""" Do something with a WebSockets client connection. """
@@ -841,7 +841,7 @@ Sec-WebSocket-Accept: %s\r
while True:
try:
try:
- self.client = None
+ self.request = None
startsock = None
pid = err = 0
child_count = 0
diff --git a/websockify/websocketproxy.py b/websockify/websocketproxy.py
index 8e5d3fe..0ea37f4 100755
--- a/websockify/websocketproxy.py
+++ b/websockify/websocketproxy.py
@@ -241,23 +241,23 @@ Traffic Legend:
cqueue = []
c_pend = 0
tqueue = []
- rlist = [self.client, target]
+ rlist = [self.request, target]
while True:
wlist = []
if tqueue: wlist.append(target)
- if cqueue or c_pend: wlist.append(self.client)
+ if cqueue or c_pend: wlist.append(self.request)
ins, outs, excepts = select(rlist, wlist, [], 1)
if excepts: raise Exception("Socket exception")
- if self.client in outs:
+ if self.request in outs:
# Send queued target data to the client
c_pend = self.send_frames(cqueue)
cqueue = []
- if self.client in ins:
+ if self.request in ins:
# Receive client data, decode it, and queue for target
bufs, closed = self.recv_frames()
tqueue.extend(bufs)