summaryrefslogtreecommitdiffstats
path: root/vbench/src/vbench/vbench/request_scheduler.h
diff options
context:
space:
mode:
Diffstat (limited to 'vbench/src/vbench/vbench/request_scheduler.h')
-rw-r--r--vbench/src/vbench/vbench/request_scheduler.h28
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
+