Searched refs:mJobs (Results 1 – 6 of 6) sorted by relevance
205 mJobs.insert(TimedJob{id, now + after, std::move(what)}); in addJob()211 std::erase_if(mJobs, [id](auto&& item) { return item.id == id; }); in removeJobs()220 mJobs.clear(); in stop()231 const auto firstJobTs = !mJobs.empty() ? mJobs.begin()->when : kInfinityTs; in runTimers()239 auto it = mJobs.begin(); in runTimers()241 for (; it != mJobs.end() && it->when <= now; it = mJobs.begin()) { in runTimers()243 mJobs.erase(it); in runTimers()249 nextJobTs = it != mJobs.end() ? it->when : kInfinityTs; in runTimers()262 std::set<TimedJob> mJobs; member in android::incremental::RealTimedQueueWrapper
193 final ArraySet<JobInstance> mJobs = new ArraySet<>(); field in ContentObserverController.ObserverInstance209 final int N = mJobs.size(); in onChange()211 JobInstance inst = mJobs.valueAt(i); in onChange()290 obs.mJobs.add(this); in JobInstance()339 obs.mJobs.remove(this); in detachLocked()340 if (obs.mJobs.size() == 0) { in detachLocked()382 int M = obs.mJobs.size(); in dumpControllerStateLocked()385 JobInstance inst = obs.mJobs.valueAt(j); in dumpControllerStateLocked()405 JobInstance inst = obs.mJobs.valueAt(j); in dumpControllerStateLocked()478 int m = obs.mJobs.size(); in dumpControllerStateLocked()[all …]
1065 final SparseArray<ArraySet<JobStatus>> mJobs; field in JobStore.JobSet1071 mJobs = new SparseArray<ArraySet<JobStatus>>(); in JobSet()1077 ArraySet<JobStatus> jobs = mJobs.get(uid); in getJobsByUid()1101 ArraySet<JobStatus> jobs = mJobs.get(uid); in add()1104 mJobs.put(uid, jobs); in add()1122 final ArraySet<JobStatus> jobs = mJobs.get(uid); in remove()1134 mJobs.remove(uid); in remove()1158 for (int jobSetIndex = mJobs.size() - 1; jobSetIndex >= 0; jobSetIndex--) { in removeAll()1159 final ArraySet<JobStatus> jobs = mJobs.valueAt(jobSetIndex); in removeAll()1162 mJobs.removeAt(jobSetIndex); in removeAll()[all …]
209 final JobStore mJobs;904 jobsForUid = mJobs.getJobsByUid(pkgUid);966 return mJobs;1072 final JobStatus toCancel = mJobs.getJobByUidAndJobId(uId, job.getId());1100 if (mJobs.countJobsForUid(uId) > MAX_JOBS_PER_APP) {1160 List<JobStatus> jobs = mJobs.getJobsByUid(uid);1172 List<JobStatus> jobs = mJobs.getJobsByUid(uid);1185 final List<JobStatus> jobsForUser = mJobs.getJobsByUser(userHandle);1196 mJobs.removeJobsOfNonUsers(umi.getUserIds());1206 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()
64 Mutexed<Jobs>::Locked jobs(mJobs); in queue()76 Mutexed<Jobs>::Locked jobs(mJobs); in threadLoop()163 Mutexed<Jobs> mJobs; member in android::C2OMXNode::QueueThread