# HG changeset patch # User Laurent Peuch # Date 1575567447 -3600 # Node ID 8cf02773a6b3a2655f028f254af98caa44298a35 # Parent 6de3af773073a59e66adc918b128e283eeff65da [refactoring] blank lines to make core more readable diff -r 6de3af773073 -r 8cf02773a6b3 cubicweb/server/repository.py --- a/cubicweb/server/repository.py Thu Dec 05 18:36:55 2019 +0100 +++ b/cubicweb/server/repository.py Thu Dec 05 18:37:27 2019 +0100 @@ -147,12 +147,15 @@ def __init__(self, source, size): self._cnxsets = [] + if size is not None: self._queue = queue.Queue() + for i in range(size): cnxset = source.wrapped_connection() self._cnxsets.append(cnxset) self._queue.put_nowait(cnxset) + else: self._queue = None self._source = source @@ -160,11 +163,13 @@ def qsize(self): if self._queue is None: return None + return self._queue.qsize() def get(self): if self._queue is None: return self._source.wrapped_connection() + try: return self._queue.get(True, timeout=5) except queue.Empty: @@ -188,6 +193,7 @@ if self._queue is not None: while not self._queue.empty(): cnxset = self._queue.get_nowait() + try: cnxset.close(True) except Exception: