Home
last modified time | relevance | path

Searched refs:record (Results 1 – 25 of 35) sorted by relevance

12

/rocksdb-6.9/trace_replay/
Dblock_cache_tracer_test.cc67 record.cf_id = kCFId; in WriteBlockAccess()
86 record, record.block_key, record.cf_name, record.referenced_key)); in WriteBlockAccess()
97 record.cf_id = kCFId; in GenerateAccessRecord()
100 record.level = kLevel; in GenerateAccessRecord()
107 return record; in GenerateAccessRecord()
167 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
191 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
230 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
235 ASSERT_OK(writer.WriteBlockAccess(record, record.block_key, record.cf_name, in TEST_F()
326 record.get_id = 1; in TEST_F()
[all …]
Dblock_cache_tracer.cc119 trace.ts = record.access_timestamp; in WriteBlockAccess()
120 trace.type = record.block_type; in WriteBlockAccess()
205 assert(record); in ReadAccess()
216 record->access_timestamp = trace.ts; in ReadAccess()
217 record->block_type = trace.type; in ReadAccess()
239 record->cf_name = cf_name.ToString(); in ReadAccess()
369 BlockCacheTraceRecord* record) { in ReadAccess() argument
390 record->cf_name = record_strs[5]; in ReadAccess()
425 record->block_key += "1"; in ReadAccess()
427 record->block_key += tmp_block_key; in ReadAccess()
[all …]
Dblock_cache_tracer.h185 Status WriteBlockAccess(const BlockCacheTraceRecord& record,
232 Status ReadAccess(BlockCacheTraceRecord* record);
249 Status ReadAccess(BlockCacheTraceRecord* record);
279 Status WriteBlockAccess(const BlockCacheTraceRecord& record,
/rocksdb-6.9/utilities/blob_db/
Dblob_log_reader.cc67 s = record->DecodeHeaderFrom(buffer_); in ReadRecord()
72 uint64_t kb_size = record->key_size + record->value_size; in ReadRecord()
83 record->key_buf.reset(new char[record->key_size]); in ReadRecord()
84 s = ReadSlice(record->key_size, &record->key, record->key_buf.get()); in ReadRecord()
85 next_byte_ += record->value_size; in ReadRecord()
89 record->key_buf.reset(new char[record->key_size]); in ReadRecord()
90 s = ReadSlice(record->key_size, &record->key, record->key_buf.get()); in ReadRecord()
92 record->value_buf.reset(new char[record->value_size]); in ReadRecord()
93 s = ReadSlice(record->value_size, &record->value, in ReadRecord()
94 record->value_buf.get()); in ReadRecord()
[all …]
Dblob_log_writer.cc106 BlobLogRecord record; in ConstructBlobHeader() local
107 record.key = key; in ConstructBlobHeader()
108 record.value = val; in ConstructBlobHeader()
109 record.expiration = expiration; in ConstructBlobHeader()
110 record.EncodeHeaderTo(buf); in ConstructBlobHeader()
Dblob_dump_tool.cc188 BlobLogRecord record; in DumpRecord() local
189 s = record.DecodeHeaderFrom(slice); in DumpRecord()
193 uint64_t key_size = record.key_size; in DumpRecord()
194 uint64_t value_size = record.value_size; in DumpRecord()
198 fprintf(stdout, " expiration : %" PRIu64 "\n", record.expiration); in DumpRecord()
/rocksdb-6.9/utilities/simulator_cache/
Dcache_simulator_test.cc35 record.block_size = 4096; in GenerateGetRecord()
38 record.cf_id = 0; in GenerateGetRecord()
39 record.cf_name = "test"; in GenerateGetRecord()
41 record.level = 6; in GenerateGetRecord()
43 record.get_id = getid; in GenerateGetRecord()
46 record.referenced_key = in GenerateGetRecord()
51 return record; in GenerateGetRecord()
60 record.cf_id = 0; in GenerateCompactionRecord()
61 record.cf_name = "test"; in GenerateCompactionRecord()
63 record.level = 6; in GenerateCompactionRecord()
[all …]
/rocksdb-6.9/db/
Dtransaction_log_impl.cc82 bool TransactionLogIteratorImpl::RestrictedRead(Slice* record) { in RestrictedRead() argument
87 return current_log_reader_->ReadRecord(record, &scratch_); in RestrictedRead()
92 Slice record; in SeekToStartSequence() local
105 while (RestrictedRead(&record)) { in SeekToStartSequence()
106 if (record.size() < WriteBatchInternal::kHeader) { in SeekToStartSequence()
111 UpdateCurrentWriteBatch(record); in SeekToStartSequence()
156 Slice record; in NextImpl() local
167 while (RestrictedRead(&record)) { in NextImpl()
168 if (record.size() < WriteBatchInternal::kHeader) { in NextImpl()
177 UpdateCurrentWriteBatch(record); in NextImpl()
[all …]
Dversion_set_test.cc724 record.clear(); in PrepareManifest()
1355 std::string record; in PrepareManifest() local
1365 record.clear(); in PrepareManifest()
1482 std::string record; in TEST_P() local
1528 std::string record; in TEST_P() local
1574 std::string record; in TEST_P() local
1585 std::string record; in TEST_P() local
1631 std::string record; in TEST_P() local
1641 std::string record; in TEST_P() local
1770 record.clear(); in PrepareManifest()
[all …]
Dlog_test.cc204 Slice record; in Read() local
208 return record.ToString(); in Read()
798 Slice record; in TryRead() local
801 result->assign(record.data(), record.size()); in TryRead()
840 std::string record; in TEST_P() local
843 while (!TryRead(&record)) { in TEST_P()
848 ASSERT_EQ("foo", record); in TEST_P()
884 std::string record; in TEST_P() local
892 ASSERT_EQ("foo", record); in TEST_P()
912 std::string record; in TEST_P() local
[all …]
Dlog_reader.cc54 bool Reader::ReadRecord(Slice* record, std::string* scratch, in ReadRecord() argument
57 record->clear(); in ReadRecord()
80 *record = fragment; in ReadRecord()
115 *record = Slice(*scratch); in ReadRecord()
399 bool FragmentBufferedReader::ReadRecord(Slice* record, std::string* scratch, in ReadRecord() argument
401 assert(record != nullptr); in ReadRecord()
403 record->clear(); in ReadRecord()
419 *record = fragment; in ReadRecord()
454 *record = Slice(*scratch); in ReadRecord()
Dwal_manager.cc487 Slice record; in ReadFirstLine() local
489 if (reader.ReadRecord(&record, &scratch) && in ReadFirstLine()
491 if (record.size() < WriteBatchInternal::kHeader) { in ReadFirstLine()
492 reporter.Corruption(record.size(), in ReadFirstLine()
497 WriteBatchInternal::SetContents(&batch, record); in ReadFirstLine()
Dflush_job_test.cc98 std::string record; in NewDB() local
99 new_db.EncodeTo(&record); in NewDB()
100 s = log.AddRecord(record); in NewDB()
103 record.clear(); in NewDB()
104 e.EncodeTo(&record); in NewDB()
105 s = log.AddRecord(record); in NewDB()
Dlog_reader.h66 virtual bool ReadRecord(Slice* record, std::string* scratch,
169 bool ReadRecord(Slice* record, std::string* scratch,
Dtransaction_log_impl.h111 bool RestrictedRead(Slice* record);
123 void UpdateCurrentWriteBatch(const Slice& record);
Drepair.cc376 Slice record; in ConvertLogToTable() local
379 while (reader.ReadRecord(&record, &scratch)) { in ConvertLogToTable()
380 if (record.size() < WriteBatchInternal::kHeader) { in ConvertLogToTable()
382 record.size(), Status::Corruption("log record too small")); in ConvertLogToTable()
385 WriteBatchInternal::SetContents(&batch, record); in ConvertLogToTable()
Dversion_set.cc3892 std::string record; in ProcessManifestWrites() local
4379 Slice record; in ReadAndRecover() local
4384 s = edit.DecodeFrom(record); in ReadAndRecover()
4810 Slice record; in ListColumnFamilies() local
4814 s = edit.DecodeFrom(record); in ListColumnFamilies()
5006 Slice record; in DumpManifest() local
5010 s = edit.DecodeFrom(record); in DumpManifest()
5229 std::string record; in WriteCurrentStateToManifest() local
5261 std::string record; in WriteCurrentStateToManifest() local
5832 Slice record; in Recover() local
[all …]
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer_test.cc101 BlockCacheTraceRecord record; in WriteBlockAccess() local
102 record.block_type = block_type; in WriteBlockAccess()
103 record.block_size = kBlockSize + key_id; in WriteBlockAccess()
105 record.access_timestamp = timestamp; in WriteBlockAccess()
106 record.cf_id = kCFId; in WriteBlockAccess()
108 record.caller = GetCaller(key_id); in WriteBlockAccess()
109 record.level = kLevel; in WriteBlockAccess()
115 record.is_cache_hit = Boolean::kFalse; in WriteBlockAccess()
116 record.no_insert = Boolean::kFalse; in WriteBlockAccess()
120 record.referenced_key = in WriteBlockAccess()
[all …]
/rocksdb-6.9/tools/
Dtrace_analyzer_tool.cc533 if (record.second.access_count <= in MakeStatistics()
579 record.first, record.second); in MakeStatistics()
596 k_count += record.second; in MakeStatistics()
603 record.first, record.second); in MakeStatistics()
622 v_count += record.second; in MakeStatistics()
670 for (auto& record : stats.a_key_stats) { in MakeStatisticKeyStatsOrPrefix() local
677 if (record.second.access_count > 0) { in MakeStatisticKeyStatsOrPrefix()
679 record.second.access_count; in MakeStatisticKeyStatsOrPrefix()
683 record.second.value_size, record.second.key_id, in MakeStatisticKeyStatsOrPrefix()
1149 std::make_pair(record.second.access_count, record.first)); in ReProcessing()
[all …]
/rocksdb-6.9/table/plain/
Dplain_table_index.cc187 IndexRecord* record = hash_to_offsets[i]; in FillIndexes() local
189 for (j = num_keys_for_bucket - 1; j >= 0 && record; in FillIndexes()
190 j--, record = record->next) { in FillIndexes()
191 EncodeFixed32(sub_index_pos + j * sizeof(uint32_t), record->offset); in FillIndexes()
193 assert(j == -1 && record == nullptr); in FillIndexes()
/rocksdb-6.9/table/block_based/
Dblock_prefix_index.cc76 PrefixRecord* record = reinterpret_cast<PrefixRecord*>( in Add() local
78 record->prefix = key_prefix; in Add()
79 record->start_block = start_block; in Add()
80 record->end_block = start_block + num_blocks - 1; in Add()
81 record->num_blocks = num_blocks; in Add()
82 prefixes_.push_back(record); in Add()
/rocksdb-6.9/table/
Dtable_test.cc2545 BlockCacheTraceRecord record; in TEST_P() local
2549 record.no_insert = Boolean::kFalse; in TEST_P()
2550 expected_records.push_back(record); in TEST_P()
2552 expected_records.push_back(record); in TEST_P()
2555 record.get_id = 1; in TEST_P()
2562 expected_records.push_back(record); in TEST_P()
2564 expected_records.push_back(record); in TEST_P()
2567 expected_records.push_back(record); in TEST_P()
2570 record.get_id = 2; in TEST_P()
2610 BlockCacheTraceRecord record; in TEST_P() local
[all …]
/rocksdb-6.9/util/
Dlog_write_bench.cc46 std::string record; in RunBenchmark() local
47 record.assign(FLAGS_record_size, 'X'); in RunBenchmark()
54 writer->Append(record); in RunBenchmark()
/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.cc200 Slice record; in RecoverLogFiles() local
203 while (reader->ReadRecord(&record, &scratch, in RecoverLogFiles()
206 if (record.size() < WriteBatchInternal::kHeader) { in RecoverLogFiles()
208 record.size(), Status::Corruption("log record too small")); in RecoverLogFiles()
211 WriteBatchInternal::SetContents(&batch, record); in RecoverLogFiles()
294 reader->GetReporter()->Corruption(record.size(), status); in RecoverLogFiles()
Ddb_impl_open.cc286 std::string record; in NewDB() local
287 new_db.EncodeTo(&record); in NewDB()
288 s = log.AddRecord(record); in NewDB()
827 Slice record; in RecoverLogFiles() local
831 reader.ReadRecord(&record, &scratch, in RecoverLogFiles()
834 if (record.size() < WriteBatchInternal::kHeader) { in RecoverLogFiles()
835 reporter.Corruption(record.size(), in RecoverLogFiles()
839 WriteBatchInternal::SetContents(&batch, record); in RecoverLogFiles()
883 reporter.Corruption(record.size(), status); in RecoverLogFiles()
950 reporter.Corruption(record.size(), status); in RecoverLogFiles()

12