1 files changed, 0 insertions, 158 deletions
diff --git a/searchcore/src/apps/vespa-feed-bm/spi_bm_feed_handler.cpp b/searchcore/src/apps/vespa-feed-bm/spi_bm_feed_handler.cpp
deleted file mode 100644
index 11149eecb3f..00000000000
--- a/searchcore/src/apps/vespa-feed-bm/spi_bm_feed_handler.cpp
+++ /dev/null
@@ -1,158 +0,0 @@
-// Copyright Verizon Media. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-
-#include "spi_bm_feed_handler.h"
-#include "pending_tracker.h"
-#include "bucket_info_queue.h"
-#include <vespa/document/fieldset/fieldsetrepo.h>
-#include <vespa/document/fieldvalue/document.h>
-#include <vespa/document/update/documentupdate.h>
-#include <vespa/persistence/spi/persistenceprovider.h>
-
-using document::Document;
-using document::DocumentId;
-using document::DocumentUpdate;
-using storage::spi::Bucket;
-using storage::spi::PersistenceProvider;
-using storage::spi::Timestamp;
-
-namespace feedbm {
-
-namespace {
-
-storage::spi::Context context(storage::spi::Priority(0), 0);
-
-void get_bucket_info_loop(PendingTracker &tracker)
-{
-    auto bucket_info_queue = tracker.get_bucket_info_queue();
-    if (bucket_info_queue != nullptr) {
-        bucket_info_queue->get_bucket_info_loop();
-    }
-}
-
-class MyOperationComplete : public storage::spi::OperationComplete
-{
-    std::atomic<uint32_t> &_errors;
-    Bucket _bucket;
-    PendingTracker& _tracker;
-public:
-    MyOperationComplete(std::atomic<uint32_t> &errors, const Bucket& bucket, PendingTracker& tracker);
-    ~MyOperationComplete() override;
-    void onComplete(std::unique_ptr<storage::spi::Result> result) override;
-    void addResultHandler(const storage::spi::ResultHandler* resultHandler) override;
-};
-
-MyOperationComplete::MyOperationComplete(std::atomic<uint32_t> &errors, const Bucket& bucket, PendingTracker& tracker)
-    : _errors(errors),
-      _bucket(bucket),
-      _tracker(tracker)
-{
-    _tracker.retain();
-}
-
-MyOperationComplete::~MyOperationComplete()
-{
-    _tracker.release();
-}
-
-void
-MyOperationComplete::onComplete(std::unique_ptr<storage::spi::Result> result)
-{
-    if (result->hasError()) {
-        ++_errors;
-    } else {
-        auto bucket_info_queue = _tracker.get_bucket_info_queue();
-        if (bucket_info_queue != nullptr) {
-            bucket_info_queue->put_bucket(_bucket);
-        }
-    }
-}
-
-void
-MyOperationComplete::addResultHandler(const storage::spi::ResultHandler * resultHandler)
-{
-    (void) resultHandler;
-}
-
-}
-
-SpiBmFeedHandler::SpiBmFeedHandler(PersistenceProvider& provider, const document::FieldSetRepo &field_set_repo, bool skip_get_spi_bucket_info)
-    : IBmFeedHandler(),
-      _name(vespalib::string("SpiBmFeedHandler(") + (skip_get_spi_bucket_info ? "skip-get-spi-bucket-info" : "get-spi-bucket-info") + ")"),
-      _provider(provider),
-      _field_set_repo(field_set_repo),
-      _errors(0u),
-      _skip_get_spi_bucket_info(skip_get_spi_bucket_info)
-{
-}
-
-SpiBmFeedHandler::~SpiBmFeedHandler() = default;
-
-void
-SpiBmFeedHandler::put(const document::Bucket& bucket, std::unique_ptr<Document> document, uint64_t timestamp, PendingTracker& tracker)
-{
-    get_bucket_info_loop(tracker);
-    Bucket spi_bucket(bucket);
-    _provider.putAsync(spi_bucket, Timestamp(timestamp), std::move(document), context, std::make_unique<MyOperationComplete>(_errors, spi_bucket, tracker));
-}
-
-void
-SpiBmFeedHandler::update(const document::Bucket& bucket, std::unique_ptr<DocumentUpdate> document_update, uint64_t timestamp, PendingTracker& tracker)
-{
-    get_bucket_info_loop(tracker);
-    Bucket spi_bucket(bucket);
-    _provider.updateAsync(spi_bucket, Timestamp(timestamp), std::move(document_update), context, std::make_unique<MyOperationComplete>(_errors, spi_bucket, tracker));
-}
-
-void
-SpiBmFeedHandler::remove(const document::Bucket& bucket, const DocumentId& document_id,  uint64_t timestamp, PendingTracker& tracker)
-{
-    get_bucket_info_loop(tracker);
-    Bucket spi_bucket(bucket);
-    _provider.removeAsync(spi_bucket, Timestamp(timestamp), document_id, context, std::make_unique<MyOperationComplete>(_errors, spi_bucket, tracker));
-}
-
-void
-SpiBmFeedHandler::get(const document::Bucket& bucket, vespalib::stringref field_set_string, const document::DocumentId& document_id, PendingTracker& tracker)
-{
-    get_bucket_info_loop(tracker);
-    Bucket spi_bucket(bucket);
-    auto field_set = _field_set_repo.getFieldSet(field_set_string);
-    auto result = _provider.get(spi_bucket, *field_set, document_id, context);
-    if (result.hasError()) {
-        ++_errors;
-    }
-}
-
-void
-SpiBmFeedHandler::create_bucket(const document::Bucket& bucket)
-{
-    _provider.createBucket(Bucket(bucket), context);
-}
-
-void
-SpiBmFeedHandler::attach_bucket_info_queue(PendingTracker& tracker)
-{
-    if (!_skip_get_spi_bucket_info) {
-        tracker.attach_bucket_info_queue(_provider, _errors);
-    }
-}
-
-uint32_t
-SpiBmFeedHandler::get_error_count() const
-{
-    return _errors;
-}
-
-const vespalib::string&
-SpiBmFeedHandler::get_name() const
-{
-    return _name;
-}
-
-bool
-SpiBmFeedHandler::manages_timestamp() const
-{
-    return false;
-}
-
-}