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

Commit 6620536d authored by Yi Kong's avatar Yi Kong Committed by Automerger Merge Worker
Browse files

Merge "profcollect dex2oat observer" into main am: 1dd991ee 

Original change: https://android-review.googlesource.com/c/platform/frameworks/base/+/2909917



Change-Id: I6eaff211c550f370a2642517a1d1631fa3d00b72
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents d2f3837d 1dd991ee

services/profcollect/Android.bp

+15 −14
Original line number Diff line number Diff line
@@ -41,5 +41,6 @@ java_library_static { 
    name: "services.profcollect",

    defaults: ["platform_service_defaults"],

    srcs: [":services.profcollect-sources"],

  libs: ["services.core"],

    static_libs: ["services.core"],

    libs: ["service-art.stubs.system_server"],

}

services/profcollect/src/com/android/server/profcollect/ProfcollectForwardingService.java

+42 −0
Original line number Diff line number Diff line
@@ -41,12 +41,15 @@ import android.util.Log; 
import com.android.internal.R;

import com.android.internal.os.BackgroundThread;

import com.android.server.IoThread;

import com.android.server.LocalManagerRegistry;

import com.android.server.LocalServices;

import com.android.server.SystemService;

import com.android.server.art.ArtManagerLocal;

import com.android.server.wm.ActivityMetricsLaunchObserver;

import com.android.server.wm.ActivityMetricsLaunchObserverRegistry;

import com.android.server.wm.ActivityTaskManagerInternal;



import java.util.concurrent.ForkJoinPool;

import java.util.concurrent.ThreadLocalRandom;

import java.util.concurrent.TimeUnit;
@@ -261,6 +264,7 @@ public final class ProfcollectForwardingService extends SystemService { 
        BackgroundThread.get().getThreadHandler().post(

                () -> {

                    registerAppLaunchObserver();

                    registerDex2oatObserver();

                    registerOTAObserver();

                });

    }
@@ -304,6 +308,44 @@ public final class ProfcollectForwardingService extends SystemService { 
        }

    }



    private void registerDex2oatObserver() {

        ArtManagerLocal aml = LocalManagerRegistry.getManager(ArtManagerLocal.class);

        if (aml == null) {

            Log.w(LOG_TAG, "Couldn't get ArtManagerLocal");

            return;

        }

        aml.setBatchDexoptStartCallback(ForkJoinPool.commonPool(),

                (snapshot, reason, defaultPackages, builder, passedSignal) -> {

                    traceOnDex2oatStart();

                });

    }



    private void traceOnDex2oatStart() {

        if (mIProfcollect == null) {

            return;

        }

        // Sample for a fraction of dex2oat runs.

        final int traceFrequency =

            DeviceConfig.getInt(DeviceConfig.NAMESPACE_PROFCOLLECT_NATIVE_BOOT,

                "dex2oat_trace_freq", 10);

        int randomNum = ThreadLocalRandom.current().nextInt(100);

        if (randomNum < traceFrequency) {

            if (DEBUG) {

                Log.d(LOG_TAG, "Tracing on dex2oat event");

            }

            BackgroundThread.get().getThreadHandler().post(() -> {

                try {

                    // Dex2oat could take a while before it starts. Add a short delay before start

                    // tracing.

                    Thread.sleep(1000);

                    mIProfcollect.trace_once("dex2oat");

                } catch (RemoteException | InterruptedException e) {

                    Log.e(LOG_TAG, "Failed to initiate trace: " + e.getMessage());

                }

            });

        }

    }



    private void registerOTAObserver() {

        UpdateEngine updateEngine = new UpdateEngine();

        updateEngine.bind(new UpdateEngineCallback() {