diff options
author | Geir Storli <geirst@yahooinc.com> | 2022-01-28 16:07:26 +0000 |
---|---|---|
committer | Geir Storli <geirst@yahooinc.com> | 2022-01-28 16:07:26 +0000 |
commit | b6d8ba500409c59c446e24e0253952ecc57af95c (patch) | |
tree | 0d61f98f53708ea313fd37eeb1f14d557208ee0b /storage | |
parent | a0b919302dac06269b996e9d174850384da8e17d (diff) |
Tag tls and operation response thread pools with cpu category WRITE.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/persistence/filestorage/filestormanager.cpp | 19 |
1 files changed, 11 insertions, 8 deletions
diff --git a/storage/src/vespa/storage/persistence/filestorage/filestormanager.cpp b/storage/src/vespa/storage/persistence/filestorage/filestormanager.cpp index ec7793cdd8d..0e511241d18 100644 --- a/storage/src/vespa/storage/persistence/filestorage/filestormanager.cpp +++ b/storage/src/vespa/storage/persistence/filestorage/filestormanager.cpp @@ -6,33 +6,35 @@ #include <vespa/storage/common/bucketmessages.h> #include <vespa/storage/common/content_bucket_space_repo.h> #include <vespa/storage/common/doneinitializehandler.h> -#include <vespa/vdslib/state/cluster_state_bundle.h> -#include <vespa/vdslib/state/clusterstate.h> #include <vespa/storage/common/hostreporter/hostinfo.h> #include <vespa/storage/common/messagebucket.h> #include <vespa/storage/persistence/bucketownershipnotifier.h> -#include <vespa/storage/persistence/persistencethread.h> #include <vespa/storage/persistence/persistencehandler.h> +#include <vespa/storage/persistence/persistencethread.h> #include <vespa/storage/persistence/provider_error_wrapper.h> #include <vespa/storageapi/message/bucketsplitting.h> -#include <vespa/storageapi/message/state.h> #include <vespa/storageapi/message/persistence.h> #include <vespa/storageapi/message/removelocation.h> #include <vespa/storageapi/message/stat.h> +#include <vespa/storageapi/message/state.h> +#include <vespa/vdslib/state/cluster_state_bundle.h> +#include <vespa/vdslib/state/clusterstate.h> #include <vespa/vespalib/stllike/asciistream.h> -#include <vespa/vespalib/util/stringfmt.h> +#include <vespa/vespalib/util/cpu_usage.h> #include <vespa/vespalib/util/idestructorcallback.h> #include <vespa/vespalib/util/sequencedtaskexecutor.h> +#include <vespa/vespalib/util/stringfmt.h> #include <algorithm> #include <thread> #include <vespa/log/bufferedlogger.h> LOG_SETUP(".persistence.filestor.manager"); -using std::shared_ptr; using document::BucketSpace; -using vespalib::make_string_short::fmt; +using std::shared_ptr; using vespa::config::content::StorFilestorConfig; +using vespalib::CpuUsage; +using vespalib::make_string_short::fmt; namespace { @@ -232,7 +234,8 @@ FileStorManager::configure(std::unique_ptr<StorFilestorConfig> config) _filestorHandler = std::make_unique<FileStorHandlerImpl>(numThreads, numStripes, *this, *_metrics, _compReg, std::move(operation_throttler)); uint32_t numResponseThreads = computeNumResponseThreads(_config->numResponseThreads); - _sequencedExecutor = vespalib::SequencedTaskExecutor::create(response_executor, numResponseThreads, 10000, + _sequencedExecutor = vespalib::SequencedTaskExecutor::create(CpuUsage::wrap(response_executor, CpuUsage::Category::WRITE), + numResponseThreads, 10000, true, selectSequencer(_config->responseSequencerType)); assert(_sequencedExecutor); LOG(spam, "Setting up the disk"); |