summaryrefslogtreecommitdiffstats
path: root/Lib/test
diff options
context:
space:
mode:
Diffstat (limited to 'Lib/test')
-rw-r--r--Lib/test/test_queue.py5
-rw-r--r--Lib/test/test_subprocess.py22
2 files changed, 26 insertions, 1 deletions
diff --git a/Lib/test/test_queue.py b/Lib/test/test_queue.py
index 86ad9c0..2cdfee4 100644
--- a/Lib/test/test_queue.py
+++ b/Lib/test/test_queue.py
@@ -46,6 +46,9 @@ class _TriggerThread(threading.Thread):
class BlockingTestMixin:
+ def tearDown(self):
+ self.t = None
+
def do_blocking_test(self, block_func, block_args, trigger_func, trigger_args):
self.t = _TriggerThread(trigger_func, trigger_args)
self.t.start()
@@ -260,7 +263,7 @@ class FailingQueue(queue.Queue):
raise FailingQueueException("You Lose")
return queue.Queue._get(self)
-class FailingQueueTest(unittest.TestCase, BlockingTestMixin):
+class FailingQueueTest(BlockingTestMixin, unittest.TestCase):
def failing_queue_test(self, q):
if q.qsize():
diff --git a/Lib/test/test_subprocess.py b/Lib/test/test_subprocess.py
index b1e9027..1a50de3 100644
--- a/Lib/test/test_subprocess.py
+++ b/Lib/test/test_subprocess.py
@@ -79,6 +79,28 @@ class PopenExecuteChildRaises(subprocess.Popen):
class ProcessTestCase(BaseTestCase):
+ def test_io_buffered_by_default(self):
+ p = subprocess.Popen([sys.executable, "-c", "import sys; sys.exit(0)"],
+ stdin=subprocess.PIPE, stdout=subprocess.PIPE,
+ stderr=subprocess.PIPE)
+ try:
+ self.assertIsInstance(p.stdin, io.BufferedIOBase)
+ self.assertIsInstance(p.stdout, io.BufferedIOBase)
+ self.assertIsInstance(p.stderr, io.BufferedIOBase)
+ finally:
+ p.wait()
+
+ def test_io_unbuffered_works(self):
+ p = subprocess.Popen([sys.executable, "-c", "import sys; sys.exit(0)"],
+ stdin=subprocess.PIPE, stdout=subprocess.PIPE,
+ stderr=subprocess.PIPE, bufsize=0)
+ try:
+ self.assertIsInstance(p.stdin, io.RawIOBase)
+ self.assertIsInstance(p.stdout, io.RawIOBase)
+ self.assertIsInstance(p.stderr, io.RawIOBase)
+ finally:
+ p.wait()
+
def test_call_seq(self):
# call() function with sequence argument
rc = subprocess.call([sys.executable, "-c",