Lines Matching refs:control
208 static ProtoMessage parseFromIncfs(const IncFsWrapper* incfs, const Control& control, in parseFromIncfs() argument
210 auto md = incfs->getMetadata(control, path); in parseFromIncfs()
253 control.close(); in ~IncFsMount()
272 if (auto err = incrementalService.mIncFs->makeDir(control, fullName, 0755); !err) { in makeStorage()
472 ifs ? loadingStateToString(mIncFs->isEverythingFullyLoaded(ifs->control)) in onDump()
506 const auto lastReadError = mIncFs->getLastReadError(ifs->control); in onDump()
547 return mIncFs->isEverythingFullyLoaded(ifs.control) == incfs::LoadingState::MissingBlocks; in needStartDataLoaderLocked()
648 IncFsMount::Control control; in createStorage() local
679 control = mIncFs->createControl(cmd, pendingReads, logs, blocksWritten); in createStorage()
688 std::move(control), *this); in createStorage()
717 mIncFs->makeFile(ifs->control, in createStorage()
779 (void)mIncFs->unlink(ifs->control, storageIt->second.name); in createLinkedStorage()
908 if (auto err = mIncFs->makeFile(ifs->control, in disallowReadLogs()
999 os::incremental::IncrementalFileSystemControlParcel control; in applyStorageParamsLocked() local
1000 control.cmd.reset(dup(ifs.control.cmd())); in applyStorageParamsLocked()
1001 control.pendingReads.reset(dup(ifs.control.pendingReads())); in applyStorageParamsLocked()
1002 auto logsFd = ifs.control.logs(); in applyStorageParamsLocked()
1004 control.log.reset(dup(logsFd)); in applyStorageParamsLocked()
1011 auto status = mVold->setIncFsMountOptions(control, enableReadLogs, enableReadTimeouts, in applyStorageParamsLocked()
1143 mIncFs->unlink(ifs->control, path::join(ifs->root, constants().mount, savedFile)); in unbind()
1201 if (auto err = mIncFs->makeFile(ifs->control, normPath, mode, id, params); err) { in makeFile()
1207 if (auto err = mIncFs->reserveSpace(ifs->control, id, params.size)) { in makeFile()
1210 (void)mIncFs->unlink(ifs->control, normPath); in makeFile()
1219 (void)mIncFs->unlink(ifs->control, normPath); in makeFile()
1233 return mIncFs->makeDir(ifs->control, normPath, mode); in makeDir()
1252 return mIncFs->makeDirs(ifs.control, normPath, mode); in makeDirs()
1272 if (auto err = mIncFs->link(ifsSrc->control, normOldPath, normNewPath); err < 0) { in link()
1283 return mIncFs->unlink(ifs->control, normOldPath); in unlink()
1309 auto node = mIncFs->makeFile(ifs.control, metadataFullPath, 0444, idFromMetadata(metadata), in addBindMount()
1320 mIncFs->unlink(ifs.control, metadataFullPath); in addBindMount()
1371 return mIncFs->getMetadata(ifs->control, normPath); in getMetadata()
1379 return mIncFs->getMetadata(ifs->control, node); in getMetadata()
1404 if (auto err = mIncFs->setUidReadTimeouts(ifs->control, perUidReadTimeouts); err < 0) { in setUidReadTimeouts()
1424 mIncFs->setUidReadTimeouts(ifs->control, {}); in clearUidReadTimeouts()
1493 auto control = mIncFs->openMount(root); in adoptMountedInstances() local
1494 if (!control) { in adoptMountedInstances()
1500 parseFromIncfs<metadata::Mount>(mIncFs.get(), control, in adoptMountedInstances()
1523 mountId, std::move(control), *this); in adoptMountedInstances()
1540 ifs->control, in adoptMountedInstances()
1546 mIncFs->unlink(ifs->control, path::join(root, name)); in adoptMountedInstances()
1615 mIncFs->unlink(ifs->control, metadataFile); in adoptMountedInstances()
1692 IncFsMount::Control control = mIncFs->createControl(cmd, pendingReads, logs, blocksWritten); in mountExistingImage() local
1695 std::move(control), *this); in mountExistingImage()
1697 auto mount = parseFromIncfs<metadata::Mount>(mIncFs.get(), ifs->control, in mountExistingImage()
1733 ifs->control, in mountExistingImage()
1739 mIncFs->unlink(ifs->control, path::join(ifs->root, constants().mount, name)); in mountExistingImage()
1805 mIncFs->forEachFile(ifs.control, [this](auto&& control, auto&& fileId) { in trimReservedSpaceV1() argument
1806 if (mIncFs->isFileFullyLoaded(control, fileId) == incfs::LoadingState::Full) { in trimReservedSpaceV1()
1807 mIncFs->reserveSpace(control, fileId, -1); in trimReservedSpaceV1()
1819 fsControlParcel.incremental->cmd.reset(dup(ifs.control.cmd())); in prepareDataLoaderLocked()
1820 fsControlParcel.incremental->pendingReads.reset(dup(ifs.control.pendingReads())); in prepareDataLoaderLocked()
1821 fsControlParcel.incremental->log.reset(dup(ifs.control.logs())); in prepareDataLoaderLocked()
1822 if (ifs.control.blocksWritten() >= 0) { in prepareDataLoaderLocked()
1823 fsControlParcel.incremental->blocksWritten.emplace(dup(ifs.control.blocksWritten())); in prepareDataLoaderLocked()
1928 sourceId = mIncFs->getFileId(ifs->control, apkFullPath); in configureNativeBinaries()
1984 if (auto res = mIncFs->makeMappedFile(ifs->control, targetLibPathAbsolute, 0755, in configureNativeBinaries()
2007 if (auto res = mIncFs->makeFile(ifs->control, targetLibPathAbsolute, 0755, libFileId, in configureNativeBinaries()
2141 const auto writeFd = mIncFs->openForSpecialOps(ifs->control, fileId); in setFileContent()
2199 return mIncFs->isFileFullyLoaded(ifs->control, filePath); in isFileFullyLoaded()
2208 return mIncFs->isEverythingFullyLoaded(ifs->control); in isMountFullyLoaded()
2233 mIncFs->countFilledBlocks(ifs.control, filePath); in getLoadingProgressFromPath()
2514 const auto lastReadError = mIncFs->getLastReadError(ifs->control); in getMetrics()
2536 FileSystemControlParcel&& control, DataLoaderStatusListener&& statusListener, in DataLoaderStub() argument
2542 mControl(std::move(control)), in DataLoaderStub()
3048 const auto& control = initializeHealthControl(); in getOldestPendingReadTs() local
3049 if (control.pendingReads() < 0) { in getOldestPendingReadTs()
3053 if (mService.mIncFs->waitForPendingReads(control, 0ms, &mLastPendingReads) != in getOldestPendingReadTs()
3061 LOG(DEBUG) << id() << ": pendingReads: fd(" << control.pendingReads() << "), count(" in getOldestPendingReadTs()
3179 const auto control = mService.mIncFs->openMount(mHealthPath); in onDump() local
3182 const auto metadata = mService.mIncFs->getMetadata(control, pendingRead.id); in onDump()