aboutsummaryrefslogtreecommitdiffstats
path: root/staging_vespalib
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-11-26 11:06:01 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-11-26 11:27:06 +0000
commit8236c60ded3e9ae63363750851fd89359d286a01 (patch)
treeaa7b014749b21d94b3a3cf24c88be06e5dc60d7f /staging_vespalib
parentc07824476253a07219cac5821e768ece213e8d5a (diff)
Remove the need for Syncable
Diffstat (limited to 'staging_vespalib')
-rw-r--r--staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp2
-rw-r--r--staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.h3
2 files changed, 3 insertions, 2 deletions
diff --git a/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp b/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp
index 954a63978f3..7c4711b6802 100644
--- a/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp
+++ b/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.cpp
@@ -167,7 +167,7 @@ SequencedTaskExecutor::getExecutorIdImPerfect(uint64_t componentId) const {
return ExecutorId(executorId);
}
-const vespalib::SyncableThreadExecutor*
+const vespalib::ThreadExecutor*
SequencedTaskExecutor::first_executor() const
{
if (_executors.empty()) {
diff --git a/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.h b/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.h
index 7bb56424849..db0723d16c8 100644
--- a/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.h
+++ b/staging_vespalib/src/vespa/vespalib/util/sequencedtaskexecutor.h
@@ -8,6 +8,7 @@
namespace vespalib {
+class ThreadExecutor;
class SyncableThreadExecutor;
/**
@@ -41,7 +42,7 @@ public:
*/
uint32_t getComponentHashSize() const { return _component2IdImperfect.size(); }
uint32_t getComponentEffectiveHashSize() const { return _nextId; }
- const vespalib::SyncableThreadExecutor* first_executor() const;
+ const vespalib::ThreadExecutor* first_executor() const;
private:
explicit SequencedTaskExecutor(std::vector<std::unique_ptr<vespalib::SyncableThreadExecutor>> executor);