Lines Matching refs:fileId
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);
352 bool IncrementalServer::SendTreeBlocksForDataBlock(const FileId fileId, const BlockIdx blockIdx) { in SendTreeBlocksForDataBlock() argument
353 auto& file = files_[fileId]; in SendTreeBlocksForDataBlock()
369 if (!SendTreeBlock(fileId, blockIdx, leaf_idx)) { in SendTreeBlocksForDataBlock()
380 if (!SendTreeBlock(fileId, blockIdx, i)) { in SendTreeBlocksForDataBlock()
388 bool IncrementalServer::SendTreeBlock(FileId fileId, int32_t fileBlockIdx, BlockIdx blockIdx) { in SendTreeBlock() argument
389 const auto& file = files_[fileId]; in SendTreeBlock()
401 buffer.header.file_id = toBigEndian(fileId); in SendTreeBlock()
410 auto IncrementalServer::SendDataBlock(FileId fileId, BlockIdx blockIdx, bool flush) -> SendResult { in SendDataBlock() argument
411 auto& file = files_[fileId]; in SendDataBlock()
421 if (!SendTreeBlocksForDataBlock(fileId, blockIdx)) { in SendDataBlock()
454 header->file_id = toBigEndian(fileId); in SendDataBlock()
581 FileId fileId = request->file_id; in Serve() local
597 if (fileId < 0 || fileId >= (FileId)files_.size() || blockIdx < 0 || in Serve()
598 blockIdx >= (BlockIdx)files_[fileId].sentBlocks.size()) { in Serve()
602 fileId, blockIdx); in Serve()
607 auto& file = files_[fileId]; in Serve()
611 (int)fileId, (int)blockIdx, in Serve()
618 if (auto res = SendDataBlock(fileId, blockIdx, true); in Serve()
625 prefetches_.emplace_front(files_[fileId], blockIdx + 1, 7); in Serve()
631 if (fileId < 0) { in Serve()
634 fileId); in Serve()
637 if (!prefetchedFiles.insert(fileId).second) { in Serve()
640 fileId); in Serve()
643 D("Received prefetch request for file_id %" PRId16 ".", fileId); in Serve()
644 prefetches_.emplace_back(files_[fileId]); in Serve()
649 request->request_type, fileId, blockIdx); in Serve()