Home
last modified time | relevance | path

Searched refs:info (Results 1 – 25 of 62) sorted by relevance

123

/rocksdb-6.9/util/
Dfilter_bench.cc367 info.filter_id_ = filter_id; in Go()
378 info.filter_ = info.plain_table_bloom_->GetRawData(); in Go()
386 info.filter_ = builder->Finish(&info.owner_); in Go()
395 info.reader_.reset( in Go()
443 info.reader_->MayMatch(kms_[0].Get(info.filter_id_, j))); in Go()
516 for (auto &info : infos_) { in RandomQueryTest() local
517 info.outside_queries_ = 0; in RandomQueryTest()
518 info.false_positives_ = 0; in RandomQueryTest()
589 kms_[i].Get(info.filter_id_, random_.Uniformish(info.keys_added_)); in RandomQueryTest()
592 kms_[i].Get(info.filter_id_, random_.Uniformish(info.keys_added_) | in RandomQueryTest()
[all …]
Dcompression.h700 level = info.options().level; in Zlib_Compress()
743 (void)info; in Zlib_Compress()
846 (void)info;
1061 (void)info; in LZ4_Compress()
1125 (void)info;
1171 level = info.options().level; in LZ4HC_Compress()
1210 (void)info; in LZ4HC_Compress()
1292 (void)info; in ZSTD_Compress()
1327 info.dict().GetRawDict().data(), info.dict().GetRawDict().size());
1330 (void)info;
[all …]
Dcrc32c.cc416 int info[4]; in isSSE42()
417 __cpuidex(info, 0x00000001, 0); in isSSE42()
418 return (info[2] & ((int)1 << 20)) != 0; in isSSE42()
434 int info[4]; in isPCLMULQDQ()
435 __cpuidex(info, 0x00000001, 0); in isPCLMULQDQ()
436 return (info[2] & ((int)1 << 1)) != 0; in isPCLMULQDQ()
/rocksdb-6.9/db/
Devent_helpers.cc30 info.db_name = db_name; in NotifyTableFileCreationStarted()
31 info.cf_name = cf_name; in NotifyTableFileCreationStarted()
33 info.job_id = job_id; in NotifyTableFileCreationStarted()
34 info.reason = reason; in NotifyTableFileCreationStarted()
147 info.db_name = db_name; in LogAndNotifyTableFileCreationFinished()
151 info.job_id = job_id; in LogAndNotifyTableFileCreationFinished()
153 info.reason = reason; in LogAndNotifyTableFileCreationFinished()
154 info.status = s; in LogAndNotifyTableFileCreationFinished()
188 info.db_name = dbname; in LogAndNotifyTableFileDeletion()
189 info.job_id = job_id; in LogAndNotifyTableFileDeletion()
[all …]
Dlistener_test.cc220 prev_fc_info_ = info; in OnTableFileCreated()
224 ASSERT_GT(info.job_id, 0); in OnTableFileCreated()
266 ASSERT_EQ(TableFileNameToNumber(info.file_path), info.file_number); in OnFlushCompleted()
742 ASSERT_GT(info.job_id, 0); in OnTableFileCreationStarted()
753 ASSERT_GT(info.job_id, 0); in OnTableFileCreated()
754 if (info.status.ok()) { in OnTableFileCreated()
984 if (info.status.ok()) { in OnFileReadFinish()
987 ReportDuration(info); in OnFileReadFinish()
992 if (info.status.ok()) { in OnFileWriteFinish()
995 ReportDuration(info); in OnFileWriteFinish()
[all …]
Dflush_job.cc452 info->cf_id = cfd_->GetID(); in GetFlushJobInfo()
453 info->cf_name = cfd_->GetName(); in GetFlushJobInfo()
456 info->file_path = in GetFlushJobInfo()
458 info->file_number = file_number; in GetFlushJobInfo()
460 info->thread_id = db_options_.env->GetThreadID(); in GetFlushJobInfo()
461 info->job_id = job_context_->job_id; in GetFlushJobInfo()
462 info->smallest_seqno = meta_.fd.smallest_seqno; in GetFlushJobInfo()
463 info->largest_seqno = meta_.fd.largest_seqno; in GetFlushJobInfo()
464 info->table_properties = table_properties_; in GetFlushJobInfo()
465 info->flush_reason = cfd_->GetFlushReason(); in GetFlushJobInfo()
[all …]
Ddb_flush_test.cc360 void OnFlushCompleted(DB* db, const FlushJobInfo& info) override { in TEST_F() argument
362 ASSERT_EQ(info.smallest_seqno, info.largest_seqno); in TEST_F()
363 ASSERT_NE(0, info.smallest_seqno); in TEST_F()
364 if (info.smallest_seqno == seq1) { in TEST_F()
373 ASSERT_EQ(info.smallest_seqno, seq2); in TEST_F()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_listener.h27 assert(IsValidColumnFamilyName(info.cf_name)); in OnFlushCompleted()
28 VerifyFilePath(info.file_path); in OnFlushCompleted()
65 assert(info.db_name == db_name_); in OnTableFileCreated()
66 assert(IsValidColumnFamilyName(info.cf_name)); in OnTableFileCreated()
67 if (info.file_size) { in OnTableFileCreated()
68 VerifyFilePath(info.file_path); in OnTableFileCreated()
71 if (info.status.ok() && info.file_size > 0) { in OnTableFileCreated()
72 assert(info.table_properties.data_size > 0 || in OnTableFileCreated()
75 assert(info.table_properties.num_entries > 0); in OnTableFileCreated()
110 size_t length_read = info.length; in OnFileReadFinish()
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_db_listener.h49 void OnFlushCompleted(DB* db, const FlushJobInfo& info) override { in OnFlushCompleted() argument
50 BlobDBListener::OnFlushCompleted(db, info); in OnFlushCompleted()
53 blob_db_impl_->ProcessFlushJobInfo(info); in OnFlushCompleted()
56 void OnCompactionCompleted(DB* db, const CompactionJobInfo& info) override { in OnCompactionCompleted() argument
57 BlobDBListener::OnCompactionCompleted(db, info); in OnCompactionCompleted()
60 blob_db_impl_->ProcessCompactionJobInfo(info); in OnCompactionCompleted()
Dblob_db_test.cc1725 FlushJobInfo info{}; in TEST_F() local
1726 info.file_number = 21; in TEST_F()
1727 info.smallest_seqno = 1; in TEST_F()
1728 info.largest_seqno = 100; in TEST_F()
1753 FlushJobInfo info{}; in TEST_F() local
1754 info.file_number = 22; in TEST_F()
1757 info.largest_seqno = 200; in TEST_F()
1786 CompactionJobInfo info{}; in TEST_F() local
1822 CompactionJobInfo info{}; in TEST_F() local
1884 FlushJobInfo info{}; in TEST_F() local
[all …]
Dblob_db_impl.cc462 LinkSstToBlobFile(info.file_number, info.oldest_blob_file_number); in ProcessFlushJobInfo()
465 assert(flush_sequence_ < info.largest_seqno); in ProcessFlushJobInfo()
466 flush_sequence_ = info.largest_seqno; in ProcessFlushJobInfo()
474 if (!info.status.ok()) { in ProcessCompactionJobInfo()
486 auto inputs = info.input_file_infos; in ProcessCompactionJobInfo()
492 auto outputs = info.output_file_infos; in ProcessCompactionJobInfo()
1120 CompactionJobInfo info{}; in CompactFiles() local
1122 compaction_job_info = &info; in CompactFiles()
1403 info, value->data(), value->size(), &contents, in GetBlobValue()
2113 ProcessFlushJobInfo(info); in TEST_ProcessFlushJobInfo()
[all …]
Dblob_db_impl.h207 void TEST_ProcessFlushJobInfo(const FlushJobInfo& info);
209 void TEST_ProcessCompactionJobInfo(const CompactionJobInfo& info);
336 void ProcessFlushJobInfo(const FlushJobInfo& info);
340 void ProcessCompactionJobInfo(const CompactionJobInfo& info);
/rocksdb-6.9/utilities/transactions/
Dtransaction_util.h36 void Merge(const TransactionKeyMapInfo& info) { in Merge()
37 assert(seq <= info.seq); in Merge()
38 num_reads += info.num_reads; in Merge()
39 num_writes += info.num_writes; in Merge()
40 exclusive |= info.exclusive; in Merge()
Dtransaction_lock_mgr.cc715 struct KeyLockInfo info; in GetLockStatusData() local
716 info.exclusive = it.second.exclusive; in GetLockStatusData()
717 info.key = it.first; in GetLockStatusData()
719 info.ids.push_back(id); in GetLockStatusData()
721 data.insert({i, info}); in GetLockStatusData()
/rocksdb-6.9/file/
Drandom_access_file_reader.h40 FileOperationInfo info(file_name_, start_ts, finish_ts); in NotifyOnFileReadFinish()
41 info.offset = offset; in NotifyOnFileReadFinish()
42 info.length = length; in NotifyOnFileReadFinish()
43 info.status = status; in NotifyOnFileReadFinish()
46 listener->OnFileReadFinish(info); in NotifyOnFileReadFinish()
Dwritable_file_writer.h41 FileOperationInfo info(file_name_, start_ts, finish_ts); in NotifyOnFileWriteFinish()
42 info.offset = offset; in NotifyOnFileWriteFinish()
43 info.length = length; in NotifyOnFileWriteFinish()
44 info.status = io_status; in NotifyOnFileWriteFinish()
47 listener->OnFileWriteFinish(info); in NotifyOnFileWriteFinish()
/rocksdb-6.9/db/db_impl/
Ddb_impl_compaction_flush.cc607 FlushJobInfo info{}; in NotifyOnFlushBegin() local
608 info.cf_id = cfd->GetID(); in NotifyOnFlushBegin()
609 info.cf_name = cfd->GetName(); in NotifyOnFlushBegin()
613 info.file_path = in NotifyOnFlushBegin()
617 info.job_id = job_id; in NotifyOnFlushBegin()
1166 CompactionJobInfo info{}; in NotifyOnCompactionBegin() local
1167 info.cf_name = cfd->GetName(); in NotifyOnCompactionBegin()
1168 info.status = st; in NotifyOnCompactionBegin()
1170 info.job_id = job_id; in NotifyOnCompactionBegin()
1173 info.stats = job_stats; in NotifyOnCompactionBegin()
[all …]
/rocksdb-6.9/buckifier/
Dbuckify_rocksdb.py138 print(ColorString.info("Generating TARGETS"))
207 print(ColorString.info("Generated TARGETS Summary:"))
208 print(ColorString.info("- %d libs" % TARGETS.total_lib))
209 print(ColorString.info("- %d binarys" % TARGETS.total_bin))
210 print(ColorString.info("- %d tests" % TARGETS.total_test))
Dutil.py44 def info(text): member in ColorString
111 print(ColorString.info("stdout: \n"), stdout)
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier.cc251 BlockInfo* info = metadata_.Insert(key, lba); in InsertImpl() local
252 assert(info); in InsertImpl()
253 if (!info) { in InsertImpl()
258 cache_file_->Add(info); in InsertImpl()
318 BlockInfo* info = metadata_.Remove(key); in Erase() local
319 assert(info); in Erase()
320 delete info; in Erase()
/rocksdb-6.9/examples/
Dcompact_files_example.cc74 DB* db, const FlushJobInfo& info) override { in OnFlushCompleted() argument
75 CompactionTask* task = PickCompaction(db, info.cf_name); in OnFlushCompleted()
77 if (info.triggered_writes_stop) { in OnFlushCompleted()
/rocksdb-6.9/coverage/
Dcoverage_test.sh78 --output-file $COVERAGE_DIR/coverage.info)
80 genhtml $COVERAGE_DIR/coverage.info -o $COVERAGE_DIR
/rocksdb-6.9/table/block_based/
Dblock_based_table_builder.cc151 Slice CompressBlock(const Slice& raw, const CompressionInfo& info, in CompressBlock() argument
156 *type = info.type(); in CompressBlock()
158 if (info.type() == kNoCompression && !info.SampleForCompression()) { in CompressBlock()
167 if (do_sample && info.SampleForCompression() && in CompressBlock()
168 Random::GetTLSInstance()->OneIn((int)info.SampleForCompression()) && in CompressBlock()
178 info.SampleForCompression()); in CompressBlock()
190 info.SampleForCompression()); in CompressBlock()
197 if (CompressBlockInternal(raw, info, format_version, compressed_output) && in CompressBlock()
/rocksdb-6.9/table/
Dblock_fetcher.cc270 UncompressionInfo info(context, uncompression_dict_, compression_type_); in ReadBlockContents() local
271 status_ = UncompressBlockContents(info, slice_.data(), block_size_, in ReadBlockContents()
Dformat.h318 extern Status UncompressBlockContents(const UncompressionInfo& info,
329 const UncompressionInfo& info, const char* data, size_t n,

123