[097]SurfaceSyncGroup的细节

王小二

发布于 2024-05-11 09:40:52

520

发布于 2024-05-11 09:40:52

文章被收录于专栏：王小二的Android站王小二的Android站

背景

最近在看SurfaceSyncGroup，很多代码还是很好理解的，但是其中有几处细节，可能你看的时候没有注意。因为这个SurfaceSyncGroup名字太长，我后面都会使用SSG缩写代替。

一、跨进程使用SSG，无法支持Child SSG添加Child SSG

如果你看过代码，你应该可以发现，如果你在同一进程中使用SSG，其实是可以如下操作的。

但是如果跨进程使用，那就要注意了，可能就会有问题了，你以为你创建的是这样子关系

其实你创建的关系和你预期的不一样。

代码分析1.1

    public boolean add(ISurfaceSyncGroup surfaceSyncGroup, boolean parentSyncGroupMerge,
            @Nullable Runnable runnable) {
        //1.1如果添加的surfaceSyncGroup和当前SurfaceSyncGroup不是同一进程，就是false。
        if (isLocalBinder(surfaceSyncGroup.asBinder())) {
            boolean didAddLocalSync = addLocalSync(surfaceSyncGroup, parentSyncGroupMerge);
            if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
            }
            return didAddLocalSync;
        }

        synchronized (mLock) {
            if (!mHasWMSync) {
                // We need to add a signal into WMS since WMS will be creating a new parent
                // SurfaceSyncGroup. When the parent SSG in WMS completes, only then do we
                // notify the registered listeners that the entire SurfaceSyncGroup is complete.
                // This is because the callers don't realize that when adding a different process
                // to this SSG, it isn't actually adding to this SSG and really just creating a
                // link in WMS. Because of this, the callers would expect the complete listeners
                // to only be called when everything, including the other process's
                // SurfaceSyncGroups, have completed. Only WMS has that info so we need to send the
                // listener to WMS when we set up a server side sync.
                mSurfaceSyncGroupCompletedListener = new ISurfaceSyncGroupCompletedListener.Stub() {
                    @Override
                    public void onSurfaceSyncGroupComplete() {
                        synchronized (mLock) {
                            invokeSyncCompleteCallbacks();
                        }
                    }
                };
                // 1.1.2 然后用自己的token在WM中创建一个替身
                if (!addSyncToWm(mToken, false /* parentSyncGroupMerge */,
                        mSurfaceSyncGroupCompletedListener)) {//跳转到代码分析1.2
                    mSurfaceSyncGroupCompletedListener = null;
                    if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                        Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
                    }
                    return false;
                }
                mHasWMSync = true;
            }
        }

        try {
             // 1.1.3 将token传递给子ssg，然后让子的ssg和你的替身建立关系
            surfaceSyncGroup.onAddedToSyncGroup(mToken, parentSyncGroupMerge);
        } catch (RemoteException e) {
            if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
            }
            return false;
        }

        if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
            Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
        }
        return true;
    }

1.1.1 如果添加的surfaceSyncGroup和当前SurfaceSyncGroup不是同一进程，就是false。 1.1.2 然后用自己的token在WM中创建一个替身ssg 1.1.3 将token传递给子ssg，然后让子的ssg和你的替身建立关系

代码分析1.2

当SSG1调用add(SSG2)的时候，SSG1和SSG2都会触发这个函数。 1.2.1 将自己和WM中的替身建立起关系。如果是SSG1，也就意味着和之前Root SSG建立的关系也就断开了。

    private boolean addSyncToWm(IBinder token, boolean parentSyncGroupMerge,
            @Nullable ISurfaceSyncGroupCompletedListener surfaceSyncGroupCompletedListener) {
        try {
            if (DEBUG) {
                Log.d(TAG, "Attempting to add remote sync to " + mName
                        + ". Setting up Sync in WindowManager.");
            }
            if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                Trace.asyncTraceForTrackBegin(Trace.TRACE_TAG_VIEW, mTrackName,
                        "addSyncToWm=" + token.hashCode(), hashCode());
            }
            AddToSurfaceSyncGroupResult addToSyncGroupResult = new AddToSurfaceSyncGroupResult();
            if (!WindowManagerGlobal.getWindowManagerService().addToSurfaceSyncGroup(token,
                    parentSyncGroupMerge, surfaceSyncGroupCompletedListener,
                    addToSyncGroupResult)) {
                if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                    Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
                }
                return false;
            }
           //1.2.1 将自己和WM中的替身建立起关系。如果是SSG1，也就意味着和之前Root SSG建立的关系也就断开了。
            setTransactionCallbackFromParent(addToSyncGroupResult.mParentSyncGroup,
                    addToSyncGroupResult.mTransactionReadyCallback);
        } catch (RemoteException e) {
            if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
            }
            return false;
        }
        if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
            Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
        }
        return true;
    }

最终的结果如下图

当SSG1添加到Root SSG的时候，一切还算正常但是当SSG2添加到SSG1的时候，意外就发生了，Root SSG和SSG1就断开了连接。

二、如果SSG1添加到Root SSG之后，将SSG1添加到 SSG2，会发生什么

