215 for source in self.sources: |
215 for source in self.sources: |
216 source.init_creating() |
216 source.init_creating() |
217 # close initialization pool and reopen fresh ones for proper |
217 # close initialization pool and reopen fresh ones for proper |
218 # initialization now that we know cubes |
218 # initialization now that we know cubes |
219 self._get_pool().close(True) |
219 self._get_pool().close(True) |
|
220 # list of available pools (we can't iterated on Queue instance) |
|
221 self.pools = [] |
220 for i in xrange(config['connections-pool-size']): |
222 for i in xrange(config['connections-pool-size']): |
221 self._available_pools.put_nowait(ConnectionsPool(self.sources)) |
223 self.pools.append(ConnectionsPool(self.sources)) |
|
224 self._available_pools.put_nowait(self.pools[-1]) |
222 self._shutting_down = False |
225 self._shutting_down = False |
223 if not (config.creating or config.repairing): |
226 if not (config.creating or config.repairing): |
224 # call instance level initialisation hooks |
227 # call instance level initialisation hooks |
225 self.hm.call_hooks('server_startup', repo=self) |
228 self.hm.call_hooks('server_startup', repo=self) |
226 # register a task to cleanup expired session |
229 # register a task to cleanup expired session |