773 lines
28 KiB
Python
773 lines
28 KiB
Python
import cgi
|
|
from eventlet import greenthread
|
|
import eventlet
|
|
import errno
|
|
import os
|
|
import socket
|
|
import sys
|
|
from tests import skipped, LimitedTestCase
|
|
from unittest import main
|
|
|
|
from eventlet import api
|
|
from eventlet import util
|
|
from eventlet import greenio
|
|
from eventlet.green import socket as greensocket
|
|
from eventlet import wsgi
|
|
from eventlet import processes
|
|
|
|
from tests import find_command
|
|
|
|
certificate_file = os.path.join(os.path.dirname(__file__), 'test_server.crt')
|
|
private_key_file = os.path.join(os.path.dirname(__file__), 'test_server.key')
|
|
|
|
try:
|
|
from cStringIO import StringIO
|
|
except ImportError:
|
|
from StringIO import StringIO
|
|
|
|
|
|
def hello_world(env, start_response):
|
|
if env['PATH_INFO'] == 'notexist':
|
|
start_response('404 Not Found', [('Content-type', 'text/plain')])
|
|
return ["not found"]
|
|
|
|
start_response('200 OK', [('Content-type', 'text/plain')])
|
|
return ["hello world"]
|
|
|
|
|
|
def chunked_app(env, start_response):
|
|
start_response('200 OK', [('Content-type', 'text/plain')])
|
|
yield "this"
|
|
yield "is"
|
|
yield "chunked"
|
|
|
|
|
|
def big_chunks(env, start_response):
|
|
start_response('200 OK', [('Content-type', 'text/plain')])
|
|
line = 'a' * 8192
|
|
for x in range(10):
|
|
yield line
|
|
|
|
def use_write(env, start_response):
|
|
if env['PATH_INFO'] == '/a':
|
|
write = start_response('200 OK', [('Content-type', 'text/plain'),
|
|
('Content-Length', '5')])
|
|
write('abcde')
|
|
if env['PATH_INFO'] == '/b':
|
|
write = start_response('200 OK', [('Content-type', 'text/plain')])
|
|
write('abcde')
|
|
return []
|
|
|
|
def chunked_post(env, start_response):
|
|
start_response('200 OK', [('Content-type', 'text/plain')])
|
|
if env['PATH_INFO'] == '/a':
|
|
return [env['wsgi.input'].read()]
|
|
elif env['PATH_INFO'] == '/b':
|
|
return [x for x in iter(lambda: env['wsgi.input'].read(4096), '')]
|
|
elif env['PATH_INFO'] == '/c':
|
|
return [x for x in iter(lambda: env['wsgi.input'].read(1), '')]
|
|
|
|
class Site(object):
|
|
def __init__(self):
|
|
self.application = hello_world
|
|
|
|
def __call__(self, env, start_response):
|
|
return self.application(env, start_response)
|
|
|
|
|
|
CONTENT_LENGTH = 'content-length'
|
|
|
|
|
|
"""
|
|
HTTP/1.1 200 OK
|
|
Date: foo
|
|
Content-length: 11
|
|
|
|
hello world
|
|
"""
|
|
|
|
class ConnectionClosed(Exception):
|
|
pass
|
|
|
|
|
|
def read_http(sock):
|
|
fd = sock.makefile()
|
|
try:
|
|
response_line = fd.readline()
|
|
except socket.error, exc:
|
|
if exc[0] == 10053:
|
|
raise ConnectionClosed
|
|
raise
|
|
if not response_line:
|
|
raise ConnectionClosed
|
|
|
|
header_lines = []
|
|
while True:
|
|
line = fd.readline()
|
|
if line == '\r\n':
|
|
break
|
|
else:
|
|
header_lines.append(line)
|
|
headers = dict()
|
|
for x in header_lines:
|
|
x = x.strip()
|
|
if not x:
|
|
continue
|
|
key, value = x.split(': ', 1)
|
|
assert key.lower() not in headers, "%s header duplicated" % key
|
|
headers[key.lower()] = value
|
|
|
|
if CONTENT_LENGTH in headers:
|
|
num = int(headers[CONTENT_LENGTH])
|
|
body = fd.read(num)
|
|
#print body
|
|
else:
|
|
# read until EOF
|
|
body = fd.read()
|
|
|
|
return response_line, headers, body
|
|
|
|
class TestHttpd(LimitedTestCase):
|
|
def setUp(self):
|
|
super(TestHttpd, self).setUp()
|
|
self.logfile = StringIO()
|
|
self.site = Site()
|
|
self.killer = None
|
|
self.spawn_server()
|
|
|
|
def tearDown(self):
|
|
super(TestHttpd, self).tearDown()
|
|
greenthread.kill(self.killer)
|
|
api.sleep(0)
|
|
|
|
def spawn_server(self, **kwargs):
|
|
"""Spawns a new wsgi server with the given arguments.
|
|
Sets self.port to the port of the server, and self.killer is the greenlet
|
|
running it.
|
|
|
|
Kills any previously-running server."""
|
|
if self.killer:
|
|
greenthread.kill(self.killer)
|
|
|
|
new_kwargs = dict(max_size=128,
|
|
log=self.logfile,
|
|
site=self.site)
|
|
new_kwargs.update(kwargs)
|
|
|
|
if 'sock' not in new_kwargs:
|
|
new_kwargs['sock'] = api.tcp_listener(('localhost', 0))
|
|
|
|
self.port = new_kwargs['sock'].getsockname()[1]
|
|
self.killer = eventlet.spawn_n(
|
|
wsgi.server,
|
|
**new_kwargs)
|
|
|
|
def test_001_server(self):
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.0\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
result = fd.read()
|
|
fd.close()
|
|
## The server responds with the maximum version it supports
|
|
self.assert_(result.startswith('HTTP'), result)
|
|
self.assert_(result.endswith('hello world'))
|
|
|
|
def test_002_keepalive(self):
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
read_http(sock)
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
read_http(sock)
|
|
fd.close()
|
|
|
|
def test_003_passing_non_int_to_read(self):
|
|
# This should go in greenio_test
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
cancel = api.exc_after(1, RuntimeError)
|
|
self.assertRaises(TypeError, fd.read, "This shouldn't work")
|
|
cancel.cancel()
|
|
fd.close()
|
|
|
|
def test_004_close_keepalive(self):
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
read_http(sock)
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n')
|
|
fd.flush()
|
|
read_http(sock)
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
self.assertRaises(ConnectionClosed, read_http, sock)
|
|
fd.close()
|
|
|
|
@skipped
|
|
def test_005_run_apachebench(self):
|
|
url = 'http://localhost:12346/'
|
|
# ab is apachebench
|
|
out = processes.Process(find_command('ab'),
|
|
['-c','64','-n','1024', '-k', url])
|
|
print out.read()
|
|
|
|
def test_006_reject_long_urls(self):
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
path_parts = []
|
|
for ii in range(3000):
|
|
path_parts.append('path')
|
|
path = '/'.join(path_parts)
|
|
request = 'GET /%s HTTP/1.0\r\nHost: localhost\r\n\r\n' % path
|
|
fd = sock.makefile()
|
|
fd.write(request)
|
|
fd.flush()
|
|
result = fd.readline()
|
|
if result:
|
|
# windows closes the socket before the data is flushed,
|
|
# so we never get anything back
|
|
status = result.split(' ')[1]
|
|
self.assertEqual(status, '414')
|
|
fd.close()
|
|
|
|
def test_007_get_arg(self):
|
|
# define a new handler that does a get_arg as well as a read_body
|
|
def new_app(env, start_response):
|
|
body = env['wsgi.input'].read()
|
|
a = cgi.parse_qs(body).get('a', [1])[0]
|
|
start_response('200 OK', [('Content-type', 'text/plain')])
|
|
return ['a is %s, body is %s' % (a, body)]
|
|
self.site.application = new_app
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
request = '\r\n'.join((
|
|
'POST / HTTP/1.0',
|
|
'Host: localhost',
|
|
'Content-Length: 3',
|
|
'',
|
|
'a=a'))
|
|
fd = sock.makefile()
|
|
fd.write(request)
|
|
fd.flush()
|
|
|
|
# send some junk after the actual request
|
|
fd.write('01234567890123456789')
|
|
reqline, headers, body = read_http(sock)
|
|
self.assertEqual(body, 'a is a, body is a=a')
|
|
fd.close()
|
|
|
|
def test_008_correctresponse(self):
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
response_line_200,_,_ = read_http(sock)
|
|
fd.write('GET /notexist HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
response_line_404,_,_ = read_http(sock)
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
response_line_test,_,_ = read_http(sock)
|
|
self.assertEqual(response_line_200,response_line_test)
|
|
fd.close()
|
|
|
|
def test_009_chunked_response(self):
|
|
self.site.application = chunked_app
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n')
|
|
fd.flush()
|
|
self.assert_('Transfer-Encoding: chunked' in fd.read())
|
|
|
|
def test_010_no_chunked_http_1_0(self):
|
|
self.site.application = chunked_app
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.0\r\nHost: localhost\r\nConnection: close\r\n\r\n')
|
|
fd.flush()
|
|
self.assert_('Transfer-Encoding: chunked' not in fd.read())
|
|
|
|
def test_011_multiple_chunks(self):
|
|
self.site.application = big_chunks
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n')
|
|
fd.flush()
|
|
headers = ''
|
|
while True:
|
|
line = fd.readline()
|
|
if line == '\r\n':
|
|
break
|
|
else:
|
|
headers += line
|
|
self.assert_('Transfer-Encoding: chunked' in headers)
|
|
chunks = 0
|
|
chunklen = int(fd.readline(), 16)
|
|
while chunklen:
|
|
chunks += 1
|
|
chunk = fd.read(chunklen)
|
|
fd.readline()
|
|
chunklen = int(fd.readline(), 16)
|
|
self.assert_(chunks > 1)
|
|
|
|
def test_012_ssl_server(self):
|
|
def wsgi_app(environ, start_response):
|
|
start_response('200 OK', {})
|
|
return [environ['wsgi.input'].read()]
|
|
|
|
certificate_file = os.path.join(os.path.dirname(__file__), 'test_server.crt')
|
|
private_key_file = os.path.join(os.path.dirname(__file__), 'test_server.key')
|
|
|
|
server_sock = api.ssl_listener(('localhost', 0), certificate_file, private_key_file)
|
|
self.spawn_server(sock=server_sock, site=wsgi_app)
|
|
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
sock = util.wrap_ssl(sock)
|
|
sock.write('POST /foo HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\nContent-length:3\r\n\r\nabc')
|
|
result = sock.read(8192)
|
|
self.assertEquals(result[-3:], 'abc')
|
|
|
|
def test_013_empty_return(self):
|
|
def wsgi_app(environ, start_response):
|
|
start_response("200 OK", [])
|
|
return [""]
|
|
|
|
certificate_file = os.path.join(os.path.dirname(__file__), 'test_server.crt')
|
|
private_key_file = os.path.join(os.path.dirname(__file__), 'test_server.key')
|
|
server_sock = api.ssl_listener(('localhost', 0), certificate_file, private_key_file)
|
|
self.spawn_server(sock=server_sock, site=wsgi_app)
|
|
|
|
sock = api.connect_tcp(('localhost', server_sock.getsockname()[1]))
|
|
sock = util.wrap_ssl(sock)
|
|
sock.write('GET /foo HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n')
|
|
result = sock.read(8192)
|
|
self.assertEquals(result[-4:], '\r\n\r\n')
|
|
|
|
def test_014_chunked_post(self):
|
|
self.site.application = chunked_post
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('PUT /a HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n'
|
|
'Transfer-Encoding: chunked\r\n\r\n'
|
|
'2\r\noh\r\n4\r\n hai\r\n0\r\n\r\n')
|
|
fd.flush()
|
|
while True:
|
|
if fd.readline() == '\r\n':
|
|
break
|
|
response = fd.read()
|
|
self.assert_(response == 'oh hai', 'invalid response %s' % response)
|
|
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('PUT /b HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n'
|
|
'Transfer-Encoding: chunked\r\n\r\n'
|
|
'2\r\noh\r\n4\r\n hai\r\n0\r\n\r\n')
|
|
fd.flush()
|
|
while True:
|
|
if fd.readline() == '\r\n':
|
|
break
|
|
response = fd.read()
|
|
self.assert_(response == 'oh hai', 'invalid response %s' % response)
|
|
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('PUT /c HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n'
|
|
'Transfer-Encoding: chunked\r\n\r\n'
|
|
'2\r\noh\r\n4\r\n hai\r\n0\r\n\r\n')
|
|
fd.flush()
|
|
while True:
|
|
if fd.readline() == '\r\n':
|
|
break
|
|
response = fd.read(8192)
|
|
self.assert_(response == 'oh hai', 'invalid response %s' % response)
|
|
|
|
def test_015_write(self):
|
|
self.site.application = use_write
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('GET /a HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n')
|
|
fd.flush()
|
|
response_line, headers, body = read_http(sock)
|
|
self.assert_('content-length' in headers)
|
|
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('GET /b HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n')
|
|
fd.flush()
|
|
response_line, headers, body = read_http(sock)
|
|
self.assert_('transfer-encoding' in headers)
|
|
self.assert_(headers['transfer-encoding'] == 'chunked')
|
|
|
|
def test_016_repeated_content_length(self):
|
|
"""
|
|
content-length header was being doubled up if it was set in
|
|
start_response and could also be inferred from the iterator
|
|
"""
|
|
def wsgi_app(environ, start_response):
|
|
start_response('200 OK', [('Content-Length', '7')])
|
|
return ['testing']
|
|
self.site.application = wsgi_app
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('GET /a HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n')
|
|
fd.flush()
|
|
header_lines = []
|
|
while True:
|
|
line = fd.readline()
|
|
if line == '\r\n':
|
|
break
|
|
else:
|
|
header_lines.append(line)
|
|
self.assertEquals(1, len([l for l in header_lines
|
|
if l.lower().startswith('content-length')]))
|
|
|
|
def test_017_ssl_zeroreturnerror(self):
|
|
|
|
def server(sock, site, log):
|
|
try:
|
|
serv = wsgi.Server(sock, sock.getsockname(), site, log)
|
|
client_socket = sock.accept()
|
|
serv.process_request(client_socket)
|
|
return True
|
|
except:
|
|
import traceback
|
|
traceback.print_exc()
|
|
return False
|
|
|
|
def wsgi_app(environ, start_response):
|
|
start_response('200 OK', [])
|
|
return [environ['wsgi.input'].read()]
|
|
|
|
certificate_file = os.path.join(os.path.dirname(__file__), 'test_server.crt')
|
|
private_key_file = os.path.join(os.path.dirname(__file__), 'test_server.key')
|
|
|
|
sock = api.ssl_listener(('localhost', 0), certificate_file, private_key_file)
|
|
|
|
server_coro = eventlet.spawn(server, sock, wsgi_app, self.logfile)
|
|
|
|
client = api.connect_tcp(('localhost', sock.getsockname()[1]))
|
|
client = util.wrap_ssl(client)
|
|
client.write('X') # non-empty payload so that SSL handshake occurs
|
|
greenio.shutdown_safe(client)
|
|
client.close()
|
|
|
|
success = server_coro.wait()
|
|
self.assert_(success)
|
|
|
|
def test_018_http_10_keepalive(self):
|
|
# verify that if an http/1.0 client sends connection: keep-alive
|
|
# that we don't close the connection
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.0\r\nHost: localhost\r\nConnection: keep-alive\r\n\r\n')
|
|
fd.flush()
|
|
|
|
response_line, headers, body = read_http(sock)
|
|
self.assert_('connection' in headers)
|
|
self.assertEqual('keep-alive', headers['connection'])
|
|
# repeat request to verify connection is actually still open
|
|
fd.write('GET / HTTP/1.0\r\nHost: localhost\r\nConnection: keep-alive\r\n\r\n')
|
|
fd.flush()
|
|
response_line, headers, body = read_http(sock)
|
|
self.assert_('connection' in headers)
|
|
self.assertEqual('keep-alive', headers['connection'])
|
|
|
|
def test_019_fieldstorage_compat(self):
|
|
def use_fieldstorage(environ, start_response):
|
|
import cgi
|
|
fs = cgi.FieldStorage(fp=environ['wsgi.input'],
|
|
environ=environ)
|
|
start_response('200 OK', [('Content-type', 'text/plain')])
|
|
return ['hello!']
|
|
|
|
self.site.application = use_fieldstorage
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
fd = sock.makefile()
|
|
fd.write('POST / HTTP/1.1\r\n'
|
|
'Host: localhost\r\n'
|
|
'Connection: close\r\n'
|
|
'Transfer-Encoding: chunked\r\n\r\n'
|
|
'2\r\noh\r\n'
|
|
'4\r\n hai\r\n0\r\n\r\n')
|
|
fd.flush()
|
|
self.assert_('hello!' in fd.read())
|
|
|
|
def test_020_x_forwarded_for(self):
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
sock.sendall('GET / HTTP/1.1\r\nHost: localhost\r\nX-Forwarded-For: 1.2.3.4, 5.6.7.8\r\n\r\n')
|
|
sock.recv(1024)
|
|
sock.close()
|
|
self.assert_('1.2.3.4,5.6.7.8,127.0.0.1' in self.logfile.getvalue())
|
|
|
|
# turning off the option should work too
|
|
self.logfile = StringIO()
|
|
self.spawn_server(log_x_forwarded_for=False)
|
|
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
sock.sendall('GET / HTTP/1.1\r\nHost: localhost\r\nX-Forwarded-For: 1.2.3.4, 5.6.7.8\r\n\r\n')
|
|
sock.recv(1024)
|
|
sock.close()
|
|
self.assert_('1.2.3.4' not in self.logfile.getvalue())
|
|
self.assert_('5.6.7.8' not in self.logfile.getvalue())
|
|
self.assert_('127.0.0.1' in self.logfile.getvalue())
|
|
|
|
def test_socket_remains_open(self):
|
|
greenthread.kill(self.killer)
|
|
server_sock = api.tcp_listener(('localhost', 0))
|
|
server_sock_2 = server_sock.dup()
|
|
self.spawn_server(sock=server_sock_2)
|
|
# do a single req/response to verify it's up
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.0\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
result = fd.read(1024)
|
|
fd.close()
|
|
self.assert_(result.startswith('HTTP'), result)
|
|
self.assert_(result.endswith('hello world'))
|
|
|
|
# shut down the server and verify the server_socket fd is still open,
|
|
# but the actual socketobject passed in to wsgi.server is closed
|
|
greenthread.kill(self.killer)
|
|
api.sleep(0.001) # make the kill go through
|
|
try:
|
|
server_sock_2.accept()
|
|
# shouldn't be able to use this one anymore
|
|
except socket.error, exc:
|
|
self.assertEqual(exc[0], errno.EBADF)
|
|
self.spawn_server(sock=server_sock)
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.0\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
result = fd.read(1024)
|
|
fd.close()
|
|
self.assert_(result.startswith('HTTP'), result)
|
|
self.assert_(result.endswith('hello world'))
|
|
|
|
def test_021_environ_clobbering(self):
|
|
def clobberin_time(environ, start_response):
|
|
for environ_var in ['wsgi.version', 'wsgi.url_scheme',
|
|
'wsgi.input', 'wsgi.errors', 'wsgi.multithread',
|
|
'wsgi.multiprocess', 'wsgi.run_once', 'REQUEST_METHOD',
|
|
'SCRIPT_NAME', 'PATH_INFO', 'QUERY_STRING', 'CONTENT_TYPE',
|
|
'CONTENT_LENGTH', 'SERVER_NAME', 'SERVER_PORT',
|
|
'SERVER_PROTOCOL']:
|
|
environ[environ_var] = None
|
|
start_response('200 OK', [('Content-type', 'text/plain')])
|
|
return []
|
|
self.site.application = clobberin_time
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.1\r\n'
|
|
'Host: localhost\r\n'
|
|
'Connection: close\r\n'
|
|
'\r\n\r\n')
|
|
fd.flush()
|
|
self.assert_('200 OK' in fd.read())
|
|
|
|
def test_022_custom_pool(self):
|
|
# just test that it accepts the parameter for now
|
|
# TODO: test that it uses the pool and that you can waitall() to
|
|
# ensure that all clients finished
|
|
from eventlet import greenpool
|
|
p = greenpool.GreenPool(5)
|
|
self.spawn_server(custom_pool=p)
|
|
|
|
# this stuff is copied from test_001_server, could be better factored
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.0\r\nHost: localhost\r\n\r\n')
|
|
fd.flush()
|
|
result = fd.read()
|
|
fd.close()
|
|
self.assert_(result.startswith('HTTP'), result)
|
|
self.assert_(result.endswith('hello world'))
|
|
|
|
def test_023_bad_content_length(self):
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('GET / HTTP/1.0\r\nHost: localhost\r\nContent-length: argh\r\n\r\n')
|
|
fd.flush()
|
|
result = fd.read()
|
|
fd.close()
|
|
self.assert_(result.startswith('HTTP'), result)
|
|
self.assert_('400 Bad Request' in result)
|
|
self.assert_('500' not in result)
|
|
|
|
def test_024_expect_100_continue(self):
|
|
def wsgi_app(environ, start_response):
|
|
if int(environ['CONTENT_LENGTH']) > 1024:
|
|
start_response('417 Expectation Failed', [('Content-Length', '7')])
|
|
return ['failure']
|
|
else:
|
|
text = environ['wsgi.input'].read()
|
|
start_response('200 OK', [('Content-Length', str(len(text)))])
|
|
return [text]
|
|
self.site.application = wsgi_app
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('PUT / HTTP/1.1\r\nHost: localhost\r\nContent-length: 1025\r\nExpect: 100-continue\r\n\r\n')
|
|
fd.flush()
|
|
response_line, headers, body = read_http(sock)
|
|
self.assert_(response_line.startswith('HTTP/1.1 417 Expectation Failed'))
|
|
self.assertEquals(body, 'failure')
|
|
fd.write('PUT / HTTP/1.1\r\nHost: localhost\r\nContent-length: 7\r\nExpect: 100-continue\r\n\r\ntesting')
|
|
fd.flush()
|
|
header_lines = []
|
|
while True:
|
|
line = fd.readline()
|
|
if line == '\r\n':
|
|
break
|
|
else:
|
|
header_lines.append(line)
|
|
self.assert_(header_lines[0].startswith('HTTP/1.1 100 Continue'))
|
|
header_lines = []
|
|
while True:
|
|
line = fd.readline()
|
|
if line == '\r\n':
|
|
break
|
|
else:
|
|
header_lines.append(line)
|
|
self.assert_(header_lines[0].startswith('HTTP/1.1 200 OK'))
|
|
self.assertEquals(fd.read(7), 'testing')
|
|
fd.close()
|
|
|
|
def test_025_accept_errors(self):
|
|
from eventlet import debug
|
|
debug.hub_exceptions(True)
|
|
listener = greensocket.socket()
|
|
listener.bind(('localhost', 0))
|
|
# NOT calling listen, to trigger the error
|
|
self.logfile = StringIO()
|
|
self.spawn_server(sock=listener)
|
|
old_stderr = sys.stderr
|
|
try:
|
|
sys.stderr = self.logfile
|
|
api.sleep(0) # need to enter server loop
|
|
try:
|
|
api.connect_tcp(('localhost', self.port))
|
|
self.fail("Didn't expect to connect")
|
|
except socket.error, exc:
|
|
self.assertEquals(exc[0], errno.ECONNREFUSED)
|
|
|
|
self.assert_('Invalid argument' in self.logfile.getvalue(),
|
|
self.logfile.getvalue())
|
|
finally:
|
|
sys.stderr = old_stderr
|
|
debug.hub_exceptions(False)
|
|
|
|
def test_026_log_format(self):
|
|
self.spawn_server(log_format="HI %(request_line)s HI")
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
sock.sendall('GET /yo! HTTP/1.1\r\nHost: localhost\r\n\r\n')
|
|
sock.recv(1024)
|
|
sock.close()
|
|
self.assert_('\nHI GET /yo! HTTP/1.1 HI\n' in self.logfile.getvalue(), self.logfile.getvalue())
|
|
|
|
def test_close_chunked_with_1_0_client(self):
|
|
# verify that if we return a generator from our app
|
|
# and we're not speaking with a 1.1 client, that we
|
|
# close the connection
|
|
self.site.application = chunked_app
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
|
|
sock.sendall('GET / HTTP/1.0\r\nHost: localhost\r\nConnection: keep-alive\r\n\r\n')
|
|
|
|
response_line, headers, body = read_http(sock)
|
|
self.assertEqual(headers['connection'], 'close')
|
|
self.assertNotEqual(headers.get('transfer-encoding'), 'chunked')
|
|
self.assertEquals(body, "thisischunked")
|
|
|
|
def test_026_http_10_nokeepalive(self):
|
|
# verify that if an http/1.0 client sends connection: keep-alive
|
|
# and the server doesn't accept keep-alives, we close the connection
|
|
self.spawn_server(keepalive=False)
|
|
sock = api.connect_tcp(
|
|
('localhost', self.port))
|
|
|
|
sock.sendall('GET / HTTP/1.0\r\nHost: localhost\r\nConnection: keep-alive\r\n\r\n')
|
|
response_line, headers, body = read_http(sock)
|
|
self.assertEqual(headers['connection'], 'close')
|
|
|
|
def test_027_keepalive_chunked(self):
|
|
self.site.application = chunked_post
|
|
sock = api.connect_tcp(('localhost', self.port))
|
|
fd = sock.makefile()
|
|
fd.write('PUT /a HTTP/1.1\r\nHost: localhost\r\nTransfer-Encoding: chunked\r\n\r\n10\r\n0123456789abcdef\r\n0\r\n\r\n')
|
|
fd.flush()
|
|
read_http(sock)
|
|
fd.write('PUT /b HTTP/1.1\r\nHost: localhost\r\nTransfer-Encoding: chunked\r\n\r\n10\r\n0123456789abcdef\r\n0\r\n\r\n')
|
|
fd.flush()
|
|
read_http(sock)
|
|
fd.write('PUT /c HTTP/1.1\r\nHost: localhost\r\nTransfer-Encoding: chunked\r\n\r\n10\r\n0123456789abcdef\r\n0\r\n\r\n')
|
|
fd.flush()
|
|
read_http(sock)
|
|
fd.write('PUT /a HTTP/1.1\r\nHost: localhost\r\nTransfer-Encoding: chunked\r\n\r\n10\r\n0123456789abcdef\r\n0\r\n\r\n')
|
|
fd.flush()
|
|
read_http(sock)
|
|
|
|
def test_028_ssl_handshake_errors(self):
|
|
errored = [False]
|
|
def server(sock):
|
|
try:
|
|
wsgi.server(sock=sock, site=hello_world, log=self.logfile)
|
|
errored[0] = 'SSL handshake error caused wsgi.server to exit.'
|
|
except greenthread.greenlet.GreenletExit:
|
|
pass
|
|
except Exception, e:
|
|
errored[0] = 'SSL handshake error raised exception %s.' % e
|
|
for data in ('', 'GET /non-ssl-request HTTP/1.0\r\n\r\n'):
|
|
srv_sock = api.ssl_listener(('localhost', 0), certificate_file, private_key_file)
|
|
port = srv_sock.getsockname()[1]
|
|
g = eventlet.spawn_n(server, srv_sock)
|
|
client = api.connect_tcp(('localhost', port))
|
|
if data: # send non-ssl request
|
|
client.sendall(data)
|
|
else: # close sock prematurely
|
|
client.close()
|
|
api.sleep(0) # let context switch back to server
|
|
self.assert_(not errored[0], errored[0])
|
|
# make another request to ensure the server's still alive
|
|
try:
|
|
from eventlet.green import ssl
|
|
client = ssl.wrap_socket(api.connect_tcp(('localhost', port)))
|
|
client.write('GET / HTTP/1.0\r\nHost: localhost\r\n\r\n')
|
|
result = client.read()
|
|
self.assert_(result.startswith('HTTP'), result)
|
|
self.assert_(result.endswith('hello world'))
|
|
except ImportError:
|
|
pass # TODO: should test with OpenSSL
|
|
greenthread.kill(g)
|
|
|
|
if __name__ == '__main__':
|
|
main()
|