| /external/guava/guava-tests/test/com/google/common/cache/ |
| LocalLoadingCacheTest.java | 34 import java.lang.Thread.UncaughtExceptionHandler;
318 Thread thread = new Thread() { local
328 thread.setUncaughtExceptionHandler(new UncaughtExceptionHandler() {
330 public void uncaughtException(Thread t, Throwable e) {}
332 thread.start();
337 for (StackTraceElement trace : thread.getStackTrace()) {
|
| /art/runtime/ |
| thread-inl.h | 20 #include "thread.h"
31 // Quickly access the current thread from a JNIEnv.
32 static inline Thread* ThreadForEnv(JNIEnv* env) {
37 inline Thread* Thread::Current() {
38 // We rely on Thread::Current returning NULL for a detached thread, so it's not obvious
43 void* thread = pthread_getspecific(Thread::pthread_key_self_); local
44 return reinterpret_cast<Thread*>(thread)
[all...] |
| /bionic/libc/bionic/ |
| pthread_create.cpp | 52 // This code is used both by each new pthread and the code that initializes the main thread.
53 void __init_tls(pthread_internal_t* thread) {
54 if (thread->user_allocated_stack()) {
56 memset(&thread->tls[0], 0, BIONIC_TLS_SLOTS * sizeof(void*));
60 thread->tls[TLS_SLOT_SELF] = thread->tls;
61 thread->tls[TLS_SLOT_THREAD_ID] = thread;
63 thread->tls[TLS_SLOT_STACK_GUARD] = (void*) __stack_chk_guard;
66 void __init_alternate_signal_stack(pthread_internal_t* thread) {
130 pthread_internal_t* thread = reinterpret_cast<pthread_internal_t*>(arg); local
161 pthread_internal_t* thread = reinterpret_cast<pthread_internal_t*>(calloc(sizeof(*thread), 1)); local
[all...] |
| /external/bluetooth/bluedroid/osi/src/ |
| thread.c | 32 #include "thread.h"
43 thread_t *thread; member in struct:start_arg
80 start.thread = ret;
98 void thread_free(thread_t *thread) {
99 if (!thread)
102 thread_stop(thread);
103 pthread_join(thread->pthread, NULL);
104 fixed_queue_free(thread->work_queue, free);
105 reactor_free(thread->reactor);
106 free(thread);
144 thread_t *thread = start->thread; local
[all...] |
| /external/chromium_org/android_webview/renderer/ |
| aw_content_renderer_client.cc | 57 RenderThread* thread = RenderThread::Get(); local
60 thread->AddObserver(aw_render_process_observer_.get());
63 thread->AddObserver(visited_link_slave_.get());
131 // Avoid any race conditions from having the browser's UI thread tell the IO
132 // thread that a subframe was created.
|
| /external/chromium_org/base/threading/ |
| simple_thread.cc | 31 DCHECK(!HasBeenStarted()) << "Tried to Start a thread multiple times.";
35 event_.Wait(); // Wait for the thread to complete initialization.
39 DCHECK(HasBeenStarted()) << "Tried to Join a never-started thread.";
40 DCHECK(!HasBeenJoined()) << "Tried to Join a thread multiple times.";
57 // We've initialized our new thread, signal that we're done to Start().
102 DelegateSimpleThread* thread = new DelegateSimpleThread(this, name_prefix_); local
103 thread->Start();
104 threads_.push_back(thread);
|
| /external/chromium_org/base/win/ |
| scoped_process_information_unittest.cc | 92 HANDLE thread = process_info.TakeThreadHandle(); local
93 EXPECT_EQ(kThreadHandle, thread);
105 HANDLE thread = process_info.TakeThreadHandle(); local
|
| /external/chromium_org/content/browser/ |
| power_save_blocker_mac.cc | 14 #include "base/threading/thread.h"
19 // Power management cannot be done on the UI thread. IOPMAssertionCreate does a
20 // synchronous MIG call to configd, so if it is called on the main thread the UI
29 static base::Thread* New(void* instance) {
30 base::Thread* thread = new (instance) base::Thread("PowerSaveBlocker"); local
31 thread->Start();
32 return thread;
34 static void Delete(base::Thread* instance) {
[all...] |
| /external/chromium_org/content/public/browser/ |
| browser_message_filter.cc | 53 BrowserThread::ID thread = BrowserThread::IO; variable
54 filter_->OverrideThreadForMessage(message, &thread);
56 if (thread == BrowserThread::IO) {
69 if (thread == BrowserThread::UI &&
75 thread, FROM_HERE,
93 "Must handle messages that were dispatched to another thread!";
188 // that can be answered on the IO thread.
189 NOTREACHED() << "Can't send sync messages to UI thread without pumping "
|
| /external/chromium_org/media/audio/ |
| audio_device_thread.cc | 21 // The actual worker thread implementation. It's very bare bones and much
23 // joining the thread handle asynchronously via a provided message loop even
24 // after the Thread object itself has been deleted.
25 class AudioDeviceThread::Thread
27 public base::RefCountedThreadSafe<AudioDeviceThread::Thread> {
29 Thread(AudioDeviceThread::Callback* callback,
36 // Stops the thread. If |loop_for_join| is non-NULL, the function posts
37 // a task to join (close) the thread handle later instead of waiting for
38 // the thread. If loop_for_join is NULL, then the function waits
39 // synchronously for the thread to terminate
124 base::PlatformThreadHandle thread = base::PlatformThreadHandle(); local
[all...] |
| /external/chromium_org/native_client_sdk/src/libraries/nacl_io/stream/ |
| stream_fs.cc | 57 // Place enqueue onto the socket thread.
63 pthread_t thread; local
64 pthread_create(&thread, NULL, StreamThreadThunk, this);
|
| /external/chromium_org/ppapi/native_client/tools/browser_tester/ |
| browser_tester.py | 11 import thread namespace
264 # is done in its own thread so the main thread can time out as needed.
268 thread.start_new_thread(Serve, ())
337 # the HTTP server thread to exit uncleanly with an EBADF error,
|
| /external/chromium_org/sandbox/win/sandbox_poc/pocdll/ |
| invasive.cc | 14 // entry point for the threads created by the thread bombing function.
30 // Create the thread and leak the handle.
31 HANDLE thread = ::CreateThread(NULL, // Default security attributes local
37 if (thread) {
38 fprintf(output, "[GRANTED] Creating thread with tid 0x%X\r\n", tid);
39 ::CloseHandle(thread);
42 fprintf(output, "[BLOCKED] Creating thread. Error %d\r\n",
56 // designed to take all CPU on the processor where the thread is running.
84 HANDLE thread = ::CreateThread(NULL, // Default security attributes. local
90 ::SetThreadAffinityMask(thread, affinity_mask)
[all...] |
| /external/chromium_org/sandbox/win/src/ |
| policy_target_test.cc | 24 // Get the thread token, using impersonation.
62 // Opens the thread token with and without impersonation.
65 // Get the thread token, using impersonation.
71 // Get the thread token, without impersonation.
79 // Opens the thread token with and without impersonation, using
87 // Get the thread token, using impersonation.
98 // Get the thread token, without impersonation.
109 // Tests that we can open the current thread.
112 HANDLE thread = ::OpenThread(SYNCHRONIZE, FALSE, thread_id); local
113 if (!thread)
131 HANDLE thread = ::CreateThread(NULL, 0, &PolicyTargetTest_thread_main, 0, 0, local
[all...] |
| /external/chromium_org/third_party/WebKit/Source/core/page/ |
| NetworkStateNotifierTest.cpp | 84 ExitTask(blink::WebThread* thread)
85 : m_thread(thread)
120 blink::WebThread* thread = blink::Platform::current()->currentThread(); local
121 thread->postTask(new ExitTask(thread));
122 thread->enterRunLoop();
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| criticalsection_unittest.cc | 35 #include "talk/base/thread.h"
85 // Each value should only be taken by one thread, so if this value
88 << "Thread=" << Thread::Current() << " value=" << values[i];
115 void StartThreads(ScopedPtrCollection<Thread>* threads,
118 Thread* thread = new Thread(); local
119 thread->Start();
120 thread->Post(handler)
[all...] |
| /external/chromium_org/third_party/npapi/npspy/extern/nspr/ |
| prthread.h | 45 ** In general, a thread of a higher priority has a statistically better
47 ** NSPR uses multiple strategies to provide execution vehicles for thread
52 ** a single GLOBAL thread.
55 ** thread associated with a given GLOBAL thread. It is further assumed
59 ** Threads have a "system flag" which when set indicates the thread
61 ** process exits when the last user thread exits).
65 ** indicates whether a thread is permanently bound to a native OS thread.
66 ** An unbound thread competes for scheduling resources in the same process
155 NSPR_API(PRStatus) PR_JoinThread(PRThread *thread); variable
169 NSPR_API(PRThreadPriority) PR_GetThreadPriority(const PRThread *thread); variable
239 NSPR_API(PRStatus) PR_Interrupt(PRThread *thread); variable
269 NSPR_API(PRThreadScope) PR_GetThreadScope(const PRThread *thread); variable
274 NSPR_API(PRThreadType) PR_GetThreadType(const PRThread *thread); variable
279 NSPR_API(PRThreadState) PR_GetThreadState(const PRThread *thread); variable
[all...] |
| /external/chromium_org/third_party/webrtc/base/ |
| criticalsection_unittest.cc | 18 #include "webrtc/base/thread.h"
68 // Each value should only be taken by one thread, so if this value
71 << "Thread=" << Thread::Current() << " value=" << values[i];
98 void StartThreads(ScopedPtrCollection<Thread>* threads,
101 Thread* thread = new Thread(); local
102 thread->Start();
103 thread->Post(handler)
[all...] |
| /external/chromium_org/third_party/webrtc/modules/video_render/ |
| incoming_video_stream.cc | 219 "%s: No thread", __FUNCTION__);
226 "%s: thread started: %u", __FUNCTION__, t_id);
229 "%s: Could not start send thread", __FUNCTION__);
251 ThreadWrapper* thread = incoming_render_thread_; local
253 thread->SetNotAlive();
258 if (thread->Stop()) {
259 delete thread;
263 "%s: Not able to stop thread, leaking", __FUNCTION__);
|
| /external/chromium_org/v8/test/cctest/ |
| test-threads.cc | 46 class ThreadA : public v8::internal::Thread {
48 ThreadA() : Thread("ThreadA") { }
74 Thread::YieldCPU();
86 class ThreadB : public v8::internal::Thread {
88 ThreadB() : Thread("ThreadB") { }
107 Thread::YieldCPU();
126 class ThreadIdValidationThread : public v8::internal::Thread {
128 ThreadIdValidationThread(i::Thread* thread_to_start,
132 : Thread("ThreadRefValidationThread"),
153 i::Thread* thread_to_start_
191 ThreadC thread; local
[all...] |
| /external/compiler-rt/lib/msan/ |
| msan_thread.cc | 14 MsanThread *thread = (MsanThread*)MmapOrDie(size, __func__); local
15 thread->start_routine_ = start_routine;
16 thread->arg_ = arg;
17 thread->destructor_iterations_ = kPthreadDestructorIterations;
19 return thread;
57 // We also clear the shadow on thread destruction because
70 // start_routine_ == 0 if we're on the main thread or on one of the
|
| /external/lldb/source/Plugins/Process/Utility/ |
| InferiorCallPOSIX.cpp | 29 Thread *thread = process->GetThreadList().GetSelectedThread().get(); local
30 if (thread == NULL)
81 = new ThreadPlanCallFunction (*thread,
101 StackFrame *frame = thread->GetStackFrameAtIndex (0).get();
141 Thread *thread = process->GetThreadList().GetSelectedThread().get(); local
142 if (thread == NULL)
172 lldb::ThreadPlanSP call_plan_sp (new ThreadPlanCallFunction (*thread,
187 StackFrame *frame = thread->GetStackFrameAtIndex (0).get()
214 Thread *thread = process->GetThreadList().GetSelectedThread().get(); local
[all...] |
| /external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
| ShadowHandlerThread.java | 18 private HandlerThread thread; field in class:ShadowHandlerThread
41 if (!thread.isAlive()) {
45 // If the thread has been started, wait until the looper has been created.
47 while (thread.isAlive() && looper == null) {
73 prepared.invoke(thread);
|
| /external/webrtc/src/system_wrappers/source/ |
| critical_section_unittest.cc | 103 ThreadWrapper* thread = ThreadWrapper::CreateThread( local
107 ASSERT_TRUE(thread->Start(id));
112 // Thus, the thread should not be able to increment the count
114 crit_sect->Leave(); // This frees the thread to act.
116 EXPECT_TRUE(thread->Stop());
117 delete thread;
135 ThreadWrapper* thread = ThreadWrapper::CreateThread(&LockUnlockRunFunction, local
139 ASSERT_TRUE(thread->Start(id));
142 // The thread is capable of grabbing the lock multiple times,
148 // The thread does not increment while lock is held
[all...] |
| /frameworks/base/libs/hwui/thread/ |
| TaskManager.cpp | 67 sp<WorkerThread> thread; local
71 thread = mThreads[i];
76 return thread->addTask(wrapper);
82 // Thread
|
