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

Commit 3e873dba authored by TreeHugger Robot's avatar TreeHugger Robot Committed by Automerger Merge Worker
Browse files

Merge "Fix concurrency logging." into udc-dev am: 13c49d38 

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



Change-Id: Ib8d1085a53d9c4be683e88cf98f3d726670eee3e
Signed-off-by: default avatarAutomerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
parents a6d1e166 13c49d38

apex/jobscheduler/service/java/com/android/server/job/JobConcurrencyManager.java

+14 −6
Original line number Diff line number Diff line
@@ -810,7 +810,7 @@ class JobConcurrencyManager { 
                mRecycledChanged, mRecycledIdle, mRecycledPreferredUidOnly, mRecycledStoppable,

                mRecycledAssignmentInfo, mRecycledPrivilegedState);



        noteConcurrency();

        noteConcurrency(true);

    }



    @VisibleForTesting
@@ -1437,12 +1437,14 @@ class JobConcurrencyManager { 
        }

    }



    private void noteConcurrency() {

    private void noteConcurrency(boolean logForHistogram) {

        mService.mJobPackageTracker.noteConcurrency(mRunningJobs.size(),

                // TODO: log per type instead of only TOP

                mWorkCountTracker.getRunningJobCount(WORK_TYPE_TOP));

        if (logForHistogram) {

            sConcurrencyHistogramLogger.logSample(mActiveServices.size());

        }

    }



    @GuardedBy("mLock")

    private void updateNonRunningPrioritiesLocked(@NonNull final PendingJobQueue jobQueue,
@@ -1582,7 +1584,9 @@ class JobConcurrencyManager { 
        final PendingJobQueue pendingJobQueue = mService.getPendingJobQueue();

        if (pendingJobQueue.size() == 0) {

            worker.clearPreferredUid();

            noteConcurrency();

            // Don't log the drop in concurrency to the histogram, otherwise, we'll end up

            // overcounting lower concurrency values as jobs end execution.

            noteConcurrency(false);

            return;

        }

        if (mActiveServices.size() >= mSteadyStateConcurrencyLimit) {
@@ -1612,7 +1616,9 @@ class JobConcurrencyManager { 
                // scheduled), but we should

                // be able to stop the other jobs soon so don't start running anything new until we

                // get back below the limit.

                noteConcurrency();

                // Don't log the drop in concurrency to the histogram, otherwise, we'll end up

                // overcounting lower concurrency values as jobs end execution.

                noteConcurrency(false);

                return;

            }

        }
@@ -1761,7 +1767,9 @@ class JobConcurrencyManager { 
            }

        }



        noteConcurrency();

        // Don't log the drop in concurrency to the histogram, otherwise, we'll end up

        // overcounting lower concurrency values as jobs end execution.

        noteConcurrency(false);

    }



    /**