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