// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.

#pragma once

#include <vespa/searchcore/proton/common/pendinglidtracker.h>
#include <vespa/vespalib/util/idestructorcallback.h>

namespace vespalib { class Executor; }

namespace proton {

class ForceCommitDoneTask;
struct IDocumentMetaStore;
class DocIdLimit;
class IPendingGidToLidChanges;

/**
 * Context class for forced commits that schedules a task when
 * instance is destroyed. Typically a shared pointer to an instance is
 * passed around to multiple worker threads that performs portions of
 * a larger task before dropping the shared pointer, triggering the
 * callback when all worker threads have completed.
 */
class ForceCommitContext : public vespalib::IDestructorCallback
{
    using IDestructorCallback = vespalib::IDestructorCallback;
    vespalib::Executor                   &_executor;
    std::unique_ptr<ForceCommitDoneTask>  _task;
    uint32_t                              _committedDocIdLimit;
    DocIdLimit                           *_docIdLimit;
    std::shared_ptr<IDestructorCallback>  _onDone;
    PendingLidTrackerBase::Snapshot       _lidsToCommit;

public:
    ForceCommitContext(vespalib::Executor &executor,
                       IDocumentMetaStore &documentMetaStore,
                       PendingLidTrackerBase::Snapshot lidsToCommit,
                       std::unique_ptr<IPendingGidToLidChanges> pending_gid_to_lid_changes,
                       std::shared_ptr<IDestructorCallback> onDone);

    ~ForceCommitContext() override;

    void reuseLids(std::vector<uint32_t> &&lids);
    void holdUnblockShrinkLidSpace();
    void registerCommittedDocIdLimit(uint32_t committedDocIdLimit, DocIdLimit *docIdLimit);
};

}  // namespace proton