Merge "libbinder: RPC delay bp refcounts" am: 692ae86f am: a212c1dd am:...

status_t RpcState::flushExcessBinderRefs(const sp<RpcSession>& session, uint64_t address,

                                         const sp<IBinder>& binder) {

    // We can flush all references when the binder is destroyed. No need to send

    // extra reference counting packets now.

    if (binder->remoteBinder()) return OK;

    std::unique_lock<std::mutex> _l(mNodeMutex);

    if (mTerminated) return DEAD_OBJECT;

    LOG_ALWAYS_FATAL_IF(it->second.binder != binder,

                        "Caller of flushExcessBinderRefs using inconsistent arguments");

    // if this is a local binder, then we want to get rid of all refcounts

    // (tell the other process it can drop the binder when it wants to - we

    // have a local sp<>, so we will drop it when we want to as well). if

    // this is a remote binder, then we need to hold onto one refcount until

    // it is dropped in BpBinder::onLastStrongRef

    size_t targetRecd = binder->localBinder() ? 0 : 1;

    // We have timesRecd RPC refcounts, but we only need to hold on to one

    // when we keep the object. All additional dec strongs are sent

    // immediately, we wait to send the last one in BpBinder::onLastDecStrong.

    if (it->second.timesRecd != targetRecd) {

    LOG_ALWAYS_FATAL_IF(it->second.timesSent <= 0, "Local binder must have been sent %p",

                        binder.get());

    // For a local binder, we only need to know that we sent it. Now that we

    // have an sp<> for this call, we don't need anything more. If the other

    // process is done with this binder, it needs to know we received the

    // refcount associated with this call, so we can acknowledge that we

    // received it. Once (or if) it has no other refcounts, it would reply with

    // its own decStrong so that it could be removed from this session.

    if (it->second.timesRecd != 0) {

        _l.unlock();

        return session->sendDecStrongToTarget(address, targetRecd);

        return session->sendDecStrongToTarget(address, 0);

    }

    return OK;