def POST(self, request):
- Server.queue.put( ('POST', request, web.data()) )
+ Server.queue.put( (request, web.data()) )
#return web.data()
# Create job threads.
lb_workers = []
for i in range(0, config.JOB_THREADS_COUNT):
- lb_worker = LBWorker(i)
+ lb_worker = config.LOAD_BALANCER(i, Server.queue)
lb_worker.daemon = True
lb_worker.start()
lb_workers.append(lb_worker)