|
@@ -204,20 +204,25 @@ class AgentService:
|
|
if blocking:
|
|
if blocking:
|
|
for thread in self.process_threads:
|
|
for thread in self.process_threads:
|
|
thread.join()
|
|
thread.join()
|
|
|
|
+ logger.debug("process threads finished")
|
|
|
|
|
|
def shutdown(self, sync=True):
|
|
def shutdown(self, sync=True):
|
|
if not self.running:
|
|
if not self.running:
|
|
raise Exception("Service is not running")
|
|
raise Exception("Service is not running")
|
|
self.running = False
|
|
self.running = False
|
|
self.scheduler.shutdown()
|
|
self.scheduler.shutdown()
|
|
|
|
+ logger.debug("scheduler shutdown")
|
|
if sync:
|
|
if sync:
|
|
for thread in self.process_threads:
|
|
for thread in self.process_threads:
|
|
thread.join()
|
|
thread.join()
|
|
- self.receive_queue.shutdown()
|
|
|
|
- self.send_queue.shutdown()
|
|
|
|
|
|
+ logger.debug("message processing threads finished")
|
|
if self.msg_scheduler_thread:
|
|
if self.msg_scheduler_thread:
|
|
self.msg_scheduler_thread.join()
|
|
self.msg_scheduler_thread.join()
|
|
self.scheduler_queue.shutdown()
|
|
self.scheduler_queue.shutdown()
|
|
|
|
+ logger.debug("scheduler message processing thread finished")
|
|
|
|
+ self.receive_queue.shutdown()
|
|
|
|
+ self.send_queue.shutdown()
|
|
|
|
+ logger.debug("receive and send queues shutdown")
|
|
|
|
|
|
def _handle_sigint(self, signum, frame):
|
|
def _handle_sigint(self, signum, frame):
|
|
self._sigint_cnt += 1
|
|
self._sigint_cnt += 1
|