summaryrefslogtreecommitdiffstats
path: root/searchcore
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-12-01 21:01:16 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-12-01 21:01:16 +0000
commit8971fae709b375eb8c8ec521cf36b0741e25e9c4 (patch)
tree1daabb9848fb221cf378a12c91ff5edbfb586da7 /searchcore
parent535b586bae36880259a792e2292f02b8495950fe (diff)
Move to .cpp file
Diffstat (limited to 'searchcore')
-rw-r--r--searchcore/src/apps/vespa-feed-bm/pending_tracker.cpp12
-rw-r--r--searchcore/src/apps/vespa-feed-bm/pending_tracker.h11
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);