Function assertDigest

src/Coordination/KeeperStateMachine.cpp:255–279

{

void assertDigest(
    const KeeperDigest & expected,
    const KeeperDigest & actual,
    const Coordination::ZooKeeperRequest & request,
    uint64_t log_idx,
    uint64_t session_id,
    bool committing)
{
    if (!KeeperStorageBase::checkDigest(expected, actual))
    {
        LOG_FATAL(
            getLogger("KeeperStateMachine"),
            "Digest for nodes is not matching after {} request of type '{}' at log index {} for session {}.\nExpected digest - {}, actual digest - {} "
            "(digest {}). Keeper will terminate to avoid inconsistencies.\nExtra information about the request:\n{}",
            committing ? "committing" : "preprocessing",
            request.getOpNum(),
            log_idx,
            session_id,
            expected.value,
            actual.value,
            expected.version,
            request.toString());
        std::terminate();
    }
}

/// Macros to construct timed lock guards for state_machine_storage_mutex with appropriate ProfileEvents.
/// We cannot use a factory function because TSA does not track lock ownership across function boundaries.