await self._semaphore.acquire()
connections = self._connections.setdefault(host, [])
- log.info('got %s in pool', len(connections))
+ log.debug('got %s in pool', len(connections))
# find an un-used connection for this host
connection = next(
(conn for conn in connections if not conn.in_use), None)
return self._closed
def release(self) -> None:
+ logging.debug('releasing %r', self)
self.in_use = False
self._pool._notify_release()
async def close(self) -> None:
if self._closed:
return
+ logging.debug('closing %r', self)
self._closed = True
self._writer.close()
self._pool._remove(self)