| /external/nist-sip/java/gov/nist/javax/sip/stack/ |
| TCPMessageProcessor.java | 42 * Mike Andrews suggested that the thread be accessible so as to implement clean stop using
43 * Thread.join(). Roger M. Persson contributed a bug fix for cleanup on stop().
48 * Sit in a loop waiting for incoming tcp connections and start a new thread to handle each new
91 Thread thread = new Thread(this); local
92 thread.setName("TCPMessageProcessorThread");
93 thread.setPriority(Thread.MAX_PRIORITY);
94 thread.setDaemon(true)
[all...] |
| TLSMessageProcessor.java | 33 * should be added. Mike Andrews suggested that the thread be
34 * accessible so as to implement clean stop using Thread.join().
58 * Sit in a loop waiting for incoming tls connections and start a new thread to handle each new
100 Thread thread = new Thread(this); local
101 thread.setName("TLSMessageProcessorThread");
103 thread.setPriority(Thread.MAX_PRIORITY);
104 thread.setDaemon(true)
[all...] |
| UDPMessageProcessor.java | 39 * packet, a new UDPMessageChannel is created (upto the max thread pool size).
40 * Each UDP message is processed in its own thread).
55 * thread pooling be added to limit the number of threads and improve
114 * If the thread auditor is enabled, define a socket timeout value in order to
146 * Start our processor thread.
152 Thread thread = new Thread(this); local
153 thread.setDaemon(true);
155 thread.setName("UDPMessageProcessorThread")
[all...] |
| /external/oj-libjdwp/src/share/classes/com/sun/tools/jdi/ |
| AbstractLauncher.java | 55 grp = Thread.currentThread().getThreadGroup();
182 Thread acceptingThread = acceptConnection();
183 Thread monitoringThread = monitorTarget();
196 // Rethrow the exception in this thread
230 Thread monitorTarget() {
231 Thread thread = new Thread(grp, local
237 * Notify waiting thread of VM error termination
245 thread.setDaemon(true)
251 Thread thread = new Thread(grp, local
[all...] |
| EventQueueImpl.java | 138 TimerThread thread = new TimerThread(timeout); local
139 thread.setDaemon(true);
140 thread.start();
141 return thread;
168 * If a timeout was specified, create a thread to
179 * possible race condition between a timed out thread
180 * and a notified thread.
216 private class TimerThread extends Thread {
231 Thread.sleep(timeout);
|
| StackFrameImpl.java | 46 private final ThreadReferenceImpl thread; field in class:StackFrameImpl
52 StackFrameImpl(VirtualMachine vm, ThreadReferenceImpl thread,
55 this.thread = thread;
58 thread.addListener(this);
73 "Invalid stack frame thread listener");
80 throw new InvalidStackFrameException("Thread has been resumed");
94 * Return the thread holding the frame.
97 public ThreadReference thread() { method in class:StackFrameImpl
99 return thread;
[all...] |
| /development/samples/LunarLander/src/com/example/android/lunarlander/ |
| LunarView.java | 48 class LunarThread extends Thread {
163 /** Message handler used by thread to interact with TextView */
430 * Used to signal the thread whether it should be running or not.
431 * Passing true allows the thread to run; passing false will shut it
470 * owned by this thread, we can't touch the state of that View.
472 * thread, which updates the user-text View.
796 /** The thread that actually draws the animation */
797 private LunarThread thread; field in class:LunarView
806 // create thread only; it's started in surfaceCreated()
807 thread = new LunarThread(holder, context, new Handler()
[all...] |
| /cts/tests/tests/database/src/android/database/sqlite/cts/ |
| DatabaseStatementTest.java | 246 private static class StatementTestThread extends Thread {
288 StatementTestThread thread = new StatementTestThread(mDatabase, statement); local
289 thread.start();
291 thread.join();
|
| /cts/tests/tests/media/src/android/media/cts/ |
| MediaCasTest.java | 288 final HandlerThread thread = new HandlerThread("EventListenerHandlerThread"); local
289 thread.start();
290 Handler handler = new Handler(thread.getLooper());
293 thread.interrupt();
|
| /external/apache-harmony/logging/src/test/java/org/apache/harmony/logging/tests/java/util/logging/ |
| SocketHandlerTest.java | 170 ServerThread thread = new ServerThread(); local
171 thread.start();
172 Thread.sleep(2000);
180 // ensure the thread exits and the port becomes available again
181 thread.getReadString();
204 ServerThread thread = new ServerThread(); local
205 thread.start();
206 Thread.sleep(2000);
214 // ensure the thread exits and the port becomes available again
215 thread.getReadString()
241 ServerThread thread = new ServerThread(); local
285 ServerThread thread = new ServerThread(); local
420 ServerThread thread = new ServerThread(); local
448 ServerThread thread = new ServerThread(); local
473 ServerThread thread = new ServerThread(); local
512 ServerThread thread = new ServerThread(); local
542 ServerThread thread = new ServerThread(); local
569 ServerThread thread = new ServerThread(); local
594 ServerThread thread = new ServerThread(); local
619 ServerThread thread = new ServerThread(); local
[all...] |
| /art/compiler/ |
| exception_test.cc | 42 #include "thread.h"
56 ScopedObjectAccess soa(Thread::Current());
130 ScopedObjectAccess soa(Thread::Current());
165 Thread* thread = Thread::Current(); local
166 thread->TransitionFromSuspendedToRunnable();
169 JNIEnv* env = thread->GetJniEnv();
213 // Set up thread to appear as if we called out of method_g_ at given pc dex.
214 thread->SetTopOfStack(reinterpret_cast<ArtMethod**>(&fake_stack[0]))
[all...] |
| /art/runtime/native/ |
| java_lang_Thread.cc | 28 #include "thread.h"
46 Thread* thread = Thread::FromManagedThread(soa, java_thread); local
47 return (thread != nullptr) ? thread->IsInterrupted() : JNI_FALSE;
52 // There are sections in the zygote that forbid thread creation.
61 Thread::CreateNativeThread(env, java_thread, stack_size, daemon == JNI_TRUE);
65 // Ordinals from Java's Thread.State.
76 Thread* thread = Thread::FromManagedThread(soa, java_thread) local
122 Thread* thread = soa.Self(); local
129 Thread* thread = Thread::FromManagedThread(soa, java_thread); local
150 Thread* thread = thread_list->SuspendThreadByPeer(peer, local
175 Thread* thread = Thread::FromManagedThread(soa, java_thread); local
[all...] |
| org_apache_harmony_dalvik_ddmc_DdmVmInternal.cc | 35 static Thread* GetSelf(JNIEnv* env) {
58 Thread* const self = GetSelf(env);
63 trace = Thread::InternalStackTraceToStackTraceElementArray(soa, internal_trace);
68 // Check for valid thread
73 // Suspend thread to build stack trace.
74 Thread* thread = thread_list->SuspendThreadByThreadId(thin_lock_id, local
77 if (thread != nullptr) {
80 jobject internal_trace = thread->CreateInternalStackTrace<false>(soa);
81 trace = Thread::InternalStackTraceToStackTraceElementArray(soa, internal_trace)
[all...] |
| /art/test/924-threads/ |
| threads.cc | 78 // private static native Thread getCurrentThread();
79 // private static native Object[] getThreadInfo(Thread t);
83 jthread thread = nullptr; local
84 jvmtiError result = jvmti_env->GetCurrentThread(&thread);
88 return thread;
92 JNIEnv* env, jclass Main_klass ATTRIBUTE_UNUSED, jthread thread) {
96 jvmtiError result = jvmti_env->GetThreadInfo(thread, &info);
115 // The thread group;
140 JNIEnv* env, jclass Main_klass ATTRIBUTE_UNUSED, jthread thread) {
142 jvmtiError result = jvmti_env->GetThreadState(thread, &state)
[all...] |
| /bionic/benchmarks/ |
| pthread_benchmark.cpp | 180 pthread_t thread; local
181 pthread_create(&thread, nullptr, IdleThread, nullptr);
183 pthread_join(thread, nullptr);
195 pthread_t thread; local
196 pthread_create(&thread, nullptr, RunThread, &state);
197 pthread_join(thread, nullptr);
208 pthread_t thread; local
209 pthread_create(&thread, nullptr, ExitThread, nullptr);
210 pthread_join(thread, nullptr);
|
| /bionic/libc/bionic/ |
| pthread_attr.cpp | 200 // Ask the kernel where our main thread's stack started.
244 pthread_internal_t* thread = reinterpret_cast<pthread_internal_t*>(t); local
245 *attr = thread->attr;
246 // We prefer reading join_state here to setting thread->attr.flags in pthread_detach.
248 if (atomic_load(&thread->join_state) == THREAD_DETACHED) {
251 // The main thread's stack information is not stored in thread->attr, and we need to
253 if (thread->tid == getpid()) {
|
| /bionic/tests/ |
| sys_socket_test.cpp | 81 pthread_t thread; local
82 ASSERT_EQ(0, pthread_create(&thread, nullptr, ConnectFn, &connect_data));
95 ASSERT_EQ(0, pthread_join(thread, &ret_val));
|
| /cts/tests/tests/nativehardware/jni/ |
| AHardwareBufferTest.cpp | 299 pthread_t thread; local
300 EXPECT_EQ(0, pthread_create(&thread, NULL, clientFunction, &data));
313 EXPECT_EQ(0, pthread_join(thread, &ret_val));
|
| /cts/tests/tests/os/src/android/os/cts/ |
| MessageQueueTest.java | 76 * occurs right before the looper's run thread had started running. The final count down
127 HandlerThread thread = new HandlerThread("testIsIdle"); local
128 thread.start();
131 assertTrue(thread.getLooper().getQueue().isIdle());
136 Handler handler = new Handler(thread.getLooper());
156 assertFalse(thread.getLooper().getQueue().isIdle());
162 assertTrue(thread.getLooper().getQueue().isIdle());
164 thread.quitSafely();
272 AssertableHandlerThread thread = new AssertableHandlerThread(); local
273 thread.start()
403 AssertableHandlerThread thread = new AssertableHandlerThread(); local
482 AssertableHandlerThread thread = new AssertableHandlerThread(); local
571 AssertableHandlerThread thread = new AssertableHandlerThread(); local
658 AssertableHandlerThread thread = new AssertableHandlerThread(); local
[all...] |
| /development/tools/bugreport/src/com/android/bugreport/inspector/ |
| DeadlockDetector.java | 43 public ThreadSnapshot thread; field in class:DeadlockDetector.ThreadRecord
45 public ThreadRecord(ProcessSnapshot process, ThreadSnapshot thread) {
47 this.thread = thread;
52 && this.thread == that.thread;
59 hash = hash * 31 + this.thread.hashCode();
68 return this.thread.compareTo(that.thread);
119 * Detect any thread cycles that are affecting the main thread of the given pid
[all...] |
| /device/google/cuttlefish_common/common/frontend/socket_vsock_proxy/ |
| main.cpp | 18 #include <thread>
127 // One thread for reading from shm and writing into a socket.
128 // One thread for reading from a socket and writing into shm.
132 std::thread(SocketToVsock, SocketReceiver{socket}, SocketSender{vsock});
163 auto thread = std::thread(HandleConnection, std::move(vsock_socket), local
165 thread.detach();
212 auto thread = std::thread(HandleConnection, std::move(vsock_client), local
214 thread.detach()
[all...] |
| /external/apache-harmony/jdwp/src/test/java/org/apache/harmony/jpda/tests/framework/jdwp/ |
| EventMod.java | 68 public long thread; field in class:EventMod
107 thread = -1;
|
| /external/autotest/client/site_tests/security_ptraceRestrictions/src/ |
| thread-prctl.c | 5 * http://bazaar.launchpad.net/~ubuntu-bugcontrol/qa-regression-testing/master/view/head:/scripts/kernel-security/ptrace/thread-prctl.c
53 printf("tracee thread started\n");
56 printf("tracee thread prtctl result: %d\n", ret);
58 printf("tracee thread finishing\n");
145 printf("tracee thread starting\n");
148 printf("tracee thread finished\n");
191 * 2: tracee calls prctl from non-leader thread.
197 * 0: ptrace happens from non-leader thread.
206 "main" : "thread");
212 main_does_ptrace ? "main" : "thread");
242 pthread_t thread; local
[all...] |
| /external/deqp/framework/delibs/destream/ |
| deThreadStream.c | 35 deThread thread; member in struct:deThreadInStream_s
44 deStreamCpyThread* thread; member in struct:deThreadOutStream_s
93 /* \todo [mika] Add handling for errors on thread stream */
101 /* \todo [mika] Add handling for status on thread stream */
112 deThread_join(threadStream->thread);
113 deThread_destroy(threadStream->thread);
147 threadStream->thread = deThread_create(inStreamCopy, threadStream, DE_NULL);
162 /* \todo [mika] Add handling for errors on thread stream */
170 /* \todo [mika] Add handling for errors on thread stream */
203 threadStream->thread = deStreamCpyThread_create(&(threadStream->consumerStream), output, ringbufferBlockSize)
[all...] |
| /external/deqp/framework/delibs/dethread/win32/ |
| deThreadWin32.c | 2 * drawElements Thread Library
21 * \brief Win32 implementation of thread management.
35 /* Thread handle equals deThread in this implementation. */
74 HANDLE thread = 0; local
82 thread = CreateThread(DE_NULL, 0, startThread, entry, 0, DE_NULL);
83 if (!thread)
90 SetThreadPriority(thread, mapPriority(attributes->priority));
92 return (deThread)thread;
95 deBool deThread_join (deThread thread)
97 HANDLE handle = (HANDLE)thread;
[all...] |
