|
@@ -65,21 +65,7 @@ def send_shutdown(module_name, **kwargs):
|
|
|
|
|
|
class ThreadingServerManager:
|
|
|
def __init__(self, server, *args, **kwargs):
|
|
|
- self.server = None
|
|
|
- # retrying to create a server object until 3 times because a
|
|
|
- # SessionTimeout depending on some environment or timing may
|
|
|
- # be accidentally raised
|
|
|
- n = 0
|
|
|
- while True:
|
|
|
- try:
|
|
|
- self.server = server(*args, **kwargs)
|
|
|
- except isc.cc.session.SessionTimeout:
|
|
|
- if self.server is not None:
|
|
|
- self.server.shutdown()
|
|
|
- if n >2: raise
|
|
|
- n = n + 1
|
|
|
- continue
|
|
|
- else: break
|
|
|
+ self.server = server(*args, **kwargs)
|
|
|
self.server_name = server.__name__
|
|
|
self.server._thread = threading.Thread(
|
|
|
name=self.server_name, target=self.server.run)
|