Lines Matching refs:req
1597 FSReadRequest req; in RetrieveMultipleBlocks() local
1598 req.offset = prev_offset; in RetrieveMultipleBlocks()
1599 req.len = prev_len; in RetrieveMultipleBlocks()
1601 req.scratch = new char[req.len]; in RetrieveMultipleBlocks()
1603 req.scratch = scratch + buf_offset; in RetrieveMultipleBlocks()
1604 buf_offset += req.len; in RetrieveMultipleBlocks()
1606 read_reqs.emplace_back(req); 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()
1624 req.scratch = scratch + buf_offset; in RetrieveMultipleBlocks()
1626 read_reqs.emplace_back(req); in RetrieveMultipleBlocks()
1647 FSReadRequest& req = read_reqs[req_idx]; in RetrieveMultipleBlocks() local
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()
1660 if (cur_read_end > req.result.size()) { in RetrieveMultipleBlocks()
1663 ToString(handle.offset()) + ", expected " + ToString(req.len) + in RetrieveMultipleBlocks()
1664 " bytes, got " + ToString(req.result.size())); in RetrieveMultipleBlocks()
1667 bool blocks_share_read_buffer = (req.result.size() != block_size(handle)); in RetrieveMultipleBlocks()
1672 assert(req.result.data() == req.scratch); in RetrieveMultipleBlocks()
1673 std::unique_ptr<char[]> raw_block(req.scratch + req_offset); in RetrieveMultipleBlocks()
1679 BlockContents(Slice(req.scratch + req_offset, handle.size())); in RetrieveMultipleBlocks()
1687 const char* data = req.result.data(); in RetrieveMultipleBlocks()
1712 Slice raw = Slice(req.scratch + req_offset, block_size(handle)); in RetrieveMultipleBlocks()
1750 s = UncompressBlockContents(info, req.result.data() + req_offset, in RetrieveMultipleBlocks()