diff options
Diffstat (limited to 'vbench/src/vbench/vbench/request_scheduler.cpp')
| -rw-r--r-- | vbench/src/vbench/vbench/request_scheduler.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/vbench/src/vbench/vbench/request_scheduler.cpp b/vbench/src/vbench/vbench/request_scheduler.cpp index 320ecc91fc6..95d29181b1f 100644 --- a/vbench/src/vbench/vbench/request_scheduler.cpp +++ b/vbench/src/vbench/vbench/request_scheduler.cpp @@ -5,8 +5,8 @@ namespace vbench { -VESPA_THREAD_STACK_TAG(vbench_request_scheduler_executor); -VESPA_THREAD_STACK_TAG(vbench_handler_executor); +VESPA_THREAD_STACK_TAG(vbench_request_scheduler_thread); +VESPA_THREAD_STACK_TAG(vbench_handler_thread); void RequestScheduler::run() @@ -26,16 +26,16 @@ RequestScheduler::run() RequestScheduler::RequestScheduler(CryptoEngine::SP crypto, Handler<Request> &next, size_t numWorkers) : _timer(), - _proxy(next, vbench_handler_executor), + _proxy(next, vbench_handler_thread), _queue(10.0, 0.020), _droppedTagger(_proxy), _dispatcher(_droppedTagger), - _thread(*this, vbench_request_scheduler_executor), + _thread(*this, vbench_request_scheduler_thread), _connectionPool(std::move(crypto), _timer), _workers() { for (size_t i = 0; i < numWorkers; ++i) { - _workers.push_back(std::unique_ptr<Worker>(new Worker(_dispatcher, _proxy, _connectionPool, _timer))); + _workers.push_back(std::make_unique<Worker>(_dispatcher, _proxy, _connectionPool, _timer)); } _dispatcher.waitForThreads(numWorkers, 256); } |