Function incr_deserialise_database

tools/comdb2ar/increment.cpp:378–544

}

void incr_deserialise_database(
    const std::string& lrldestdir,
    const std::string& datadestdir,
    const std::string& dbname,
    std::set<std::string>& table_set,
    std::string& sha_fingerprint,
    unsigned percent_full,
    bool force_mode,
    std::vector<std::string>& options,
    bool& is_disk_full,
    bool& dryrun
)
// Read from STDIN to deserialise an incremental backup
{
    static const char zero_head[512] = {0};

    bool manifest_read = false;
    bool done_with_incr = true;

    std::map<std::string, FileInfo> new_files;
    std::map<std::string, std::pair<FileInfo, std::vector<uint32_t> > > updated_files;
    std::set<std::string> deleted_files;
    std::vector<std::string> file_order;

    while(true) {

        // Read the tar block header
        tar_block_header head;
        size_t bytes_read = readall(0, head.c, sizeof(head.c));
        if(bytes_read == 0){
            // Lazy check that all increments are done (ie STDIN has no additional input)
            break;
        } else if(bytes_read != sizeof(head.c)) {

            // Failed to read a full block header
            std::ostringstream ss;
            ss << "Error reading tar block header: "
                << errno << " " << strerror(errno);
            throw Error(ss);
        }

        // If the block is entirely blank then we're done with the increment
        if(std::memcmp(head.c, zero_head, 512) == 0) {
            if(!done_with_incr){
                std::clog << "done with increment" << std::endl << std::endl;
                done_with_incr = true;
                new_files.clear();
                updated_files.clear();
                deleted_files.clear();
                file_order.clear();
            }
            continue;
        }

        done_with_incr = false;

        // Get the file name
        if(head.h.filename[sizeof(head.h.filename) - 1] != '\0') {