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

Commit 8605c215 authored by Alessio Balsini's avatar Alessio Balsini
Browse files

Create puller for storage lifetime information 



This puller generates data for the atom 10239
(AndroidHardwareHealthStorage).

Bug: 407553184
Flag: EXEMPT create atom puller for metrics
Test: statsd_testdrive 10239
Change-Id: I6fdaca9c718e8eed24182c305f06fd1fbda41dfc
Signed-off-by: default avatarAlessio Balsini <balsini@google.com>
parent fb4bcf40

services/core/java/com/android/server/stats/pull/StatsPullAtomService.java

+62 −0
Original line number Diff line number Diff line
@@ -143,6 +143,7 @@ import android.os.Environment; 
import android.os.IStoraged;

import android.os.IThermalEventListener;

import android.os.IThermalService;

import android.os.IVold;

import android.os.OutcomeReceiver;

import android.os.ParcelFileDescriptor;

import android.os.Parcelable;
@@ -417,6 +418,9 @@ public class StatsPullAtomService extends SystemService { 
    @GuardedBy("mHealthHalLock")

    private HealthServiceWrapper mHealthService;



    @GuardedBy("mVoldLock")

    private IVold mVoldService;



    @Nullable

    @GuardedBy("mCpuTimePerThreadFreqLock")

    private KernelCpuThreadReaderDiff mKernelCpuThreadReader;
@@ -521,6 +525,7 @@ public class StatsPullAtomService extends SystemService { 
    private final Object mNotificationRemoteViewsLock = new Object();

    private final Object mDangerousPermissionStateLock = new Object();

    private final Object mHealthHalLock = new Object();

    private final Object mVoldLock = new Object();

    private final Object mAttributedAppOpsLock = new Object();

    private final Object mSettingsStatsLock = new Object();

    private final Object mInstalledIncrementalPackagesLock = new Object();
@@ -811,6 +816,10 @@ public class StatsPullAtomService extends SystemService { 
                        synchronized (mHealthHalLock) {

                            return pullHealthHalLocked(atomTag, data);

                        }

                    case FrameworkStatsLog.STORAGE_HEALTH:

                        synchronized (mVoldLock) {

                            return pullVoldLocked(atomTag, data);

                        }

                    case FrameworkStatsLog.ATTRIBUTED_APP_OPS:

                        synchronized (mAttributedAppOpsLock) {

                            return pullAttributedAppOpsLocked(atomTag, data);
@@ -1042,6 +1051,7 @@ public class StatsPullAtomService extends SystemService { 
        registerBatteryCycleCount();

        registerBatteryHealth();

        registerSettingsStats();

        registerStorageHealth();

        registerInstalledIncrementalPackages();

        registerKeystoreStorageStats();

        registerKeystoreKeyCreationWithGeneralInfo();
@@ -1226,6 +1236,29 @@ public class StatsPullAtomService extends SystemService { 
        return mStorageService;

    }



    @GuardedBy("mVoldLock")

    private IVold getIVoldService() {

        synchronized (mVoldLock) {

            if (mVoldService == null) {

                mVoldService = IVold.Stub.asInterface(

                        ServiceManager.getService("vold"));

            }

            if (mVoldService != null) {

                try {

                    mVoldService.asBinder().linkToDeath(() -> {

                        synchronized (mVoldLock) {

                            mVoldService = null;

                        }

                    }, /* flags */ 0);

                } catch (RemoteException e) {

                    Slog.e(TAG, "linkToDeath with Vold failed", e);

                    mVoldService = null;

                }

            }

        }

        return mVoldService;

    }



    private INotificationManager getINotificationManagerService() {

        synchronized (mNotificationStatsLock) {

            if (mNotificationManagerService == null) {
@@ -4548,6 +4581,35 @@ public class StatsPullAtomService extends SystemService { 
        return StatsManager.PULL_SUCCESS;

    }



    private void registerStorageHealth() {

        int tagId = FrameworkStatsLog.STORAGE_HEALTH;

        mStatsManager.setPullAtomCallback(

                tagId,

                null, // use default PullAtomMetadata values

                DIRECT_EXECUTOR,

                mStatsCallbackImpl);

    }



    @GuardedBy("mVoldLock")

    int pullVoldLocked(int atomTag, List<StatsEvent> pulledData) {

        IVold vold = getIVoldService();

        if (vold == null) {

            Slog.e(TAG, "Failed getting Vold service");

            return StatsManager.PULL_SKIP;

        }



        int remainingLifetime = -1;

        try {

            remainingLifetime = vold.getStorageRemainingLifetime();

        } catch (RemoteException e) {

            Slog.e(TAG, "Failed fetching Vold remaining lifetime");

            return StatsManager.PULL_SKIP;

        }



        pulledData.add(FrameworkStatsLog.buildStatsEvent(atomTag, remainingLifetime));

        return StatsManager.PULL_SUCCESS;

    }



    private void registerSettingsStats() {

        int tagId = FrameworkStatsLog.SETTING_SNAPSHOT;

        mStatsManager.setPullAtomCallback(