Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 749a73ff authored by Arun Johnson's avatar Arun Johnson
Browse files

Codec2: Detect and release component if the client process terminates

Attach death-notifier to listen to the client process termination
from the HAL process (specifically, register death-recipient with
the remote ComponentListener object).
Invoke release() on component to clean-up the resources gracefully
on client's death.
This avoids race conditions that may result from the listener's
context holding the last-strong-reference and trying to destruct
the component from within one of it's own calling contexts.
( Eg: Component destructor invoked from onWorkDone(..) )

Test: presubmit
Bug: 219653800

Change-Id: I159c16cab4e20dd30fb3b5d4eb543bb24d2bf064
parent 6a7c4290
Loading
Loading
Loading
Loading
+31 −0
Original line number Original line Diff line number Diff line
@@ -520,6 +520,37 @@ void Component::initListener(const sp<Component>& self) {
    if (res != C2_OK) {
    if (res != C2_OK) {
        mInit = res;
        mInit = res;
    }
    }

    struct ListenerDeathRecipient : public HwDeathRecipient {
        ListenerDeathRecipient(const wp<Component>& comp)
            : component{comp} {
        }

        virtual void serviceDied(
                uint64_t /* cookie */,
                const wp<::android::hidl::base::V1_0::IBase>& /* who */
                ) override {
            auto strongComponent = component.promote();
            if (strongComponent) {
                LOG(INFO) << "Client died ! release the component !!";
                strongComponent->release();
            } else {
                LOG(ERROR) << "Client died ! no component to release !!";
            }
        }

        wp<Component> component;
    };

    mDeathRecipient = new ListenerDeathRecipient(self);
    Return<bool> transStatus = mListener->linkToDeath(
            mDeathRecipient, 0);
    if (!transStatus.isOk()) {
        LOG(ERROR) << "Listener linkToDeath() transaction failed.";
    }
    if (!static_cast<bool>(transStatus)) {
        LOG(DEBUG) << "Listener linkToDeath() call failed.";
    }
}
}


Component::~Component() {
Component::~Component() {
+4 −0
Original line number Original line Diff line number Diff line
@@ -142,6 +142,10 @@ protected:
    friend struct ComponentStore;
    friend struct ComponentStore;


    struct Listener;
    struct Listener;

    using HwDeathRecipient = ::android::hardware::hidl_death_recipient;
    sp<HwDeathRecipient> mDeathRecipient;

};
};


} // namespace utils
} // namespace utils