| /aosp12/system/incremental_delivery/libdataloader/ |
| H A D | DataLoaderConnector.cpp | 261 std::vector<ReadInfo> pendingReads; member
421 int onPendingReadsLooperEvent(std::vector<ReadInfoType>& pendingReads) { in onPendingReadsLooperEvent() argument
425 pendingReads.resize(kPendingReadsBufferSize); in onPendingReadsLooperEvent()
428 pendingReads.empty()) { in onPendingReadsLooperEvent()
434 pendingReads.size()); in onPendingReadsLooperEvent()
439 pendingReads.size()); in onPendingReadsLooperEvent()
471 int onPendingReadsLooperEvent(std::vector<ReadInfo>& pendingReads, in onPendingReadsLooperEvent() argument
477 return this->onPendingReadsLooperEvent(pendingReads); in onPendingReadsLooperEvent()
854 if (control->pendingReads() >= 0) { in DataLoaderService_OnStart()
891 if (control->pendingReads() >= 0) { in DataLoaderService_OnStop_NoStatus()
[all …]
|
| H A D | ManagedDataLoader.h | 32 void (*onPendingReads)(struct LegacyDataLoader* self, const IncFsReadInfo pendingReads[],
|
| /aosp12/system/incremental_delivery/libdataloader/include/ |
| H A D | dataloader_inline.h | 44 onPendingReads = [](DataLoader* self, const IncFsReadInfo pendingReads[], in DataLoaderImpl()
47 PendingReads(pendingReads, pendingReadsCount)); in DataLoaderImpl()
53 onPendingReadsWithUid = [](DataLoader* self, const IncFsReadInfoWithUid pendingReads[], in DataLoaderImpl()
56 PendingReadsWithUid(pendingReads, pendingReadsCount)); in DataLoaderImpl()
|
| H A D | dataloader_ndk.h | 94 void (*onPendingReads)(struct DataLoader* self, const IncFsReadInfo pendingReads[],
104 const IncFsReadInfoWithUid pendingReads[], int pendingReadsCount);
|
| H A D | dataloader.h | 80 virtual void onPendingReads(PendingReads pendingReads) = 0;
83 virtual void onPendingReadsWithUid(PageReadsWithUid pendingReads) = 0;
|
| /aosp12/system/incremental_delivery/incfs/ |
| H A D | incfs.cpp | 64 IncFsFd pendingReads; member
68 : cmd(cmd), pendingReads(pendingReads), logs(logs), blocksWritten(blocksWritten) {} in IncFsControl()
404 if (!pendingReads.ok()) { in makeControl()
422 (void)pendingReads.release(); in makeControl()
621 return control->pendingReads; in IncFs_GetControlFd()
639 out[PENDING_READS] = std::exchange(control->pendingReads, -1); in IncFs_ReleaseControlFds()
655 if (control->pendingReads >= 0) { in IncFs_DeleteControl()
656 close(control->pendingReads); in IncFs_DeleteControl()
1200 std::vector<RawPendingRead> pendingReads(*bufferSize); in waitForReads() local
1221 if (!control || control->pendingReads < 0) { in IncFs_WaitForPendingReads()
[all …]
|
| /aosp12/frameworks/base/core/java/android/os/incremental/ |
| H A D | IncrementalFileSystemControlParcel.aidl | 26 ParcelFileDescriptor pendingReads;
|
| /aosp12/frameworks/base/services/incremental/ |
| H A D | IncrementalService.cpp | 649 if (controlParcel.cmd.get() < 0 || controlParcel.pendingReads.get() < 0 || in createStorage()
655 int pendingReads = controlParcel.pendingReads.release().release(); in createStorage() local
659 control = mIncFs->createControl(cmd, pendingReads, logs, blocksWritten); in createStorage()
981 control.pendingReads.reset(dup(ifs.control.pendingReads())); in applyStorageParamsLocked()
1668 int pendingReads = controlParcel.pendingReads.release().release(); in mountExistingImage() local
1800 fsControlParcel.incremental->pendingReads.reset(dup(ifs.control.pendingReads())); in prepareDataLoaderLocked()
3004 if (mHealthControl.pendingReads() < 0) { in initializeHealthControl()
3007 if (mHealthControl.pendingReads() < 0) { in initializeHealthControl()
3023 if (control.pendingReads() < 0) { in getOldestPendingReadTs()
3044 const auto pendingReadsFd = mHealthControl.pendingReads(); in registerForPendingReads()
[all …]
|
| H A D | ServiceWrappers.cpp | 156 Control createControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs, in createControl() argument
158 return incfs::createControl(cmd, pendingReads, logs, blocksWritten); in createControl()
|
| H A D | ServiceWrappers.h | 98 virtual Control createControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs,
|
| /aosp12/system/incremental_delivery/incfs/include/ |
| H A D | incfs_inline.h | 111 inline IncFsFd UniqueControl::pendingReads() const { in pendingReads() function
144 inline UniqueControl createControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs, in createControl() argument
146 return UniqueControl(IncFs_CreateControl(cmd, pendingReads, logs, blocksWritten)); in createControl()
|
| H A D | incfs.h | 102 IncFsFd pendingReads() const;
215 UniqueControl createControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs, IncFsFd blocksWritten);
|
| H A D | incfs_ndk.h | 215 IncFsControl* IncFs_CreateControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs,
|
| /aosp12/system/incremental_delivery/incfs/tests/include/ |
| H A D | IncFsTestBase.h | 51 ASSERT_TRUE(control_.pendingReads() >= 0); in SetUp()
|
| /aosp12/frameworks/base/core/java/android/service/dataloader/ |
| H A D | DataLoaderService.java | 150 IoUtils.closeQuietly(control.incremental.pendingReads); in create()
|
| /aosp12/frameworks/base/services/core/jni/ |
| H A D | com_android_server_pm_PackageManagerShellCommandDataLoader.cpp | 655 void onPendingReads(dataloader::PendingReads pendingReads) final {} in onPendingReads() argument
658 void onPendingReadsWithUid(dataloader::PendingReadsWithUid pendingReads) final { in onPendingReadsWithUid() argument
664 for (auto&& pendingRead : pendingReads) { in onPendingReadsWithUid()
|
| /aosp12/system/vold/ |
| H A D | VoldNativeService.cpp | 1027 _aidl_return->pendingReads.reset(unique_fd(fds[PENDING_READS].release())); in mountIncFs()
1054 incfs::createControl(control.cmd.get(), control.pendingReads.get(), control.log.get(), in setIncFsMountOptions()
|
| /aosp12/system/incremental_delivery/incfs/tests/ |
| H A D | incfs_test.cpp | 338 ASSERT_TRUE(control.pendingReads() >= 0); in TEST_F()
346 ASSERT_TRUE(control.pendingReads() < 0); in TEST_F()
|
| /aosp12/frameworks/base/services/incremental/test/ |
| H A D | IncrementalServiceTest.cpp | 104 _aidl_return->pendingReads.reset(base::unique_fd(dup(STDIN_FILENO))); in incFsSuccess()
383 Control(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs,
|