Lines Matching refs:proto
764 proto = MyProto(loop=loop)
765 proto.loop = loop
768 (lambda: proto), conn, ssl=server_ssl))
770 proto.transport.close()
775 self.assertEqual(proto.state, 'CLOSED')
776 self.assertEqual(proto.nbytes, len(message))
833 proto = MyProto(self.loop)
834 f = self.loop.create_server(lambda: proto, '0.0.0.0', 0)
844 self.loop.run_until_complete(proto.connected)
845 self.assertEqual('CONNECTED', proto.state)
847 test_utils.run_until(self.loop, lambda: proto.nbytes > 0)
848 self.assertEqual(3, proto.nbytes)
851 self.assertIsNotNone(proto.transport.get_extra_info('sockname'))
853 proto.transport.get_extra_info('peername')[0])
856 proto.transport.close()
857 self.loop.run_until_complete(proto.done)
859 self.assertEqual('CLOSED', proto.state)
870 proto = MyProto(self.loop)
872 lambda: proto, '0.0.0.0', 0)
883 proto = MyProto(self.loop)
885 lambda: proto, '0.0.0.0', 0, reuse_port=True)
905 proto = MyProto(loop=self.loop)
906 server, path = self._make_unix_server(lambda: proto)
913 self.loop.run_until_complete(proto.connected)
914 self.assertEqual('CONNECTED', proto.state)
915 test_utils.run_until(self.loop, lambda: proto.nbytes > 0)
916 self.assertEqual(3, proto.nbytes)
919 proto.transport.close()
920 self.loop.run_until_complete(proto.done)
922 self.assertEqual('CLOSED', proto.state)
933 proto = MyProto(loop=self.loop)
936 f = self.loop.create_unix_server(lambda: proto, '/test', sock=sock)
965 proto = MyProto(loop=self.loop)
967 lambda: proto, test_utils.ONLYCERT, test_utils.ONLYKEY)
974 self.loop.run_until_complete(proto.connected)
975 self.assertEqual('CONNECTED', proto.state)
977 test_utils.run_until(self.loop, lambda: proto.nbytes > 0)
978 self.assertEqual(3, proto.nbytes)
984 proto.transport.close()
985 self.loop.run_until_complete(proto.done)
986 self.assertEqual('CLOSED', proto.state)
998 proto = MyProto(loop=self.loop)
1000 lambda: proto, test_utils.ONLYCERT, test_utils.ONLYKEY)
1009 self.loop.run_until_complete(proto.connected)
1010 self.assertEqual('CONNECTED', proto.state)
1011 test_utils.run_until(self.loop, lambda: proto.nbytes > 0)
1012 self.assertEqual(3, proto.nbytes)
1015 proto.transport.close()
1016 self.loop.run_until_complete(proto.done)
1017 self.assertEqual('CLOSED', proto.state)
1028 proto = MyProto(loop=self.loop)
1030 lambda: proto, test_utils.SIGNED_CERTFILE)
1052 self.assertIsNone(proto.transport)
1058 proto = MyProto(loop=self.loop)
1060 lambda: proto, test_utils.SIGNED_CERTFILE)
1082 self.assertIsNone(proto.transport)
1087 proto = MyProto(loop=self.loop)
1089 lambda: proto, test_utils.SIGNED_CERTFILE)
1112 self.assertIsNone(proto.transport)
1118 proto = MyProto(loop=self.loop)
1120 lambda: proto, test_utils.SIGNED_CERTFILE)
1134 self.loop.run_until_complete(proto.connected)
1137 proto.transport.close()
1140 self.loop.run_until_complete(proto.done)
1144 proto = MyProto(loop=self.loop)
1146 lambda: proto, test_utils.SIGNED_CERTFILE)
1160 self.loop.run_until_complete(proto.connected)
1167 proto.transport.close()
1170 self.loop.run_until_complete(proto.done)
1173 proto = self.loop.create_future()
1178 proto.set_result(self)
1237 proto = self.loop.run_until_complete(f_proto)
1238 proto.transport.close()
1245 proto = self.loop.run_until_complete(f_proto)
1246 proto.transport.close()
1330 for family, type, proto, cname, address in infos:
1332 sock = socket.socket(family=family, type=type, proto=proto)
1365 proto = MyReadPipeProto(loop=self.loop)
1372 lambda: proto, pipeobj)
1373 self.assertIs(p, proto)
1374 self.assertIs(t, proto.transport)
1375 self.assertEqual(['INITIAL', 'CONNECTED'], proto.state)
1376 self.assertEqual(0, proto.nbytes)
1381 test_utils.run_until(self.loop, lambda: proto.nbytes >= 1)
1382 self.assertEqual(1, proto.nbytes)
1385 test_utils.run_until(self.loop, lambda: proto.nbytes >= 5)
1386 self.assertEqual(['INITIAL', 'CONNECTED'], proto.state)
1387 self.assertEqual(5, proto.nbytes)
1390 self.loop.run_until_complete(proto.done)
1392 ['INITIAL', 'CONNECTED', 'EOF', 'CLOSED'], proto.state)
1394 self.assertIsNotNone(proto.transport.get_extra_info('pipe'))
1434 proto = MyReadPipeProto(loop=self.loop)
1440 t, p = await self.loop.connect_read_pipe(lambda: proto,
1442 self.assertIs(p, proto)
1443 self.assertIs(t, proto.transport)
1444 self.assertEqual(['INITIAL', 'CONNECTED'], proto.state)
1445 self.assertEqual(0, proto.nbytes)
1450 test_utils.run_until(self.loop, lambda: proto.nbytes)
1451 self.assertEqual(1, proto.nbytes)
1454 test_utils.run_until(self.loop, lambda: proto.nbytes >= 5)
1455 self.assertEqual(['INITIAL', 'CONNECTED'], proto.state)
1456 self.assertEqual(5, proto.nbytes)
1459 proto.transport.close()
1460 self.loop.run_until_complete(proto.done)
1462 ['INITIAL', 'CONNECTED', 'EOF', 'CLOSED'], proto.state)
1464 self.assertIsNotNone(proto.transport.get_extra_info('pipe'))
1472 proto = MyWritePipeProto(loop=self.loop)
1473 connect = self.loop.connect_write_pipe(lambda: proto, pipeobj)
1475 self.assertIs(p, proto)
1476 self.assertIs(transport, proto.transport)
1477 self.assertEqual('CONNECTED', proto.state)
1493 self.assertEqual('CONNECTED', proto.state)
1498 self.assertIsNotNone(proto.transport.get_extra_info('pipe'))
1501 proto.transport.close()
1502 self.loop.run_until_complete(proto.done)
1503 self.assertEqual('CLOSED', proto.state)
1512 proto = MyWritePipeProto(loop=self.loop)
1513 connect = self.loop.connect_write_pipe(lambda: proto, pipeobj)
1515 self.assertIs(p, proto)
1516 self.assertIs(transport, proto.transport)
1517 self.assertEqual('CONNECTED', proto.state)
1525 self.loop.run_until_complete(proto.done)
1526 self.assertEqual('CLOSED', proto.state)
1538 proto = MyWritePipeProto(loop=self.loop)
1539 connect = self.loop.connect_write_pipe(lambda: proto, slave_write_obj)
1541 self.assertIs(p, proto)
1542 self.assertIs(transport, proto.transport)
1543 self.assertEqual('CONNECTED', proto.state)
1561 self.assertEqual('CONNECTED', proto.state)
1566 self.assertIsNotNone(proto.transport.get_extra_info('pipe'))
1569 proto.transport.close()
1570 self.loop.run_until_complete(proto.done)
1571 self.assertEqual('CLOSED', proto.state)
1802 transp, proto = self.loop.run_until_complete(connect)
1803 self.assertIsInstance(proto, MySubprocessProtocol)
1804 self.loop.run_until_complete(proto.connected)
1805 self.assertEqual('CONNECTED', proto.state)
1809 self.loop.run_until_complete(proto.got_data[1].wait())
1812 self.loop.run_until_complete(proto.completed)
1813 self.check_killed(proto.returncode)
1814 self.assertEqual(b'Python The Winner', proto.data[1])
1823 transp, proto = self.loop.run_until_complete(connect)
1824 self.assertIsInstance(proto, MySubprocessProtocol)
1825 self.loop.run_until_complete(proto.connected)
1826 self.assertEqual('CONNECTED', proto.state)
1830 self.loop.run_until_complete(proto.got_data[1].wait())
1831 proto.got_data[1].clear()
1832 self.assertEqual(b'Python ', proto.data[1])
1835 self.loop.run_until_complete(proto.got_data[1].wait())
1836 self.assertEqual(b'Python The Winner', proto.data[1])
1840 self.loop.run_until_complete(proto.completed)
1841 self.check_killed(proto.returncode)
1847 transp, proto = self.loop.run_until_complete(connect)
1848 self.assertIsInstance(proto, MySubprocessProtocol)
1849 self.loop.run_until_complete(proto.connected)
1852 self.loop.run_until_complete(proto.completed)
1853 self.assertEqual(0, proto.returncode)
1854 self.assertTrue(all(f.done() for f in proto.disconnects.values()))
1855 self.assertEqual(proto.data[1].rstrip(b'\r\n'), b'Python')
1856 self.assertEqual(proto.data[2], b'')
1864 transp, proto = self.loop.run_until_complete(connect)
1865 self.assertIsInstance(proto, MySubprocessProtocol)
1866 self.loop.run_until_complete(proto.completed)
1867 self.assertEqual(7, proto.returncode)
1875 transp, proto = self.loop.run_until_complete(connect)
1876 self.assertIsInstance(proto, MySubprocessProtocol)
1880 self.loop.run_until_complete(proto.completed)
1881 self.assertEqual(7, proto.returncode)
1891 transp, proto = self.loop.run_until_complete(connect)
1892 self.assertIsInstance(proto, MySubprocessProtocol)
1893 self.loop.run_until_complete(proto.connected)
1896 self.loop.run_until_complete(proto.completed)
1897 self.check_killed(proto.returncode)
1907 transp, proto = self.loop.run_until_complete(connect)
1908 self.assertIsInstance(proto, MySubprocessProtocol)
1909 self.loop.run_until_complete(proto.connected)
1912 self.loop.run_until_complete(proto.completed)
1913 self.check_terminated(proto.returncode)
1930 transp, proto = self.loop.run_until_complete(connect)
1931 self.assertIsInstance(proto, MySubprocessProtocol)
1932 self.loop.run_until_complete(proto.connected)
1935 self.loop.run_until_complete(proto.completed)
1936 self.assertEqual(-signal.SIGHUP, proto.returncode)
1948 transp, proto = self.loop.run_until_complete(connect)
1949 self.assertIsInstance(proto, MySubprocessProtocol)
1950 self.loop.run_until_complete(proto.connected)
1955 self.loop.run_until_complete(proto.completed)
1958 self.assertEqual(b'OUT:test', proto.data[1])
1959 self.assertTrue(proto.data[2].startswith(b'ERR:test'), proto.data[2])
1960 self.assertEqual(0, proto.returncode)
1970 transp, proto = self.loop.run_until_complete(connect)
1971 self.assertIsInstance(proto, MySubprocessProtocol)
1972 self.loop.run_until_complete(proto.connected)
1979 self.loop.run_until_complete(proto.completed)
1980 self.assertTrue(proto.data[1].startswith(b'OUT:testERR:test'),
1981 proto.data[1])
1982 self.assertEqual(b'', proto.data[2])
1985 self.assertEqual(0, proto.returncode)
1994 transp, proto = self.loop.run_until_complete(connect)
1995 self.assertIsInstance(proto, MySubprocessProtocol)
1996 self.loop.run_until_complete(proto.connected)
2001 self.loop.run_until_complete(proto.got_data[1].wait())
2002 self.assertEqual(b'OUT:test', proto.data[1])
2005 self.loop.run_until_complete(proto.disconnects[1])
2007 self.loop.run_until_complete(proto.got_data[2].wait())
2009 self.assertEqual(b'ERR:BrokenPipeError', proto.data[2])
2015 self.assertEqual(b'ERR:OSError', proto.data[2])
2018 self.loop.run_until_complete(proto.completed)
2019 self.check_killed(proto.returncode)
2027 transp, proto = self.loop.run_until_complete(connect)
2028 self.assertIsInstance(proto, MySubprocessProtocol)
2029 self.loop.run_until_complete(proto.completed)
2030 self.assertEqual(7, proto.returncode)
2857 proto = MyProto(loop)
2858 server = loop.run_until_complete(loop.create_server(lambda: proto, '0.0.0.0', 0))