aboutsummaryrefslogtreecommitdiffstats
path: root/netlib
diff options
context:
space:
mode:
Diffstat (limited to 'netlib')
-rw-r--r--netlib/http.py8
-rw-r--r--netlib/websockets.py12
2 files changed, 10 insertions, 10 deletions
diff --git a/netlib/http.py b/netlib/http.py
index fe27240a..43155486 100644
--- a/netlib/http.py
+++ b/netlib/http.py
@@ -33,7 +33,7 @@ def _is_valid_host(host):
return True
-def get_line(fp):
+def get_request_line(fp):
"""
Get a line, possibly preceded by a blank.
"""
@@ -41,8 +41,6 @@ def get_line(fp):
if line == "\r\n" or line == "\n":
# Possible leftover from previous message
line = fp.readline()
- if line == "":
- raise tcp.NetLibDisconnect()
return line
@@ -457,7 +455,9 @@ def read_request(rfile, include_body=True, body_size_limit=None, wfile=None):
httpversion, host, port, scheme, method, path, headers, content = (
None, None, None, None, None, None, None, None)
- request_line = get_line(rfile)
+ request_line = get_request_line(rfile)
+ if not request_line:
+ raise tcp.NetLibDisconnect()
request_line_parts = parse_init(request_line)
if not request_line_parts:
diff --git a/netlib/websockets.py b/netlib/websockets.py
index d5c5c2fe..da03768d 100644
--- a/netlib/websockets.py
+++ b/netlib/websockets.py
@@ -350,16 +350,16 @@ def get_payload_length_pair(payload_bytestring):
return (length_code, actual_length)
-def check_client_handshake(req):
- if req.headers.get_first("upgrade", None) != "websocket":
+def check_client_handshake(headers):
+ if headers.get_first("upgrade", None) != "websocket":
return
- return req.headers.get_first('sec-websocket-key')
+ return headers.get_first('sec-websocket-key')
-def check_server_handshake(resp):
- if resp.headers.get_first("upgrade", None) != "websocket":
+def check_server_handshake(headers):
+ if headers.get_first("upgrade", None) != "websocket":
return
- return resp.headers.get_first('sec-websocket-accept')
+ return headers.get_first('sec-websocket-accept')
def create_server_nonce(client_nonce):