summaryrefslogtreecommitdiff
path: root/waitress/tests/test_functional.py
diff options
context:
space:
mode:
authorMichael Merickel <michael@merickel.org>2019-04-10 04:00:22 -0500
committerMichael Merickel <michael@merickel.org>2019-04-10 04:00:22 -0500
commit827e16d4095aa207164e7e6227cbb350b6cba160 (patch)
treeaa2b0cb3bff4105503d68461a49af1965b946684 /waitress/tests/test_functional.py
parent5583715063c30fda571ab0e0169b0068403dc53d (diff)
downloadwaitress-resource-warnings.tar.gz
fix resource warningsresource-warnings
Diffstat (limited to 'waitress/tests/test_functional.py')
-rw-r--r--waitress/tests/test_functional.py8
1 files changed, 8 insertions, 0 deletions
diff --git a/waitress/tests/test_functional.py b/waitress/tests/test_functional.py
index 0571ce6..fd86a43 100644
--- a/waitress/tests/test_functional.py
+++ b/waitress/tests/test_functional.py
@@ -75,6 +75,7 @@ class SubprocessTests(object):
self.sock.close()
# This give us one FD back ...
self.queue.close()
+ self.proc.join()
def assertline(self, line, status, reason, version):
v, s, r = (x.strip() for x in line.split(None, 2))
@@ -125,6 +126,7 @@ class SleepyThreadTests(TcpTests, unittest.TestCase):
for proc in procs:
if proc.returncode is not None: # pragma: no cover
proc.terminate()
+ proc.wait()
# the notsleepy response should always be first returned (it sleeps
# for 2 seconds, then returns; the notsleepy response should be
# processed in the meantime)
@@ -193,16 +195,20 @@ class EchoTests(object):
self.assertEqual(response_body, b'')
def test_multiple_requests_with_body(self):
+ orig_sock = self.sock
for x in range(3):
self.sock = self.create_socket()
self.test_send_with_body()
self.sock.close()
+ self.sock = orig_sock
def test_multiple_requests_without_body(self):
+ orig_sock = self.sock
for x in range(3):
self.sock = self.create_socket()
self.test_send_empty_body()
self.sock.close()
+ self.sock = orig_sock
def test_without_crlf(self):
data = "Echo\nthis\r\nplease"
@@ -252,6 +258,8 @@ class EchoTests(object):
responses.append(response)
for response in responses:
response.read()
+ for h in conns:
+ h.close()
def test_chunking_request_without_content(self):
header = tobytes(