equal
deleted
inserted
replaced
217 for i in xrange(config['connections-pool-size']): |
217 for i in xrange(config['connections-pool-size']): |
218 self.pools.append(pool.ConnectionsPool(self.sources)) |
218 self.pools.append(pool.ConnectionsPool(self.sources)) |
219 self._available_pools.put_nowait(self.pools[-1]) |
219 self._available_pools.put_nowait(self.pools[-1]) |
220 self._shutting_down = False |
220 self._shutting_down = False |
221 self.hm = self.vreg['hooks'] |
221 self.hm = self.vreg['hooks'] |
222 if not (config.creating or config.repairing): |
|
223 # call instance level initialisation hooks |
|
224 self.hm.call_hooks('server_startup', repo=self) |
|
225 # register a task to cleanup expired session |
|
226 self.looping_task(config['session-time']/3., self.clean_sessions) |
|
227 |
222 |
228 # internals ############################################################### |
223 # internals ############################################################### |
229 |
224 |
230 def get_source(self, uri, source_config): |
225 def get_source(self, uri, source_config): |
231 source_config['uri'] = uri |
226 source_config['uri'] = uri |
270 finally: |
265 finally: |
271 session.close() |
266 session.close() |
272 self.set_schema(appschema) |
267 self.set_schema(appschema) |
273 |
268 |
274 def start_looping_tasks(self): |
269 def start_looping_tasks(self): |
|
270 if not (self.config.creating or self.config.repairing): |
|
271 # call instance level initialisation hooks |
|
272 self.hm.call_hooks('server_startup', repo=self) |
|
273 # register a task to cleanup expired session |
|
274 self.looping_task(self.config['session-time']/3., self.clean_sessions) |
275 assert isinstance(self._looping_tasks, list), 'already started' |
275 assert isinstance(self._looping_tasks, list), 'already started' |
276 for i, (interval, func, args) in enumerate(self._looping_tasks): |
276 for i, (interval, func, args) in enumerate(self._looping_tasks): |
277 self._looping_tasks[i] = task = utils.LoopTask(interval, func, args) |
277 self._looping_tasks[i] = task = utils.LoopTask(interval, func, args) |
278 self.info('starting task %s with interval %.2fs', task.name, |
278 self.info('starting task %s with interval %.2fs', task.name, |
279 interval) |
279 interval) |