代码分析2.1

private void setTransactionCallbackFromParent(ISurfaceSyncGroup parentSyncGroup,
            ITransactionReadyCallback transactionReadyCallback) {
        ...
        synchronized (mLock) {
            if (mFinished) {
                finished = true;
            } else {
                // If this SurfaceSyncGroup was already added to a different SurfaceSyncGroup, we
                // need to combine everything. We can add the old SurfaceSyncGroup parent to the new
                // parent so the new parent doesn't complete until the old parent does.
                // Additionally, the old parent will not get the final transaction object and
                // instead will send it to the new parent, ensuring that any other SurfaceSyncGroups
                // from the original parent are also combined with the new parent SurfaceSyncGroup.
                // 2.1.1 如果发现SSG1有parent SSG了， 就将parent ssg（Root SSG）添加到SSG2
                if (mParentSyncGroup != null && mParentSyncGroup != parentSyncGroup) {
                    if (DEBUG) {
                        Log.d(TAG, "Trying to add to " + parentSyncGroup
                                + " but already part of sync group " + mParentSyncGroup + " "
                                + mName);
                    }
                    try {
                        //最终会跳转到代码分析 2.2
                        parentSyncGroup.addToSync(mParentSyncGroup,
                                true /* parentSyncGroupMerge */);
                    } catch (RemoteException e) {
                    }
                }

                if (DEBUG && mParentSyncGroup == parentSyncGroup) {
                    Log.d(TAG, "Added to parent that was already the parent");
                }

                // 2.1.2 保存前一个parent ssg（Root SSG）的callback。
                Consumer<Transaction> lastCallback = mTransactionReadyConsumer;
                // 2.1.3 将parent ssg 换成 SSG2
                mParentSyncGroup = parentSyncGroup;
                mTransactionReadyConsumer = (transaction) -> {
                    if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                        Trace.asyncTraceForTrackBegin(Trace.TRACE_TAG_VIEW, mTrackName,
                                "Invoke transactionReadyCallback="
                                        + transactionReadyCallback.hashCode(), hashCode());
                    }
                    // 2.1.4 在SSG1完成任务的时候，虽然SSG1和Root SSG没有名义上的关系了，但是残留在Root SSG mPendingSyncs中SSG1的callback还是要触发一下的，否则会导致Root SSG无法ready。
                    lastCallback.accept(null);

                    try {
                        transactionReadyCallback.onTransactionReady(transaction);
                    } catch (RemoteException e) {
                        transaction.apply();
                    }
                    if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                        Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
                    }
                };
                addedToSyncListener = mAddedToSyncListener;
            }
        }

        // Invoke the callback outside of the lock when the SurfaceSyncGroup being added was already
        // complete.
        if (finished) {
            try {
                transactionReadyCallback.onTransactionReady(null);
            } catch (RemoteException e) {
            }
        } else if (addedToSyncListener != null) {
            addedToSyncListener.run();
        }
        if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
            Trace.asyncTraceForTrackEnd(Trace.TRACE_TAG_VIEW, mTrackName, hashCode());
        }
    }

2.1.1 如果发现SSG1有parent SSG了，就将parent ssg（Root SSG）添加到SSG2 2.1.2 保存前一个parent ssg（Root SSG）的callback。 2.1.3 将parent ssg 换成 SSG2 2.1.4 在SSG1完成任务的时候，虽然SSG1和Root SSG没有名义上的关系了，但是残留在Root SSG mPendingSyncs中SSG1的callback还是要触发一下的，否则会导致Root SSG无法ready。

代码分析 2.2

代码分析2.1中parentSyncGroup.addToSync(mParentSyncGroup, true /* parentSyncGroupMerge */)最终会跳转到这里，关键的就是parentSyncGroupMerge为true

    public ITransactionReadyCallback createTransactionReadyCallback(boolean parentSyncGroupMerge) {
        ITransactionReadyCallback transactionReadyCallback =
                new ITransactionReadyCallback.Stub() {
                    @Override
                    public void onTransactionReady(Transaction t) {
                        synchronized (mLock) {
                            if (t != null) {
                                t.sanitize(Binder.getCallingPid(), Binder.getCallingUid());
                                // When an older parent sync group is added due to a child syncGroup
                                // getting added to multiple groups, we need to maintain merge order
                                // so the older parentSyncGroup transactions are overwritten by
                                // anything in the newer parentSyncGroup.
                                // 2.2.1 这里解释了如果为true，为了保证merge的顺序，有一些处理。
                                if (parentSyncGroupMerge) {
                                    t.merge(mTransaction);
                                }
                                mTransaction.merge(t);//p add c
                            }
                            mPendingSyncs.remove(this);
                            if (Trace.isTagEnabled(Trace.TRACE_TAG_VIEW)) {
                                Trace.instantForTrack(Trace.TRACE_TAG_VIEW, mTrackName,
                                        "onTransactionReady callback=" + hashCode());
                            }
                            checkIfSyncIsComplete();
                        }
                    }
                };
        return transactionReadyCallback;
    }

2.2.1 这里解释了如果为true，为了保证merge的顺序，有一些处理，用一个图来表示，就是如下图。