@@ -71,7 +71,8 @@ def __init__(
7171 our_role = h11 .CLIENT ,
7272 max_incomplete_event_size = self .MAX_INCOMPLETE_EVENT_SIZE ,
7373 )
74- self ._socket_used_at = time .monotonic ()
74+ # Assuming we were just connected
75+ self ._network_stream_used_at = time .monotonic ()
7576
7677 async def handle_async_request (self , request : Request ) -> Response :
7778 if not self .can_handle_request (request .url .origin ):
@@ -177,7 +178,7 @@ async def _send_event(
177178 bytes_to_send = self ._h11_state .send (event )
178179 if bytes_to_send is not None :
179180 await self ._network_stream .write (bytes_to_send , timeout = timeout )
180- self ._socket_used_at = time .monotonic ()
181+ self ._network_stream_used_at = time .monotonic ()
181182
182183 # Receiving the response...
183184
@@ -229,7 +230,7 @@ async def _receive_event(
229230 data = await self ._network_stream .read (
230231 self .READ_NUM_BYTES , timeout = timeout
231232 )
232- self ._socket_used_at = time .monotonic ()
233+ self ._network_stream_used_at = time .monotonic ()
233234
234235 # If we feed this case through h11 we'll raise an exception like:
235236 #
@@ -294,8 +295,8 @@ def has_expired(self) -> bool:
294295 # only valid state is that the socket is about to return b"", indicating
295296 # a server-initiated disconnect.
296297 # Checking the readable status is relatively expensive so check it at a lower frequency.
297- if (now - self ._socket_used_at ) > self ._socket_poll_interval ():
298- self ._socket_used_at = now
298+ if (now - self ._network_stream_used_at ) > self ._socket_poll_interval ():
299+ self ._network_stream_used_at = now
299300 server_disconnected = (
300301 self ._state == HTTPConnectionState .IDLE
301302 and self ._network_stream .get_extra_info ("is_readable" )
0 commit comments