Home
last modified time | relevance | path

Searched refs:worker (Results 1 – 25 of 70) sorted by relevance

123

/aosp12/hardware/interfaces/audio/core/all-versions/vts/functional/tests/
H A Dstreamworker_tests.cpp79 worker.pause(); in TEST_P()
85 worker.resume(); in TEST_P()
98 worker.pause(); in TEST_P()
105 worker.resume(); in TEST_P()
144 worker.pause(); in TEST_P()
148 worker.resume(); in TEST_P()
158 worker.pause(); in TEST_P()
159 worker.stop(); in TEST_P()
168 worker.pause(); in TEST_P()
178 worker.resume(); in TEST_P()
[all …]
/aosp12/art/test/004-ThreadStress/
H A Dexpected-stdout.txt2 Starting worker for N
3 Starting worker for N
7 Finishing worker
8 Finishing worker
9 Finishing worker
10 Finishing worker
11 Finishing worker
18 Finishing worker
19 Finishing worker
20 Finishing worker
[all …]
/aosp12/packages/apps/Car/Settings/src/com/android/car/settings/qc/
H A DSettingsQCBackgroundWorker.java92 if (worker == null) { in getInstance()
96 LIVE_WORKERS.put(uri, worker); in getInstance()
98 worker.setQCItem(qcItem); in getInstance()
99 return worker; in getInstance()
117 worker.close(); in shutdown()
127 if (worker != null) { in shutdown()
129 worker.close(); in shutdown()
195 Uri uri = worker.getUri(); in handleMessage()
196 Context context = worker.getContext(); in handleMessage()
202 if (hasMessages(MSG_UPDATE_QCITEM, worker)) { in updateQCItem()
[all …]
H A DSettingsQCProvider.java108 SettingsQCBackgroundWorker worker = SettingsQCBackgroundWorker.getInstance( in startBackgroundWorker() local
110 mSubscribedWorkers.put(uri, worker); in startBackgroundWorker()
111 worker.subscribe(); in startBackgroundWorker()
116 SettingsQCBackgroundWorker worker = mSubscribedWorkers.get(uri); in stopBackgroundWorker() local
117 if (worker != null) { in stopBackgroundWorker()
118 worker.unsubscribe(); in stopBackgroundWorker()
/aosp12/packages/apps/Settings/src/com/android/settings/slices/
H A DSliceBackgroundWorker.java94 SliceBackgroundWorker worker = getInstance(uri); in getInstance() local
95 if (worker == null) { in getInstance()
99 LIVE_WORKERS.put(uri, worker); in getInstance()
101 return worker; in getInstance()
119 worker.close(); in shutdown()
218 final Uri uri = worker.getUri(); in handleMessage()
219 final Context context = worker.getContext(); in handleMessage()
224 private void updateSlice(SliceBackgroundWorker worker) { in updateSlice() argument
225 if (hasMessages(MSG_UPDATE_SLICE, worker)) { in updateSlice()
244 removeMessages(MSG_UPDATE_SLICE, worker); in cancelSliceUpdate()
[all …]
H A DSettingsSliceProvider.java492 final SliceBackgroundWorker worker = SliceBackgroundWorker.getInstance( in startBackgroundWorker() local
494 mPinnedWorkers.put(uri, worker); in startBackgroundWorker()
495 worker.pin(); in startBackgroundWorker()
499 final SliceBackgroundWorker worker = mPinnedWorkers.get(uri); in stopBackgroundWorker() local
500 if (worker != null) { in stopBackgroundWorker()
502 worker.unpin(); in stopBackgroundWorker()
/aosp12/hardware/interfaces/biometrics/fingerprint/aidl/default/tests/
H A DWorkerThreadTest.cpp33 WorkerThread worker(1 /*maxQueueSize*/); in TEST() local
38 ASSERT_TRUE(worker.schedule(Callable::from([promise = std::move(promise)]() mutable { in TEST()
48 WorkerThread worker(2 /*maxQueueSize*/); in TEST() local
54 ASSERT_TRUE(worker.schedule(Callable::from([promise = std::move(promise)]() mutable { in TEST()
66 ASSERT_TRUE(worker.schedule(Callable::from([] {}))); in TEST()
67 ASSERT_TRUE(worker.schedule(Callable::from([] {}))); in TEST()
69 EXPECT_FALSE(worker.schedule(Callable::from([] {}))); in TEST()
74 WorkerThread worker(NUM_TASKS); in TEST() local
82 worker.schedule(Callable::from([&mut, &results, i] { in TEST()
91 worker.schedule(Callable::from([&mut, &cv, &finished] { in TEST()
[all …]
/aosp12/bionic/tests/
H A Dsys_ptrace_test.cpp376 pid_t worker = -1; member in PtraceResumptionTest
391 worker = fork(); in PtraceResumptionTest()
392 if (worker == -1) { in PtraceResumptionTest()
394 } else if (worker == 0) { in PtraceResumptionTest()
463 if (worker == -1) { in WaitForWorker()
477 if (rc != worker) { in WaitForWorker()
514 wait_for_ptrace_stop(worker); in TEST_F()
524 ASSERT_EQ(worker, TEMP_FAILURE_RETRY(waitpid(worker, &result, 0))); in TEST_F()
537 wait_for_ptrace_stop(worker); in TEST_F()
547 wait_for_ptrace_stop(worker); in TEST_F()
[all …]
/aosp12/packages/apps/Dialer/java/com/android/dialer/common/concurrent/
H A DDefaultDialerExecutorFactory.java63 @NonNull Worker<InputT, OutputT> worker) { in createUiTaskBuilder() argument
67 Assert.isNotNull(worker), in createUiTaskBuilder()
75 @NonNull Worker<InputT, OutputT> worker) { in createNonUiTaskBuilder() argument
92 Worker<InputT, OutputT> worker, in BaseTaskBuilder() argument
95 this.worker = worker; in BaseTaskBuilder()
125 Worker<InputT, OutputT> worker, in UiTaskBuilder() argument
140 super.worker, in build()
153 Worker<InputT, OutputT> worker, in NonUiTaskBuilder() argument
163 super.worker, in build()
213 Worker<InputT, OutputT> worker, in NonUiDialerExecutor() argument
[all …]
H A DDialerUiTaskFragment.java45 private Worker<InputT, OutputT> worker; field in DialerUiTaskFragment
80 Worker<InputT, OutputT> worker, in create() argument
95 fragment.worker = worker; in create()
145 OutputT output = worker.doInBackground(input); in runTask()
H A DDialerExecutorFactory.java48 @NonNull Worker<InputT, OutputT> worker); in createUiTaskBuilder() argument
62 @NonNull Worker<InputT, OutputT> worker); in createNonUiTaskBuilder() argument
/aosp12/packages/apps/Settings/tests/robotests/src/com/android/settings/nfc/
H A DNfcPreferenceControllerTest.java231 final NfcSliceWorker worker = spy( in ncfSliceWorker_nfcBroadcast_noExtra_sliceDoesntUpdate() local
233 final NfcUpdateReceiver receiver = worker.new NfcUpdateReceiver(worker); in ncfSliceWorker_nfcBroadcast_noExtra_sliceDoesntUpdate()
243 final NfcSliceWorker worker = spy( in ncfSliceWorker_nfcBroadcast_turningOn_sliceDoesntUpdate() local
245 final NfcUpdateReceiver receiver = worker.new NfcUpdateReceiver(worker); in ncfSliceWorker_nfcBroadcast_turningOn_sliceDoesntUpdate()
256 final NfcSliceWorker worker = spy( in ncfSliceWorker_nfcBroadcast_turningOff_sliceDoesntUpdate() local
258 final NfcUpdateReceiver receiver = worker.new NfcUpdateReceiver(worker); in ncfSliceWorker_nfcBroadcast_turningOff_sliceDoesntUpdate()
269 final NfcSliceWorker worker = spy( in ncfSliceWorker_nfcBroadcast_nfcOn_sliceUpdates() local
271 final NfcUpdateReceiver receiver = worker.new NfcUpdateReceiver(worker); in ncfSliceWorker_nfcBroadcast_nfcOn_sliceUpdates()
277 verify(worker).updateSlice(); in ncfSliceWorker_nfcBroadcast_nfcOn_sliceUpdates()
284 final NfcUpdateReceiver receiver = worker.new NfcUpdateReceiver(worker); in ncfSliceWorker_nfcBroadcast_nfcOff_sliceUpdates()
[all …]
/aosp12/packages/apps/Car/Settings/tests/robotests/src/com/android/car/settings/security/
H A DSaveLockWorkerTest.java39 SaveLockWorker worker = spy(new SaveLockWorker()); in testSaveLockSuccessReturnsTrue() local
41 doNothing().when(worker).saveLock(); in testSaveLockSuccessReturnsTrue()
43 assertThat(worker.saveAndVerifyInBackground()).isTrue(); in testSaveLockSuccessReturnsTrue()
51 SaveLockWorker worker = spy(new SaveLockWorker()); in testSaveLockFailureReturnsFalse() local
53 doThrow(new RuntimeException()).when(worker).saveLock(); in testSaveLockFailureReturnsFalse()
55 assertThat(worker.saveAndVerifyInBackground()).isFalse(); in testSaveLockFailureReturnsFalse()
/aosp12/packages/apps/Car/Settings/tests/unit/src/com/android/car/settings/qc/
H A DSettingsQCProviderTest.java78 SettingsQCBackgroundWorker worker = mProvider.mSubscribedWorkers.get(QCTestUtils.URI); in onSubscribe_startsBackgroundWorker() local
79 assertThat(worker).isNotNull(); in onSubscribe_startsBackgroundWorker()
80 assertThat(worker instanceof TestSettingsQCBackgroundWorker).isTrue(); in onSubscribe_startsBackgroundWorker()
81 TestSettingsQCBackgroundWorker testWorker = (TestSettingsQCBackgroundWorker) worker; in onSubscribe_startsBackgroundWorker()
90 SettingsQCBackgroundWorker worker = mProvider.mSubscribedWorkers.get(QCTestUtils.URI); in onSubscribe_stopsBackgroundWorker() local
91 assertThat(worker).isNotNull(); in onSubscribe_stopsBackgroundWorker()
92 assertThat(worker instanceof TestSettingsQCBackgroundWorker).isTrue(); in onSubscribe_stopsBackgroundWorker()
93 TestSettingsQCBackgroundWorker testWorker = (TestSettingsQCBackgroundWorker) worker; in onSubscribe_stopsBackgroundWorker()
/aosp12/packages/apps/Settings/src/com/android/settings/network/
H A DProviderModelSlice.java107 final NetworkProviderWorker worker = getWorker(); in getSlice() local
108 if (worker != null) { in getSlice()
109 maxListSize = worker.getApRowCount(); in getSlice()
129 worker != null ? worker.getNetworkTypeDescription() : "")); in getSlice()
142 List<WifiSliceItem> wifiList = (worker != null) ? worker.getResults() : null; in getSlice()
240 if (worker != null) { in getMobileDataDisableDialog()
241 worker.updateSlice(); in getMobileDataDisableDialog()
274 if (worker == null) { in doCarrierNetworkAction()
284 worker.connectCarrierNetwork(); in doCarrierNetworkAction()
320 if (worker == null) { in getInternetType()
[all …]
/aosp12/art/runtime/
H A Dthread_pool.cc120 ThreadPoolWorker* worker = reinterpret_cast<ThreadPoolWorker*>(arg); in Callback() local
123 worker->name_.c_str(), in Callback()
131 worker->thread_pool_->create_peers_ ? runtime->GetSystemThreadGroup() : nullptr, in Callback()
132 worker->thread_pool_->create_peers_)); in Callback()
133 worker->thread_ = Thread::Current(); in Callback()
135 worker->thread_->SetIsRuntimeThread(true); in Callback()
137 worker->Run(); in Callback()
321 for (ThreadPoolWorker* worker : threads_) { in SetPthreadPriority()
322 worker->SetPthreadPriority(priority); in SetPthreadPriority()
328 for (ThreadPoolWorker* worker : threads_) { in CheckPthreadPriority()
[all …]
/aosp12/frameworks/native/cmds/surfacereplayer/replayer/
H A DREADME.md99 - numThreads - Number of worker threads the replayer will use.
213 A worker thread's flow looks like so
226 and worker threads. Every time an increment is dispatched, an Event object is also created.
230 - **SettingUp** - The worker is in the process of completing all non-time sensitive work
231 - **Waiting** - The worker is waiting on the main thread to signal it.
232 - **Signaled** - The worker has just been signaled by the main thread
233 - **Running** - The worker is running again and finishing the rest of its work.
235 When the main thread wants to finish the execution of a worker, the worker can either still be
237 main thread will **Signal** it to complete. The worker thread changes itself to the **Running**
244 worker and main thread respectively.
[all …]
/aosp12/packages/apps/Settings/src/com/android/settings/wifi/slice/
H A DConnectToWifiHandler.java53 final WifiScanWorker worker = getWifiScanWorker(intent); in onReceive() local
54 if (worker == null) { in onReceive()
57 final WifiEntry wifiEntry = worker.getWifiEntry(key); in onReceive()
/aosp12/packages/apps/Dialer/java/com/android/dialer/calldetails/
H A DReportDialogFragment.java102 Worker<String, CachedContactInfo> worker = in lookupContactInfo() local
107 .createUiTaskBuilder(getFragmentManager(), "lookup_contact_info", worker) in lookupContactInfo()
125 Worker<Context, Pair<Context, Boolean>> worker = this::reportCallerId; in startReportCallerIdWorker() local
129 .createUiTaskBuilder(getFragmentManager(), "report_caller_id", worker) in startReportCallerIdWorker()
/aosp12/frameworks/base/packages/StatementService/src/com/android/statementservice/domain/
H A DDomainVerificationReceiverV1.kt24 import com.android.statementservice.domain.worker.CollectV1Worker
25 import com.android.statementservice.domain.worker.SingleV1RequestWorker
/aosp12/frameworks/native/libs/renderengine/skia/debug/
H A DCommonPool.cpp39 std::thread worker([pool, i] { in CommonPool() local
49 worker.detach(); in CommonPool()
/aosp12/packages/modules/ExtServices/native/
H A DImageHashManager.cpp62 PhashFingerprinter worker; in generatePHash() local
63 const int64_t result = worker.GenerateFingerprint(compressedBuffer.data()); in generatePHash()
/aosp12/frameworks/base/libs/hwui/thread/
H A DCommonPool.cpp38 std::thread worker([pool, i, &mLock, &tids, &tidConditionVars] { in CommonPool() local
57 worker.detach(); in CommonPool()
/aosp12/packages/apps/Settings/src/com/android/settings/homepage/contextualcards/slices/
H A DBluetoothUpdateWorker.java159 private void startLoadingBtManager(BluetoothUpdateWorker worker) { in startLoadingBtManager() argument
160 mWorker = worker; in startLoadingBtManager()
/aosp12/packages/apps/Messaging/src/com/android/messaging/datamodel/action/
H A DAction.java90 public void sendBackgroundActions(final BackgroundWorker worker) { in sendBackgroundActions() argument
91 worker.queueBackgroundWork(mBackgroundActions); in sendBackgroundActions()

123