Lines Matching refs:BlockIdx
59 using BlockIdx = int32_t; typedef
86 static constexpr inline off64_t blockIndexToOffset(BlockIdx blockIdx) { in blockIndexToOffset()
124 BlockIdx block_idx;
134 BlockIdx block_idx; // 4 bytes
159 int64_t ReadDataBlock(BlockIdx block_idx, void* buf, bool* is_zip_compressed) const { in ReadDataBlock()
165 int64_t ReadTreeBlock(BlockIdx block_idx, void* buf) const { in ReadTreeBlock()
172 const std::vector<BlockIdx>& PriorityBlocks() const { return priority_blocks_; } in PriorityBlocks()
192 std::vector<BlockIdx> priority_blocks_;
212 BlockIdx overallIndex = 0;
213 BlockIdx overallEnd = 0;
214 BlockIdx priorityIndex = 0;
216 explicit PrefetchState(const File& f, BlockIdx start, int count) in PrefetchState()
219 overallEnd(std::min<BlockIdx>(start + count, f.sentBlocks.size())) {} in PrefetchState()
222 : PrefetchState(f, 0, (BlockIdx)f.sentBlocks.size()) {} in PrefetchState()
229 return overallSent && (priorityIndex >= (BlockIdx)file->PriorityBlocks().size()); in done()
239 SendResult SendDataBlock(FileId fileId, BlockIdx blockIdx, bool flush = false);
241 bool SendTreeBlock(FileId fileId, int32_t fileBlockIdx, BlockIdx blockIdx);
242 bool SendTreeBlocksForDataBlock(FileId fileId, BlockIdx blockIdx);
348 request.block_idx = readBigEndian<BlockIdx>(&commandBuf[4]); in ReadRequest()
352 bool IncrementalServer::SendTreeBlocksForDataBlock(const FileId fileId, const BlockIdx blockIdx) { in SendTreeBlocksForDataBlock()
388 bool IncrementalServer::SendTreeBlock(FileId fileId, int32_t fileBlockIdx, BlockIdx blockIdx) { in SendTreeBlock()
410 auto IncrementalServer::SendDataBlock(FileId fileId, BlockIdx blockIdx, bool flush) -> SendResult { in SendDataBlock()
486 blocksToSend > 0 && i < (BlockIdx)priority_blocks.size(); ++i) { in RunPrefetching()
582 BlockIdx blockIdx = request->block_idx; in Serve()
598 blockIdx >= (BlockIdx)files_[fileId].sentBlocks.size()) { in Serve()