Searched refs:mJobs (Results 1 – 6 of 6) sorted by relevance
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 for (auto it = mJobs.begin(); it != mJobs.end() && it->when <= now; in runTimers()330 it = mJobs.begin()) { in runTimers()331 auto jobNode = mJobs.extract(it); in runTimers()349 std::multiset<TimedJob> mJobs; member in android::incremental::RealTimedQueueWrapper
217 final ArraySet<JobInstance> mJobs = new ArraySet<>(); field in ContentObserverController.ObserverInstance233 final int N = mJobs.size(); in onChange()235 JobInstance inst = mJobs.valueAt(i); in onChange()314 obs.mJobs.add(this); in JobInstance()364 obs.mJobs.remove(this); in detachLocked()365 if (obs.mJobs.size() == 0) { in detachLocked()407 int M = obs.mJobs.size(); in dumpControllerStateLocked()410 JobInstance inst = obs.mJobs.valueAt(j); in dumpControllerStateLocked()430 JobInstance inst = obs.mJobs.valueAt(j); in dumpControllerStateLocked()503 int m = obs.mJobs.size(); in dumpControllerStateLocked()[all …]
1171 final SparseArray<ArraySet<JobStatus>> mJobs; field in JobStore.JobSet1177 mJobs = new SparseArray<ArraySet<JobStatus>>(); in JobSet()1183 ArraySet<JobStatus> jobs = mJobs.get(uid); in getJobsByUid()1207 ArraySet<JobStatus> jobs = mJobs.get(uid); in add()1210 mJobs.put(uid, jobs); in add()1228 final ArraySet<JobStatus> jobs = mJobs.get(uid); in remove()1240 mJobs.remove(uid); in remove()1263 for (int jobSetIndex = mJobs.size() - 1; jobSetIndex >= 0; jobSetIndex--) { in removeAll()1264 final ArraySet<JobStatus> jobs = mJobs.valueAt(jobSetIndex); in removeAll()1267 mJobs.removeAt(jobSetIndex); in removeAll()[all …]
214 final JobStore mJobs;911 jobsForUid = mJobs.getJobsByUid(pkgUid);978 return mJobs;1097 final JobStatus toCancel = mJobs.getJobByUidAndJobId(uId, job.getId());1131 if (mJobs.countJobsForUid(uId) > MAX_JOBS_PER_APP) {1195 List<JobStatus> jobs = mJobs.getJobsByUid(uid);1207 List<JobStatus> jobs = mJobs.getJobsByUid(uid);1219 final List<JobStatus> jobsForUser = mJobs.getJobsByUser(userHandle);1233 mJobs.removeJobsOfUnlistedUsers(umi.getUserIds());1243 final List<JobStatus> jobsForUid = mJobs.getJobsByUid(uid);[all …]
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()
69 Mutexed<Jobs>::Locked jobs(mJobs); in queue()77 Mutexed<Jobs>::Locked jobs(mJobs); in setDataspace()102 Mutexed<Jobs>::Locked jobs(mJobs); in threadLoop()194 Mutexed<Jobs> mJobs; member in android::C2OMXNode::QueueThread