Method export_static_sync_blocks

src/Core/Node.cpp:1039–1093

}

void Node::export_static_sync_blocks(const BlockChainState &block_chain, const std::string &folder) {
	if (block_chain.get_tip_height() < block_chain.get_currency().last_hard_checkpoint().height)
		throw std::runtime_error("Daemon must be synced at least to last hard checkpoint");
	if (!platform::folder_exists(folder))
		throw std::runtime_error("Folder for static sync_blocks must exist " + folder);
	api::cnd::SyncBlocks::Request req;
	req.max_size            = 1024 * 1024;
	req.max_count           = 1000;
	req.need_redundant_data = false;
	std::vector<Hash> all_chain(block_chain.get_currency().last_hard_checkpoint().height + 1);
	std::cout << "Reading chain, can take a minute or two..." << std::endl;
	for (Height i = 0; i != block_chain.get_currency().last_hard_checkpoint().height + 1; ++i)
		invariant(block_chain.get_chain(i, &all_chain.at(i)), "");
	Height ha = 0;
	api::cnd::SyncBlocks::ResponseCompact res;
	size_t max_total_count     = 0;
	size_t min_total_count     = std::numeric_limits<size_t>::max();
	size_t sum_total_size_real = 0;
	size_t sum_total_size_link = 0;
	while (ha <= block_chain.get_currency().last_hard_checkpoint().height) {
		res.blocks.clear();
		size_t total_size = 0;
		while (ha + res.blocks.size() <= block_chain.get_currency().last_hard_checkpoint().height) {
			res.blocks.push_back(block_chain.fill_sync_block_compact(all_chain.at(ha + res.blocks.size())));
			total_size += seria::binary_size(res.blocks.back());
			if (total_size >= req.max_size)
				break;
		}
		invariant(!res.blocks.empty(), "");
		auto ba = json_rpc::create_binary_response_body(res, common::JsonValue(nullptr));
		std::cout << "Saving chunk start=" << ha << ", count=" << res.blocks.size() << ", size=" << ba.size()
		          << std::endl;
		sum_total_size_real += ba.size();
		for (size_t d = 0; d != res.blocks.size(); ++d) {
			if (d == 1) {
				ba = common::to_string(ha);
				sum_total_size_link += ba.size() * (res.blocks.size() - 1);
			}
			std::string subfolder;
			auto file_name = api::cnd::SyncBlocks::get_filename(Height(ha + d), &subfolder);
			invariant(
			    platform::create_folders_if_necessary(folder + api::cnd::SyncBlocks::url_prefix() + "/" + subfolder),
			    "");
			invariant(platform::save_file(
			              folder + api::cnd::SyncBlocks::url_prefix() + "/" + file_name, ba.data(), ba.size()),
			    "");
		}
		ha += res.blocks.size();
		max_total_count = std::max(max_total_count, res.blocks.size());
		min_total_count = std::min(min_total_count, res.blocks.size());
	}
	std::cout << "min_total_count=" << min_total_count << " max_total_count=" << max_total_count << std::endl;
	std::cout << "sum_total_size_real=" << sum_total_size_real << " sum_total_size_link=" << sum_total_size_link
	          << std::endl;
}