• Home
  • Raw
  • Download

Lines Matching refs:fileId

240     SendResult SendDataBlock(FileId fileId, BlockIdx blockIdx, bool flush = false);
242 bool SendTreeBlock(FileId fileId, int32_t fileBlockIdx, BlockIdx blockIdx);
243 bool SendTreeBlocksForDataBlock(FileId fileId, BlockIdx blockIdx);
353 bool IncrementalServer::SendTreeBlocksForDataBlock(const FileId fileId, const BlockIdx blockIdx) { in SendTreeBlocksForDataBlock() argument
354 auto& file = files_[fileId]; in SendTreeBlocksForDataBlock()
370 if (!SendTreeBlock(fileId, blockIdx, leaf_idx)) { in SendTreeBlocksForDataBlock()
381 if (!SendTreeBlock(fileId, blockIdx, i)) { in SendTreeBlocksForDataBlock()
389 bool IncrementalServer::SendTreeBlock(FileId fileId, int32_t fileBlockIdx, BlockIdx blockIdx) { in SendTreeBlock() argument
390 const auto& file = files_[fileId]; in SendTreeBlock()
402 buffer.header.file_id = toBigEndian(fileId); in SendTreeBlock()
411 auto IncrementalServer::SendDataBlock(FileId fileId, BlockIdx blockIdx, bool flush) -> SendResult { in SendDataBlock() argument
412 auto& file = files_[fileId]; in SendDataBlock()
422 if (!SendTreeBlocksForDataBlock(fileId, blockIdx)) { in SendDataBlock()
455 header->file_id = toBigEndian(fileId); in SendDataBlock()
582 FileId fileId = request->file_id; in Serve() local
598 if (fileId < 0 || fileId >= (FileId)files_.size() || blockIdx < 0 || in Serve()
599 blockIdx >= (BlockIdx)files_[fileId].sentBlocks.size()) { in Serve()
603 fileId, blockIdx); in Serve()
608 auto& file = files_[fileId]; in Serve()
612 (int)fileId, (int)blockIdx, in Serve()
619 if (auto res = SendDataBlock(fileId, blockIdx, true); in Serve()
626 prefetches_.emplace_front(files_[fileId], blockIdx + 1, 7); in Serve()
632 if (fileId < 0) { in Serve()
635 fileId); in Serve()
638 if (!prefetchedFiles.insert(fileId).second) { in Serve()
641 fileId); in Serve()
644 D("Received prefetch request for file_id %" PRId16 ".", fileId); in Serve()
645 prefetches_.emplace_back(files_[fileId]); in Serve()
650 request->request_type, fileId, blockIdx); in Serve()