[PR #10714/75bbc03e backport][3.11] Only fetch SSLContext and peername once per connection (#10734)

Co-authored-by: J. Nick Koston <[email protected]>

Author: patchback[bot]

CHANGES/10714.misc.rst

@@ -0,0 +1 @@
+Improved web server performance when connection can be reused -- by :user:`bdraco`.

aiohttp/test_utils.py

@@ -730,6 +730,10 @@ def make_mocked_request(
     if protocol is sentinel:
         protocol = mock.Mock()
         protocol.transport = transport
+        type(protocol).peername = mock.PropertyMock(
+            return_value=transport.get_extra_info("peername")
+        )
+        type(protocol).ssl_context = mock.PropertyMock(return_value=sslcontext)
 
     if writer is sentinel:
         writer = mock.Mock()

aiohttp/web_protocol.py

@@ -24,6 +24,7 @@
 
 import attr
 import yarl
+from propcache import under_cached_property
 
 from .abc import AbstractAccessLogger, AbstractStreamWriter
 from .base_protocol import BaseProtocol
@@ -47,6 +48,8 @@
 __all__ = ("RequestHandler", "RequestPayloadError", "PayloadAccessError")
 
 if TYPE_CHECKING:
+    import ssl
+
     from .web_server import Server
 
 
@@ -167,6 +170,7 @@ class RequestHandler(BaseProtocol):
         "_current_request",
         "_timeout_ceil_threshold",
         "_request_in_progress",
+        "_cache",
     )
 
     def __init__(
@@ -246,13 +250,34 @@ def __init__(
         self._close = False
         self._force_close = False
         self._request_in_progress = False
+        self._cache: dict[str, Any] = {}
 
     def __repr__(self) -> str:
         return "<{} {}>".format(
             self.__class__.__name__,
             "connected" if self.transport is not None else "disconnected",
         )
 
+    @under_cached_property
+    def ssl_context(self) -> Optional["ssl.SSLContext"]:
+        """Return SSLContext if available."""
+        return (
+            None
+            if self.transport is None
+            else self.transport.get_extra_info("sslcontext")
+        )
+
+    @under_cached_property
+    def peername(
+        self,
+    ) -> Optional[Union[str, Tuple[str, int, int, int], Tuple[str, int]]]:
+        """Return peername if available."""
+        return (
+            None
+            if self.transport is None
+            else self.transport.get_extra_info("peername")
+        )
+
     @property
     def keepalive_timeout(self) -> float:
         return self._keepalive_timeout

aiohttp/web_request.py

@@ -198,10 +198,8 @@ def __init__(
         self._client_max_size = client_max_size
         self._loop = loop
 
-        transport = protocol.transport
-        assert transport is not None
-        self._transport_sslcontext = transport.get_extra_info("sslcontext")
-        self._transport_peername = transport.get_extra_info("peername")
+        self._transport_sslcontext = protocol.ssl_context
+        self._transport_peername = protocol.peername
 
         if remote is not None:
             self._cache["remote"] = remote