From a0577c66ff79067b3b7089ab97f752539937950e Mon Sep 17 00:00:00 2001 From: Johannes Findeisen Date: Sun, 20 Oct 2013 04:09:46 +0200 Subject: [PATCH] some more threading stuff for backends. --- bin/linspector | 8 +++++--- linspector/backends/backend.py | 5 +++-- linspector/backends/jsonrpc.py | 6 +++--- 3 files changed, 11 insertions(+), 8 deletions(-) diff --git a/bin/linspector b/bin/linspector index 0a8f6d6..c5fc0b5 100755 --- a/bin/linspector +++ b/bin/linspector @@ -124,17 +124,19 @@ def main(): job.set_logger(log) jobs.append(job) - #x = JsonrpcBackend() + interface = LinspectorInterface(jobs, scheduler, linConf) + + #x = JsonrpcBackend(interface) #x.daemon = True #x.start() - #TODO: Load Backend Threads here before initializing the frontend. + #TODO: load all backends in a loop ''' for backend in backends.enabled backend.start take care of signals etc. to sthutdown the threads when stopping linspector. ''' - interface = LinspectorInterface(jobs, scheduler, linConf) + LishFrontend(interface) log.debug("shutting down scheduler") diff --git a/linspector/backends/backend.py b/linspector/backends/backend.py index 14b2194..ba67cae 100644 --- a/linspector/backends/backend.py +++ b/linspector/backends/backend.py @@ -27,5 +27,6 @@ import threading class Backend(threading.Thread): - def __init__(self, **kwargs): - threading.Thread.__init__(self) \ No newline at end of file + def __init__(self, interface, **kwargs): + threading.Thread.__init__(self) + self.interface = interface \ No newline at end of file diff --git a/linspector/backends/jsonrpc.py b/linspector/backends/jsonrpc.py index 4d63828..5826d0d 100644 --- a/linspector/backends/jsonrpc.py +++ b/linspector/backends/jsonrpc.py @@ -25,11 +25,11 @@ from linspector.backends.backend import Backend class JsonrpcBackend(Backend): - def __init__(self, **kwargs): + def __init__(self, interface, **kwargs): super(Backend, self).__init__(**kwargs) - return + self.interface = interface def run(self): while True: - print "foo" + print "hello from JsonrpcBackend thread..." time.sleep(5)