Searched refs:pendingReads (Results 1 – 11 of 11) sorted by relevance
| /system/incremental_delivery/incfs/ |
| D | incfs.cpp | 62 IncFsFd pendingReads; member
64 constexpr IncFsControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs) in IncFsControl()
65 : cmd(cmd), pendingReads(pendingReads), logs(logs) {} in IncFsControl()
311 unique_fd pendingReads(fcntl(cmd.get(), F_DUPFD_CLOEXEC, cmd.get())); in makeControl() local
312 if (!pendingReads.ok()) { in makeControl()
317 auto control = IncFs_CreateControl(cmd.get(), pendingReads.get(), logs.get()); in makeControl()
320 (void)pendingReads.release(); in makeControl()
490 return control->pendingReads; in IncFs_GetControlFd()
506 out[PENDING_READS] = std::exchange(control->pendingReads, -1); in IncFs_ReleaseControlFds()
511 IncFsControl* IncFs_CreateControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs) { in IncFs_CreateControl() argument
[all …]
|
| /system/incremental_delivery/libdataloader/ |
| D | DataLoaderConnector.cpp | 248 std::vector<ReadInfo> pendingReads; member
378 int onPendingReadsLooperEvent(std::vector<ReadInfo>& pendingReads) { in onPendingReadsLooperEvent() argument
382 pendingReads.resize(kPendingReadsBufferSize); in onPendingReadsLooperEvent()
383 if (android::incfs::waitForPendingReads(mControl, 0ms, &pendingReads) != in onPendingReadsLooperEvent()
385 pendingReads.empty()) { in onPendingReadsLooperEvent()
388 mDataLoader->onPendingReads(mDataLoader, pendingReads.data(), pendingReads.size()); in onPendingReadsLooperEvent()
491 return dataLoaderConnector->onPendingReadsLooperEvent(globals().pendingReads); in onPendingReadsLooperEvent()
668 ALOGI("DataLoader::create1 pendingReads: %d|%s", nativeControl.pendingReads(), in DataLoaderService_OnCreate()
669 pathFromFd(nativeControl.pendingReads()).c_str()); in DataLoaderService_OnCreate()
751 if (control->pendingReads() >= 0 && !globals().pendingReadsLooperThread.joinable()) { in DataLoaderService_OnStart()
[all …]
|
| D | ManagedDataLoader.h | 39 void onPendingReads(PendingReads pendingReads) final {} in onPendingReads()
|
| /system/incremental_delivery/libdataloader/include/ |
| D | dataloader_inline.h | 41 onPendingReads = [](DataLoader* self, const IncFsReadInfo pendingReads[], in DataLoaderImpl()
44 PendingReads(pendingReads, pendingReadsCount)); in DataLoaderImpl()
|
| D | dataloader_ndk.h | 91 void (*onPendingReads)(struct DataLoader* self, const IncFsReadInfo pendingReads[],
|
| D | dataloader.h | 73 virtual void onPendingReads(PendingReads pendingReads) = 0;
|
| /system/incremental_delivery/incfs/include/ |
| D | incfs_inline.h | 107 inline IncFsFd UniqueControl::pendingReads() const { in pendingReads() function
136 inline UniqueControl createControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs) { in createControl() argument
137 return UniqueControl(IncFs_CreateControl(cmd, pendingReads, logs)); in createControl()
|
| D | incfs.h | 98 IncFsFd pendingReads() const;
199 UniqueControl createControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs);
|
| D | incfs_ndk.h | 157 IncFsControl* IncFs_CreateControl(IncFsFd cmd, IncFsFd pendingReads, IncFsFd logs);
|
| /system/incremental_delivery/incfs/tests/ |
| D | incfs_test.cpp | 65 ASSERT_TRUE(control_.pendingReads() >= 0); in SetUp()
313 ASSERT_TRUE(control.pendingReads() >= 0); in TEST_F()
321 ASSERT_TRUE(control.pendingReads() < 0); in TEST_F()
|
| /system/vold/ |
| D | VoldNativeService.cpp | 874 _aidl_return->pendingReads.emplace(unique_fd(dup(IncFs_GetControlFd(control, PENDING_READS)))); in mountIncFs()
|