Searched refs:req (Results 1 – 8 of 8) sorted by relevance
| /rocksdb-6.9/env/ |
| D | io_posix.cc | 630 FSReadRequest* req; in MultiRead() member
662 rep_to_submit->req->len - rep_to_submit->finished_len; in MultiRead()
690 FSReadRequest* req = req_wrap->req; in MultiRead() local
692 req->result = Slice(req->scratch, 0); in MultiRead()
699 req->result = Slice(req->scratch, req->len); in MultiRead()
700 req->status = IOStatus::OK(); in MultiRead()
707 req->status = in MultiRead()
708 Read(req->offset + req_wrap->finished_len, in MultiRead()
710 req->scratch + req_wrap->finished_len, dbg); in MultiRead()
711 req->result = in MultiRead()
[all …]
|
| D | composite_env_wrapper.h | 665 ReadRequest req; in MultiRead() local
667 req.offset = fs_reqs[i].offset; in MultiRead()
668 req.len = fs_reqs[i].len; in MultiRead()
669 req.scratch = fs_reqs[i].scratch; in MultiRead()
670 req.status = Status::OK(); in MultiRead()
672 reqs.emplace_back(req); in MultiRead()
|
| /rocksdb-6.9/file/ |
| D | random_access_file_reader.cc | 162 FSReadRequest req; in Align() local
163 req.offset = static_cast<uint64_t>( in Align()
165 req.len = Roundup(End(r), alignment) - req.offset; in Align()
166 req.scratch = nullptr; in Align()
167 return req; in Align()
|
| /rocksdb-6.9/table/block_based/ |
| D | block_based_table_reader.cc | 1597 FSReadRequest req; in RetrieveMultipleBlocks() local
1599 req.len = prev_len; in RetrieveMultipleBlocks()
1601 req.scratch = new char[req.len]; in RetrieveMultipleBlocks()
1618 FSReadRequest req; in RetrieveMultipleBlocks() local
1619 req.offset = prev_offset; in RetrieveMultipleBlocks()
1620 req.len = prev_len; in RetrieveMultipleBlocks()
1622 req.scratch = new char[req.len]; in RetrieveMultipleBlocks()
1648 Status s = req.status; in RetrieveMultipleBlocks()
1650 if (req.result.size() != req.len) { in RetrieveMultipleBlocks()
1654 ToString(req.len) + " bytes, got " + ToString(req.result.size())); in RetrieveMultipleBlocks()
[all …]
|
| /rocksdb-6.9/include/rocksdb/ |
| D | file_system.h | 645 FSReadRequest& req = reqs[i]; in MultiRead() local
646 req.status = in MultiRead()
647 Read(req.offset, req.len, options, &req.result, req.scratch, dbg); in MultiRead()
|
| D | env.h | 670 ReadRequest& req = reqs[i]; in MultiRead() local
671 req.status = Read(req.offset, req.len, &req.result, req.scratch); in MultiRead()
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_compaction_flush.cc | 1566 FlushRequest* req) { in GenerateFlushRequest() argument
1567 assert(req != nullptr); in GenerateFlushRequest()
1568 req->reserve(cfds.size()); in GenerateFlushRequest()
1575 req->emplace_back(cfd, max_memtable_id); in GenerateFlushRequest()
|
| D | db_impl.h | 1559 FlushRequest* req);
1561 void SchedulePendingFlush(const FlushRequest& req, FlushReason flush_reason);
|