| /frameworks/base/apex/jobscheduler/service/java/com/android/server/job/ |
| D | PendingJobQueue.java | 315 private final List<AdjustedJobStatus> mJobs = new ArrayList<>(); field in PendingJobQueue.AppJobQueue
326 int where = Collections.binarySearch(mJobs, adjustedJobStatus, sJobComparator); in add()
330 mJobs.add(where, adjustedJobStatus); in add()
338 final long prevTimestamp = mJobs.get(where - 1).adjustedEnqueueTime; in add()
342 final int numJobs = mJobs.size(); in add()
346 final AdjustedJobStatus ajs = mJobs.get(i); in add()
369 int where = Collections.binarySearch(mJobs, adjustedJobStatus, sJobComparator); in addAll()
373 mJobs.add(where, adjustedJobStatus); in addAll()
382 final int numJobs = mJobs.size(); in addAll()
384 final AdjustedJobStatus ajs = mJobs.get(i); in addAll()
[all …]
|
| D | JobStore.java | 1792 final SparseArray<ArraySet<JobStatus>> mJobs; field in JobStore.JobSet
1798 mJobs = new SparseArray<ArraySet<JobStatus>>(); in JobSet()
1809 ArraySet<JobStatus> jobs = mJobs.get(uid); in getJobsByUid()
1832 ArraySet<JobStatus> jobs = mJobs.get(uid); in add()
1835 mJobs.put(uid, jobs); in add()
1853 final ArraySet<JobStatus> jobs = mJobs.get(uid); in remove()
1865 mJobs.remove(uid); in remove()
1888 for (int jobSetIndex = mJobs.size() - 1; jobSetIndex >= 0; jobSetIndex--) { in removeAll()
1889 final ArraySet<JobStatus> jobs = mJobs.valueAt(jobSetIndex); in removeAll()
1892 mJobs.removeAt(jobSetIndex); in removeAll()
[all …]
|
| D | JobSchedulerService.java | 270 final JobStore mJobs;
607 mJobs.setUseSplitFiles(mConstants.PERSIST_IN_SPLIT_FILES);
1531 jobsForUid = mJobs.getJobsByUid(pkgUid);
1606 return mJobs;
1776 mJobs.getJobByUidAndJobId(callingUid, namespace, job.getId());
1813 mJobs.touchJob(toCancel);
1847 if (mJobs.countJobsForUid(callingUid) > MAX_JOBS_PER_APP) {
1978 ArraySet<JobStatus> jobs = mJobs.getJobsByUid(uid);
1996 ArraySet<JobStatus> jobs = mJobs.getJobsByUid(uid);
2052 JobStatus job = mJobs.getJobByUidAndJobId(uid, namespace, jobId);
[all …]
|
| D | JobServiceContext.java | 809 mService.mJobs.touchJob(mRunningJob); in doDequeueWork()
828 mService.mJobs.touchJob(mRunningJob); in doCompleteWork()
1422 mService.mJobs.touchJob(mRunningJob); in handleOpTimeoutLocked()
|
| /frameworks/base/apex/jobscheduler/service/java/com/android/server/job/controllers/ |
| D | ContentObserverController.java | 217 final ArraySet<JobInstance> mJobs = new ArraySet<>(); field in ContentObserverController.ObserverInstance
233 final int N = mJobs.size(); in onChange()
235 JobInstance inst = mJobs.valueAt(i); in onChange()
314 obs.mJobs.add(this); in JobInstance()
366 obs.mJobs.remove(this); in detachLocked()
367 if (obs.mJobs.size() == 0) { in detachLocked()
409 int M = obs.mJobs.size(); in dumpControllerStateLocked()
412 JobInstance inst = obs.mJobs.valueAt(j); in dumpControllerStateLocked()
432 JobInstance inst = obs.mJobs.valueAt(j); in dumpControllerStateLocked()
505 int m = obs.mJobs.size(); in dumpControllerStateLocked()
[all …]
|
| /frameworks/base/services/incremental/ |
| D | ServiceWrappers.cpp | 294 mJobs.insert(TimedJob{id, now + timeout, std::move(what)}); in addJob()
300 std::erase_if(mJobs, [id](auto&& item) { return item.id == id; }); in removeJobs()
309 mJobs.clear(); in stop()
317 const TimePoint nextJobTs = mJobs.empty() ? kInfinityTs : mJobs.begin()->when; in runTimers()
320 const auto newFirstJobTs = !mJobs.empty() ? mJobs.begin()->when : kInfinityTs; in runTimers()
329 if (mJobs.empty()) { in runTimers()
340 for (auto it = mJobs.begin(); it != mJobs.end() && it->when <= now; in runTimers()
341 it = mJobs.begin()) { in runTimers()
342 auto jobNode = mJobs.extract(it); in runTimers()
360 std::multiset<TimedJob> mJobs; member in android::incremental::RealTimedQueueWrapper
|
| /frameworks/base/services/tests/servicestests/src/com/android/server/job/ |
| D | JobSetTest.java | 96 assertHaveSameJobs(mJobSet.mJobsPerSourceUid, mJobSet.mJobs); in testBothMapsHaveSameJobs()
99 assertHaveSameJobs(mJobSet.mJobsPerSourceUid, mJobSet.mJobs); in testBothMapsHaveSameJobs()
101 assertHaveSameJobs(mJobSet.mJobsPerSourceUid, mJobSet.mJobs); in testBothMapsHaveSameJobs()
103 assertTrue("mJobs should be empty", mJobSet.mJobs.size() == 0); in testBothMapsHaveSameJobs()
|
| /frameworks/av/media/ndk/fuzzer/ |
| D | ndk_async_codec_fuzzer.cpp | 169 std::queue<std::function<void()>> mJobs; member in NdkAsyncCodecFuzzer::ThreadPool
206 mQueueMutexCondition.wait(lock, [this] { return !mJobs.empty() || mShouldTerminate; }); in ThreadLoop()
210 job = mJobs.front(); in ThreadLoop()
211 mJobs.pop(); in ThreadLoop()
220 mJobs.push(job); in queueJob()
|
| /frameworks/av/media/codec2/sfplugin/ |
| D | C2NodeImpl.cpp | 66 Mutexed<Jobs>::Locked jobs(mJobs); in queue()
74 Mutexed<Jobs>::Locked jobs(mJobs); in setDataspace()
99 Mutexed<Jobs>::Locked jobs(mJobs); in threadLoop()
191 Mutexed<Jobs> mJobs; member in android::C2NodeImpl::QueueThread
|