Method write_streaming_

src/serializers/RocksDbSerializer.cpp:124–287

}

void RocksDbSerializer::write_streaming_() {
	const auto& input_filename = std::get<std::string>(file_);

	IfcParse::impl::rocks_db_file_storage storage(rocksdb_filename_, nullptr);

	std::string tmp;

	IfcParse::InstanceStreamer streamer(input_filename);

	// We do not want to coerce attribute counts here, because we want
	// to store exactly what is in the file for validation purposes
	streamer.coerce_attribute_count = false;

	while (streamer) {
		auto inst = streamer.readInstance();
		if (inst) {
			// name can be zero in case of header instances
			auto name = std::get<0>(*inst);
			const auto* decl = std::get<1>(*inst);
			const auto& data = std::get<2>(*inst);

			const bool is_header = decl->schema() == &Header_section_schema::get_schema();

			std::vector<IfcUtil::IfcBaseClass*> simple_type_instances;

			for (size_t i = 0; i < data.storage_->size(); i++) {
				auto val = data.get_attribute_value(nullptr, decl, 0, i);
				val.apply_visitor([&](const auto& t) {
					using T = std::decay_t<decltype(t)>;
					if constexpr (std::is_same_v<T, IfcUtil::IfcBaseClass*>) {
						// instance is per definition a simple type here, because instance
						// references are not resolved yet, but provided in vector of
						// references
						simple_type_instances.push_back(t);
					}
					rocks_db_attribute_storage{}.set(&storage, decl, name, i, t);
				});
			}

			std::set<size_t> type_identities_wrote_as_refs;

			for (auto& p : streamer.references()) {
				// @nb cast to int in order not be interpreted as a char when appending to string
				int index = p.first.index_;

				auto key = (is_header ? "h|" : (decl->as_entity() ? "i|" : "t|")) +
					(is_header ? decl->name() : std::to_string(p.first.name_)) + "|" +
					std::to_string(index);

				if (storage.db->Get(storage.ropts, key, &tmp) == rocksdb::Status::OK() && tmp.size() == (sizeof(size_t) + 2) && tmp[0] == TypeEncoder::encode_type<IfcUtil::IfcBaseClass*>() && tmp[1] == 't')
				{
					size_t iden;
					memcpy(&iden, tmp.data() + 2, sizeof(size_t));
					key = "t|" + std::to_string(iden) + "|0";
					type_identities_wrote_as_refs.insert(iden);
				}

				std::visit([&](const auto& v) {