Lines Matching refs:control
203 static ProtoMessage parseFromIncfs(const IncFsWrapper* incfs, const Control& control, in parseFromIncfs() argument
205 auto md = incfs->getMetadata(control, path); in parseFromIncfs()
248 control.close(); in ~IncFsMount()
267 if (auto err = incrementalService.mIncFs->makeDir(control, fullName, 0755); !err) { in makeStorage()
486 const auto lastReadError = mIncFs->getLastReadError(ifs->control); in onDump()
527 return mIncFs->isEverythingFullyLoaded(ifs.control) == incfs::LoadingState::MissingBlocks; in needStartDataLoaderLocked()
628 IncFsMount::Control control; in createStorage() local
659 control = mIncFs->createControl(cmd, pendingReads, logs, blocksWritten); in createStorage()
668 std::move(control), *this); in createStorage()
697 mIncFs->makeFile(ifs->control, in createStorage()
759 (void)mIncFs->unlink(ifs->control, storageIt->second.name); in createLinkedStorage()
888 if (auto err = mIncFs->makeFile(ifs->control, in disallowReadLogs()
979 os::incremental::IncrementalFileSystemControlParcel control; in applyStorageParamsLocked() local
980 control.cmd.reset(dup(ifs.control.cmd())); in applyStorageParamsLocked()
981 control.pendingReads.reset(dup(ifs.control.pendingReads())); in applyStorageParamsLocked()
982 auto logsFd = ifs.control.logs(); in applyStorageParamsLocked()
984 control.log.reset(dup(logsFd)); in applyStorageParamsLocked()
991 auto status = mVold->setIncFsMountOptions(control, enableReadLogs, enableReadTimeouts, in applyStorageParamsLocked()
1123 mIncFs->unlink(ifs->control, path::join(ifs->root, constants().mount, savedFile)); in unbind()
1181 if (auto err = mIncFs->makeFile(ifs->control, normPath, mode, id, params); err) { in makeFile()
1187 if (auto err = mIncFs->reserveSpace(ifs->control, id, params.size)) { in makeFile()
1190 (void)mIncFs->unlink(ifs->control, normPath); in makeFile()
1199 (void)mIncFs->unlink(ifs->control, normPath); in makeFile()
1213 return mIncFs->makeDir(ifs->control, normPath, mode); in makeDir()
1232 return mIncFs->makeDirs(ifs.control, normPath, mode); in makeDirs()
1252 if (auto err = mIncFs->link(ifsSrc->control, normOldPath, normNewPath); err < 0) { in link()
1263 return mIncFs->unlink(ifs->control, normOldPath); in unlink()
1289 auto node = mIncFs->makeFile(ifs.control, metadataFullPath, 0444, idFromMetadata(metadata), in addBindMount()
1300 mIncFs->unlink(ifs.control, metadataFullPath); in addBindMount()
1351 return mIncFs->getMetadata(ifs->control, normPath); in getMetadata()
1359 return mIncFs->getMetadata(ifs->control, node); in getMetadata()
1384 if (auto err = mIncFs->setUidReadTimeouts(ifs->control, perUidReadTimeouts); err < 0) { in setUidReadTimeouts()
1404 mIncFs->setUidReadTimeouts(ifs->control, {}); in clearUidReadTimeouts()
1473 auto control = mIncFs->openMount(root); in adoptMountedInstances() local
1474 if (!control) { in adoptMountedInstances()
1480 parseFromIncfs<metadata::Mount>(mIncFs.get(), control, in adoptMountedInstances()
1503 mountId, std::move(control), *this); in adoptMountedInstances()
1520 ifs->control, in adoptMountedInstances()
1526 mIncFs->unlink(ifs->control, path::join(root, name)); in adoptMountedInstances()
1595 mIncFs->unlink(ifs->control, metadataFile); in adoptMountedInstances()
1672 IncFsMount::Control control = mIncFs->createControl(cmd, pendingReads, logs, blocksWritten); in mountExistingImage() local
1675 std::move(control), *this); in mountExistingImage()
1677 auto mount = parseFromIncfs<metadata::Mount>(mIncFs.get(), ifs->control, in mountExistingImage()
1713 ifs->control, in mountExistingImage()
1719 mIncFs->unlink(ifs->control, path::join(ifs->root, constants().mount, name)); in mountExistingImage()
1785 mIncFs->forEachFile(ifs.control, [this](auto&& control, auto&& fileId) { in trimReservedSpaceV1() argument
1786 if (mIncFs->isFileFullyLoaded(control, fileId) == incfs::LoadingState::Full) { in trimReservedSpaceV1()
1787 mIncFs->reserveSpace(control, fileId, -1); in trimReservedSpaceV1()
1799 fsControlParcel.incremental->cmd.reset(dup(ifs.control.cmd())); in prepareDataLoaderLocked()
1800 fsControlParcel.incremental->pendingReads.reset(dup(ifs.control.pendingReads())); in prepareDataLoaderLocked()
1801 fsControlParcel.incremental->log.reset(dup(ifs.control.logs())); in prepareDataLoaderLocked()
1802 if (ifs.control.blocksWritten() >= 0) { in prepareDataLoaderLocked()
1803 fsControlParcel.incremental->blocksWritten.emplace(dup(ifs.control.blocksWritten())); in prepareDataLoaderLocked()
1908 sourceId = mIncFs->getFileId(ifs->control, apkFullPath); in configureNativeBinaries()
1964 if (auto res = mIncFs->makeMappedFile(ifs->control, targetLibPathAbsolute, 0755, in configureNativeBinaries()
1987 if (auto res = mIncFs->makeFile(ifs->control, targetLibPathAbsolute, 0755, libFileId, in configureNativeBinaries()
2121 const auto writeFd = mIncFs->openForSpecialOps(ifs->control, fileId); in setFileContent()
2179 return mIncFs->isFileFullyLoaded(ifs->control, filePath); in isFileFullyLoaded()
2188 return mIncFs->isEverythingFullyLoaded(ifs->control); in isMountFullyLoaded()
2213 mIncFs->countFilledBlocks(ifs.control, filePath); in getLoadingProgressFromPath()
2494 const auto lastReadError = mIncFs->getLastReadError(ifs->control); in getMetrics()
2516 FileSystemControlParcel&& control, DataLoaderStatusListener&& statusListener, in DataLoaderStub() argument
2522 mControl(std::move(control)), in DataLoaderStub()
3022 const auto& control = initializeHealthControl(); in getOldestPendingReadTs() local
3023 if (control.pendingReads() < 0) { in getOldestPendingReadTs()
3027 if (mService.mIncFs->waitForPendingReads(control, 0ms, &mLastPendingReads) != in getOldestPendingReadTs()
3035 LOG(DEBUG) << id() << ": pendingReads: fd(" << control.pendingReads() << "), count(" in getOldestPendingReadTs()
3153 const auto control = mService.mIncFs->openMount(mHealthPath); in onDump() local
3156 const auto metadata = mService.mIncFs->getMetadata(control, pendingRead.id); in onDump()