refactor
This commit is contained in:
@ -5,13 +5,9 @@ from threading import Thread
|
|||||||
|
|
||||||
class RPCServerThread(Thread):
|
class RPCServerThread(Thread):
|
||||||
|
|
||||||
def __init__(self, host, port, *args, **kwargs):
|
def __init__(self, *args, **kwargs):
|
||||||
super().__init__(daemon=True) # atexit seems to only work for deamon threads
|
super().__init__(daemon=True) # atexit seems to only work for deamon threads
|
||||||
|
self.server = RPCServer(*args, **kwargs)
|
||||||
addr = (host, port)
|
|
||||||
kwargs.setdefault("allow_none", True)
|
|
||||||
self.server = xrs.SimpleXMLRPCServer(addr, *args, **kwargs)
|
|
||||||
|
|
||||||
self.thread_shutdown = None
|
self.thread_shutdown = None
|
||||||
|
|
||||||
|
|
||||||
@ -40,6 +36,15 @@ class RPCServerThread(Thread):
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
class RPCServer(xrs.SimpleXMLRPCServer):
|
||||||
|
|
||||||
|
def __init__(self, host, port, *args, **kwargs):
|
||||||
|
addr = (host, port)
|
||||||
|
kwargs.setdefault("allow_none", True)
|
||||||
|
super().__init__(addr, *args, **kwargs)
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
|
Reference in New Issue
Block a user