Lines Matching refs:transport
54 transport = TestSubprocessTransport(
57 return (transport, protocol)
61 transport, protocol = self.create_transport(waiter)
62 transport._process_exited(6)
65 self.assertEqual(transport.get_returncode(), 6)
72 self.assertFalse(transport.is_closing())
73 self.assertIsNone(transport._loop)
74 self.assertIsNone(transport._proc)
75 self.assertIsNone(transport._protocol)
79 transport.send_signal, signal.SIGTERM)
80 self.assertRaises(ProcessLookupError, transport.terminate)
81 self.assertRaises(ProcessLookupError, transport.kill)
83 transport.close()
87 transport, protocol = self.create_transport(waiter)
88 transport._process_exited(6)
92 repr(transport),
95 transport._returncode = None
97 repr(transport),
100 transport._pid = None
101 transport._returncode = None
103 repr(transport),
106 transport.close()
307 transport, protocol = await connect_read_pipe(*args, **kw)
308 transport.pause_reading = mock.Mock()
309 transport.resume_reading = mock.Mock()
310 return (transport, protocol)
325 # the stream reader transport should pause the protocol to not
331 stdout, transport = self.loop.run_until_complete(test_pause_reading())
334 self.assertTrue(transport.pause_reading.called)
335 self.assertTrue(transport.resume_reading.called)
517 transport, protocol = await create
525 proc = transport.get_extra_info('subprocess')
528 returncode = transport.get_returncode()
529 transport.close()
530 await asyncio.wait_for(transport._wait(), 5)
545 # transport.close() must kill the process if it is still running
554 transport, protocol = await create
555 proc = transport.get_extra_info('subprocess')
563 transport_returncode = transport.get_returncode()
564 transport.close()
579 # transport.close() must not kill the process if it finished, even if
580 # the transport was not notified yet
610 # Issue #24763: check that the subprocess transport is closed