cubicweb/server/repository.py
changeset 12960 2c3a8a4f5a02
parent 12959 39ee325e6758
child 12935 cfa03a9778c7
equal deleted inserted replaced
12959:39ee325e6758 12960:2c3a8a4f5a02
   150 
   150 
   151     def qsize(self):
   151     def qsize(self):
   152         return None
   152         return None
   153 
   153 
   154     def get(self):
   154     def get(self):
       
   155         return self._new_cnxset()
       
   156 
       
   157     def _new_cnxset(self):
   155         return self._source.wrapped_connection()
   158         return self._source.wrapped_connection()
   156 
   159 
   157     def release(self, cnxset):
   160     def release(self, cnxset):
   158         cnxset.close(True)
   161         cnxset.close(True)
   159 
   162 
   171         super().__init__(source)
   174         super().__init__(source)
   172         self._cnxsets = []
   175         self._cnxsets = []
   173         self._queue = queue.Queue()
   176         self._queue = queue.Queue()
   174 
   177 
   175         for i in range(size):
   178         for i in range(size):
   176             cnxset = source.wrapped_connection()
   179             self._queue.put_nowait(self._new_cnxset())
   177             self._cnxsets.append(cnxset)
   180 
   178             self._queue.put_nowait(cnxset)
   181     def _new_cnxset(self):
       
   182         cnxset = super()._new_cnxset()
       
   183         self._cnxsets.append(cnxset)
       
   184         return cnxset
   179 
   185 
   180     def qsize(self):
   186     def qsize(self):
   181         return self._queue.qsize()
   187         return self._queue.qsize()
   182 
   188 
   183     def get(self):
   189     def get(self):