Searched refs:reqs (Results 1 – 8 of 8) sorted by relevance
| /rocksdb-6.9/file/ |
| D | random_access_file_reader_test.cc | 69 for (const auto& r : reqs) { in AssertResult()
137 reqs.push_back(std::move(r0)); in TEST_F()
138 reqs.push_back(std::move(r1)); in TEST_F()
140 ASSERT_OK(r->MultiRead(reqs.data(), reqs.size(), &aligned_buf)); in TEST_F()
142 AssertResult(content, reqs); in TEST_F()
177 ASSERT_OK(r->MultiRead(reqs.data(), reqs.size(), &aligned_buf)); in TEST_F()
179 AssertResult(content, reqs); in TEST_F()
214 ASSERT_OK(r->MultiRead(reqs.data(), reqs.size(), &aligned_buf)); in TEST_F()
216 AssertResult(content, reqs); in TEST_F()
243 ASSERT_OK(r->MultiRead(reqs.data(), reqs.size(), &aligned_buf)); in TEST_F()
[all …]
|
| D | random_access_file_reader.h | 125 Status MultiRead(FSReadRequest* reqs, size_t num_reqs,
|
| /rocksdb-6.9/env/ |
| D | env_test.cc | 1158 std::vector<ReadRequest> reqs(3); in TEST_P() local
1162 reqs[i].offset = offset; in TEST_P()
1164 reqs[i].len = kSectorSize; in TEST_P()
1166 reqs[i].scratch = data.back().get(); in TEST_P()
1175 ASSERT_OK(file->MultiRead(reqs.data(), reqs.size())); in TEST_P()
1178 ASSERT_OK(reqs[i].status); in TEST_P()
1254 std::vector<ReadRequest> reqs(num_reads); in TEST_F() local
1256 reqs[i].offset = offsets[i]; in TEST_F()
1257 reqs[i].len = lens[i]; in TEST_F()
1265 ASSERT_OK(file->MultiRead(reqs.data(), reqs.size())); in TEST_F()
[all …]
|
| D | composite_env_wrapper.h | 65 Status MultiRead(ReadRequest* reqs, size_t num_reqs) override { in MultiRead() argument
73 fs_reqs[i].offset = reqs[i].offset; in MultiRead()
74 fs_reqs[i].len = reqs[i].len; in MultiRead()
75 fs_reqs[i].scratch = reqs[i].scratch; in MultiRead()
80 reqs[i].result = fs_reqs[i].result; in MultiRead()
81 reqs[i].status = fs_reqs[i].status; in MultiRead()
660 std::vector<ReadRequest> reqs; in MultiRead() local
663 reqs.reserve(num_reqs); in MultiRead()
672 reqs.emplace_back(req); in MultiRead()
674 status = target_->MultiRead(reqs.data(), num_reqs); in MultiRead()
[all …]
|
| D | io_posix.cc | 607 IOStatus PosixRandomAccessFile::MultiRead(FSReadRequest* reqs, in MultiRead() argument
626 return FSRandomAccessFile::MultiRead(reqs, num_reqs, options, dbg); in MultiRead()
640 req_wraps.emplace_back(&reqs[i]); in MultiRead()
729 return FSRandomAccessFile::MultiRead(reqs, num_reqs, options, dbg); in MultiRead()
|
| D | io_posix.h | 197 virtual IOStatus MultiRead(FSReadRequest* reqs, size_t num_reqs,
|
| /rocksdb-6.9/include/rocksdb/ |
| D | file_system.h | 641 virtual IOStatus MultiRead(FSReadRequest* reqs, size_t num_reqs, in MultiRead() argument
643 assert(reqs != nullptr); in MultiRead()
645 FSReadRequest& req = reqs[i]; in MultiRead()
1238 IOStatus MultiRead(FSReadRequest* reqs, size_t num_reqs, in MultiRead() argument
1240 return target_->MultiRead(reqs, num_reqs, options, dbg); in MultiRead()
|
| D | env.h | 667 virtual Status MultiRead(ReadRequest* reqs, size_t num_reqs) { in MultiRead() argument
668 assert(reqs != nullptr); in MultiRead()
670 ReadRequest& req = reqs[i]; in MultiRead()
1438 Status MultiRead(ReadRequest* reqs, size_t num_reqs) override { in MultiRead() argument
1439 return target_->MultiRead(reqs, num_reqs); in MultiRead()
|