Function deserialise_database

tools/comdb2ar/deserialise.cpp:358–977

#define write_size (1000*1024)

void deserialise_database(
        const std::string *p_lrldestdir,
        const std::string *p_datadestdir,
        bool strip_cluster_info,
        bool strip_consumer_info,
        bool run_full_recovery,
        const std::string& comdb2_task,
        unsigned percent_full,
        bool force_mode,
        bool legacy_mode,
        bool& is_disk_full,
        bool run_with_done_file,
        bool incr_mode,
        bool dryrun
)
// Deserialise a database from serialised from received on stdin.
// If lrldestdir and datadestdir are not NULL then the lrl and data files
// will be placed accordingly.  Otherwise the lrl file and the data files will
// be placed in the same directory as specified in the serialised form.
// The lrl file written out will be updated to reflect the resulting directory
// structure.  If the destination disk reaches or exceeds the specified
// percent_full during the deserialisation then the operation is halted.
{
    static const char zero_head[512] = {0};
    int stlen;
    is_disk_full = false;
    void *empty_page = NULL;
    unsigned long long skipped_bytes = 0;
    int rc =0;
    std::vector<std::string> options;

    bool file_is_sparse = false;

    std::string fingerprint;

    std::string done_file_string;

    // This is the directory listing of the data directory taken at the time
    // when we find the lrl file in out input stream and can therefore fix
    // the data directory.
    std::list<std::string> data_dir_files;

    // The absolute path names of the files that we have already extracted.
    std::set<std::string> extracted_files;

    // List of known tables
    std::set<std::string> table_set;

    std::string datadestdir;

    std::string fullpath;

    empty_page = malloc(65536);
    memset(empty_page, 0, 65536);

    if (p_datadestdir == NULL && p_lrldestdir)
        p_datadestdir = p_lrldestdir;