diff options
| author | 2020-03-29 17:11:22 +0000 | |
|---|---|---|
| committer | 2020-03-29 17:11:22 +0000 | |
| commit | 520ae0a35874e35c5228c9b3a35efeecb0591c83 (patch) | |
| tree | 4b728ef6f176a7581917ed631edd242f16638994 /services/incremental/IncrementalService.cpp | |
| parent | 5532c77904352b80c44d0a783532b418f497f74e (diff) | |
| parent | 20d6ef247794ca9d3d09445c644fd29fb474ee32 (diff) | |
Merge "[frameworks] update with incfs.h" into rvc-dev
Diffstat (limited to 'services/incremental/IncrementalService.cpp')
| -rw-r--r-- | services/incremental/IncrementalService.cpp | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/services/incremental/IncrementalService.cpp b/services/incremental/IncrementalService.cpp index ae27c7aabdda..25da8fe4a2e8 100644 --- a/services/incremental/IncrementalService.cpp +++ b/services/incremental/IncrementalService.cpp @@ -157,7 +157,6 @@ std::string makeBindMdName() { IncrementalService::IncFsMount::~IncFsMount() { incrementalService.mDataLoaderManager->destroyDataLoader(mountId); - control.reset(); LOG(INFO) << "Unmounting and cleaning up mount " << mountId << " with root '" << root << '\''; for (auto&& [target, _] : bindPoints) { LOG(INFO) << "\tbind: " << target; @@ -424,9 +423,10 @@ StorageId IncrementalService::createStorage( LOG(ERROR) << "Vold::mountIncFs() returned invalid control parcel."; return kInvalidStorageId; } - control.cmd = controlParcel.cmd.release().release(); - control.pendingReads = controlParcel.pendingReads.release().release(); - control.logs = controlParcel.log.release().release(); + int cmd = controlParcel.cmd.release().release(); + int pendingReads = controlParcel.pendingReads.release().release(); + int logs = controlParcel.log.release().release(); + control = mIncFs->createControl(cmd, pendingReads, logs); } std::unique_lock l(mLock); @@ -965,16 +965,17 @@ bool IncrementalService::mountExistingImage(std::string_view root, std::string_v auto mountTarget = path::join(root, constants().mount); const auto backing = path::join(root, constants().backing); - IncFsMount::Control control; IncrementalFileSystemControlParcel controlParcel; auto status = mVold->mountIncFs(backing, mountTarget, 0, &controlParcel); if (!status.isOk()) { LOG(ERROR) << "Vold::mountIncFs() failed: " << status.toString8(); return false; } - control.cmd = controlParcel.cmd.release().release(); - control.pendingReads = controlParcel.pendingReads.release().release(); - control.logs = controlParcel.log.release().release(); + + int cmd = controlParcel.cmd.release().release(); + int pendingReads = controlParcel.pendingReads.release().release(); + int logs = controlParcel.log.release().release(); + IncFsMount::Control control = mIncFs->createControl(cmd, pendingReads, logs); auto ifs = std::make_shared<IncFsMount>(std::string(root), -1, std::move(control), *this); @@ -1084,10 +1085,10 @@ bool IncrementalService::prepareDataLoader(IncrementalService::IncFsMount& ifs, } FileSystemControlParcel fsControlParcel; fsControlParcel.incremental = aidl::make_nullable<IncrementalFileSystemControlParcel>(); - fsControlParcel.incremental->cmd.reset(base::unique_fd(::dup(ifs.control.cmd))); + fsControlParcel.incremental->cmd.reset(base::unique_fd(::dup(ifs.control.cmd()))); fsControlParcel.incremental->pendingReads.reset( - base::unique_fd(::dup(ifs.control.pendingReads))); - fsControlParcel.incremental->log.reset(base::unique_fd(::dup(ifs.control.logs))); + base::unique_fd(::dup(ifs.control.pendingReads()))); + fsControlParcel.incremental->log.reset(base::unique_fd(::dup(ifs.control.logs()))); sp<IncrementalDataLoaderListener> listener = new IncrementalDataLoaderListener(*this, externalListener ? *externalListener |