Lines Matching refs:storage

466             for (auto&& [storageId, storage] : mnt.storages) {  in onDump()
469 storage.name.c_str(), in onDump()
470 (int)(getLoadingProgressFromPath(mnt, storage.name.c_str()).getProgress() * in onDump()
479 dprintf(fd, " [%s]->[%d]:\n", target.c_str(), bind.storage); in onDump()
531 dprintf(fd, " [%s]->[%d]:\n", target.c_str(), bind.storage); in onDump()
868 void IncrementalService::onInstallationComplete(StorageId storage) { in onInstallationComplete() argument
869 IfsMountPtr ifs = getIfs(storage); in onInstallationComplete()
891 return it->second->second.storage; in findStorageId()
1063 IncrementalService::IfsMountPtr IncrementalService::getIfs(StorageId storage) const { in getIfs()
1065 return getIfsLocked(storage); in getIfs()
1068 const IncrementalService::IfsMountPtr& IncrementalService::getIfsLocked(StorageId storage) const { in getIfsLocked()
1069 auto it = mMounts.find(storage); in getIfsLocked()
1077 int IncrementalService::bind(StorageId storage, std::string_view source, std::string_view target, in bind() argument
1084 const auto ifs = getIfs(storage); in bind()
1086 LOG(ERROR) << __func__ << ": no ifs object for storage " << storage; in bind()
1091 const auto storageInfo = ifs->storages.find(storage); in bind()
1103 return addBindMount(*ifs, storage, storageInfo->second.name, std::move(normSource), in bind()
1107 int IncrementalService::unbind(StorageId storage, std::string_view target) { in unbind() argument
1112 LOG(INFO) << "Removing bind point " << target << " for storage " << storage; in unbind()
1119 if (storageIt == mBindsByPath.end() || storageIt->second->second.storage != storage) { in unbind()
1123 const auto storageId = bindIt->second.storage; in unbind()
1168 std::string IncrementalService::normalizePathToStorage(const IncFsMount& ifs, StorageId storage, in normalizePathToStorage() argument
1171 const auto storageInfo = ifs.storages.find(storage); in normalizePathToStorage()
1178 int IncrementalService::makeFile(StorageId storage, std::string_view path, int mode, FileId id, in makeFile() argument
1180 const auto ifs = getIfs(storage); in makeFile()
1196 const std::string normPath = normalizePathToStorage(*ifs, storage, path); in makeFile()
1198 LOG(ERROR) << "Internal error: storageId " << storage << " failed to normalize: " << path; in makeFile()
1202 LOG(ERROR) << "Internal error: storageId " << storage << " failed to makeFile [" << normPath in makeFile()
1280 int IncrementalService::unlink(StorageId storage, std::string_view path) { in unlink() argument
1281 if (auto ifs = getIfs(storage)) { in unlink()
1282 std::string normOldPath = normalizePathToStorage(*ifs, storage, path); in unlink()
1288 int IncrementalService::addBindMount(IncFsMount& ifs, StorageId storage, in addBindMount() argument
1301 bp.set_storage_id(storage); in addBindMount()
1317 const auto res = addBindMountWithMd(ifs, storage, std::move(mdFileName), std::move(source), in addBindMount()
1325 int IncrementalService::addBindMountWithMd(IncrementalService::IncFsMount& ifs, StorageId storage, in addBindMountWithMd() argument
1347 addBindMountRecordLocked(ifs, storage, std::move(metadataName), std::move(source), in addBindMountWithMd()
1352 void IncrementalService::addBindMountRecordLocked(IncFsMount& ifs, StorageId storage, in addBindMountRecordLocked() argument
1357 IncFsMount::Bind{storage, std::move(metadataName), in addBindMountRecordLocked()
1362 RawMetadata IncrementalService::getMetadata(StorageId storage, std::string_view path) const { in getMetadata() argument
1363 const auto ifs = getIfs(storage); in getMetadata()
1367 const auto normPath = normalizePathToStorage(*ifs, storage, path); in getMetadata()
1374 RawMetadata IncrementalService::getMetadata(StorageId storage, FileId node) const { in getMetadata() argument
1375 const auto ifs = getIfs(storage); in getMetadata()
1382 void IncrementalService::setUidReadTimeouts(StorageId storage, in setUidReadTimeouts() argument
1398 const auto ifs = getIfs(storage); in setUidReadTimeouts()
1400 LOG(ERROR) << "Setting read timeouts failed: invalid storage id: " << storage; in setUidReadTimeouts()
1410 addIfsStateCallback(storage, [this, timeout](StorageId storageId, IfsState state) -> bool { in setUidReadTimeouts()
1419 void IncrementalService::clearUidReadTimeouts(StorageId storage) { in clearUidReadTimeouts() argument
1420 const auto ifs = getIfs(storage); in clearUidReadTimeouts()
1427 bool IncrementalService::checkUidReadTimeouts(StorageId storage, IfsState state, in checkUidReadTimeouts() argument
1507 auto mountId = mountRecord.storage().id(); in adoptMountedInstances()
1704 ifs->mountId = mount.storage().id(); in mountExistingImage()
1883 bool IncrementalService::configureNativeBinaries(StorageId storage, std::string_view apkFullPath, in configureNativeBinaries() argument
1888 const auto ifs = getIfs(storage); in configureNativeBinaries()
1890 LOG(ERROR) << "Invalid storage " << storage; in configureNativeBinaries()
1895 path::join(path::dirname(normalizePathToStorage(*ifs, storage, apkFullPath)), in configureNativeBinaries()
1899 if (auto res = makeDirs(*ifs, storage, targetLibPathRelativeToStorage, 0755)) { in configureNativeBinaries()
1966 const auto targetLibPathAbsolute = normalizePathToStorage(*ifs, storage, targetLibPath); in configureNativeBinaries()
2107 bool IncrementalService::waitForNativeBinariesExtraction(StorageId storage) { in waitForNativeBinariesExtraction() argument
2121 auto ifs = getIfs(storage); in waitForNativeBinariesExtraction()
2185 incfs::LoadingState IncrementalService::isFileFullyLoaded(StorageId storage, in isFileFullyLoaded() argument
2188 const auto ifs = getIfsLocked(storage); in isFileFullyLoaded()
2190 LOG(ERROR) << "isFileFullyLoaded failed, invalid storageId: " << storage; in isFileFullyLoaded()
2193 const auto storageInfo = ifs->storages.find(storage); in isFileFullyLoaded()
2195 LOG(ERROR) << "isFileFullyLoaded failed, no storage: " << storage; in isFileFullyLoaded()
2202 incfs::LoadingState IncrementalService::isMountFullyLoaded(StorageId storage) const { in isMountFullyLoaded()
2203 const auto ifs = getIfs(storage); in isMountFullyLoaded()
2205 LOG(ERROR) << "isMountFullyLoaded failed, invalid storageId: " << storage; in isMountFullyLoaded()
2212 StorageId storage) const { in getLoadingProgress()
2214 const auto ifs = getIfsLocked(storage); in getLoadingProgress()
2216 LOG(ERROR) << "getLoadingProgress failed, invalid storageId: " << storage; in getLoadingProgress()
2219 const auto storageInfo = ifs->storages.find(storage); in getLoadingProgress()
2221 LOG(ERROR) << "getLoadingProgress failed, no storage: " << storage; in getLoadingProgress()
2254 bool IncrementalService::updateLoadingProgress(StorageId storage, in updateLoadingProgress() argument
2256 const auto progress = getLoadingProgress(storage); in updateLoadingProgress()
2261 progressListener->onStorageLoadingProgressChanged(storage, progress.getProgress()); in updateLoadingProgress()
2266 addTimedJob(*mProgressUpdateJobQueue, storage, in updateLoadingProgress()
2268 [storage, progressListener = std::move(progressListener), this]() mutable { in updateLoadingProgress()
2269 updateLoadingProgress(storage, std::move(progressListener)); in updateLoadingProgress()
2275 StorageId storage, StorageLoadingProgressListener progressListener) { in registerLoadingProgressListener() argument
2276 return updateLoadingProgress(storage, std::move(progressListener)); in registerLoadingProgressListener()
2279 bool IncrementalService::unregisterLoadingProgressListener(StorageId storage) { in unregisterLoadingProgressListener() argument
2280 return removeTimedJobs(*mProgressUpdateJobQueue, storage); in unregisterLoadingProgressListener()
3207 *_aidl_return = incrementalService.setStorageParams(storage, enableReadLogs); in setStorageParams()