Method commit

src/Disks/DiskObjectStorage/DiskObjectStorageTransaction.cpp:532–574

}

void DiskObjectStorageTransaction::commit()
{
    auto component_guard = Coordination::setCurrentComponent("DiskObjectStorageTransaction::commit");
    for (size_t i = 0; i < operations_to_execute.size(); ++i)
    {
        try
        {
            operations_to_execute[i](metadata_transaction);
        }
        catch (...)
        {
            tryLogCurrentException(
                getLogger("DiskObjectStorageTransaction"),
                fmt::format("An error occurred while executing transaction's operation #{}", i));

            undo();

            throw;
        }
    }

    try
    {
        fiu_do_on(FailPoints::disk_object_storage_fail_commit_metadata_transaction,
        {
            throw Exception(ErrorCodes::FAULT_INJECTED, "disk_object_storage_fail_commit_metadata_transaction");
        });

        metadata_transaction->commit(NoCommitOptions{});
    }
    catch (...)
    {
        undo();
        throw;
    }

    if (wait_blob_removal)
        waitBlobRemoval(metadata_transaction->getSubmittedForRemovalBlobs());

    operations_to_execute.clear();
    written_blobs.clear();
    LOG_TEST(getLogger("DiskObjectStorageTransaction"), "Transaction committed successfully");
}

TransactionCommitOutcomeVariant DiskObjectStorageTransaction::tryCommit(const TransactionCommitOptionsVariant & options)
{