diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-12-01 21:01:16 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-12-01 21:01:16 +0000 |
commit | 8971fae709b375eb8c8ec521cf36b0741e25e9c4 (patch) | |
tree | 1daabb9848fb221cf378a12c91ff5edbfb586da7 /searchcore | |
parent | 535b586bae36880259a792e2292f02b8495950fe (diff) |
Move to .cpp file
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/apps/vespa-feed-bm/pending_tracker.cpp | 12 | ||||
-rw-r--r-- | searchcore/src/apps/vespa-feed-bm/pending_tracker.h | 11 |
2 files changed, 13 insertions, 10 deletions
diff --git a/searchcore/src/apps/vespa-feed-bm/pending_tracker.cpp b/searchcore/src/apps/vespa-feed-bm/pending_tracker.cpp index de60ae88f65..94bed4cb3bd 100644 --- a/searchcore/src/apps/vespa-feed-bm/pending_tracker.cpp +++ b/searchcore/src/apps/vespa-feed-bm/pending_tracker.cpp @@ -2,6 +2,10 @@ #include "pending_tracker.h" #include "bucket_info_queue.h" +#include <thread> +#include <chrono> + +using namespace std::chrono_literals; namespace feedbm { @@ -18,6 +22,14 @@ PendingTracker::~PendingTracker() } void +PendingTracker::retain() { + while (_pending >= _limit) { + std::this_thread::sleep_for(1ms); + } + _pending++; +} + +void PendingTracker::drain() { if (_bucket_info_queue) { diff --git a/searchcore/src/apps/vespa-feed-bm/pending_tracker.h b/searchcore/src/apps/vespa-feed-bm/pending_tracker.h index 14c84e8d1dd..4ca84ab7442 100644 --- a/searchcore/src/apps/vespa-feed-bm/pending_tracker.h +++ b/searchcore/src/apps/vespa-feed-bm/pending_tracker.h @@ -4,8 +4,6 @@ #include <atomic> #include <memory> -#include <thread> -#include <chrono> namespace storage::spi { struct PersistenceProvider; } @@ -29,14 +27,7 @@ public: void release() { _pending--; } - void retain() { - using namespace std::chrono_literals; - while (_pending >= _limit) { - std::this_thread::sleep_for(1ms); - } - _pending++; - } - + void retain(); void drain(); void attach_bucket_info_queue(storage::spi::PersistenceProvider& provider, std::atomic<uint32_t>& errors); |