Home
last modified time | relevance | path

Searched refs:mScheduler (Results 1 – 25 of 28) sorted by relevance

12

/packages/modules/ImsMedia/tests/native/service/src/com/android/telephony/imsmedia/lib/libimsmedia/core/utils/
DStreamSchedulerTest.cpp100 std::shared_ptr<StreamScheduler> mScheduler; member in __anona28d7ef80111::StreamSchedulerTest
103 virtual void SetUp() override { mScheduler = std::make_shared<StreamScheduler>(); } in SetUp()
110 mScheduler->Start(); in TEST_F()
112 EXPECT_FALSE(mScheduler->IsThreadRunning()); in TEST_F()
113 mScheduler->Stop(); in TEST_F()
119 mScheduler->RegisterNode(&node); in TEST_F()
120 EXPECT_EQ(mScheduler->GetNumRegisteredNodes(), 1); in TEST_F()
121 mScheduler->Start(); in TEST_F()
123 EXPECT_FALSE(mScheduler->IsThreadRunning()); in TEST_F()
125 mScheduler->Stop(); in TEST_F()
[all …]
/packages/modules/Wifi/service/tests/wifitests/src/com/android/server/wifi/scanner/
DBackgroundScanSchedulerTest.java62 private BackgroundScanScheduler mScheduler; field in BackgroundScanSchedulerTest
72 mScheduler = new BackgroundScanScheduler(mChannelHelper); in setUp()
73 mScheduler.setMaxBuckets(DEFAULT_MAX_BUCKETS); in setUp()
74 mScheduler.setMaxChannelsPerBucket(DEFAULT_MAX_CHANNELS_PER_BUCKET); in setUp()
75 mScheduler.setMaxBatch(DEFAULT_MAX_BATCH); in setUp()
76 mScheduler.setMaxApPerScan(DEFAULT_MAX_AP_PER_SCAN); in setUp()
88 mScheduler.updateSchedule(requests); in noRequest()
89 WifiNative.ScanSettings schedule = mScheduler.getSchedule(); in noRequest()
102 mScheduler.updateSchedule(requests); in singleRequest()
103 WifiNative.ScanSettings schedule = mScheduler.getSchedule(); in singleRequest()
[all …]
/packages/apps/TV/tests/robotests/src/com/android/tv/dvr/recorder/
DInputTaskSchedulerTest.java71 private InputTaskScheduler mScheduler; field in InputTaskSchedulerTest
88 mScheduler = in setUp()
123 mScheduler.handleAddSchedule(r); in testAddSchedule_past()
124 mScheduler.handleBuildSchedule(); in testAddSchedule_past()
136 mScheduler.handleAddSchedule( in testAddSchedule_start()
142 mScheduler.handleBuildSchedule(); in testAddSchedule_start()
151 mScheduler.handleAddSchedule( in testAddSchedule_consecutiveNoStop()
154 mScheduler.handleBuildSchedule(); in testAddSchedule_consecutiveNoStop()
157 mScheduler.handleAddSchedule( in testAddSchedule_consecutiveNoStop()
160 mScheduler.handleBuildSchedule(); in testAddSchedule_consecutiveNoStop()
[all …]
DSchedulerTest.java62 private RecordingScheduler mScheduler; field in SchedulerTest
77 mScheduler = in setUp()
97 mScheduler.updateAndStartServiceIfNeeded(); in testUpdate_none()
115 mScheduler.updateAndStartServiceIfNeeded(); in testUpdate_nextIn12Hours()
130 assertFalse(mScheduler.startsWithin(r, 2)); in testStartsWithin()
131 assertTrue(mScheduler.startsWithin(r, 3)); in testStartsWithin()
/packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/receivers/
DWorkFailureAlarmReceiverTest.java61 private DeviceLockControllerScheduler mScheduler; field in WorkFailureAlarmReceiverTest
72 mScheduler = mTestApp.getDeviceLockControllerScheduler(); in setUp()
80 when(mScheduler.maybeScheduleInitialCheckIn()).thenReturn(Futures.immediateVoidFuture()); in onReceive_reasonInitialization_shouldCallMaybeScheduleInitialCheckIn()
89 verify(mScheduler).maybeScheduleInitialCheckIn(); in onReceive_reasonInitialization_shouldCallMaybeScheduleInitialCheckIn()
90 verifyNoMoreInteractions(mScheduler); in onReceive_reasonInitialization_shouldCallMaybeScheduleInitialCheckIn()
98 when(mScheduler.maybeScheduleInitialCheckIn()).thenReturn(Futures.immediateVoidFuture()); in onReceive_reasonInitialCheckIn_shouldCallMaybeScheduleInitialCheckIn()
107 verify(mScheduler).maybeScheduleInitialCheckIn(); in onReceive_reasonInitialCheckIn_shouldCallMaybeScheduleInitialCheckIn()
108 verifyNoMoreInteractions(mScheduler); in onReceive_reasonInitialCheckIn_shouldCallMaybeScheduleInitialCheckIn()
115 when(mScheduler.scheduleRetryCheckInWork(any(Duration.class))) in onReceive_reasonRetryCheckIn_shouldCallScheduleRetryCheckInWork()
125 verify(mScheduler).scheduleRetryCheckInWork(eq(Duration.ZERO)); in onReceive_reasonRetryCheckIn_shouldCallScheduleRetryCheckInWork()
[all …]
DCheckInBootCompletedReceiverTest.java52 private DeviceLockControllerScheduler mScheduler; field in CheckInBootCompletedReceiverTest
64 mScheduler = mTestApp.getDeviceLockControllerScheduler(); in setUp()
69 when(mScheduler.maybeScheduleInitialCheckIn()).thenReturn(Futures.immediateVoidFuture()); in onReceive_shouldCallMaybeScheduleInitialCheckIn()
85 verify(mScheduler).maybeScheduleInitialCheckIn(); in onReceive_shouldCallMaybeScheduleInitialCheckIn()
100 verifyNoInteractions(mScheduler); in onReceive_notSystemUser_disablesReceiver()
DLockedBootCompletedReceiverTest.java48 private DeviceLockControllerScheduler mScheduler; field in LockedBootCompletedReceiverTest
53 mScheduler = mTestApplication.getDeviceLockControllerScheduler(); in setUp()
64 verify(mScheduler).notifyRebootWhenProvisionPaused(); in onReceive_provisionPaused_shouldRescheduleResume()
73 verify(mScheduler).notifyRebootWhenProvisionFailed(); in onReceive_provisionFailed_shouldRescheduleFailedStepAndReset()
/packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/schedule/
DDeviceLockControllerSchedulerImplTest.java83 DeviceLockControllerSchedulerImpl mScheduler; field in DeviceLockControllerSchedulerImplTest
89 mScheduler = new DeviceLockControllerSchedulerImpl(mTestApp, TEST_CLOCK, in setUp()
111 mScheduler.correctStoredTime(UNPROVISIONED); in correctExpectedToRunTime_retryCheckInExpected_positiveDelta_shouldUpdate()
134 mScheduler.correctStoredTime(UNPROVISIONED); in correctExpectedToRunTime_retryCheckInExpected_negativeDelta_shouldUpdate()
156 mScheduler.correctStoredTime(PROVISION_PAUSED); in correctExpectedToRunTime_resumeProvisionExpected_positiveDelta_shouldUpdate()
178 mScheduler.correctStoredTime(PROVISION_PAUSED); in correctExpectedToRunTime_resumeProvisionExpected_negativeDelta_shouldUpdate()
198 mScheduler.scheduleResumeProvisionAlarm(); in scheduleResumeProvisionAlarm()
227 runBySequentialExecutor(mScheduler::rescheduleResumeProvisionAlarmIfNeeded); in rescheduleResumeProvisionAlarm()
248 mScheduler.scheduleInitialCheckInWork(); in scheduleInitialCheckInWork()
268 mScheduler.scheduleRetryCheckInWork(TEST_RETRY_CHECK_IN_DELAY); in scheduleRetryCheckInWork()
[all …]
/packages/modules/Connectivity/service-t/src/com/android/server/connectivity/mdns/
DDiscoveryExecutor.java54 Scheduler mScheduler; field in DiscoveryExecutor
112 && this.mScheduler == null) { in executeDelayed()
113 this.mScheduler = SchedulerFactory.createScheduler(mHandler); in executeDelayed()
115 scheduler = this.mScheduler; in executeDelayed()
139 if (mScheduler != null) { in shutDown()
140 mScheduler.close(); in shutDown()
/packages/modules/ImsMedia/service/src/com/android/telephony/imsmedia/lib/libimsmedia/core/
DBaseStreamGraph.cpp25 mScheduler = std::make_shared<StreamScheduler>(); in BaseStreamGraph()
115 mScheduler->RegisterNode(pNode); in AddNode()
130 mScheduler->DeRegisterNode(pNode); in RemoveNode()
163 mScheduler->Start(); in startNodes()
169 mScheduler->Stop(); in stopNodes()
/packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/provision/worker/
DDeviceCheckInHelperTest.java130 private DeviceLockControllerScheduler mScheduler; field in DeviceCheckInHelperTest
140 mScheduler = mTestApplication.getDeviceLockControllerScheduler(); in setUp()
231 assertThat(mHelper.handleGetDeviceCheckInStatusResponse(response, mScheduler, in handleGetDeviceCheckInStatusResponse_ready_nonEmptyFcmDoesNotStartFcmWork()
242 assertThat(mHelper.handleGetDeviceCheckInStatusResponse(response, mScheduler, in handleGetDeviceCheckInStatusResponse_readyForProvisioning_emptyFcmStartsWork()
262 assertThat(mHelper.handleGetDeviceCheckInStatusResponse(response, mScheduler, in handleGetDeviceCheckInStatusResponse_retryCheckIn_shouldScheduleRetryWork()
265 verify(mScheduler).scheduleRetryCheckInWork(eq(TEST_CHECK_RETRY_DURATION)); in handleGetDeviceCheckInStatusResponse_retryCheckIn_shouldScheduleRetryWork()
274 assertThat(mHelper.handleGetDeviceCheckInStatusResponse(response, mScheduler, in handleGetDeviceCheckInStatusResponse_retryCheckIn_nonEmptyFcmDoesNotStartFcmWork()
286 assertThat(mHelper.handleGetDeviceCheckInStatusResponse(response, mScheduler, in handleGetDeviceCheckInStatusResponse_retryCheckIn_emptyFcmStartsWork()
306 assertThat(mHelper.handleGetDeviceCheckInStatusResponse(response, mScheduler, in handleGetDeviceCheckInStatusResponse_retryCheckIn_durationIsNegative_shouldRetry()
309 verify(mScheduler).scheduleRetryCheckInWork(eq(Duration.ZERO)); in handleGetDeviceCheckInStatusResponse_retryCheckIn_durationIsNegative_shouldRetry()
/packages/modules/IPsec/tests/iketests/src/java/com/android/internal/net/ipsec/ike/
DIkeLocalRequestSchedulerTest.java59 private IkeLocalRequestScheduler mScheduler; field in IkeLocalRequestSchedulerTest
84 mScheduler = new IkeLocalRequestScheduler(mMockConsumer, mSpyContext); in setUp()
103 mScheduler.readyForNextProcedure(); in testAddMultipleRequestProcessOnlyOne()
114 mScheduler.addRequest(r); in addAllRequestsToScheduler()
123 for (int i = 0; i < mMockRequestArray.length; i++) mScheduler.readyForNextProcedure(); in testProcessOrder()
148 mScheduler.readyForNextProcedure(); in testPriorityProcessOrder()
/packages/modules/Virtualization/libs/service-compos/java/com/android/server/compos/
DIsolatedCompilationService.java90 private final JobScheduler mScheduler; field in IsolatedCompilationService.StagedApexObserver
114 mScheduler = scheduler; in StagedApexObserver()
125 if (IsolatedCompilationJobService.isStagedApexJobScheduled(mScheduler)) { in checkModules()
139 IsolatedCompilationJobService.scheduleStagedApexJob(mScheduler); in checkModules()
/packages/modules/ImsMedia/service/src/com/android/telephony/imsmedia/lib/libimsmedia/core/text/
DTextStreamGraphRtpRx.cpp68 std::static_pointer_cast<StreamSchedulerCallback>(mScheduler)); in create()
75 renderer->SetSchedulerCallback(std::static_pointer_cast<StreamSchedulerCallback>(mScheduler)); in create()
119 mScheduler->Stop(); in update()
134 mScheduler->Start(); in update()
DTextStreamGraphRtcp.cpp118 mScheduler->Stop(); in update()
145 mScheduler->Start(); in update()
DTextStreamGraphRtpTx.cpp143 mScheduler->Stop(); in update()
159 mScheduler->Start(); in update()
/packages/modules/ImsMedia/service/src/com/android/telephony/imsmedia/lib/libimsmedia/core/audio/
DAudioStreamGraphRtpTx.cpp137 mScheduler->Stop(); in update()
147 mScheduler->Start(); in update()
213 std::static_pointer_cast<StreamSchedulerCallback>(mScheduler)); in createDtmfGraph()
221 std::static_pointer_cast<StreamSchedulerCallback>(mScheduler)); in createDtmfGraph()
DAudioStreamGraphRtcp.cpp116 mScheduler->Stop(); in update()
128 mScheduler->Start(); in update()
/packages/modules/ImsMedia/service/src/com/android/telephony/imsmedia/lib/libimsmedia/core/video/
DVideoStreamGraphRtpRx.cpp69 std::static_pointer_cast<StreamSchedulerCallback>(mScheduler)); in create()
76 renderer->SetSchedulerCallback(std::static_pointer_cast<StreamSchedulerCallback>(mScheduler)); in create()
125 mScheduler->Stop(); in update()
140 mScheduler->Start(); in update()
DVideoStreamGraphRtcp.cpp118 mScheduler->Stop(); in update()
144 mScheduler->Start(); in update()
DVideoStreamGraphRtpTx.cpp315 mScheduler->Stop(); in updateNodes()
333 mScheduler->Start(); in updateNodes()
/packages/apps/ImsServiceEntitlement/tests/unittests/src/com/android/imsserviceentitlement/fcm/
DFcmRegistrationServiceTest.java64 private JobScheduler mScheduler; field in FcmRegistrationServiceTest
78 mScheduler = mContext.getSystemService(JobScheduler.class); in setup()
86 assertThat(mScheduler.getPendingJob(JobManager.REGISTER_FCM_JOB_ID)).isNotNull(); in enqueueJob_getPendingJob_registerFcmOnceNetworkReady()
/packages/modules/ImsMedia/service/src/com/android/telephony/imsmedia/lib/libimsmedia/core/nodes/
DBaseNode.cpp48 mScheduler = nullptr; in BaseNode()
69 mScheduler = callback; in SetSchedulerCallback()
323 if (needRunCount && mScheduler != nullptr) in SendDataToRearNode()
325 mScheduler->onAwakeScheduler(); in SendDataToRearNode()
/packages/apps/ImsServiceEntitlement/tests/unittests/src/com/android/imsserviceentitlement/
DImsEntitlementPollingServiceTest.java83 private JobScheduler mScheduler; field in ImsEntitlementPollingServiceTest
98 mScheduler = mContext.getSystemService(JobScheduler.class); in setUp()
263 mScheduler.getPendingJob( in doEntitlementCheck_ImsEntitlementShouldRetry_rescheduleJob()
284 mScheduler.getPendingJob( in doEntitlementCheck_WfcEntitlementShouldRetry_rescheduleJob()
317 mScheduler.getPendingJob( in enqueueJob_hasJob()
/packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/policy/
DProvisionHelperImpl.java110 private final DeviceLockControllerScheduler mScheduler; field in ProvisionHelperImpl
123 mScheduler = schedulerProvider.getDeviceLockControllerScheduler(); in ProvisionHelperImpl()
139 mScheduler.scheduleResumeProvisionAlarm(); in pauseProvision()
357 mScheduler.scheduleMandatoryResetDeviceAlarm(); in handleFailure()

12