Home
last modified time | relevance | path

Searched refs:reader (Results 1 – 25 of 47) sorted by relevance

12

/rocksdb-6.9/table/block_based/
Dblock_based_filter_block_test.cc67 ASSERT_TRUE(reader.KeyMayMatch( in TEST_F()
71 ASSERT_TRUE(reader.KeyMayMatch( in TEST_F()
121 ASSERT_TRUE(!reader.KeyMayMatch( in TEST_F()
125 ASSERT_TRUE(!reader.KeyMayMatch( in TEST_F()
170 ASSERT_TRUE(!reader.KeyMayMatch( in TEST_F()
256 FilterBlockReader* reader = in TEST_F() local
268 delete reader; in TEST_F()
288 FilterBlockReader* reader = in TEST_F() local
320 delete reader; in TEST_F()
350 FilterBlockReader* reader = in TEST_F() local
[all …]
Dfull_filter_block_test.cc122 FullFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F() local
124 ASSERT_TRUE(reader.KeyMayMatch("foo", /*prefix_extractor=*/nullptr, in TEST_F()
145 FullFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F() local
146 ASSERT_TRUE(reader.KeyMayMatch("foo", /*prefix_extractor=*/nullptr, in TEST_F()
151 ASSERT_TRUE(reader.KeyMayMatch("bar", /*prefix_extractor=*/nullptr, in TEST_F()
171 ASSERT_TRUE(!reader.KeyMayMatch( in TEST_F()
175 ASSERT_TRUE(!reader.KeyMayMatch( in TEST_F()
198 FullFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F() local
292 FullFilterBlockReader reader(table_.get(), std::move(block)); in TEST_F() local
318 ASSERT_TRUE(!reader.KeyMayMatch( in TEST_F()
[all …]
Dpartitioned_filter_block_test.cc156 auto reader = in NewReader() local
158 return reader; in NewReader()
164 std::unique_ptr<PartitionedFilterBlockReader> reader( in VerifyReader() local
179 ASSERT_TRUE(reader->KeyMayMatch( in VerifyReader()
188 ASSERT_TRUE(reader->KeyMayMatch( in VerifyReader()
193 ASSERT_FALSE(reader->KeyMayMatch( in VerifyReader()
338 std::unique_ptr<PartitionedFilterBlockReader> reader( in TEST_P() local
343 ASSERT_TRUE(reader->PrefixMayMatch( in TEST_P()
353 ASSERT_TRUE(reader->PrefixMayMatch( in TEST_P()
385 std::unique_ptr<PartitionedFilterBlockReader> reader( in TEST_P() local
[all …]
Dblock_test.cc96 Block reader(std::move(contents)); in TEST_F() local
100 InternalIterator *iter = reader.NewDataIterator( in TEST_F()
114 iter = reader.NewDataIterator(options.comparator, options.comparator, in TEST_F()
380 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F() local
384 DataBlockIter *iter = reader.NewDataIterator( in TEST_F()
413 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F() local
416 DataBlockIter *iter = reader.NewDataIterator( in TEST_F()
448 Block reader(std::move(contents), kBytesPerBit, stats.get()); in TEST_F() local
451 DataBlockIter *iter = reader.NewDataIterator( in TEST_F()
568 Block reader(std::move(contents)); in TEST_P() local
[all …]
Ddata_block_hash_index_test.cc287 Block reader(std::move(contents)); in TEST() local
289 ASSERT_EQ(reader.IndexType(), in TEST()
309 Block reader(std::move(contents)); in TEST() local
311 ASSERT_EQ(reader.IndexType(), in TEST()
340 Block reader(std::move(contents)); in TEST() local
342 ASSERT_EQ(reader.IndexType(), in TEST()
364 Block reader(std::move(contents)); in TEST() local
367 ASSERT_EQ(reader.IndexType(), in TEST()
391 Block reader(std::move(contents)); in TEST() local
394 auto iter = reader.NewDataIterator(&icmp, icmp.user_comparator(), in TEST()
[all …]
/rocksdb-6.9/trace_replay/
Dblock_cache_tracer_test.cc112 assert(reader); in VerifyAccess()
116 ASSERT_OK(reader->ReadAccess(&record)); in VerifyAccess()
178 ASSERT_NOK(reader.ReadHeader(&header)); in TEST_F()
202 ASSERT_OK(reader.ReadHeader(&header)); in TEST_F()
206 ASSERT_NOK(reader.ReadAccess(&record)); in TEST_F()
246 ASSERT_OK(reader.ReadHeader(&header)); in TEST_F()
250 ASSERT_NOK(reader.ReadAccess(&record)); in TEST_F()
309 ASSERT_OK(reader.ReadHeader(&header)); in TEST_F()
320 ASSERT_NOK(reader.ReadAccess(&record)); in TEST_F()
347 ASSERT_OK(reader.ReadHeader(&header)); in TEST_F()
[all …]
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_reader_test.cc121 ASSERT_OK(reader.status()); in CreateCuckooFileAndCheckReader()
151 ASSERT_OK(reader.status()); in CheckIterator()
152 InternalIterator* it = reader.NewIterator( in CheckIterator()
222 ASSERT_TRUE(reader.status().IsInvalidArgument()); in TEST_F()
342 ASSERT_OK(reader.status()); in TEST_F()
356 ASSERT_OK(reader.status()); in TEST_F()
370 ASSERT_OK(reader.status()); in TEST_F()
386 ASSERT_OK(reader.status()); in TEST_F()
454 ASSERT_OK(reader.status()); in WriteFile()
487 ASSERT_OK(reader.status()); in ReadKeys()
[all …]
Dcuckoo_table_reader.cc201 explicit CuckooTableIterator(CuckooTableReader* reader);
258 CuckooTableIterator::CuckooTableIterator(CuckooTableReader* reader) in CuckooTableIterator() argument
259 : bucket_comparator_(reader->file_data_, reader->ucomp_, in CuckooTableIterator()
260 reader->bucket_length_, reader->user_key_length_), in CuckooTableIterator()
261 reader_(reader), in CuckooTableIterator()
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DSstFileReaderTest.java113 final SstFileReader reader = new SstFileReader(options)) { in readSstFile()
115 reader.open(sstFile.getAbsolutePath()); in readSstFile()
117 final SstFileReaderIterator iterator = reader.newIterator(readOptions); in readSstFile()
123 reader.verifyChecksum(); in readSstFile()
126 assertEquals(reader.getTableProperties().getNumEntries(), 1); in readSstFile()
/rocksdb-6.9/file/
Dfile_prefetch_buffer.cc24 Status FilePrefetchBuffer::Prefetch(RandomAccessFileReader* reader, in Prefetch() argument
27 if (!enable_ || reader == nullptr) { in Prefetch()
30 size_t alignment = reader->file()->GetRequiredBufferAlignment(); in Prefetch()
89 s = reader->Read(rounddown_offset + chunk_len, in Prefetch()
Drandom_access_file_reader_test.cc60 std::unique_ptr<RandomAccessFileReader>* reader) { in Read() argument
64 (*reader).reset(new RandomAccessFileReader(std::move(f), fpath, env_)); in Read()
/rocksdb-6.9/table/
Dsst_file_reader_test.cc74 SstFileReader reader(options_); in CheckFile() local
75 ASSERT_OK(reader.Open(file_name)); in CheckFile()
76 ASSERT_OK(reader.VerifyChecksum()); in CheckFile()
77 std::unique_ptr<Iterator> iter(reader.NewIterator(ropts)); in CheckFile()
91 auto properties = reader.GetTableProperties(); in CheckFile()
Dtable_test.cc1125 s = reader.ReadAccess(&access); in VerifyBlockAccessTrace()
1823 auto* reader = c.GetTableReader(); in TEST_P() local
1865 auto reader = c.GetTableReader(); in TEST_P() local
1928 auto reader = c.GetTableReader(); in IndexTest() local
2138 auto reader = c.GetTableReader(); in TEST_P() local
2240 auto reader = c.GetTableReader(); in TEST_P() local
2415 auto reader = c.GetTableReader(); in TEST_P() local
3932 auto reader = c.GetTableReader(); in TEST_P() local
4593 auto reader = c.GetTableReader(); in TEST_P() local
4673 auto* reader = c.GetTableReader(); in TEST_P() local
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_file.cc186 std::shared_ptr<RandomAccessFileReader>* reader, in GetReader() argument
188 assert(reader != nullptr); in GetReader()
199 *reader = ra_file_reader_; in GetReader()
207 *reader = ra_file_reader_; in GetReader()
224 *reader = ra_file_reader_; in GetReader()
Dblob_db_impl.cc646 std::shared_ptr<RandomAccessFileReader>* reader) { in GetBlobFileReader() argument
647 assert(reader != nullptr); in GetBlobFileReader()
649 Status s = blob_file->GetReader(env_, env_options_, reader, &fresh_open); in GetBlobFileReader()
651 assert(*reader != nullptr); in GetBlobFileReader()
1474 std::shared_ptr<RandomAccessFileReader> reader; in GetRawBlobFromFile() local
1475 Status s = GetBlobFileReader(blob_file, &reader); in GetRawBlobFromFile()
1493 if (reader->use_direct_io()) { in GetRawBlobFromFile()
1494 s = reader->Read(record_offset, static_cast<size_t>(record_size), in GetRawBlobFromFile()
1498 s = reader->Read(record_offset, static_cast<size_t>(record_size), in GetRawBlobFromFile()
/rocksdb-6.9/db/
Dversion_edit_handler.cc30 Status VersionEditHandler::Iterate(log::Reader& reader, std::string* db_id) { in Iterate() argument
35 while (reader.ReadRecord(&record, &scratch) && s.ok()) { in Iterate()
74 CheckIterationResult(reader, &s); in Iterate()
249 void VersionEditHandler::CheckIterationResult(const log::Reader& reader, in CheckIterationResult() argument
327 version_set_->manifest_file_size_ = reader.GetReadOffset(); in CheckIterationResult()
487 const log::Reader& reader, Status* s) { in CheckIterationResult() argument
488 VersionEditHandler::CheckIterationResult(reader, s); in CheckIterationResult()
Dversion_edit_handler.h43 Status Iterate(log::Reader& reader, std::string* db_id);
63 virtual void CheckIterationResult(const log::Reader& reader, Status* s);
114 void CheckIterationResult(const log::Reader& reader, Status* s) override;
Dforward_iterator_bench.cc79 Reader* reader; member
252 state.reader->onWrite(shard); in run()
365 shard_states[i].reader = &readers[reader_dist(rng)]; in main()
Dversion_set.cc4370 log::Reader* reader, AtomicGroupReadBuffer* read_buffer, in ReadAndRecover() argument
4376 assert(reader != nullptr); in ReadAndRecover()
4382 while (reader->ReadRecord(&record, &scratch) && s.ok()) { in ReadAndRecover()
4502 current_manifest_file_size = reader.GetReadOffset(); in Recover()
4769 s = handler_pit.Iterate(reader, db_id); in TryRecoverFromOneManifest()
4812 while (reader.ReadRecord(&record, &scratch) && s.ok()) { in ListColumnFamilies()
5826 log::Reader* reader = manifest_reader->get(); in Recover() local
5831 assert(reader != nullptr); in Recover()
5951 log::Reader* reader = manifest_reader->get(); in ReadAndApply() local
5953 while (reader->ReadRecord(&record, &scratch)) { in ReadAndApply()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_secondary.cc183 log::FragmentBufferedReader* reader = nullptr; in RecoverLogFiles() local
184 status = MaybeInitLogReader(log_number, &reader); in RecoverLogFiles()
188 assert(reader != nullptr); in RecoverLogFiles()
193 log::FragmentBufferedReader* reader = it->second->reader_; in RecoverLogFiles() local
203 while (reader->ReadRecord(&record, &scratch, in RecoverLogFiles()
207 reader->GetReporter()->Corruption( in RecoverLogFiles()
294 reader->GetReporter()->Corruption(record.size(), status); in RecoverLogFiles()
/rocksdb-6.9/docs/_posts/
D2014-06-27-avoid-expensive-locks-in-get.markdown69 (1) A reader thread uses CAS to acquire SuperVersion from its local storage and to put in a special…
74 …reader thread tries to return SuperVersion to local storage by CAS, expecting the special flag (Su…
79 … across all threads’ local storage and frees encountered SuperVersion. A reader thread must re-acq…
D2019-03-08-format-version-4.markdown24 …nd sets `index_key_is_user_key` in TableProperties, which is used by the reader to know how to dec…
27 …leProperties::index_value_is_delta_encoded` is set, which is used by the reader to know how to dec…
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DSstFileReaderIterator.java24 protected SstFileReaderIterator(SstFileReader reader, long nativeHandle) { in SstFileReaderIterator() argument
25 super(reader, nativeHandle); in SstFileReaderIterator()
/rocksdb-6.9/utilities/trace/
Dfile_trace_reader_writer.cc19 std::unique_ptr<RandomAccessFileReader>&& reader) in FileTraceReader() argument
20 : file_reader_(std::move(reader)), in FileTraceReader()
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_trace_analyzer_plot.py55 rows = csv.reader(csvfile, delimiter=",")
97 rows = csv.reader(csvfile, delimiter=",")
155 csv_rows = csv.reader(csvfile, delimiter=",")
177 csv_rows = csv.reader(csvfile, delimiter=",")

12