diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-10-22 11:22:48 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-10-22 11:22:48 +0000 |
commit | 912f4526813d1239d2b90edea9fda289896dd221 (patch) | |
tree | 2b33505cf16697e935413999b67caa4f52d3de10 /staging_vespalib | |
parent | de33bea303b8c207a647551d6e7d575925a2b803 (diff) |
foreground executors are never woken up.
Diffstat (limited to 'staging_vespalib')
-rw-r--r-- | staging_vespalib/src/vespa/vespalib/util/foreground_thread_executor.h | 2 | ||||
-rw-r--r-- | staging_vespalib/src/vespa/vespalib/util/foregroundtaskexecutor.cpp | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/staging_vespalib/src/vespa/vespalib/util/foreground_thread_executor.h b/staging_vespalib/src/vespa/vespalib/util/foreground_thread_executor.h index 99a4ddffa22..c1e56572614 100644 --- a/staging_vespalib/src/vespa/vespalib/util/foreground_thread_executor.h +++ b/staging_vespalib/src/vespa/vespalib/util/foreground_thread_executor.h @@ -23,7 +23,7 @@ public: } size_t getNumThreads() const override { return 0; } ExecutorStats getStats() override { - return ExecutorStats(ExecutorStats::QueueSizeT(), _accepted.load(std::memory_order_relaxed), 0, 1); + return ExecutorStats(ExecutorStats::QueueSizeT(), _accepted.load(std::memory_order_relaxed), 0, 0); } void setTaskLimit(uint32_t taskLimit) override { (void) taskLimit; } uint32_t getTaskLimit() const override { return std::numeric_limits<uint32_t>::max(); } diff --git a/staging_vespalib/src/vespa/vespalib/util/foregroundtaskexecutor.cpp b/staging_vespalib/src/vespa/vespalib/util/foregroundtaskexecutor.cpp index e756b608a3d..703256c5521 100644 --- a/staging_vespalib/src/vespa/vespalib/util/foregroundtaskexecutor.cpp +++ b/staging_vespalib/src/vespa/vespalib/util/foregroundtaskexecutor.cpp @@ -36,7 +36,7 @@ void ForegroundTaskExecutor::setTaskLimit(uint32_t) { } ExecutorStats ForegroundTaskExecutor::getStats() { - return ExecutorStats(ExecutorStats::QueueSizeT(0) , _accepted.load(std::memory_order_relaxed), 0, 1); + return ExecutorStats(ExecutorStats::QueueSizeT(0) , _accepted.load(std::memory_order_relaxed), 0, 0); } ISequencedTaskExecutor::ExecutorId |