MCPcopy Create free account
hub / github.com/apple/foundationdb / populateMetaData

Function populateMetaData

fdbserver/KeyValueStoreRocksDB.actor.cpp:318–347  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

316}
317
318void populateMetaData(CheckpointMetaData* checkpoint, const rocksdb::ExportImportFilesMetaData& metaData) {
319 RocksDBColumnFamilyCheckpoint rocksCF;
320 rocksCF.dbComparatorName = metaData.db_comparator_name;
321 for (const rocksdb::LiveFileMetaData& fileMetaData : metaData.files) {
322 LiveFileMetaData liveFileMetaData;
323 liveFileMetaData.size = fileMetaData.size;
324 liveFileMetaData.name = fileMetaData.name;
325 liveFileMetaData.file_number = fileMetaData.file_number;
326 liveFileMetaData.db_path = fileMetaData.db_path;
327 liveFileMetaData.smallest_seqno = fileMetaData.smallest_seqno;
328 liveFileMetaData.largest_seqno = fileMetaData.largest_seqno;
329 liveFileMetaData.smallestkey = fileMetaData.smallestkey;
330 liveFileMetaData.largestkey = fileMetaData.largestkey;
331 liveFileMetaData.num_reads_sampled = fileMetaData.num_reads_sampled;
332 liveFileMetaData.being_compacted = fileMetaData.being_compacted;
333 liveFileMetaData.num_entries = fileMetaData.num_entries;
334 liveFileMetaData.num_deletions = fileMetaData.num_deletions;
335 liveFileMetaData.temperature = static_cast<uint8_t>(fileMetaData.temperature);
336 liveFileMetaData.oldest_blob_file_number = fileMetaData.oldest_blob_file_number;
337 liveFileMetaData.oldest_ancester_time = fileMetaData.oldest_ancester_time;
338 liveFileMetaData.file_creation_time = fileMetaData.file_creation_time;
339 liveFileMetaData.file_checksum = fileMetaData.file_checksum;
340 liveFileMetaData.file_checksum_func_name = fileMetaData.file_checksum_func_name;
341 liveFileMetaData.column_family_name = fileMetaData.column_family_name;
342 liveFileMetaData.level = fileMetaData.level;
343 rocksCF.sstFiles.push_back(liveFileMetaData);
344 }
345 checkpoint->setFormat(RocksDBColumnFamily);
346 checkpoint->serializedCheckpoint = ObjectWriter::toValue(rocksCF, IncludeVersion());
347}
348
349rocksdb::Slice toSlice(StringRef s) {
350 return rocksdb::Slice(reinterpret_cast<const char*>(s.begin()), s.size());

Callers 1

actionMethod · 0.85

Calls 3

IncludeVersionFunction · 0.85
setFormatMethod · 0.80
push_backMethod · 0.45

Tested by

no test coverage detected