// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "storagelinkqueued.hpp"
#include <vespa/log/log.h>

LOG_SETUP(".application.link.queued");

namespace storage {

StorageLinkQueued::StorageLinkQueued(const std::string& name, framework::ComponentRegister& cr)
    : StorageLink(name),
      _compReg(cr),
      _replyDispatcher(*this),
      _closeState(0)
{ }

StorageLinkQueued::~StorageLinkQueued()
{
    if (_closeState != 7) {
        LOG(error, "Link %s has closing state %u at destruction. Has likely "
                   "implemented onFlush/onClose without calling storage link "
                   "queued's implementations. This is a bug which can cause "
                   "crashes on shutdown.",
            getName().c_str(), _closeState);
    }
}

void StorageLinkQueued::dispatchUp(
        const std::shared_ptr<api::StorageMessage>& msg)
{
        // Verify acceptable state to send messages up
    switch(getState()) {
        case OPENED:
        case CLOSING:
        case FLUSHINGDOWN:
        case FLUSHINGUP:
            break;
        default:
            LOG(error, "Link %s trying to dispatch %s up while in state %u",
                toString().c_str(), msg->toString().c_str(), getState());
            assert(false);
    }
    _replyDispatcher.add(msg);
}

void StorageLinkQueued::logError(const char* err) {
    LOG(error, "%s", err);
};

void StorageLinkQueued::logDebug(const char* err) {
    LOG(debug, "%s", err);
};

template class StorageLinkQueued::Dispatcher<storage::api::StorageMessage>;

} // storage