diff options
Diffstat (limited to 'searchcore/src/apps/vespa-feed-bm/bucket_info_queue.cpp')
-rw-r--r-- | searchcore/src/apps/vespa-feed-bm/bucket_info_queue.cpp | 38 |
1 files changed, 0 insertions, 38 deletions
diff --git a/searchcore/src/apps/vespa-feed-bm/bucket_info_queue.cpp b/searchcore/src/apps/vespa-feed-bm/bucket_info_queue.cpp deleted file mode 100644 index fc43402d68e..00000000000 --- a/searchcore/src/apps/vespa-feed-bm/bucket_info_queue.cpp +++ /dev/null @@ -1,38 +0,0 @@ -// Copyright Verizon Media. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. - -#include "bucket_info_queue.h" -#include <vespa/persistence/spi/persistenceprovider.h> - -namespace feedbm { - -BucketInfoQueue::BucketInfoQueue(storage::spi::PersistenceProvider& provider, std::atomic<uint32_t>& errors) - : _mutex(), - _buckets(), - _provider(provider), - _errors(errors) -{ -} - -BucketInfoQueue::~BucketInfoQueue() -{ - get_bucket_info_loop(); -} - -void -BucketInfoQueue::get_bucket_info_loop() -{ - std::unique_lock guard(_mutex); - while (!_buckets.empty()) { - auto bucket = _buckets.front(); - _buckets.pop_front(); - guard.unlock(); - auto bucket_info = _provider.getBucketInfo(bucket); - if (bucket_info.hasError()) { - ++_errors; - } - guard.lock(); - } -} - -} - |