Method writeFile

src/Disks/DiskCacheWrapper.cpp:181–203

}

std::unique_ptr<WriteBufferFromFileBase>
DiskCacheWrapper::writeFile(const String & path, const WriteSettings& settings)
{
    if (!cache_file_predicate(path))
        return DiskDecorator::writeFile(path, settings);

    LOG_DEBUG(log, "Write file {} to cache", backQuote(path));

    auto dir_path = directoryPath(path);
    if (!cache_disk->exists(dir_path))
        cache_disk->createDirectories(dir_path);

    return std::make_unique<CompletionAwareWriteBuffer>(
        cache_disk->writeFile(path, settings),
        [this, path, settings]()
        {
            /// Copy file from cache to actual disk when cached buffer is finalized.
            auto src_buffer = cache_disk->readFile(path, ReadSettings().initializeReadSettings(settings.buffer_size));
            auto dst_buffer = DiskDecorator::writeFile(path, settings);
            copyData(*src_buffer, *dst_buffer);
            dst_buffer->finalize();
        });
}

void DiskCacheWrapper::clearDirectory(const String & path)
{