Searched refs:read_reqs (Results 1 – 2 of 2) sorted by relevance
| /rocksdb-6.9/file/ |
| D | random_access_file_reader.cc | 189 Status RandomAccessFileReader::MultiRead(FSReadRequest* read_reqs, in MultiRead() argument
203 FSReadRequest* fs_reqs = read_reqs; in MultiRead()
213 aligned_reqs.push_back(Align(read_reqs[0], alignment)); in MultiRead()
215 const auto& r = Align(read_reqs[i], alignment); in MultiRead()
257 auto& r = read_reqs[i]; in MultiRead()
278 NotifyOnFileReadFinish(read_reqs[i].offset, read_reqs[i].result.size(), in MultiRead()
279 start_ts, finish_ts, read_reqs[i].status); in MultiRead()
282 IOSTATS_ADD_IF_POSITIVE(bytes_read, read_reqs[i].result.size()); in MultiRead()
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_reader.cc | 1570 autovector<FSReadRequest, MultiGetContext::MAX_BATCH_SIZE> read_reqs; in RetrieveMultipleBlocks() local
1606 read_reqs.emplace_back(req); in RetrieveMultipleBlocks()
1614 req_idx_for_block.emplace_back(read_reqs.size()); in RetrieveMultipleBlocks()
1626 read_reqs.emplace_back(req); in RetrieveMultipleBlocks()
1629 file->MultiRead(&read_reqs[0], read_reqs.size(), nullptr); in RetrieveMultipleBlocks()
1643 assert(req_idx_for_block[valid_batch_idx] < read_reqs.size()); in RetrieveMultipleBlocks()
1647 FSReadRequest& req = read_reqs[req_idx]; in RetrieveMultipleBlocks()
|