diff options
Diffstat (limited to 'vbench/src/vbench/vbench/request_scheduler.h')
-rw-r--r-- | vbench/src/vbench/vbench/request_scheduler.h | 28 |
1 files changed, 19 insertions, 9 deletions
diff --git a/vbench/src/vbench/vbench/request_scheduler.h b/vbench/src/vbench/vbench/request_scheduler.h index 60fe4af12fc..1de61073d35 100644 --- a/vbench/src/vbench/vbench/request_scheduler.h +++ b/vbench/src/vbench/vbench/request_scheduler.h @@ -1,14 +1,23 @@ // Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. + #pragma once -#include "worker.h" -#include "dropped_tagger.h" +#include <memory> + +#include <vespa/vespalib/util/sync.h> +#include <vespa/vespalib/util/thread.h> +#include <vespa/vespalib/util/runnable.h> +#include <vespa/vespalib/util/active.h> + +#include <vbench/core/handler.h> #include <vbench/core/time_queue.h> #include <vbench/core/dispatcher.h> #include <vbench/core/handler_thread.h> -#include <vespa/vespalib/util/sync.h> -#include <vespa/vespalib/util/active.h> + +#include "request.h" +#include "worker.h" +#include "dropped_tagger.h" namespace vbench { @@ -31,15 +40,16 @@ private: HttpConnectionPool _connectionPool; std::vector<Worker::UP> _workers; - void run() override; + virtual void run() override; public: typedef std::unique_ptr<RequestScheduler> UP; RequestScheduler(Handler<Request> &next, size_t numWorkers); void abort(); - void handle(Request::UP request) override; - void start() override; - RequestScheduler &stop() override; - void join() override; + virtual void handle(Request::UP request) override; + virtual void start() override; + virtual RequestScheduler &stop() override; + virtual void join() override; }; } // namespace vbench + |