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

Lines Matching refs:transport
31         self.transport = None
44     def connection_made(self, transport):
45         self.transport = transport
67             self.transport.close()
77         self.transport = None
79     def connection_made(self, transport):
81         self.transport = transport
128         # just in case if we have transport close callbacks
165     def reduce_send_buffer_size(self, sock, transport=None):
172         if transport is not None:
173             transport.set_write_buffer_limits(high=self.BUF_SIZE)
189             if proto.transport is not None:
192                 proto.transport.close()
251     # Note: sendfile via SSL transport is equal to sendfile fallback
282         self.reduce_send_buffer_size(cli_sock, transport=tr)
285             srv_proto.transport.close()
286             cli_proto.transport.close()
314             self.loop.sendfile(cli_proto.transport, self.file))
315         cli_proto.transport.close()
333             self.loop.sendfile(cli_proto.transport, self.file))
334         cli_proto.transport.close()
357                 self.loop.sendfile(cli_proto.transport, self.file,
360         cli_proto.transport.close()
368             self.loop.sendfile(cli_proto.transport, self.file))
369         cli_proto.transport.close()
378         cli_proto.transport.close()
380             self.run_loop(self.loop.sendfile(cli_proto.transport, self.file))
389         cli_proto.transport.write(PREFIX)
391             self.loop.sendfile(cli_proto.transport, self.file))
392         cli_proto.transport.write(SUFFIX)
393         cli_proto.transport.close()
403         cli_proto.transport.write(PREFIX)
405             self.loop.sendfile(cli_proto.transport, self.file))
406         cli_proto.transport.write(SUFFIX)
407         cli_proto.transport.close()
416             self.loop.sendfile(cli_proto.transport, self.file, 1000, 100))
417         cli_proto.transport.close()
427             self.loop.sendfile(cli_proto.transport, self.file, 1000, 100))
428         cli_proto.transport.close()
439             self.loop.sendfile(cli_proto.transport, self.file))
440         cli_proto.transport.close()
451             self.loop.sendfile(cli_proto.transport, self.file))
468                 self.loop.sendfile(cli_proto.transport, self.file))
475         self.assertTrue(cli_proto.transport.is_closing())
490                     self.loop.sendfile(cli_proto.transport, self.file))
514             return await self.loop.sendfile(cli_proto.transport, self.file)
520             cli_proto.transport.write(b'data')
525         transport = mock.Mock()
526         transport.is_closing.side_effect = lambda: False
527         transport._sendfile_compatible = constants._SendfileMode.FALLBACK
530                 self.loop.sendfile(transport, None, fallback=False))