Home
last modified time | relevance | path

Searched refs:job (Results 1 – 25 of 273) sorted by relevance

1234567891011

/frameworks/base/services/tests/mockingservicestests/src/com/android/server/job/controllers/
DJobStatusTest.java17 package com.android.server.job.controllers;
25 import static com.android.server.job.JobSchedulerService.ACTIVE_INDEX;
26 import static com.android.server.job.JobSchedulerService.EXEMPTED_INDEX;
27 import static com.android.server.job.JobSchedulerService.FREQUENT_INDEX;
28 import static com.android.server.job.JobSchedulerService.NEVER_INDEX;
29 import static com.android.server.job.JobSchedulerService.RARE_INDEX;
30 import static com.android.server.job.JobSchedulerService.RESTRICTED_INDEX;
31 import static com.android.server.job.JobSchedulerService.WORKING_INDEX;
32 import static com.android.server.job.JobSchedulerService.sElapsedRealtimeClock;
33 import static com.android.server.job.controllers.JobStatus.CONSTRAINT_BACKGROUND_NOT_RESTRICTED;
[all …]
DStateControllerTest.java17 package com.android.server.job.controllers;
30 import android.app.job.JobInfo;
41 import com.android.server.job.JobSchedulerService;
42 import com.android.server.job.JobSchedulerService.Constants;
145 JobStatus job = spy(createJobStatus("testWouldBeReadyWithConstraintLocked", 1)); in testWouldBeReadyWithConstraintLocked() local
147 when(job.wouldBeReadyWithConstraint(anyInt())).thenReturn(false); in testWouldBeReadyWithConstraintLocked()
148 assertFalse(mStateController.wouldBeReadyWithConstraintLocked(job, 1)); in testWouldBeReadyWithConstraintLocked()
150 when(job.wouldBeReadyWithConstraint(anyInt())).thenReturn(true); in testWouldBeReadyWithConstraintLocked()
151 when(mJobSchedulerService.areComponentsInPlaceLocked(job)).thenReturn(false); in testWouldBeReadyWithConstraintLocked()
152 assertFalse(mStateController.wouldBeReadyWithConstraintLocked(job, 1)); in testWouldBeReadyWithConstraintLocked()
[all …]
/frameworks/base/apex/jobscheduler/service/java/com/android/server/job/controllers/
DTimeController.java17 package com.android.server.job.controllers;
19 import static com.android.server.job.JobSchedulerService.sElapsedRealtimeClock;
36 import com.android.server.job.JobSchedulerService;
37 import com.android.server.job.StateControllerProto;
90 public void maybeStartTrackingJobLocked(JobStatus job, JobStatus lastJob) { in maybeStartTrackingJobLocked() argument
91 if (job.hasTimingDelayConstraint() || job.hasDeadlineConstraint()) { in maybeStartTrackingJobLocked()
92 maybeStopTrackingJobLocked(job, null); in maybeStartTrackingJobLocked()
100 if (job.hasDeadlineConstraint() && evaluateDeadlineConstraint(job, nowElapsedMillis)) { in maybeStartTrackingJobLocked()
105 } else if (job.hasTimingDelayConstraint() && evaluateTimingDelayConstraint(job, in maybeStartTrackingJobLocked()
107 if (!job.hasDeadlineConstraint()) { in maybeStartTrackingJobLocked()
[all …]
DJobStatus.java17 package com.android.server.job.controllers;
19 import static com.android.server.job.JobSchedulerService.ACTIVE_INDEX;
20 import static com.android.server.job.JobSchedulerService.EXEMPTED_INDEX;
21 import static com.android.server.job.JobSchedulerService.NEVER_INDEX;
22 import static com.android.server.job.JobSchedulerService.RESTRICTED_INDEX;
23 import static com.android.server.job.JobSchedulerService.WORKING_INDEX;
24 import static com.android.server.job.JobSchedulerService.sElapsedRealtimeClock;
25 import static com.android.server.job.controllers.FlexibilityController.SYSTEM_WIDE_FLEXIBLE_CONSTRA…
31 import android.app.job.JobInfo;
32 import android.app.job.JobParameters;
[all …]
/frameworks/base/apex/jobscheduler/service/java/com/android/server/job/restrictions/
DThermalStatusRestriction.java17 package com.android.server.job.restrictions;
19 import android.app.job.JobInfo;
20 import android.app.job.JobParameters;
21 import android.app.job.JobScheduler;
27 import com.android.server.job.Flags;
28 import com.android.server.job.JobSchedulerService;
29 import com.android.server.job.controllers.JobStatus;
89 public boolean isJobRestricted(JobStatus job, int bias) { in isJobRestricted() argument
104 final int priority = job.getEffectivePriority(); in isJobRestricted()
114 if (job.shouldTreatAsUserInitiatedJob()) { in isJobRestricted()
[all …]
DJobRestriction.java17 package com.android.server.job.restrictions;
19 import android.app.job.JobInfo;
20 import android.app.job.JobParameters;
21 import android.app.job.JobScheduler;
25 import com.android.server.job.JobSchedulerService;
26 import com.android.server.job.controllers.JobStatus;
69 public abstract boolean isJobRestricted(JobStatus job, int bias); in isJobRestricted() argument
/frameworks/base/services/tests/servicestests/src/com/android/server/job/
DPendingJobQueueTest.java17 package com.android.server.job;
19 import static android.app.job.JobInfo.NETWORK_TYPE_ANY;
20 import static android.app.job.JobInfo.NETWORK_TYPE_NONE;
29 import android.app.job.JobInfo;
39 import com.android.server.job.controllers.JobStatus;
83 JobStatus job; in testAdd() local
84 while ((job = jobQueue.next()) != null) { in testAdd()
85 jobs.remove(job); in testAdd()
103 JobStatus job; in testAddAll() local
104 while ((job = jobQueue.next()) != null) { in testAddAll()
[all …]
/frameworks/base/apex/jobscheduler/service/java/com/android/server/job/
DJobServiceContext.java17 package com.android.server.job;
19 import static com.android.server.job.JobConcurrencyManager.WORK_TYPE_NONE;
20 import static com.android.server.job.JobSchedulerService.sElapsedRealtimeClock;
21 import static com.android.server.job.JobSchedulerService.safelyScaleBytesToKBForHistogram;
31 import android.app.job.IJobCallback;
32 import android.app.job.IJobService;
33 import android.app.job.JobInfo;
34 import android.app.job.JobParameters;
35 import android.app.job.JobProtoEnums;
36 import android.app.job.JobWorkItem;
[all …]
DPendingJobQueue.java17 package com.android.server.job;
26 import com.android.server.job.controllers.JobStatus;
89 void add(@NonNull JobStatus job) { in add() argument
90 final AppJobQueue ajq = getAppJobQueue(job.getSourceUid(), true); in add()
92 ajq.add(job); in add()
103 final JobStatus job = jobs.valueAt(i); in addAll() local
104 List<JobStatus> appJobs = jobsByUid.get(job.getSourceUid()); in addAll()
107 jobsByUid.put(job.getSourceUid(), appJobs); in addAll()
109 appJobs.add(job); in addAll()
130 boolean contains(@NonNull JobStatus job) { in contains() argument
[all …]
DJobSchedulerService.java17 package com.android.server.job;
38 import android.app.job.IJobScheduler;
39 import android.app.job.IUserVisibleJobObserver;
40 import android.app.job.JobInfo;
41 import android.app.job.JobParameters;
42 import android.app.job.JobProtoEnums;
43 import android.app.job.JobScheduler;
44 import android.app.job.JobService;
45 import android.app.job.JobSnapshot;
46 import android.app.job.JobWorkItem;
[all …]
/frameworks/proto_logging/stats/atoms/art/
Dbackground_extension_dexopt_atoms.proto7 import "frameworks/proto_logging/stats/enums/app/job/job_enums.proto";
18 * Logs when a background dexopt job is ended.
30 // The job has finished. This value is used even if some packages have
31 // failed compilation during the job. (Corresponds to either
36 // The job is aborted by the job scheduler. The reason is logged in
40 // The job is aborted by itself because there is no space left. Note
41 // that this does NOT include cases where the job is aborted by the job
47 // The job is aborted by itself because of thermal issues. Note that
48 // this does NOT include cases where the job is aborted by the job
53 // Only applies to the legacy dexopt job.
[all …]
/frameworks/base/services/tests/mockingservicestests/src/com/android/server/job/
DJobConcurrencyManagerTest.java17 package com.android.server.job;
24 import static com.android.server.job.JobConcurrencyManager.KEY_PKG_CONCURRENCY_LIMIT_EJ;
25 import static com.android.server.job.JobConcurrencyManager.KEY_PKG_CONCURRENCY_LIMIT_REGULAR;
26 import static com.android.server.job.JobConcurrencyManager.WORK_TYPE_BG;
27 import static com.android.server.job.JobConcurrencyManager.WORK_TYPE_BGUSER;
28 import static com.android.server.job.JobConcurrencyManager.WORK_TYPE_BGUSER_IMPORTANT;
29 import static com.android.server.job.JobConcurrencyManager.WORK_TYPE_EJ;
30 import static com.android.server.job.JobConcurrencyManager.WORK_TYPE_FGS;
31 import static com.android.server.job.JobConcurrencyManager.WORK_TYPE_NONE;
32 import static com.android.server.job.JobConcurrencyManager.WORK_TYPE_TOP;
[all …]
DJobSchedulerServiceTest.java17 package com.android.server.job;
28 import static com.android.server.job.JobSchedulerService.ACTIVE_INDEX;
29 import static com.android.server.job.JobSchedulerService.RARE_INDEX;
30 import static com.android.server.job.JobSchedulerService.sElapsedRealtimeClock;
31 import static com.android.server.job.JobSchedulerService.sUptimeMillisClock;
32 import static com.android.server.job.Flags.FLAG_BATCH_ACTIVE_BUCKET_JOBS;
33 import static com.android.server.job.Flags.FLAG_BATCH_CONNECTIVITY_JOBS_PER_NETWORK;
34 import static com.android.server.job.Flags.FLAG_THERMAL_RESTRICTIONS_TO_FGS_JOBS;
55 import android.app.job.JobInfo;
56 import android.app.job.JobParameters;
[all …]
/frameworks/base/tests/JobSchedulerPerfTests/src/com/android/frameworks/perftests/job/
DJobStorePerfTests.java16 package com.android.frameworks.perftests.job;
18 import android.app.job.JobInfo;
29 import com.android.server.job.JobStore;
30 import com.android.server.job.JobStore.JobSet;
31 import com.android.server.job.controllers.JobStatus;
86 for (JobStatus job : jobList) { in runPersistedJobWriting()
87 sJobStore.addForTesting(job); in runPersistedJobWriting()
114 for (JobStatus job : jobList) { in runPersistedJobWriting_delta()
115 sJobStore.addForTesting(job); in runPersistedJobWriting_delta()
119 for (JobStatus job : jobAdditions) { in runPersistedJobWriting_delta()
[all …]
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/mobile/domain/interactor/
DMobileIconInteractorTest.kt95 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in gsm_usesGsmLevel() constant
99 job.cancel() in gsm_usesGsmLevel()
111 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in gsm_alwaysShowCdmaTrue_stillUsesGsmLevel() constant
115 job.cancel() in gsm_alwaysShowCdmaTrue_stillUsesGsmLevel()
124 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in notGsm_level_default_unknown() constant
127 job.cancel() in notGsm_level_default_unknown()
139 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in notGsm_alwaysShowCdmaTrue_usesCdmaLevel() constant
143 job.cancel() in notGsm_alwaysShowCdmaTrue_usesCdmaLevel()
155 val job = underTest.signalLevelIcon.onEach { latest = it.level }.launchIn(this) in notGsm_alwaysShowCdmaFalse_usesPrimaryLevel() constant
159 job.cancel() in notGsm_alwaysShowCdmaFalse_usesPrimaryLevel()
[all …]
/frameworks/base/libs/dream/lowlight/tests/src/com.android.dream.lowlight/
DLowLightTransitionCoordinatorTest.kt72 val job = launch { in <lambda>() constant
77 assertThat(job.isCompleted).isTrue() in <lambda>()
84 val job = launch { in <lambda>() constant
89 assertThat(job.isCompleted).isTrue() in <lambda>()
97 val job = launch { in <lambda>() constant
102 assertThat(job.isCompleted).isTrue() in <lambda>()
110 val job = launch { in <lambda>() constant
116 assertThat(job.isCompleted).isFalse() in <lambda>()
121 assertThat(job.isCompleted).isTrue() in <lambda>()
122 assertThat(job.isCancelled).isFalse() in <lambda>()
[all …]
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/mobile/data/repository/prod/
DMobileConnectionRepositoryTest.kt180 val job = underTest.isEmergencyOnly.onEach { latest = it }.launchIn(this) in emergencyOnly() constant
189 job.cancel() in emergencyOnly()
196 val job = underTest.isEmergencyOnly.onEach { latest = it }.launchIn(this) in emergencyOnly_toggles() constant
206 job.cancel() in emergencyOnly_toggles()
213 val job = underTest.cdmaLevel.onEach { latest = it }.launchIn(this) in cdmaLevelUpdates() constant
227 job.cancel() in cdmaLevelUpdates()
234 val job = underTest.primaryLevel.onEach { latest = it }.launchIn(this) in gsmLevelUpdates() constant
247 job.cancel() in gsmLevelUpdates()
254 val job = underTest.isGsm.onEach { latest = it }.launchIn(this) in isGsm() constant
267 job.cancel() in isGsm()
[all …]
/frameworks/base/packages/SystemUI/multivalentTests/src/com/android/systemui/statusbar/pipeline/wifi/domain/interactor/
DWifiInteractorImplTest.kt70 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_unavailableNetwork_outputsNull() constant
75 job.cancel() in ssid_unavailableNetwork_outputsNull()
84 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_inactiveNetwork_outputsNull() constant
89 job.cancel() in ssid_inactiveNetwork_outputsNull()
100 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_carrierMergedNetwork_outputsNull() constant
105 job.cancel() in ssid_carrierMergedNetwork_outputsNull()
121 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_isPasspointAccessPoint_outputsPasspointName() constant
126 job.cancel() in ssid_isPasspointAccessPoint_outputsPasspointName()
142 val job = underTest.ssid.onEach { latest = it }.launchIn(this) in ssid_isOnlineSignUpForPasspoint_outputsPasspointName() constant
147 job.cancel() in ssid_isOnlineSignUpForPasspoint_outputsPasspointName()
[all …]
/frameworks/base/packages/SystemUI/multivalentTests/src/com/android/systemui/biometrics/
DUdfpsKeyguardViewLegacyControllerWithCoroutinesTest.kt91 val job = mController.listenForBouncerExpansion(this) in bouncerExpansionChange_fadeIn() constant
99 job.cancel() in bouncerExpansionChange_fadeIn()
113 val job = mController.listenForBouncerExpansion(this) in bouncerExpansionChange_pauseAuth() constant
121 job.cancel() in bouncerExpansionChange_pauseAuth()
135 val job = mController.listenForBouncerExpansion(this) in bouncerExpansionChange_unpauseAuth() constant
143 job.cancel() in bouncerExpansionChange_unpauseAuth()
155 val job = mController.listenForAlternateBouncerVisibility(this) in shadeLocked_showAlternateBouncer_unpauseAuth() constant
163 job.cancel() in shadeLocked_showAlternateBouncer_unpauseAuth()
176 val job = mController.listenForBouncerExpansion(this) in shouldPauseAuthBouncerShowing() constant
184 job.cancel() in shouldPauseAuthBouncerShowing()
[all …]
/frameworks/base/core/java/com/android/internal/infra/
DServiceConnector.java74 boolean run(@NonNull VoidJob<I> job); in run() argument
98 AndroidFuture<Void> post(@NonNull VoidJob<I> job); in post() argument
109 <R> AndroidFuture<R> postForResult(@NonNull Job<I, R> job); in postForResult() argument
126 <R> AndroidFuture<R> postAsync(@NonNull Job<I, CompletableFuture<R>> job); in postAsync() argument
390 public boolean run(@NonNull VoidJob<I> job) { in run() argument
393 return !post(job).isCompletedExceptionally(); in run()
395 return enqueue(job); in run()
399 public AndroidFuture<Void> post(@NonNull VoidJob<I> job) { in post() argument
400 return postForResult((Job) job); in post()
404 public <R> CompletionAwareJob<I, R> postForResult(@NonNull Job<I, R> job) { in postForResult() argument
[all …]
/frameworks/base/packages/SystemUI/tests/src/com/android/systemui/statusbar/pipeline/mobile/data/repository/demo/
DDemoMobileConnectionsRepositoryTest.kt118 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>() constant
127 job.cancel() in <lambda>()
134 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>() constant
143 job.cancel() in <lambda>()
150 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>() constant
165 job.cancel() in <lambda>()
172 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>() constant
187 job.cancel() in <lambda>()
194 val job = underTest.subscriptions.onEach { latest = it }.launchIn(this) in <lambda>() constant
201 job.cancel() in <lambda>()
[all …]
/frameworks/base/apex/jobscheduler/framework/java/android/app/job/
DIJobScheduler.aidl17 package android.app.job;
19 import android.app.job.IUserVisibleJobObserver;
20 import android.app.job.JobInfo;
21 import android.app.job.JobSnapshot;
22 import android.app.job.JobWorkItem;
31 int schedule(String namespace, in JobInfo job); in schedule() argument
32 int enqueue(String namespace, in JobInfo job, in JobWorkItem work); in enqueue() argument
33 …int scheduleAsPackage(String namespace, in JobInfo job, String packageName, int userId, String tag… in scheduleAsPackage() argument
/frameworks/base/packages/SystemUI/src/com/android/systemui/haptics/slider/
DSliderTracker.kt49 protected var job: Job? = null in <lambda>() variable in com.android.systemui.haptics.slider.SliderTracker
53 get() = job != null && job?.isActive == true in <lambda>()
58 job = in <lambda>()
69 job?.cancel("Stopped tracking slider state") in <lambda>()
70 job = null in <lambda>()
/frameworks/ex/camera2/portability/src/com/android/ex/camera2/portability/
DDispatchThread.java51 public void runJob(Runnable job) { in runJob() argument
61 mJobQueue.add(job); in runJob()
74 public void runJobSync(final Runnable job, Object waitLock, long timeoutMs, String jobMsg) { in runJobSync() argument
79 runJob(job); in runJobSync()
109 Runnable job = null; in run() local
120 job = mJobQueue.poll(); in run()
123 if (job == null) { in run()
132 job.run(); in run()
/frameworks/base/services/tests/mockingservicestests/src/com/android/server/app/
DFakeServiceConnector.java46 public boolean run(VoidJob<T> job) { in run() argument
47 AndroidFuture<Void> unusedFuture = post(job); in run()
52 public AndroidFuture<Void> post(VoidJob<T> job) { in post() argument
55 return postForResult(job); in post()
59 public <R> AndroidFuture<R> postForResult(Job<T, R> job) { in postForResult() argument
64 androidFuture.complete(job.run(mService)); in postForResult()
73 public <R> AndroidFuture<R> postAsync(Job<T, CompletableFuture<R>> job) { in postAsync() argument
78 CompletableFuture<R> future = job.run(mService); in postAsync()

1234567891011