diff --git a/bin/linspector b/bin/linspector index 3fe438e..028be95 100755 --- a/bin/linspector +++ b/bin/linspector @@ -20,7 +20,7 @@ along with this program. If not, see . """ -__version__ = "0.15.2/AMNESIA" +__version__ = "0.15.3/AMNESIA" import argparse import datetime @@ -125,8 +125,7 @@ def main(): workers = [] for i in range(0, args.instances): - name = "LinspectorWorker-"+str(i) - process = LinspectorWorker(name, args.corethreads, args.threads) + process = LinspectorWorker(args.corethreads, args.threads) workers.append(process) process.daemon = True @@ -161,13 +160,13 @@ def main(): if instance == args.instances: instance = 0 + print("\nScheduled " + str(job_count) + " jobs") + schedulers = [] for worker in workers: schedulers.append(worker.get_scheduler()) worker.start() - print("\nScheduled " + str(job_count) + " jobs") - interface = LinspectorInterface(jobs, schedulers, lin_conf, root_logger, __version__) if "jsonrpc_backend" in core and core["jsonrpc_backend"]: diff --git a/linspector/core/worker.py b/linspector/core/worker.py index c8e46fb..ce0f1b2 100644 --- a/linspector/core/worker.py +++ b/linspector/core/worker.py @@ -27,10 +27,9 @@ logger = getLogger(__name__) class LinspectorWorker(Process): - def __init__(self, name, core_threads, max_threads): + def __init__(self, core_threads, max_threads): super(LinspectorWorker, self).__init__() - self._name = name self.core_threads = core_threads self.max_threads = max_threads @@ -46,7 +45,7 @@ class LinspectorWorker(Process): job.handle_call() def get_name(self): - return self.name + return self._name def get_scheduler(self): return self.scheduler