bootstrap-vz/bootstrapvz/base/remote/callback.py
2015-04-16 22:15:17 +02:00

24 lines
584 B
Python

class CallbackServer(object):
def __init__(self, listen_port):
self.listen_port = listen_port
self.stop_serving = False
def start(self, log_server):
import Pyro4
Pyro4.config.COMMTIMEOUT = 0.5
daemon = Pyro4.Daemon('localhost', port=self.listen_port, unixsocket=None)
daemon.register(log_server)
def serve():
daemon.requestLoop(loopCondition=lambda: not self.stop_serving)
from threading import Thread
self.thread = Thread(target=serve)
self.thread.start()
def stop(self):
self.stop_serving = True
if hasattr(self, 'thread'):
self.thread.join()