Home
last modified time | relevance | path

Searched refs:Read (Results 1 – 25 of 93) sorted by relevance

1234

/rocksdb-6.9/db/
Dlog_test.cc282 ASSERT_EQ("foo", Read()); in TEST_P()
283 ASSERT_EQ("bar", Read()); in TEST_P()
284 ASSERT_EQ("", Read()); in TEST_P()
286 ASSERT_EQ("EOF", Read()); in TEST_P()
297 ASSERT_EQ("EOF", Read()); in TEST_P()
307 ASSERT_EQ("EOF", Read()); in TEST_P()
320 ASSERT_EQ("", Read()); in TEST_P()
321 ASSERT_EQ("bar", Read()); in TEST_P()
322 ASSERT_EQ("EOF", Read()); in TEST_P()
334 ASSERT_EQ("bar", Read()); in TEST_P()
[all …]
/rocksdb-6.9/util/
Dfile_reader_writer_test.cc270 ASSERT_EQ("", Read(0, 1)); in TEST_P()
271 ASSERT_EQ("", Read(0, 0)); in TEST_P()
272 ASSERT_EQ("", Read(13, 13)); in TEST_P()
282 Read(7, 30)); in TEST_P()
283 ASSERT_EQ("", Read(100, 100)); in TEST_P()
315 Read(offset, n)); in TEST_P()
344 std::string Read(size_t n) { in Read() function in ROCKSDB_NAMESPACE::ReadaheadSequentialFileTest
366 ASSERT_EQ("", Read(0)); in TEST_P()
367 ASSERT_EQ("", Read(1)); in TEST_P()
368 ASSERT_EQ("", Read(13)); in TEST_P()
[all …]
/rocksdb-6.9/utilities/
Denv_mirror_test.cc129 ASSERT_OK(seq_file->Read(5, &result, scratch)); // Read "hello". in TEST_F()
132 ASSERT_OK(seq_file->Read(1000, &result, scratch)); // Read "world". in TEST_F()
134 ASSERT_OK(seq_file->Read(1000, &result, scratch)); // Try reading past EOF. in TEST_F()
137 ASSERT_OK(seq_file->Read(1000, &result, scratch)); in TEST_F()
142 ASSERT_OK(rand_file->Read(6, 5, &result, scratch)); // Read "world". in TEST_F()
144 ASSERT_OK(rand_file->Read(0, 5, &result, scratch)); // Read "hello". in TEST_F()
146 ASSERT_OK(rand_file->Read(10, 100, &result, scratch)); // Read "d". in TEST_F()
150 ASSERT_TRUE(!rand_file->Read(1000, 5, &result, scratch).ok()); in TEST_F()
194 ASSERT_OK(seq_file->Read(3, &result, scratch)); // Read "foo". in TEST_F()
200 ASSERT_OK(seq_file->Read(kWriteSize - read, &result, scratch)); in TEST_F()
Denv_mirror.cc24 Status Read(size_t n, Slice* result, char* scratch) override { in Read() function in ROCKSDB_NAMESPACE::SequentialFileMirror
26 Status as = a_->Read(n, &aslice, scratch); in Read()
33 Status bs = b_->Read(left, &bslice, bscratch); in Read()
42 Status bs = b_->Read(n, result, scratch); in Read()
68 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function in ROCKSDB_NAMESPACE::RandomAccessFileMirror
70 Status as = a_->Read(offset, n, result, scratch); in Read()
77 Status bs = b_->Read(offset + off, left, &bslice, bscratch); in Read()
85 Status bs = b_->Read(offset, n, result, scratch); in Read()
Denv_librados_test.cc188 ASSERT_OK(seq_file->Read(5, &result, scratch)); // Read "hello". in TEST_F()
191 ASSERT_OK(seq_file->Read(1000, &result, scratch)); // Read "world". in TEST_F()
196 ASSERT_OK(seq_file->Read(1000, &result, scratch)); in TEST_F()
201 ASSERT_OK(rand_file->Read(6, 5, &result, scratch)); // Read "world". in TEST_F()
203 ASSERT_OK(rand_file->Read(0, 5, &result, scratch)); // Read "hello". in TEST_F()
205 ASSERT_OK(rand_file->Read(10, 100, &result, scratch)); // Read "d". in TEST_F()
209 ASSERT_OK(rand_file->Read(1000, 5, &result, scratch)); in TEST_F()
263 ASSERT_OK(seq_file->Read(3, &result, scratch)); // Read "foo". in TEST_F()
269 ASSERT_OK(seq_file->Read(kWriteSize - read, &result, scratch)); in TEST_F()
299 ASSERT_OK(seq_file->Read(3, &result, scratch)); // Read "foo". in TEST_F()
[all …]
/rocksdb-6.9/env/
Denv_basic_test.cc223 ASSERT_OK(seq_file->Read(5, &result, scratch)); // Read "hello". in TEST_P()
226 ASSERT_OK(seq_file->Read(1000, &result, scratch)); // Read "world". in TEST_P()
228 ASSERT_OK(seq_file->Read(1000, &result, scratch)); // Try reading past EOF. in TEST_P()
231 ASSERT_OK(seq_file->Read(1000, &result, scratch)); in TEST_P()
236 ASSERT_OK(rand_file->Read(6, 5, &result, scratch)); // Read "world". in TEST_P()
238 ASSERT_OK(rand_file->Read(0, 5, &result, scratch)); // Read "hello". in TEST_P()
240 ASSERT_OK(rand_file->Read(10, 100, &result, scratch)); // Read "d". in TEST_P()
244 ASSERT_TRUE(rand_file->Read(1000, 5, &result, scratch).ok()); in TEST_P()
277 ASSERT_OK(seq_file->Read(3, &result, scratch)); // Read "foo". in TEST_P()
283 ASSERT_OK(seq_file->Read(kWriteSize - read, &result, scratch)); in TEST_P()
Dmock_env_test.cc42 ASSERT_OK(rand_file->Read(0, kGood.size(), &result, &(scratch[0]))); in TEST_F()
49 ASSERT_OK(rand_file->Read(0, kGood.size(), &result, &(scratch[0]))); in TEST_F()
56 ASSERT_OK(rand_file->Read(kGood.size(), kCorrupted.size(), in TEST_F()
62 ASSERT_OK(rand_file->Read(kGood.size(), kCorrupted.size(), in TEST_F()
Denv_encryption.cc46 Status Read(size_t n, Slice* result, char* scratch) override { in Read() function in ROCKSDB_NAMESPACE::EncryptedSequentialFile
48 Status status = file_->Read(n, result, scratch); in Read()
127 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function in ROCKSDB_NAMESPACE::EncryptedRandomAccessFile
131 auto status = file_->Read(offset, n, result, scratch); in Read()
353 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function in ROCKSDB_NAMESPACE::EncryptedRandomRWFile
357 auto status = file_->Read(offset, n, result, scratch); in Read()
404 status = underlying->Read(prefixLength, &prefixSlice, prefixBuf.BufferStart()); in NewSequentialFile()
442 status = underlying->Read(0, prefixLength, &prefixSlice, prefixBuf.BufferStart()); in NewRandomAccessFile()
618 status = underlying->Read(0, prefixLength, &prefixSlice, prefixBuf.BufferStart()); in NewRandomRWFile()
Denv_test.cc1747 ASSERT_OK(file->Read(0, 10, &read_res, buf)); in TEST_P()
1751 ASSERT_OK(file->Read(0, 10, &read_res, buf)); in TEST_P()
1755 ASSERT_OK(file->Read(10, 10, &read_res, buf)); in TEST_P()
1759 ASSERT_OK(file->Read(10, 10, &read_res, buf)); in TEST_P()
1771 ASSERT_OK(file->Read(0, 9, &read_res, buf)); in TEST_P()
1774 ASSERT_OK(file->Read(2, 4, &read_res, buf)); in TEST_P()
1781 ASSERT_OK(file->Read(0, 9, &read_res, buf)); in TEST_P()
1784 ASSERT_OK(file->Read(10, 3, &read_res, buf)); in TEST_P()
1787 ASSERT_OK(file->Read(200, 9, &read_res, buf)); in TEST_P()
1791 ASSERT_OK(file->Read(0, 10, &read_res, buf)); in TEST_P()
[all …]
Dmock_env.cc103 Status Read(uint64_t offset, size_t n, Slice* result, char* scratch) const { in Read() function in ROCKSDB_NAMESPACE::MemFile
188 Status Read(size_t n, Slice* result, char* scratch) override { in Read() function in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockSequentialFile
189 Status s = file_->Read(pos_, n, result, scratch); in Read()
219 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockRandomAccessFile
221 return file_->Read(offset, n, result, scratch); in Read()
238 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function in ROCKSDB_NAMESPACE::__anoncf69f33a0111::MockRandomRWFile
240 return file_->Read(offset, n, result, scratch); in Read()
Dcomposite_env_wrapper.h29 Status Read(size_t n, Slice* result, char* scratch) override { in Read() function
32 return target_->Read(n, io_opts, result, scratch, &dbg); in Read()
59 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function
63 return target_->Read(offset, n, io_opts, result, scratch, &dbg); in Read()
225 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function
229 return target_->Read(offset, n, io_opts, result, scratch, &dbg); in Read()
620 IOStatus Read(size_t n, const IOOptions& /*options*/, Slice* result, in Read() function
622 return status_to_io_status(target_->Read(n, result, scratch)); in Read()
652 IOStatus Read(uint64_t offset, size_t n, const IOOptions& /*options*/, in Read() function
655 return status_to_io_status(target_->Read(offset, n, result, scratch)); in Read()
[all …]
Dio_posix.h139 virtual IOStatus Read(size_t n, const IOOptions& opts, Slice* result,
193 virtual IOStatus Read(uint64_t offset, size_t n, const IOOptions& opts,
285 virtual IOStatus Read(uint64_t offset, size_t n, const IOOptions& opts,
356 virtual IOStatus Read(uint64_t offset, size_t n, const IOOptions& opts,
/rocksdb-6.9/tools/dump/
Ddb_dump_tool.cc155 status = dumpfile->Read(8, &slice, scratch8); in Run()
163 status = dumpfile->Read(8, &slice, scratch8); in Run()
171 status = dumpfile->Read(4, &slice, scratch8); in Run()
203 status = dumpfile->Read(4, &slice, scratch8); in Run()
211 status = dumpfile->Read(keysize, &keyslice, keyscratch.get()); in Run()
219 status = dumpfile->Read(4, &slice, scratch8); in Run()
232 status = dumpfile->Read(valsize, &valslice, valscratch.get()); in Run()
/rocksdb-6.9/file/
Dsequence_file_reader.cc25 Status SequentialFileReader::Read(size_t n, Slice* result, char* scratch) { in Read() function in ROCKSDB_NAMESPACE::SequentialFileReader
43 r = buf.Read(scratch, offset_advance, in Read()
49 s = file_->Read(n, IOOptions(), result, scratch, nullptr); in Read()
88 IOStatus Read(size_t n, const IOOptions& opts, Slice* result, char* scratch, in Read() function in ROCKSDB_NAMESPACE::__anon88823ea90111::ReadaheadSequentialFile
108 s = file_->Read(n, opts, result, scratch + cached_len, dbg); in Read()
197 IOStatus s = file_->Read(n, opts, &result, buffer_.BufferStart(), dbg); in ReadIntoBuffer()
Dreadahead_raf.cc38 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function in ROCKSDB_NAMESPACE::__anon832aeac60111::ReadaheadRandomAccessFile
42 return file_->Read(offset, n, result, scratch); in Read()
135 Status s = file_->Read(offset, n, &result, buffer_.BufferStart()); in ReadIntoBuffer()
Drandom_access_file_reader.cc24 Status RandomAccessFileReader::Read(uint64_t offset, size_t n, Slice* result, in Read() function in ROCKSDB_NAMESPACE::RandomAccessFileReader
67 s = file_->Read(aligned_offset + buf.CurrentSize(), allowed, in Read()
85 buf.Read(scratch, offset_advance, res_len); in Read()
121 s = file_->Read(offset + pos, allowed, IOOptions(), &tmp_result, in Read()
Drandom_access_file_reader_test.cc59 void Read(const std::string& fname, const FileOptions& opts, in Read() function in ROCKSDB_NAMESPACE::RandomAccessFileReaderTest
92 Read(f, FileOptions(), &r); in GetAlignment()
115 Read(fname, opts, &r); in TEST_F()
/rocksdb-6.9/utilities/blob_db/
Dblob_dump_tool.cc94 Status BlobDumpTool::Read(uint64_t offset, size_t size, Slice* result) { in Read() function in ROCKSDB_NAMESPACE::blob_db::BlobDumpTool
104 Status s = reader_->Read(offset, size, result, buffer_.get(), nullptr); in Read()
117 Status s = Read(0, BlobLogHeader::kSize, &slice); in DumpBlobLogHeader()
156 Status s = Read(*footer_offset, BlobLogFooter::kSize, &slice); in DumpBlobLogFooter()
184 Status s = Read(*offset, BlobLogRecord::kHeaderSize, &slice); in DumpRecord()
201 s = Read(*offset, static_cast<size_t>(key_size + value_size), &slice); in DumpRecord()
Dblob_file.cc145 s = ra_file_reader_->Read(footer_offset, BlobLogFooter::kSize, &result, in ReadFooter()
149 s = ra_file_reader_->Read(footer_offset, BlobLogFooter::kSize, &result, in ReadFooter()
269 s = file_reader->Read(0, BlobLogHeader::kSize, &header_slice, nullptr, in ReadMetadata()
273 s = file_reader->Read(0, BlobLogHeader::kSize, &header_slice, in ReadMetadata()
309 s = file_reader->Read(file_size - BlobLogFooter::kSize, in ReadMetadata()
314 s = file_reader->Read(file_size - BlobLogFooter::kSize, in ReadMetadata()
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file.h114 virtual bool Read(const LBA& /*lba*/, Slice* /*key*/, Slice* /*block*/, in Read() function
161 bool Read(const LBA& lba, Slice* key, Slice* block, char* scratch) override;
195 bool Read(const LBA& lba, Slice* key, Slice* block, char* scratch) override { in Read() function
200 return RandomAccessCacheFile::Read(lba, key, block, scratch); in Read()
/rocksdb-6.9/table/plain/
Dplain_table_key_coding.cc56 bool success = file_reader_.Read(start_offset, 1, &next_byte_slice); in DecodeSize()
213 Status s = file_info_->file->Read(file_offset, size_to_read, &read_result, in ReadNonMmap()
248 if (!Read(offset, bytes_to_read, &bytes)) { in ReadVarint32NonMmap()
264 bool success = file_reader_.Read(file_offset, user_key_size + 1, &tmp_slice); in ReadInternalKey()
276 success = file_reader_.Read(file_offset, user_key_size + 8, internal_key); in ReadInternalKey()
471 success = file_reader_.Read(start_offset + *bytes_read, value_size, value); in NextKey()
/rocksdb-6.9/utilities/trace/
Dfile_trace_reader_writer.cc34 Status FileTraceReader::Read(std::string* data) { in Read() function in ROCKSDB_NAMESPACE::FileTraceReader
36 Status s = file_reader_->Read(offset_, kTraceMetadataSize, &result_, buffer_, in Read()
61 s = file_reader_->Read(offset_, to_read, &result_, buffer_, nullptr); in Read()
/rocksdb-6.9/include/rocksdb/
Dfile_system.h546 virtual IOStatus Read(size_t n, const IOOptions& options, Slice* result,
623 virtual IOStatus Read(uint64_t offset, size_t n, const IOOptions& options,
647 Read(req.offset, req.len, options, &req.result, req.scratch, dbg); in MultiRead()
918 virtual IOStatus Read(uint64_t offset, size_t n, const IOOptions& options,
1206 IOStatus Read(size_t n, const IOOptions& options, Slice* result, in Read() function
1208 return target_->Read(n, options, result, scratch, dbg); in Read()
1233 IOStatus Read(uint64_t offset, size_t n, const IOOptions& options, in Read() function
1236 return target_->Read(offset, n, options, result, scratch, dbg); in Read()
1359 IOStatus Read(uint64_t offset, size_t n, const IOOptions& options, in Read() function
1362 return target_->Read(offset, n, options, result, scratch, dbg); in Read()
Denv.h579 virtual Status Read(size_t n, Slice* result, char* scratch) = 0;
652 virtual Status Read(uint64_t offset, size_t n, Slice* result,
671 req.status = Read(req.offset, req.len, &req.result, req.scratch); in MultiRead()
931 virtual Status Read(uint64_t offset, size_t n, Slice* result,
1409 Status Read(size_t n, Slice* result, char* scratch) override { in Read() function
1410 return target_->Read(n, result, scratch); in Read()
1434 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function
1436 return target_->Read(offset, n, result, scratch); in Read()
1541 Status Read(uint64_t offset, size_t n, Slice* result, in Read() function
1543 return target_->Read(offset, n, result, scratch); in Read()
/rocksdb-6.9/port/win/
Dio_win.h113 virtual Status Read(size_t n, Slice* result, char* scratch) override;
141 virtual Status Read(uint64_t offset, size_t n, Slice* result,
268 virtual Status Read(uint64_t offset, size_t n, Slice* result,
405 virtual Status Read(uint64_t offset, size_t n, Slice* result,

1234