equal
deleted
inserted
replaced
456 self.hm.call_hooks('server_shutdown', repo=self) |
456 self.hm.call_hooks('server_shutdown', repo=self) |
457 for thread in self._running_threads: |
457 for thread in self._running_threads: |
458 self.info('waiting thread %s...', thread.getName()) |
458 self.info('waiting thread %s...', thread.getName()) |
459 thread.join() |
459 thread.join() |
460 self.info('thread %s finished', thread.getName()) |
460 self.info('thread %s finished', thread.getName()) |
461 self.close_sessions() |
|
462 self.cnxsets.close() |
461 self.cnxsets.close() |
463 hits, misses = self.querier.cache_hit, self.querier.cache_miss |
462 hits, misses = self.querier.cache_hit, self.querier.cache_miss |
464 try: |
463 try: |
465 self.info('rql st cache hit/miss: %s/%s (%s%% hits)', hits, misses, |
464 self.info('rql st cache hit/miss: %s/%s (%s%% hits)', hits, misses, |
466 (hits * 100) / (hits + misses)) |
465 (hits * 100) / (hits + misses)) |
688 @deprecated('[3.23] use .new_session instead (and get a plain session object)') |
687 @deprecated('[3.23] use .new_session instead (and get a plain session object)') |
689 def connect(self, login, **kwargs): |
688 def connect(self, login, **kwargs): |
690 return self.new_session(login, **kwargs).sessionid |
689 return self.new_session(login, **kwargs).sessionid |
691 |
690 |
692 # session handling ######################################################## |
691 # session handling ######################################################## |
693 |
|
694 def close_sessions(self): |
|
695 """close every opened sessions""" |
|
696 for session in list(self._sessions.values()): |
|
697 session.close() |
|
698 |
692 |
699 def clean_sessions(self): |
693 def clean_sessions(self): |
700 """close sessions not used since an amount of time specified in the |
694 """close sessions not used since an amount of time specified in the |
701 configuration |
695 configuration |
702 """ |
696 """ |