Home
last modified time | relevance | path

Searched refs:mWorker (Results 1 – 25 of 33) sorted by relevance

12

/packages/modules/AdServices/adservices/tests/unittest/service-core/src/com/android/adservices/service/measurement/rollback/
DMeasurementRollbackCompatManagerTest.java65 @Mock private MeasurementRollbackWorker<String> mWorker; field in MeasurementRollbackCompatManagerTest
84 verify(mWorker) in testRecordAdServicesDeletionOccurred()
87 verifyNoMoreInteractions(mWorker); in testRecordAdServicesDeletionOccurred()
95 verify(mWorker, never()).recordAdServicesDeletionOccurred(anyInt(), anyLong()); in testRecordAdServicesDeletionOccurred_noCurrentApex()
96 verifyNoMoreInteractions(mWorker); in testRecordAdServicesDeletionOccurred_noCurrentApex()
102 .when(mWorker) in testRecordAdServicesDeletionOccurred_exception()
111 doReturn(null).when(mWorker).getAdServicesDeletionRollbackMetadata(anyInt()); in testNeedsToHandleRollbackReconciliation_StoredDataNull()
113 verify(mWorker).getAdServicesDeletionRollbackMetadata(anyInt()); in testNeedsToHandleRollbackReconciliation_StoredDataNull()
114 verify(mWorker, never()).clearAdServicesDeletionOccurred(anyString()); in testNeedsToHandleRollbackReconciliation_StoredDataNull()
115 verifyNoMoreInteractions(mWorker); in testNeedsToHandleRollbackReconciliation_StoredDataNull()
[all …]
DAdServicesExtStorageMeasurementRollbackWorkerTest.java42 private AdServicesExtStorageMeasurementRollbackWorker mWorker; field in AdServicesExtStorageMeasurementRollbackWorkerTest
54 mWorker = new AdServicesExtStorageMeasurementRollbackWorker(mStorageManager); in setup()
59 mWorker.recordAdServicesDeletionOccurred(MEASUREMENT_DELETION, CURRENT_APEX_VERSION); in testRecordAdServicesDeletionOccurred()
65 mWorker.clearAdServicesDeletionOccurred(null); in testClearAdServicesDeletionOccurred()
74 Pair<Long, Void> data = mWorker.getAdServicesDeletionRollbackMetadata(MEASUREMENT_DELETION); in testGetAdServicesDeletionRollbackMetadata()
84 Pair<Long, Void> data = mWorker.getAdServicesDeletionRollbackMetadata(MEASUREMENT_DELETION); in testGetAdServicesDeletionRollbackMetadataIfNoDataPresent()
/packages/apps/Car/Settings/tests/unit/src/com/android/car/settings/qc/
DWifiBaseWorkerTestCase.java34 private E mWorker; field in WifiBaseWorkerTestCase
41 mWorker = getWorker(); in setUp()
46 assertThat(mWorker.getLifecycle().getCurrentState()).isEqualTo(Lifecycle.State.CREATED); in onCreate_lifecycleCreated()
52 mWorker.onQCItemSubscribe(); in onSubscribe_lifecycleResumed()
53 assertThat(mWorker.getLifecycle().getCurrentState()).isEqualTo(Lifecycle.State.RESUMED); in onSubscribe_lifecycleResumed()
59 mWorker.onQCItemSubscribe(); in onUnsubscribe_lifecycleCreated()
60 mWorker.onQCItemUnsubscribe(); in onUnsubscribe_lifecycleCreated()
61 assertThat(mWorker.getLifecycle().getCurrentState()).isEqualTo(Lifecycle.State.CREATED); in onUnsubscribe_lifecycleCreated()
67 mWorker.onQCItemSubscribe(); in onClose_lifecycleDestroyed()
68 mWorker.close(); in onClose_lifecycleDestroyed()
[all …]
DPairedBluetoothDevicesWorkerTest.java44 private PairedBluetoothDevicesWorker mWorker; field in PairedBluetoothDevicesWorkerTest
59 mWorker = new PairedBluetoothDevicesWorker(mContext, in setUp()
72 mWorker.onQCItemSubscribe(); in onSubscribe_registersReceiver()
73 verify(mBluetoothEventManager).registerCallback(mWorker); in onSubscribe_registersReceiver()
78 mWorker.onQCItemSubscribe(); in onUnsubscribe_unregistersReceiver()
79 mWorker.onQCItemUnsubscribe(); in onUnsubscribe_unregistersReceiver()
80 verify(mBluetoothEventManager).unregisterCallback(mWorker); in onUnsubscribe_unregistersReceiver()
DHotspotRowWorkerTest.java49 private HotspotRowWorker mWorker; field in HotspotRowWorkerTest
63 mWorker = new HotspotRowWorker(mContext, SettingsQCRegistry.HOTSPOT_ROW_URI); in setUp()
64 mWorker.setQCItem(mQCItem); in setUp()
69 mWorker.onQCItemSubscribe(); in onSubscribe_registersCallbacks()
82 mWorker.onQCItemSubscribe(); in onUnsubscribe_unregistersCallbacks()
88 mWorker.onQCItemUnsubscribe(); in onUnsubscribe_unregistersCallbacks()
98 mWorker.onQCItemSubscribe(); in onTetheringSupported_updatesQCItem()
111 mWorker.onQCItemSubscribe(); in onConnectedClientsChanged_updatesQCItem()
DMediaVolumeSliderWorkerTest.java47 private MediaVolumeSliderWorker mWorker; field in MediaVolumeSliderWorkerTest
62 mWorker = new MediaVolumeSliderWorker(mContext, in setUp()
68 mWorker.onQCItemSubscribe(); in onSubscribe_registerCarVolumeCallback()
74 mWorker.onQCItemSubscribe(); in onUnsubscribe_unregisterCarVolumeCallback()
75 mWorker.onQCItemUnsubscribe(); in onUnsubscribe_unregisterCarVolumeCallback()
81 mWorker.getVolumeChangeCallback().onGroupVolumeChanged(TEST_ZONE_ID, GROUP_ID, FLAGS); in onGroupVolumeChanged_updateVolumeAndMute()
DHotspotTileWorkerTest.java44 private HotspotTileWorker mWorker; field in HotspotTileWorkerTest
58 mWorker = new HotspotTileWorker(mContext, SettingsQCRegistry.HOTSPOT_TILE_URI); in setUp()
59 mWorker.setQCItem(mQCItem); in setUp()
64 mWorker.onQCItemSubscribe(); in onSubscribe_registersCallbacks()
77 mWorker.onQCItemSubscribe(); in onUnsubscribe_unregistersCallbacks()
83 mWorker.onQCItemUnsubscribe(); in onUnsubscribe_unregistersCallbacks()
DMobileDataBaseWorkerTestCase.java49 private E mWorker; field in MobileDataBaseWorkerTestCase
77 mWorker.onQCItemSubscribe(); in onSubscribe_validSubId_registerObserver()
85 mWorker.onQCItemSubscribe(); in onSubscribe_invalidSubId_doesNotRegisterObserver()
94 mWorker.onQCItemSubscribe(); in onUnsubscribe_unregistersObserver()
97 mWorker.onQCItemUnsubscribe(); in onUnsubscribe_unregistersObserver()
103 mWorker = getWorker(); in createWorker()
DBluetoothSwitchWorkerTest.java41 private BluetoothSwitchWorker mWorker; field in BluetoothSwitchWorkerTest
45 mWorker = new BluetoothSwitchWorker(mContext, SettingsQCRegistry.BLUETOOTH_SWITCH_URI); in setUp()
51 mWorker.onQCItemSubscribe(); in onSubscribe_registersReceiver()
59 mWorker.onQCItemSubscribe(); in onUnsubscribe_unregistersReceiver()
61 mWorker.onQCItemUnsubscribe(); in onUnsubscribe_unregistersReceiver()
/packages/apps/Messaging/tests/src/com/android/messaging/datamodel/action/
DActionServiceSystemTest.java103 synchronized(mWorker) { in testChatActionSucceeds()
107 mWorker.wait(2000); in testChatActionSucceeds()
114 mWorker.getRequestsMade().size()); in testChatActionSucceeds()
115 final Action request = mWorker.getRequestsMade().get(0); in testChatActionSucceeds()
151 synchronized(mWorker) { in testChatActionFails()
155 mWorker.wait(2000); in testChatActionFails()
162 mWorker.getRequestsMade().size()); in testChatActionFails()
163 final Action request = mWorker.getRequestsMade().get(0); in testChatActionFails()
192 synchronized(mWorker) { in testChatActionNoMonitor()
196 mWorker.wait(2000); in testChatActionNoMonitor()
[all …]
DActionServiceTest.java95 synchronized(mWorker) { in testChatServiceCreatesIntentAndExecutesAction()
99 mWorker.wait(2000); in testChatServiceCreatesIntentAndExecutesAction()
117 StubBackgroundWorker mWorker; field in ActionServiceTest
142 mWorker = new StubBackgroundWorker(); in setUp()
146 .withBackgroundWorkerForActionService(mWorker) in setUp()
/packages/modules/AdServices/adservices/tests/unittest/service-core/appsearch/src/com/android/adservices/service/appsearch/
DAppSearchMeasurementRollbackWorkerTest.java70 private AppSearchMeasurementRollbackWorker mWorker; field in AppSearchMeasurementRollbackWorkerTest
99 mWorker = AppSearchMeasurementRollbackWorker.getInstance(mContext, USERID); in setup()
121 mWorker.clearAdServicesDeletionOccurred(mockRowId); in testClearAdServicesDeletionOccurred()
141 () -> mWorker.clearAdServicesDeletionOccurred("mock_row_id")); in testClearAdServicesDeletionOccurred_throwsUnchecked()
148 NullPointerException.class, () -> mWorker.clearAdServicesDeletionOccurred(null)); in testClearAdServicesDeletionOccurred_nullInput()
162 mWorker.getAdServicesDeletionRollbackMetadata( in testGetAdServicesDeletionApexVersion_documentFound()
186 mWorker.getAdServicesDeletionRollbackMetadata( in testGetAdServicesDeletionApexVersion_documentNotFound()
207 AppSearchMeasurementRollbackWorker spyWorker = spy(mWorker); in testRecordAdServicesDeletionOccurred()
225 AppSearchMeasurementRollbackWorker spyWorker = spy(mWorker); in testRecordAdServicesDeletionOccurred_throwsUnchecked()
243 mWorker.createAppSearchMeasurementRollbackDao( in testCreateAppSearchMeasurementRollbackDao()
/packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/provision/worker/
DDeviceCheckInWorkerTest.java83 private DeviceCheckInWorker mWorker; field in DeviceCheckInWorkerTest
95 mWorker = TestListenableWorkerBuilder.from( in setUp()
127 final Result result = Futures.getUnchecked(mWorker.startWork()); in checkIn_allInfoAvailable_checkInResponseSuccessfulAndHandleable_successAndLogged()
146 final Result result = Futures.getUnchecked(mWorker.startWork()); in checkIn_allInfoAvailable_checkInResponseSuccessfulNotHandleable_retryAndLogged()
165 final Result result = Futures.getUnchecked(mWorker.startWork()); in checkIn_allInfoAvailable_checkInResponseHasRecoverableError_retryAndLogCheckIn()
184 final Result result = Futures.getUnchecked(mWorker.startWork()); in checkIn_allInfoAvailable_checkInResponseHasNonRecoverableError_failAndLogCheckIn()
206 Futures.getUnchecked(mWorker.startWork()); in checkIn_carrierInfoUnavailable_shouldAtLeastSendCheckInRequest()
223 Futures.getUnchecked(mWorker.startWork()); in checkIn_deviceIdsUnavailable_shouldNotSendCheckInRequest()
245 final Result result = Futures.getUnchecked(mWorker.startWork()); in checkIn_fcmTokenUnavailable_responseSuccessfulAndLogged()
DReportDeviceProvisionStateWorkerTest.java91 private ReportDeviceProvisionStateWorker mWorker; field in ReportDeviceProvisionStateWorkerTest
107 mWorker = TestListenableWorkerBuilder.from( in setUp()
138 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.retry()); in doWork_responseHasRecoverableError_returnRetryAndNotLogged()
147 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.failure()); in doWork_responseHasFatalError_returnFailureAndNotLogged()
159 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.success()); in doWork_responseIsSuccessful_globalParametersSetAndEventLogged()
177 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.success()); in doWork_mandatory_doesNotSendNotificationOrScheduleAlarm()
197 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.success()); in doWork_deferred_retryState_schedulesAlarm()
213 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.success()); in doWork_deferred_dismissibleUiState_schedulesAlarmAndSendsNotification()
243 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.success()); in doWork_deferred_persistentUiState_schedulesAlarmAndSendsOngoingNotification()
273 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.success()); in doWork_deferred_factoryResetState_schedulesResetDeviceAlarm()
DSetupWizardCompletionTimeoutWorkerTest.java61 private SetupWizardCompletionTimeoutWorker mWorker; field in SetupWizardCompletionTimeoutWorkerTest
68 mWorker = TestListenableWorkerBuilder.from( in setUp()
92 assertThat(Futures.getUnchecked(mWorker.startWork())) in doWork_suwComplete_doesNotStartFlow()
107 assertThat(Futures.getUnchecked(mWorker.startWork())) in doWork_suwNotComplete_notUnprovisioned_doesNotStartFlow()
125 assertThat(Futures.getUnchecked(mWorker.startWork())) in doWork_suwNotComplete_unprovisioned_provisionNotReady_doesNotStartFlow()
145 assertThat(Futures.getUnchecked(mWorker.startWork())) in doWork_suwNotComplete_unprovisioned_provisionReady_startsFlow()
DReportDeviceLockProgramCompleteWorkerTest.java62 private ReportDeviceLockProgramCompleteWorker mWorker; field in ReportDeviceLockProgramCompleteWorkerTest
71 mWorker = TestListenableWorkerBuilder.from( in setUp()
94 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.success()); in doWork_responseIsSuccessful_returnSuccess()
102 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.retry()); in doWork_responseHasRecoverableError_returnRetry()
110 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.failure()); in doWork_responseHasFatalError_returnFailure()
DIsDeviceInApprovedCountryWorkerTest.java63 private IsDeviceInApprovedCountryWorker mWorker; field in IsDeviceInApprovedCountryWorkerTest
70 mWorker = TestListenableWorkerBuilder.from( in setUp()
98 Result actual = Futures.getUnchecked(mWorker.startWork()); in doWork_responseIsSuccessful_isInApprovedCountry_correctResultAndLog()
113 Result actual = Futures.getUnchecked(mWorker.startWork()); in doWork_responseIsSuccessful_isNotInApprovedCountry_correctResultAndLog()
127 Result actual = Futures.getUnchecked(mWorker.startWork()); in doWork_responseIsNotSuccessful_failureResultAndLog()
DPauseProvisioningWorkerTest.java63 private PauseProvisioningWorker mWorker; field in PauseProvisioningWorkerTest
70 mWorker = TestListenableWorkerBuilder.from( in setUp()
95 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.success()); in doWork_responseIsSuccessful_resultSuccessAndLogged()
104 assertThat(Futures.getUnchecked(mWorker.startWork())).isEqualTo(Result.failure()); in doWork_responseIsNotSuccessful_resultFailure()
DGetFcmTokenWorkerTest.java58 private GetFcmTokenWorker mWorker; field in GetFcmTokenWorkerTest
82 mWorker = TestListenableWorkerBuilder.from(mContext, GetFcmTokenWorker.class) in setUp()
105 final Result result = Futures.getUnchecked(mWorker.startWork()); in startWork_returnsExpectedResult()
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/
DSingleThreadNamedTaskExecutor.kt26 private val mWorker: Thread constant
30 if (DBG) Log.d(TAG, "Cancelling " + mQueue.size.toString() + " tasks: " + mWorker.name) in cancelPendingTasks()
39 mWorker.interrupt() in close()
96 mWorker = threadFactory!!.newThread(Worker())
97 mWorker.start()
/packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/policy/
DStartLockTaskModeWorkerTest.java90 private StartLockTaskModeWorker mWorker; field in StartLockTaskModeWorkerTest
96 mWorker = TestListenableWorkerBuilder.from(mTestApp, StartLockTaskModeWorker.class) in setUp()
135 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_launchesActivityInLockedTaskMode()
160 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_hitsException_failsAndEnforcesCriticalFailure()
174 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_alreadyLockedDoesNothing()
190 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_failsWhenNoLaunchIntent()
204 final Result result = mBgExecutor.submit(() -> mWorker.startWork().get()).get(); in doWork_failsLaunchIntentNotPermitted()
/packages/apps/Settings/src/com/android/settings/homepage/contextualcards/slices/
DBluetoothUpdateWorker.java116 private BluetoothUpdateWorker mWorker; field in BluetoothUpdateWorker.LoadBtManagerHandler
146 if (mWorker != null) { in getLocalBtManager()
148 mWorker.notifySliceChange(); in getLocalBtManager()
160 mWorker = worker; in startLoadingBtManager()
/packages/apps/Settings/src/com/android/settings/media/
DMediaOutputIndicatorSlice.java47 private MediaOutputIndicatorWorker mWorker; field in MediaOutputIndicatorSlice
112 if (mWorker == null) { in getWorker()
113 mWorker = SliceBackgroundWorker.getInstance(getUri()); in getWorker()
115 return mWorker; in getWorker()
/packages/apps/Settings/src/com/android/settings/notification/
DMediaVolumePreferenceController.java49 private MediaOutputIndicatorWorker mWorker; field in MediaVolumePreferenceController
192 if (mWorker == null) { in getWorker()
193 mWorker = SliceBackgroundWorker.getInstance(getUri()); in getWorker()
195 return mWorker; in getWorker()
/packages/modules/StatsD/tests/apps/statsdapp/src/com/android/server/cts/device/statsd/
DStatsdJobService.java50 final Runnable mWorker = new Runnable() { field in StatsdJobService
79 mHandler.post(mWorker); in onStartJob()

12