equal
deleted
inserted
replaced
318 self.info('canceling task %s...', looptask.name) |
318 self.info('canceling task %s...', looptask.name) |
319 looptask.cancel() |
319 looptask.cancel() |
320 looptask.join() |
320 looptask.join() |
321 self.info('task %s finished', looptask.name) |
321 self.info('task %s finished', looptask.name) |
322 for thread in self._running_threads: |
322 for thread in self._running_threads: |
323 self.info('waiting thread %s...', thread.name) |
323 self.info('waiting thread %s...', thread.getName()) |
324 thread.join() |
324 thread.join() |
325 self.info('thread %s finished', thread.name) |
325 self.info('thread %s finished', thread.getName()) |
326 if not (self.config.creating or self.config.repairing |
326 if not (self.config.creating or self.config.repairing |
327 or self.config.quick_start): |
327 or self.config.quick_start): |
328 self.hm.call_hooks('server_shutdown', repo=self) |
328 self.hm.call_hooks('server_shutdown', repo=self) |
329 self.close_sessions() |
329 self.close_sessions() |
330 while not self._available_pools.empty(): |
330 while not self._available_pools.empty(): |