| /packages/apps/DocumentsUI/src/com/android/documentsui/services/ |
| D | FileOperationService.java | 247 Job job = operation.createJob(this, this, jobId, features); in handleOperation() local
249 if (job == null) { in handleOperation()
253 assert (job != null); in handleOperation()
255 Log.d(TAG, "Scheduling job " + job.id + "."); in handleOperation()
257 Future<?> future = getExecutorService(operation.getOpType()).submit(job); in handleOperation()
258 mJobs.put(jobId, new JobRecord(job, future)); in handleOperation()
289 record.job.cancel(); in handleCancel()
290 updateForegroundState(record.job); in handleCancel()
318 private void deleteJob(Job job) { in deleteJob() argument
320 Log.d(TAG, "deleteJob: " + job.id); in deleteJob()
[all …]
|
| /packages/modules/AdServices/shared/libraries/device-side/proto/ |
| D | job_policy.proto | 21 // The Policy used to schedule a background job in Scheduling Policy Engine (SPE).
26 // Unique identifier of a job.
29 // Set basic description of the kind of network the job requires.
39 // This job requires any network connectivity.
42 // This job requires network connectivity that is unmetered.
45 // This job requires network connectivity that is not roaming.
48 // This job requires network connectivity that is a cellular network (metered).
52 // Set the battery constraint for the job.
59 // The job doesn't have any battery condition.
62 // The job requires the battery to be charged.
[all …]
|
| /packages/apps/Settings/tests/unit/src/com/android/settings/fingerprint2/ui/settings/ |
| D | FingerprintSettingsNavigationViewModelTest.kt | 87 val job = launch { underTest.nextStep.collect { nextStep = it } } in testNoGateKeeper_launchesConfirmDeviceCredential() constant
91 job.cancel() in testNoGateKeeper_launchesConfirmDeviceCredential()
98 val job = launch { underTest.nextStep.collect { nextStep = it } } in testConfirmDevice_fails() constant
104 job.cancel() in testConfirmDevice_fails()
111 val job = launch { underTest.nextStep.collect { nextStep = it } } in confirmDeviceSuccess_noGateKeeper() constant
117 job.cancel() in confirmDeviceSuccess_noGateKeeper()
126 val job = launch { underTest.nextStep.collect { nextStep = it } } in confirmDeviceSuccess_launchesEnrollment_ifNoPreviousEnrollments() constant
132 job.cancel() in confirmDeviceSuccess_launchesEnrollment_ifNoPreviousEnrollments()
141 val job = launch { underTest.nextStep.collect { nextStep = it } } in firstEnrollment_failsWithReason() constant
151 job.cancel() in firstEnrollment_failsWithReason()
[all …]
|
| /packages/services/Car/tests/GarageModeTestApp/src/com/google/android/car/garagemode/testapp/ |
| D | JobSchedulerWrapper.java | 18 import android.app.job.JobInfo;
19 import android.app.job.JobScheduler;
209 for (JobInfo job : mJobScheduler.getAllPendingJobs()) { in checkIdForExistence()
210 if (job.getId() == jobId) { in checkIdForExistence()
219 for (JobInfo job : list) { in printJobsOnce()
220 LOG.d("Job(" + job.getId() + ") will run " + job.getService()); in printJobsOnce()
225 for (JobInfo job : mNewJobs) { in reportNewJobs()
227 mWatchdog.logEvent("New job with id(" + job.getId() + ") has been scheduled"); in reportNewJobs()
233 for (JobInfo job : mCompletedJobs) { in reportCompletedJobs()
235 mWatchdog.logEvent("Job with id(" + job.getId() + ") has been completed."); in reportCompletedJobs()
[all …]
|
| D | DishService.java | 18 import android.app.job.JobParameters;
19 import android.app.job.JobService;
41 JobParameters job = (JobParameters) msg.obj;
44 LOG.d("Job " + job.getJobId() + " done!");
45 mTaskMap.remove(job.getJobId());
46 jobFinished(job, false);
49 DishWasherTask task = new DishWasherTask(this, job, msg.arg1);
51 mTaskMap.put(job.getJobId(), job);
54 JobParameters job1 = mTaskMap.get(job.getJobId());
58 mTaskMap.remove(job.getJobId());
|
| /packages/services/BuiltInPrintService/src/com/android/bips/ |
| D | JobQueue.java | 34 void print(LocalPrintJob job) { in print() argument
35 mJobs.add(job); in print()
41 for (LocalPrintJob job : mJobs) { in cancel()
42 if (printerId.equals(job.getPrintJob().getInfo().getPrinterId())) { in cancel()
43 cancel(job.getPrintJobId()); in cancel()
62 for (LocalPrintJob job : mJobs) { in cancel()
63 if (job.getPrintJobId().equals(id)) { in cancel()
64 mJobs.remove(job); in cancel()
65 job.getPrintJob().cancel(); in cancel()
82 mCurrent.start(job -> { in startNextJob()
|
| /packages/apps/Camera2/src/com/android/camera/processing/imagebackend/ |
| D | ImageProcessorProxyListener.java | 150 public void onStart(TaskImageContainer.TaskInfo job) { in onStart() argument
153 listeners = filteredListeners(job.contentId); in onStart()
157 l.onStart(job); in onStart()
161 public void onResultCompressed(TaskImageContainer.TaskInfo job, in onResultCompressed() argument
165 listeners = filteredListeners(job.contentId); in onResultCompressed()
169 l.onResultCompressed(job, payload); in onResultCompressed()
173 public void onResultUncompressed(TaskImageContainer.TaskInfo job, in onResultUncompressed() argument
177 listeners = filteredListeners(job.contentId); in onResultUncompressed()
181 l.onResultUncompressed(job, payload); in onResultUncompressed()
185 public void onResultUri(TaskImageContainer.TaskInfo job, Uri uri) { in onResultUri() argument
[all …]
|
| /packages/modules/HealthFitness/tests/unittests/src/com/android/server/healthconnect/migration/ |
| D | MigrationStateChangeJobTest.java | 49 import android.app.job.JobInfo;
50 import android.app.job.JobScheduler;
401 job -> in testScheduleCompletionJob()
403 job, in testScheduleCompletionJob()
421 job -> in testSchedulePauseJob()
423 job, in testSchedulePauseJob()
481 private boolean hasExpectedParameters(JobInfo job, String jobName, long jobRunInterval) { in hasExpectedParameters() argument
482 return !job.isPersisted() in hasExpectedParameters()
483 && isExpectedComponent(job) in hasExpectedParameters()
484 && hasCorrectName(job, jobName) in hasExpectedParameters()
[all …]
|
| /packages/modules/Virtualization/java/service/src/com/android/system/virtualmachine/ |
| D | SecretkeeperJobService.java | 21 import android.app.job.JobInfo;
22 import android.app.job.JobParameters;
23 import android.app.job.JobScheduler;
24 import android.app.job.JobService;
84 SecretkeeperJob job = new SecretkeeperJob(getPackageManager()); in onStartJob() local
85 sJob.set(job); in onStartJob()
91 job.run(); in onStartJob()
108 SecretkeeperJob job = sJob.getAndSet(null); in onStopJob() local
109 if (job != null) { in onStopJob()
110 job.stop(); in onStopJob()
|
| /packages/apps/Settings/src/com/android/settings/sim/receivers/ |
| D | SimSlotChangeService.kt | 18 import android.app.job.JobInfo
19 import android.app.job.JobParameters
20 import android.app.job.JobScheduler
21 import android.app.job.JobService
34 private var job: Job? = null variable in com.android.settings.sim.receivers.SimSlotChangeService
37 job = CoroutineScope(Dispatchers.Default + SupervisorJob()).launch { in onStartJob()
49 job?.cancel() in onStopJob()
|
| /packages/apps/Settings/src/com/android/settings/sim/ |
| D | PrimarySubscriptionListChangedService.kt | 19 import android.app.job.JobInfo
20 import android.app.job.JobParameters
21 import android.app.job.JobScheduler
22 import android.app.job.JobService
36 private var job: Job? = null variable in com.android.settings.sim.PrimarySubscriptionListChangedService
39 job = CoroutineScope(Dispatchers.Default + SupervisorJob()).launch { in onStartJob()
56 job?.cancel() in onStopJob()
|
| /packages/providers/MediaProvider/src/com/android/providers/media/stableuris/job/ |
| D | StableUriIdleMaintenanceService.java | 17 package com.android.providers.media.stableuris.job;
21 import android.app.job.JobInfo;
22 import android.app.job.JobParameters;
23 import android.app.job.JobScheduler;
24 import android.app.job.JobService;
72 final JobInfo job = new JobInfo.Builder(IDLE_JOB_ID, in scheduleIdlePass() local
79 scheduler.schedule(job); in scheduleIdlePass()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/cobalt/ |
| D | CobaltJobService.java | 24 import android.app.job.JobInfo;
25 import android.app.job.JobParameters;
26 import android.app.job.JobScheduler;
27 import android.app.job.JobService;
148 JobInfo job = in schedule() local
157 jobScheduler.schedule(job); in schedule()
183 JobInfo job = jobScheduler.getPendingJob(COBALT_LOGGING_JOB_ID); in scheduleIfNeeded() local
184 if (job != null && !forceSchedule) { in scheduleIfNeeded()
185 long cobaltJobPeriodMs = job.getIntervalMillis(); in scheduleIfNeeded()
|
| /packages/apps/Settings/tests/unit/src/com/android/settings/fingerprint2/ui/enrollment/modules/enrolling/rfps/viewmodel/ |
| D | RFPSIconTouchViewModelTest.kt | 66 val job = launch { rfpsIconTouchViewModel.shouldShowDialog.collect { shouldShowDialog = it } } in initShouldNotShowDialog() constant
71 job.cancel() in initShouldNotShowDialog()
79 val job = launch { rfpsIconTouchViewModel.shouldShowDialog.collect { shouldShowDialog = it } } in shouldShowDialogTest() constant
88 job.cancel() in shouldShowDialogTest()
96 val job = launch { rfpsIconTouchViewModel.shouldShowDialog.collect { shouldShowDialog = it } } in stateShouldBeFalseAfterReset() constant
111 job.cancel() in stateShouldBeFalseAfterReset()
119 val job = launch { rfpsIconTouchViewModel.shouldShowDialog.collect { shouldShowDialog = it } } in toggleMultipleTimes() constant
140 job.cancel() in toggleMultipleTimes()
|
| /packages/apps/Gallery2/src/com/android/gallery3d/util/ |
| D | JobLimiter.java | 48 public JobWrapper(Job<T> job, FutureListener<T> listener) { in JobWrapper() argument
49 mJob = job; in JobWrapper()
105 Job<T> job = null; in run() local
108 job = mJob; in run()
112 result = job.run(jc); in run()
114 Log.w(TAG, "error executing job: " + job, t); in run()
136 public synchronized <T> Future<T> submit(Job<T> job, FutureListener<T> listener) { in submit() argument
137 JobWrapper<T> future = new JobWrapper<T>(Utils.checkNotNull(job), listener); in submit()
|
| /packages/modules/Permission/PermissionController/src/com/android/permissioncontroller/permission/service/ |
| D | PermissionEventCleanupJobService.kt | 19 import android.app.job.JobInfo
20 import android.app.job.JobParameters
21 import android.app.job.JobScheduler
22 import android.app.job.JobService
93 var job: Job? = null in getClearOldEventsCheckFrequencyMs() variable in com.android.permissioncontroller.permission.service.PermissionEventCleanupJobService
103 job = in getClearOldEventsCheckFrequencyMs()
118 job?.cancel() in onStopJob()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/measurement/reporting/ |
| D | DebugReportingJobService.java | 22 import android.app.job.JobInfo;
23 import android.app.job.JobParameters;
24 import android.app.job.JobScheduler;
25 import android.app.job.JobService;
104 static void schedule(JobScheduler jobScheduler, JobInfo job) { in schedule() argument
105 jobScheduler.schedule(job); in schedule()
130 JobInfo job = buildJobInfo(context, flags); in scheduleIfNeeded() local
131 if (forceSchedule || !job.equals(scheduledJobInfo)) { in scheduleIfNeeded()
132 schedule(jobScheduler, job); in scheduleIfNeeded()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/signals/ |
| D | PeriodicEncodingJobService.java | 24 import android.app.job.JobInfo;
25 import android.app.job.JobParameters;
26 import android.app.job.JobScheduler;
27 import android.app.job.JobService;
174 JobInfo job = jobScheduler.getPendingJob(PROTECTED_SIGNALS_PERIODIC_ENCODING_JOB_ID); in scheduleIfNeeded() local
176 if (job == null in scheduleIfNeeded()
179 || (job.getIntervalMillis() != existingJobPeriodMillis in scheduleIfNeeded()
204 final JobInfo job = in schedule() local
214 jobScheduler.schedule(job); in schedule()
|
| /packages/apps/Settings/tests/unit/src/com/android/settings/fingerprint2/enrollment/viewmodel/ |
| D | FingerprintEnrollFindSensorViewModelV2Test.kt | 165 val job = launch { underTest.udfpsLottieInfo.collect { udfpsLottieInfo = it } } in udfpsLottieInfo() constant
169 job.cancel() in udfpsLottieInfo()
177 val job = launch { in sfpsLottieInfoWhenFolded() constant
189 job.cancel() in sfpsLottieInfoWhenFolded()
197 val job = launch { in sfpsLottieInfoWhenUnFolded() constant
209 job.cancel() in sfpsLottieInfoWhenUnFolded()
229 val job = launch { underTest.showRfpsAnimation.collect { showRfpsAnimation = it } } in rfpsAnimation() constant
233 job.cancel() in rfpsAnimation()
253 val job = launch { underTest.showPrimaryButton.collect { showPrimaryButton = it } } in showPrimaryButton_ifUdfps() constant
257 job.cancel() in showPrimaryButton_ifUdfps()
[all …]
|
| /packages/providers/MediaProvider/src/com/android/providers/media/ |
| D | IdleService.java | 19 import android.app.job.JobInfo;
20 import android.app.job.JobParameters;
21 import android.app.job.JobScheduler;
22 import android.app.job.JobService;
65 final JobInfo job = new JobInfo.Builder(IDLE_JOB_ID, in scheduleIdlePass() local
71 scheduler.schedule(job); in scheduleIdlePass()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/ |
| D | MaintenanceJobService.java | 25 import android.app.job.JobInfo;
26 import android.app.job.JobParameters;
27 import android.app.job.JobScheduler;
28 import android.app.job.JobService;
190 final JobInfo job = in schedule() local
199 jobScheduler.schedule(job); in schedule()
230 JobInfo job = jobScheduler.getPendingJob(MAINTENANCE_JOB_ID); in scheduleIfNeeded() local
232 if (job != null && !forceSchedule) { in scheduleIfNeeded()
233 long maintenanceJobPeriodMs = job.getIntervalMillis(); in scheduleIfNeeded()
234 long maintenanceJobFlexMs = job.getFlexMillis(); in scheduleIfNeeded()
|
| /packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/topics/ |
| D | EpochJobService.java | 32 import android.app.job.JobInfo;
33 import android.app.job.JobParameters;
34 import android.app.job.JobScheduler;
35 import android.app.job.JobService;
170 final JobInfo job = in schedule() local
179 jobScheduler.schedule(job); in schedule()
214 JobInfo job = jobScheduler.getPendingJob(TOPICS_EPOCH_JOB_ID); in scheduleIfNeeded() local
216 if (job != null && !forceSchedule) { in scheduleIfNeeded()
217 long epochJobPeriodMs = job.getIntervalMillis(); in scheduleIfNeeded()
218 long epochJobFlexMs = job.getFlexMillis(); in scheduleIfNeeded()
|
| /packages/apps/ImsServiceEntitlement/src/com/android/imsserviceentitlement/job/ |
| D | JobManager.java | 17 package com.android.imsserviceentitlement.job;
19 import android.app.job.JobInfo;
20 import android.app.job.JobParameters;
21 import android.app.job.JobScheduler;
135 JobInfo job = in queryEntitlementStatusOnceNetworkReady() local
140 mJobScheduler.schedule(job); in queryEntitlementStatusOnceNetworkReady()
146 JobInfo job = in registerFcmOnceNetworkReady() local
150 mJobScheduler.schedule(job); in registerFcmOnceNetworkReady()
|
| /packages/apps/Settings/tests/unit/src/com/android/settings/fingerprint2/domain/interactor/ |
| D | FingerprintManagerInteractorTest.kt | 181 val job = testScope.launch { result = underTest.generateChallenge(1L) } in testGenerateChallenge() constant
188 job.cancelAndJoin() in testGenerateChallenge()
203 val job = in testRemoveFingerprint_succeeds() constant
212 job.cancelAndJoin() in testRemoveFingerprint_succeeds()
226 val job = in testRemoveFingerprint_fails() constant
239 job.cancelAndJoin() in testRemoveFingerprint_fails()
260 val job = launch { result = underTest.authenticate() } in testAuth_succeeds() constant
279 job.cancelAndJoin() in testAuth_succeeds()
287 val job = launch { result = underTest.authenticate() } in testAuth_lockout() constant
304 job.cancelAndJoin() in testAuth_lockout()
[all …]
|
| /packages/modules/Virtualization/compos/service/java/com/android/server/compos/ |
| D | IsolatedCompilationJobService.java | 21 import android.app.job.JobInfo;
22 import android.app.job.JobParameters;
23 import android.app.job.JobScheduler;
24 import android.app.job.JobService;
120 CompilationJob job = mCurrentJob.getAndSet(null); in onStopJob() local
121 if (job == null) { in onStopJob()
124 job.stop(); in onStopJob()
132 CompilationJob job = mCurrentJob.getAndSet(null); in onCompletion() local
133 if (job == null) { in onCompletion()
|