equal
deleted
inserted
replaced
333 self.info('task %s finished', looptask.name) |
333 self.info('task %s finished', looptask.name) |
334 for thread in self._running_threads: |
334 for thread in self._running_threads: |
335 self.info('waiting thread %s...', thread.name) |
335 self.info('waiting thread %s...', thread.name) |
336 thread.join() |
336 thread.join() |
337 self.info('thread %s finished', thread.name) |
337 self.info('thread %s finished', thread.name) |
338 self.hm.call_hooks('server_shutdown', repo=self) |
338 if not (self.config.creating or self.config.repairing): |
|
339 self.hm.call_hooks('server_shutdown', repo=self) |
339 self.close_sessions() |
340 self.close_sessions() |
340 while not self._available_pools.empty(): |
341 while not self._available_pools.empty(): |
341 pool = self._available_pools.get_nowait() |
342 pool = self._available_pools.get_nowait() |
342 try: |
343 try: |
343 pool.close(True) |
344 pool.close(True) |