| /frameworks/base/services/tests/servicestests/src/com/android/server/am/ |
| ActivityManagerServiceTest.java | 215 -1, // expectedBlockState, -1 to verify there are no interactions with main thread.
226 -1, // expectedBlockState, -1 to verify there are no interactions with main thread.
239 -1, // expectedBlockState, -1 to verify there are no interactions with main thread.
251 -1, // expectedBlockState, -1 to verify there are no interactions with main thread.
263 appRec.thread = Mockito.mock(IApplicationThread.class);
272 CustomThread thread = new CustomThread(uidRec.networkStateLock); local
273 thread.startAndWait("Unexpected state for " + uidRec);
286 verify(app.thread).setNetworkBlockSeq(uidRec.curProcStateSeq);
288 verifyZeroInteractions(app.thread);
290 Mockito.reset(app.thread);
752 CustomThread thread = new CustomThread(record.networkStateLock, new Runnable() { local
[all...] |
| /hardware/qcom/camera/msm8998/QCamera2/HAL3/test/ |
| QCameraHAL3RawSnapshotTest.cpp | 51 LOGD("\n Raw buffer thread created for testcase : %d", testcase);
161 /* Close the Thread */
177 buffer_thread_t thread; local
184 pthread_mutex_init(&thread.mutex, NULL);
185 pthread_cond_init(&thread.cond, NULL);
186 thread.is_thread_started = 0;
187 thread.readfd = pfd[0];
188 thread.writefd = pfd[1];
189 thread.data_obj = this;
190 ret = pthread_create(&thread.td, &attr, hal3_thread_ops, &thread )
213 buffer_thread_t *thread = (buffer_thread_t*)data; local
[all...] |
| QCameraHAL3SnapshotTest.cpp | 174 buffer_thread_t thread; local
181 pthread_mutex_init(&thread.mutex, NULL);
182 pthread_cond_init(&thread.cond, NULL);
183 thread.is_thread_started = 0;
184 thread.readfd = pfd[0];
185 thread.writefd = pfd[1];
186 thread.data_obj = this;
187 ret = pthread_create(&thread.td, &attr, hal3_thread_ops, &thread );
188 pthread_setname_np(thread.td, "TestApp_Thread")
203 buffer_thread_t *thread = (buffer_thread_t*)data; local
[all...] |
| QCameraHAL3Test.cpp | 38 buffer_thread_t thread; member in namespace:qcamera
158 pthread_mutex_init(&thread.mutex, NULL);
159 pthread_cond_init(&thread.cond, NULL);
161 thread.is_thread_started = 0;
162 thread.readfd = pfd[0];
163 thread.writefd = pfd[1];
164 thread.data_obj = obj;
165 thread.testcase = testcase;
166 pthread_mutex_lock(&thread.mutex);
167 ret = pthread_create(&thread.td, &attr, processBuffers, &thread )
178 buffer_thread_t *thread = (buffer_thread_t*)data; local
[all...] |
| /prebuilts/ndk/r16/sources/cxx-stl/llvm-libc++/src/ |
| thread.cpp | 1 //===------------------------- thread.cpp----------------------------------===//
13 #include "thread"
41 thread::~thread()
48 thread::join()
59 __throw_system_error(ec, "thread::join failed");
63 thread::detach()
74 __throw_system_error(ec, "thread::detach failed");
78 thread::hardware_concurrency() _NOEXCEPT
107 return 0; // Means not computable [thread.thread.static
[all...] |
| /system/bt/btif/src/ |
| btif_sock_sco.cc | 41 #include "osi/include/thread.h"
84 static thread_t* thread; // Not owned, do not free. variable
92 thread = thread_;
172 socket_register(socket, thread_get_reactor(thread), sco_socket,
191 // socket thread
|
| /system/bt/hci/src/ |
| hci_inject.cc | 35 #include "osi/include/thread.h"
64 static thread_t* thread; variable
73 CHECK(thread == NULL);
79 thread = thread_new("hci_inject");
80 if (!thread) goto error;
90 socket_register(listen_socket, thread_get_reactor(thread), NULL, accept_ready,
106 thread_free(thread);
109 thread = NULL;
144 socket_register(socket, thread_get_reactor(thread), client, read_ready, NULL);
|
| /system/bt/osi/src/ |
| thread.cc | 21 #include "osi/include/thread.h"
52 thread_t* thread; member in struct:start_arg
85 start.thread = ret;
108 void thread_free(thread_t* thread) {
109 if (!thread) return;
111 thread_stop(thread);
112 thread_join(thread);
114 fixed_queue_free(thread->work_queue, osi_free);
115 reactor_free(thread->reactor);
116 osi_free(thread);
198 thread_t* thread = start->thread; local
[all...] |
| /system/core/debuggerd/handler/ |
| debuggerd_fallback.cpp | 77 ThreadInfo thread; local
78 thread.pid = getpid();
79 thread.tid = gettid();
80 thread.thread_name = get_thread_name(gettid());
81 thread.registers.reset(Regs::CreateFromUcontext(Regs::CurrentArch(), ucontext));
85 dump_backtrace_thread(output_fd, map.get(), thread);
129 // Make sure the thread actually got the signal.
195 // We received some other thread's info request?
197 "thread %d received output fd for thread %d?", gettid(), tid)
[all...] |
| /system/core/libunwindstack/tests/ |
| UnwindTest.cpp | 31 #include <thread>
219 std::thread thread([&]() {
249 ASSERT_TRUE(ucontext != nullptr) << "Timed out waiting for thread to respond to signal.";
260 thread.join();
323 std::vector<std::thread*> threads;
329 std::thread* thread = new std::thread([i, &frames, &maps, &process_memory, &wait]() { local
338 ASSERT_LE(3U, frames[i]) << "Failed for thread " << i
[all...] |
| /cts/tests/tests/content/src/android/content/cts/ |
| ContentQueryMapTest.java | 213 new Thread(new Runnable() {
218 //listener is ready, release the sender thread
242 new Thread(new Runnable() {
247 //listener is ready, release the sender thread
272 HandlerThread thread = new HandlerThread("testSetKeepUpdatedWithHandler"); local
273 thread.start();
274 Handler handler = new Handler(thread.getLooper());
|
| /external/jmdns/src/javax/jmdns/impl/ |
| DNSStatefulObject.java | 18 * <b>Implementation note:</b> This interface is accessed from multiple threads. The implementation must be thread safe.
25 * This class define a semaphore. On this multiple threads can wait the arrival of one event. Thread wait for a maximum defined by the timeout.
37 private final ConcurrentMap<Thread, Semaphore> _semaphores;
46 _semaphores = new ConcurrentHashMap<Thread, Semaphore>(50);
50 * Blocks the current thread until the event arrives or the timeout expires.
56 Thread thread = Thread.currentThread(); local
57 Semaphore semaphore = _semaphores.get(thread);
61 _semaphores.putIfAbsent(thread, semaphore)
[all...] |
| /external/webrtc/talk/app/webrtc/androidtests/src/org/webrtc/ |
| SurfaceTextureHelperTest.java | 49 // Thread where frames are expected to be received on.
50 private final Thread expectedThread;
56 MockTextureListener(Thread expectedThread) {
63 if (expectedThread != null && Thread.currentThread() != expectedThread) {
64 throw new IllegalStateException("onTextureFrameAvailable called on wrong thread.");
292 * Test use SurfaceTextureHelper on a separate thread. A uniform texture frame is created and
293 * received on a thread separate from the test thread.
297 final HandlerThread thread = new HandlerThread("SurfaceTextureHelperTestThread"); local
298 thread.start()
333 final HandlerThread thread = new HandlerThread("SurfaceTextureHelperTestThread"); local
[all...] |
| /frameworks/base/services/core/java/com/android/server/ |
| NetworkTimeUpdateService.java | 83 // NTP lookup is done on this thread and handler
128 HandlerThread thread = new HandlerThread(TAG); local
129 thread.start();
130 mHandler = new MyHandler(thread.getLooper());
|
| /packages/services/Car/tests/carservice_test/src/com/android/car/ |
| GarageModeTest.java | 103 HandlerThread thread = new HandlerThread("testPolicy"); local
104 thread.start();
113 thread.getLooper());
128 Thread.sleep(WAIT_FOR_COMPLETION_TIME);
134 thread.getLooper());
144 Thread.sleep(WAIT_FOR_COMPLETION_TIME);
|
| /packages/services/Telephony/src/com/android/phone/ |
| SimContacts.java | 100 private class ImportAllSimContactsThread extends Thread
304 ImportAllSimContactsThread thread = new ImportAllSimContactsThread(); local
316 getString(R.string.cancel), thread);
321 thread.start();
|
| /development/samples/JetBoy/src/com/example/android/jetboy/ |
| JetBoyView.java | 125 class JetBoyThread extends Thread implements OnJetEventListener {
215 /** Message handler used by thread to interact with TextView */
433 // JET info: inthis animation thread object.
1293 private JetBoyThread thread; field in class:JetBoyView
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| MoreExecutorsTest.java | 108 Thread otherThread = new Thread(
129 assertEquals(Thread.State.TERMINATED, otherThread.getState());
131 assertNull("Throwable from other thread: "
176 Thread otherThread = new Thread(new Runnable() {
239 assertEquals(Thread.State.TERMINATED, otherThread.getState());
241 assertNull("Throwable from other thread: "
596 String oldName = Thread.currentThread().getName();
599 assertEquals("FooBar", Thread.currentThread().getName())
678 Thread thread = new Thread(new Runnable() { local
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/ |
| ThreadGroupTest.java | 27 private Thread.UncaughtExceptionHandler originalThreadDefaultUncaughtExceptionHandler;
31 initialThreadGroup = Thread.currentThread().getThreadGroup();
42 originalThreadDefaultUncaughtExceptionHandler = Thread.getDefaultUncaughtExceptionHandler();
44 Thread.setDefaultUncaughtExceptionHandler(testThreadDefaultUncaughtExceptionHandler);
50 Thread.setDefaultUncaughtExceptionHandler(originalThreadDefaultUncaughtExceptionHandler);
80 newGroup.getParent() == Thread.currentThread().getThreadGroup());
103 Thread t1 = new Thread(tg, new Runnable() {
106 Thread.sleep(5000);
181 Thread noOp = new Thread(testRoot, null, "no-op thread")
512 Thread thread = new Thread(testRoot, null, "suicidal thread") { local
546 Thread thread = new Thread(testRoot, null, "no-op thread"); local
580 Thread thread = new Thread(testRoot, null, "RuntimeException thread") { local
617 Thread thread = new Thread(testRoot, null, "RuntimeException thread") { local
649 Thread thread = new Thread(testRoot, null, "no-op thread") { local
776 private Thread thread; field in class:ThreadGroupTest.TestThreadDefaultUncaughtExceptionHandler
[all...] |
| /libcore/libart/src/main/java/java/lang/ |
| Daemons.java | 69 private Thread thread; field in class:Daemons.Daemon
87 if (thread != null) {
90 thread = new Thread(ThreadGroup.systemThreadGroup, this, name);
91 thread.setDaemon(true);
92 thread.start();
97 // We don't set the priority before the Thread.start() call above because
98 // Thread.start() will call SetNativePriority and overwrite the desired native
100 // java.lang.Thread-level priority (native priorities are more coarse-grained.
[all...] |
| /development/tools/bugreport/src/com/android/bugreport/html/ |
| Renderer.java | 151 * Any single thread will only appear once in the triage panel, at the topmost
269 private void makeThreadSnapshotHdf(Data hdf, ProcessSnapshot process, ThreadSnapshot thread) {
272 hdf.setValue("name", thread.name);
273 hdf.setValue("daemon", thread.daemon);
274 hdf.setValue("priority", Integer.toString(thread.priority));
275 hdf.setValue("tid", Integer.toString(thread.tid));
276 hdf.setValue("sysTid", Integer.toString(thread.sysTid));
277 hdf.setValue("vmState", thread.vmState);
278 hdf.setValue("runnable", thread.runnable ? "1" : "0");
279 hdf.setValue("blocked", thread.blocked ? "1" : "0")
449 final ThreadSnapshot thread = process.threads.get(i); local
[all...] |
| /device/google/accessory/demokit/app/src/com/google/android/DemoKit/ |
| DemoKitActivity.java | 225 Thread thread = new Thread(null, this, "DemoKit"); local
226 thread.start();
|
| /external/icu/android_icu4j/src/main/tests/android/icu/dev/test/rbbi/ |
| RBBITest.java | 388 final AssertionError[] assertErr = new AssertionError[1]; // saves an error found from within a thread
410 List<Thread> threads = new ArrayList<Thread>();
412 threads.add(new Thread(new WorkerThread()));
414 for (Thread thread: threads) {
415 thread.start();
417 for (Thread thread: threads) {
419 thread.join()
[all...] |
| /external/ims/rcs/rcsservice/src/com/android/service/ims/ |
| RcsStackAdaptor.java | 184 logger.debug( "Thread=" + Thread.currentThread().getName() + " received "
604 Thread thread = new Thread(() -> { local
624 }, "initAllSubRcsServices thread");
626 thread.start();
|
| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| TCPMessageChannel.java | 53 * It starts a message parser in its own thread and talks to the message parser via a pipe. The
71 protected InputStream myClientInputStream; // just to pass to thread.
81 private Thread mythread;
131 mythread = new Thread(this);
148 * Zurich) sent in a bug fix for this method. A thread was being uncessarily created.
270 Thread thread = new Thread(this); local
271 thread.setDaemon(true);
272 thread.setName("TCPMessageChannelThread")
[all...] |
