| /packages/providers/ContactsProvider/src/com/android/providers/contacts/ |
| D | ContactsTaskScheduler.java | 50 private HandlerThread mThread; field in ContactsTaskScheduler
75 Log.v(TAG, "[" + mName + "] " + mThread + " dispatching " + msg.what); in handleMessage()
89 return mThread != null; in isRunning()
104 mThread = new HandlerThread("Worker-" + mThreadSequenceNumber.incrementAndGet()); in scheduleTask()
105 mThread.start(); in scheduleTask()
106 mHandler = new MyHandler(mThread.getLooper()); in scheduleTask()
109 Log.v(TAG, "[" + mName + "] " + mThread + " started."); in scheduleTask()
134 Log.v(TAG, "[" + mName + "] " + mThread + " stopping..."); in stopThread()
136 if (mThread != null) { in stopThread()
137 mThread.quit(); in stopThread()
[all …]
|
| /packages/apps/Bluetooth/tests/unit/src/com/android/bluetooth/audio_util/ |
| D | MediaPlayerWrapperTest.java | 62 private HandlerThread mThread; field in MediaPlayerWrapperTest
109 mThread = new HandlerThread("MediaPlayerWrapperTestThread"); in setUp()
110 mThread.start(); in setUp()
176 MediaPlayerWrapperFactory.wrap(mMockContext, null, mThread.getLooper()); in testNullControllerLooper()
190 MediaPlayerWrapperFactory.wrap(mMockContext, mMockController, mThread.getLooper()); in testIsReady()
219 MediaPlayerWrapperFactory.wrap(mMockContext, mMockController, mThread.getLooper()); in testControllerUpdate()
251 TestLooperManager looperManager = new TestLooperManager(mThread.getLooper()); in testNoQueueMediaUpdates()
253 MediaPlayerWrapperFactory.wrap(mMockContext, mMockController, mThread.getLooper()); in testNoQueueMediaUpdates()
313 TestLooperManager looperManager = new TestLooperManager(mThread.getLooper()); in testDataOnUpdateNoQueue()
315 MediaPlayerWrapperFactory.wrap(mMockContext, mMockController, mThread.getLooper()); in testDataOnUpdateNoQueue()
[all …]
|
| D | BrowserPlayerWrapperTest.java | 70 private HandlerThread mThread; field in BrowserPlayerWrapperTest
124 mThread = new HandlerThread("MediaPlayerWrapperTestThread"); in setUp()
125 mThread.start(); in setUp()
134 if (mThread != null) { in tearDown()
135 mThread.quitSafely(); in tearDown()
137 mThread = null; in tearDown()
175 BrowsedPlayerWrapper.wrap(mMockContext, mThread.getLooper(), "test", "test"); in testWrap()
190 BrowsedPlayerWrapper.wrap(mMockContext, mThread.getLooper(), "test", "test"); in testConnect_Successful()
204 BrowsedPlayerWrapper.wrap(mMockContext, mThread.getLooper(), "test", "test"); in testConnect_Suspended()
221 BrowsedPlayerWrapper.wrap(mMockContext, mThread.getLooper(), "test", "test"); in testConnect_Failed()
[all …]
|
| /packages/services/Car/tests/EmbeddedKitchenSinkApp/src/com/google/android/car/kitchensink/audio/ |
| D | AudioTrackPlayer.java | 57 private Thread mThread; field in AudioTrackPlayer
85 if (mThread != null) { in stop()
87 mThread.join(WAIT_TIME_MS); in stop()
88 mThread = null; in stop()
98 mThread = new Thread(() -> { in startTrackLocked()
114 mThread.start(); in startTrackLocked()
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/ |
| D | PackageIconLoaderTest.java | 36 private ConsumerThread mThread; field in PackageIconLoaderTest
40 mThread = new ConsumerThread(); in setUp()
41 mThread.start(); in setUp()
48 mThread.exit(); in tearDown()
56 return new PackageIconLoader(mContext, mContext.getPackageName(), mThread.getHandler(), in create()
|
| /packages/services/Car/service/jni/evs/ |
| D | EvsCallbackThread.cpp | 26 mVm(vm), mRunning(true), mThread(&EvsCallbackThread::threadLoop, this) { in EvsCallbackThread()
114 if (mThread.get_id() == std::this_thread::get_id()) { in stop()
116 mThread.detach(); in stop()
117 } else if (mThread.joinable()) { in stop()
118 mThread.join(); in stop()
|
| D | EvsCallbackThread.h | 41 std::thread mThread; variable
|
| /packages/apps/Messaging/src/com/android/messaging/util/ |
| D | NotificationPlayer.java | 211 mThread = null; in run()
239 private CmdThread mThread; field in NotificationPlayer
319 if (mThread == null) { in enqueueLocked()
321 mThread = new CmdThread(); in enqueueLocked()
322 mThread.start(); in enqueueLocked()
340 if (mWakeLock != null || mThread != null) { in setUsesWakeLock()
344 + " mThread=" + mThread); in setUsesWakeLock()
|
| /packages/modules/Connectivity/tests/unit/java/com/android/server/ |
| D | NsdServiceTest.java | 83 HandlerThread mThread; field in NsdServiceTest
89 mThread = new HandlerThread("mock-service-handler"); in setUp()
90 mThread.start(); in setUp()
92 mHandler = new TestHandler(mThread.getLooper()); in setUp()
98 if (mThread != null) { in tearDown()
99 mThread.quit(); in tearDown()
100 mThread = null; in tearDown()
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/mapclient/ |
| D | MasClient.java | 84 private HandlerThread mThread; field in MasClient
96 mThread = new HandlerThread("Client"); in MasClient()
97 mThread.start(); in MasClient()
100 Looper looper = mThread.getLooper(); in MasClient()
201 mThread.quitSafely(); in shutdown()
|
| /packages/modules/NeuralNetworks/runtime/ |
| D | ExecutionCallback.cpp | 49 if (mThread.joinable()) { in wait()
50 mThread.join(); in wait()
73 if (mThread.joinable()) { in bindThread()
85 mThread = std::move(asyncThread); in bindThread()
|
| D | ExecutionCallback.h | 214 mutable std::thread mThread GUARDED_BY(mMutex);
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/opp/ |
| D | BluetoothOppObexClientSession.java | 69 private ClientThread mThread; field in BluetoothOppObexClientSession
97 mThread = new ClientThread(mContext, mTransport, numShares); in start()
98 mThread.start(); in start()
106 if (mThread != null) { in stop()
109 mThread.interrupt(); in stop()
113 mThread.join(); in stop()
114 mThread = null; in stop()
127 mThread.addShare(share); in addShare()
|
| /packages/apps/Bluetooth/src/com/android/bluetooth/avrcpcontroller/ |
| D | AvrcpBipClient.java | 77 private final HandlerThread mThread; field in AvrcpBipClient
135 mThread = new HandlerThread("AvrcpBipClient"); in AvrcpBipClient()
136 mThread.start(); in AvrcpBipClient()
138 Looper looper = mThread.getLooper(); in AvrcpBipClient()
174 mThread.quitSafely(); in shutdown()
|
| /packages/services/AlternativeNetworkAccess/src/com/android/ons/ |
| D | ONSNetworkScanCtlr.java | 72 HandlerThread mThread; field in ONSNetworkScanCtlr
191 mThread = new HandlerThread(LOG_TAG); in init()
192 mThread.start(); in init()
193 mHandler = new Handler(mThread.getLooper()) { in init()
|
| D | ONSProfileSelector.java | 109 HandlerThread mThread; field in ONSProfileSelector
916 mThread = new HandlerThread(LOG_TAG); in init()
917 mThread.start(); in init()
918 mHandler = new Handler(mThread.getLooper()) { in init()
|
| /packages/services/Car/cpp/computepipe/runner/graph/ |
| D | StreamSetObserver.cpp | 43 mThread = std::thread([this]() { in startObservingStream()
121 if (mThread.joinable()) { in ~SingleStreamObserver()
122 mThread.join(); in ~SingleStreamObserver()
|
| D | StreamSetObserver.h | 74 std::thread mThread; variable
|
| /packages/services/Car/cpp/computepipe/runner/debug_display_manager/ |
| D | EvsDisplayManager.cpp | 78 if (mThread.joinable()) { in stopThread()
79 mThread.join(); in stopThread()
179 mThread = std::thread(&EvsDisplayManager::threadFn, this); in handleExecutionPhase()
|
| /packages/apps/Car/Calendar/tests/unit/src/com/android/car/calendar/common/ |
| D | EventsLiveDataTest.java | 546 final HandlerThread mThread; field in EventsLiveDataTest.TestHandler
561 mThread = thread; in TestHandler()
565 mThread.quit(); in stop()
|
| /packages/services/Car/cpp/computepipe/runner/debug_display_manager/include/ |
| D | EvsDisplayManager.h | 64 std::thread mThread; variable
|
| /packages/modules/NetworkStack/src/com/android/server/connectivity/ |
| D | NetworkMonitor.java | 1547 private Thread mThread; field in NetworkMonitor.ProbingState
1566 mThread = new Thread(() -> sendMessage(obtainMessage(CMD_PROBE_COMPLETE, token, 0, in enter()
1568 mThread.start(); in enter()
1634 if (mThread.isAlive()) { in exit()
1635 mThread.interrupt(); in exit()
1637 mThread = null; in exit()
|