equal
deleted
inserted
replaced
33 from warnings import warn |
33 from warnings import warn |
34 from itertools import chain |
34 from itertools import chain |
35 from time import time, localtime, strftime |
35 from time import time, localtime, strftime |
36 from contextlib import contextmanager |
36 from contextlib import contextmanager |
37 |
37 |
38 from six.moves import queue |
38 from six.moves import range, queue |
39 |
39 |
40 from logilab.common.decorators import cached, clear_cache |
40 from logilab.common.decorators import cached, clear_cache |
41 from logilab.common.deprecation import deprecated |
41 from logilab.common.deprecation import deprecated |
42 |
42 |
43 from yams import BadSchemaDefinition |
43 from yams import BadSchemaDefinition |
241 self.vreg.init_properties(self.properties()) |
241 self.vreg.init_properties(self.properties()) |
242 # 4. close initialization connection set and reopen fresh ones for |
242 # 4. close initialization connection set and reopen fresh ones for |
243 # proper initialization |
243 # proper initialization |
244 self._get_cnxset().close(True) |
244 self._get_cnxset().close(True) |
245 self.cnxsets = [] # list of available cnxsets (can't iterate on a Queue) |
245 self.cnxsets = [] # list of available cnxsets (can't iterate on a Queue) |
246 for i in xrange(config['connections-pool-size']): |
246 for i in range(config['connections-pool-size']): |
247 self.cnxsets.append(self.system_source.wrapped_connection()) |
247 self.cnxsets.append(self.system_source.wrapped_connection()) |
248 self._cnxsets_pool.put_nowait(self.cnxsets[-1]) |
248 self._cnxsets_pool.put_nowait(self.cnxsets[-1]) |
249 |
249 |
250 # internals ############################################################### |
250 # internals ############################################################### |
251 |
251 |