Lines Matching refs:transport
47 transport = TestSubprocessTransport(
50 return (transport, protocol)
54 transport, protocol = self.create_transport(waiter)
55 transport._process_exited(6)
58 self.assertEqual(transport.get_returncode(), 6)
65 self.assertFalse(transport.is_closing())
66 self.assertIsNone(transport._loop)
67 self.assertIsNone(transport._proc)
68 self.assertIsNone(transport._protocol)
72 transport.send_signal, signal.SIGTERM)
73 self.assertRaises(ProcessLookupError, transport.terminate)
74 self.assertRaises(ProcessLookupError, transport.kill)
76 transport.close()
240 transport, protocol = yield from connect_read_pipe(*args, **kw)
241 transport.pause_reading = mock.Mock()
242 transport.resume_reading = mock.Mock()
243 return (transport, protocol)
258 # the stream reader transport should pause the protocol to not
264 stdout, transport = self.loop.run_until_complete(test_pause_reading())
267 self.assertTrue(transport.pause_reading.called)
268 self.assertTrue(transport.resume_reading.called)
378 transport, protocol = yield from create
386 proc = transport.get_extra_info('subprocess')
389 returncode = transport.get_returncode()
390 transport.close()
391 yield from transport._wait()
399 # transport.close() must kill the process if it is still running
408 transport, protocol = yield from create
409 proc = transport.get_extra_info('subprocess')
417 transport_returncode = transport.get_returncode()
418 transport.close()
433 # transport.close() must not kill the process if it finished, even if
434 # the transport was not notified yet
445 # Issue #24763: check that the subprocess transport is closed
