Method update_pool

pymongo/asynchronous/topology.py:701–716

(self)

        return self._description.readable_servers

    async def update_pool(self) -> None:
        # Remove any stale sockets and add new sockets if pool is too small.
        servers = []
        async with self._lock:
            # Only update pools for data-bearing servers.
            for sd in self.data_bearing_servers():
                server = self._servers[sd.address]
                servers.append((server, server.pool.gen.get_overall()))

        for server, generation in servers:
            try:
                await server.pool.remove_stale_sockets(generation)
            except PyMongoError as exc:
                ctx = _ErrorContext(exc, 0, generation, False, None)
                await self.handle_error(server.description.address, ctx)
                raise

    async def close(self) -> None:
        """Clear pools and terminate monitors. Topology does not reopen on