test_events.py - OpenGrok cross reference for /third_party/python/Lib/test/test_asyncio/test

Lines Matching refs:transport
84         self.transport = None
95     def connection_made(self, transport):
96         self.transport = transport
118     def connection_made(self, transport):
119         super().connection_made(transport)
120         transport.write(b'GET / HTTP/1.0\r\nHost: example.com\r\n\r\n')
136     def connection_made(self, transport):
137         self.transport = transport
161         self.transport = None
169     def connection_made(self, transport):
170         self.transport = transport
196         self.transport = None
204     def connection_made(self, transport):
205         self.transport = transport
220         self.transport = None
233     def connection_made(self, transport):
234         self.transport = transport
258         self.returncode = self.transport.get_returncode()
269         # just in case if we have transport close callbacks
531         self.assertIs(pr.transport, tr)
670             expected = pr.transport.get_extra_info('sockname')[1]
736                 self.transport.write(expected_response)
770         proto.transport.close()
851         self.assertIsNotNone(proto.transport.get_extra_info('sockname'))
853                          proto.transport.get_extra_info('peername')[0])
856         proto.transport.close()
919         proto.transport.close()
984         proto.transport.close()
1015         proto.transport.close()
1052         self.assertIsNone(proto.transport)
1082         self.assertIsNone(proto.transport)
1111         # transport is None because TLS ALERT aborted the handshake
1112         self.assertIsNone(proto.transport)
1137         proto.transport.close()
1167         proto.transport.close()
1176             def connection_made(self, transport):
1177                 super().connection_made(transport)
1215             def connection_made(self, transport):
1216                 super().connection_made(transport)
1238         proto.transport.close()
1246         proto.transport.close()
1276                 self.transport.sendto(b'resp:'+data, addr)
1288         self.assertIs(server.transport, s_transport)
1293         transport, client = self.loop.run_until_complete(coro)
1295         self.assertIsInstance(transport, asyncio.Transport)
1298         self.assertIs(client.transport, transport)
1300         transport.sendto(b'xxx')
1309         self.assertIsNotNone(transport.get_extra_info('sockname'))
1312         transport.close()
1315         server.transport.close()
1374             self.assertIs(t, proto.transport)
1394         self.assertIsNotNone(proto.transport.get_extra_info('pipe'))
1443             self.assertIs(t, proto.transport)
1459         proto.transport.close()
1464         self.assertIsNotNone(proto.transport.get_extra_info('pipe'))
1474         transport, p = self.loop.run_until_complete(connect)
1476         self.assertIs(transport, proto.transport)
1479         transport.write(b'1')
1490         transport.write(b'2345')
1498         self.assertIsNotNone(proto.transport.get_extra_info('pipe'))
1501         proto.transport.close()
1514         transport, p = self.loop.run_until_complete(connect)
1516         self.assertIs(transport, proto.transport)
1519         transport.write(b'1')
1540         transport, p = self.loop.run_until_complete(connect)
1542         self.assertIs(transport, proto.transport)
1545         transport.write(b'1')
1557         transport.write(b'2345')
1566         self.assertIsNotNone(proto.transport.get_extra_info('pipe'))
1569         proto.transport.close()
1590         self.assertIs(read_transport, read_proto.transport)
1601         self.assertIs(write_transport, write_proto.transport)