| /external/bluetooth/glib/tests/refcount/ |
| objects.c | 133 GThread *thread; local
135 thread = g_thread_create ((GThreadFunc) run_thread, test1, TRUE, NULL);
136 g_array_append_val (test_threads, thread);
138 thread = g_thread_create ((GThreadFunc) run_thread, test2, TRUE, NULL);
139 g_array_append_val (test_threads, thread);
149 GThread *thread; local
151 thread = g_array_index (test_threads, GThread *, i);
152 g_thread_join (thread);
|
| /external/libvpx/vp8/common/ |
| threading.h | 19 /* Thread management macros */
31 #define pthread_join(thread, result) ((WaitForSingleObject((thread),VPXINFINITE)!=WAIT_OBJECT_0) || !CloseHandle(thread))
32 #define pthread_detach(thread) if(thread!=NULL)CloseHandle(thread)
34 #define pthread_cancel(thread) terminate_thread(thread,0)
|
| /external/valgrind/main/drd/tests/ |
| annotate_trace_memory.stderr.exp | 4 store 0x........ size 4 (thread x / vc ...)
7 store 0x........ size 4 (thread x / vc ...)
10 Conflicting store by thread x at 0x........ size 4
15 load 0x........ size 4 (thread x / vc ...)
|
| pth_cancel_locked.c | 1 /** Cancel a thread that holds a lock on a mutex. */
14 static void* thread(void* arg) function
18 /* Inform the main thread that s_mutex2 has been locked, and wait for pthread_cancel(). */
34 /* Create thread. */
36 pthread_create(&tid, 0, &thread, 0);
38 /* Wait until the created thread has locked s_mutex2. */
42 /* Cancel the created thread. */
45 /* Join the created thread. */
|
| pth_detached_sem.c | 4 * in this test program the main thread uses a counting semaphore instead
61 // thread attributes.
64 pthread_t thread; local
65 pthread_create(&thread, &attr, thread_func1, &thread_arg[i]);
73 pthread_t thread; local
74 pthread_create(&thread, &attr, thread_func2, &thread_arg[i]);
|
| read_after_free.stderr.exp | 2 Conflicting load by thread 1 at 0x........ size 1
10 Conflicting load by thread 1 at 0x........ size 1
|
| tc01_simple_race.stderr.exp | 2 Conflicting load by thread 1 at 0x........ size 4
7 Conflicting store by thread 1 at 0x........ size 4
|
| /libcore/dalvik/src/main/java/dalvik/system/profiler/ |
| DalvikThreadSampler.java | 39 @Override public StackTraceElement[] getStackTrace(Thread thread) {
40 int count = VMStack.fillStackTraceElements(thread, mutableStackTraceElements[depth]);
|
| /packages/providers/DownloadProvider/tests/src/com/android/providers/downloads/ |
| ThreadingTest.java | 29 public void startThread(Thread thread) {
30 thread.start();
40 Thread.sleep(50); // give threads a chance to finish
53 Thread.sleep(10);
|
| /system/extras/tests/bionic/libc/other/ |
| test_thread_max.c | 36 fprintf(stderr, "thread %ld\n", (long)arg );
50 pthread_t thread; local
53 if (pthread_create( &thread, &attr, thread_func, (void*)(long)count ) < 0) {
54 fprintf(stderr, "could not create thread %d\n", count);
|
| /external/webkit/Source/WebKit/android/WebCoreSupport/ |
| WebUrlLoaderClient.cpp | 47 base::Thread* WebUrlLoaderClient::ioThread()
49 static base::Thread* networkThread = 0;
57 networkThread = new base::Thread("network");
65 base::Thread::Options options;
135 base::Thread* thread = ioThread(); local
136 if (thread) {
138 thread->message_loop()->PostTask(FROM_HERE, NewRunnableMethod(m_request.get(), &WebRequest::appendBytesToUpload, data));
151 base::Thread* thread = ioThread() local
172 base::Thread* thread = ioThread(); local
270 base::Thread* thread = ioThread(); local
313 base::Thread* thread = ioThread(); local
321 base::Thread* thread = ioThread(); local
487 base::Thread* thread = ioThread(); local
[all...] |
| WebCache.cpp | 95 base::Thread* ioThread = WebUrlLoaderClient::ioThread();
129 base::Thread* thread = WebUrlLoaderClient::ioThread(); local
130 if (thread)
131 thread->message_loop()->PostTask(FROM_HERE, NewRunnableMethod(this, &WebCache::clearImpl));
136 base::Thread* thread = WebUrlLoaderClient::ioThread(); local
137 if (thread)
138 thread->message_loop()->PostTask(FROM_HERE, NewRunnableMethod(this, &WebCache::closeIdleImpl));
187 // This is called on the UI thread
[all...] |
| /external/chromium/base/synchronization/ |
| lock_unittest.cc | 51 BasicLockTestThread thread(&lock);
54 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle));
85 EXPECT_GE(thread.acquired(), 20);
115 // This thread will not be able to get the lock.
117 TryLockTestThread thread(&lock);
120 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle));
124 ASSERT_FALSE(thread.got_lock());
129 // This thread will....
131 TryLockTestThread thread(&lock);
134 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle))
[all...] |
| /external/qemu/ |
| qemu-thread.c | 2 * Wrappers around mutex/cond/thread functions
20 #include "qemu-thread.h"
152 void qemu_thread_create(QemuThread *thread,
163 err = pthread_create(&thread->thread, NULL, start_routine, arg);
170 void qemu_thread_signal(QemuThread *thread, int sig)
174 err = pthread_kill(thread->thread, sig);
179 void qemu_thread_self(QemuThread *thread)
181 thread->thread = pthread_self()
[all...] |
| /libcore/luni/src/main/java/java/lang/ |
| ThreadGroup.java | 28 * This class is obsolete. See <i>Effective Java</i> Item 73, "Avoid thread groups" for details.
29 * @see Thread
31 public class ThreadGroup implements Thread.UncaughtExceptionHandler {
38 private int maxPriority = Thread.MAX_PRIORITY;
48 private final List<WeakReference<Thread>> threadRefs = new ArrayList<WeakReference<Thread>>(5);
54 private final Iterable<Thread> threads = CollectionUtils.dereferenceIterable(threadRefs, true);
57 * Thread groups. Access is guarded by synchronizing on this field.
73 * will be child of the {@code ThreadGroup} to which the calling thread belongs.
76 * @see Thread#currentThrea
342 Thread thread = threadRefs.get(i).get(); local
[all...] |
| /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...] |
| /external/qemu/audio/ |
| audio_pt_int.h | 8 pthread_t thread; member in struct:audio_pt
|
| /external/valgrind/main/helgrind/tests/ |
| tc06_two_races.stderr.exp | 2 Thread #x is the program's root thread
4 Thread #x was created
9 Possible data race during read of size 4 at 0x........ by thread #x
11 This conflicts with a previous write of size 4 by thread #x
18 Possible data race during write of size 4 at 0x........ by thread #x
20 This conflicts with a previous write of size 4 by thread #x
27 Possible data race during read of size 4 at 0x........ by thread #x
29 This conflicts with a previous write of size 4 by thread #x
36 Possible data race during write of size 4 at 0x........ by thread #
[all...] |
| /external/webkit/Source/WebCore/platform/network/cf/ |
| LoaderRunLoopCF.h | 32 #error This code is not needed on platforms other than Windows, because the CFRunLoop from the main thread can be used.
|
| /libcore/luni/src/test/java/org/apache/harmony/crypto/tests/javax/crypto/func/ |
| TestThread.java | 34 Thread thread = null; local
38 thread = new Thread(this);
39 thread.start();
41 thread.join();
|
| /libcore/luni/src/test/java/org/apache/harmony/xnet/provider/jsse/ |
| FileClientSessionCacheTest.java | 35 Thread[] threads = new Thread[10];
39 threads[i] = new Thread() {
48 for (Thread thread : threads) {
49 thread.start();
51 for (Thread thread : threads) {
52 thread.join();
|
| /dalvik/vm/interp/ |
| Stack.h | 33 determined when the thread is created.
176 * setting thread->interpStackStart).
178 bool dvmInitInterpStack(Thread* thread, int stackSize);
182 * "fake" native frames at the top of each thread stack.
184 bool dvmPushJNIFrame(Thread* thread, const Method* method);
189 bool dvmPushLocalFrame(Thread* thread, const Method* method);
190 bool dvmPopLocalFrame(Thread* thread)
[all...] |
| Interp.cpp | 138 Thread* self = dvmThreadSelf();
412 * This will only be run from the JDWP thread, and it will happen while
430 * This can be called from the JDWP thread (because the debugger has
431 * cancelled the breakpoint) or from an event thread (because it's a
497 * We set up some initial values based on the thread's current state. This
498 * won't work well if the thread is running, so it's up to the caller to
501 * This is only called from the JDWP thread.
503 bool dvmAddSingleStep(Thread* thread, int size, int depth)
507 if (pCtrl->active && thread != pCtrl->thread)
1498 Thread* thread; local
1556 Thread* thread; local
[all...] |
| /external/webkit/Source/JavaScriptCore/wtf/gtk/ |
| ThreadingGtk.cpp | 86 static ThreadIdentifier identifierByGthreadHandle(GThread*& thread)
92 if (i->second == thread)
99 static ThreadIdentifier establishIdentifierForThread(GThread*& thread)
101 ASSERT(!identifierByGthreadHandle(thread));
107 threadMap().add(identifierCount, thread);
130 GThread* thread; local
131 if (!(thread = g_thread_create(entryPoint, data, TRUE, 0))) {
132 LOG_ERROR("Failed to create thread at entry point %p with data %p", entryPoint, data);
136 ThreadIdentifier threadID = establishIdentifierForThread(thread);
148 GThread* thread = threadForIdentifier(threadID) local
[all...] |
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| OldServerSocketChannelTest.java | 92 class MyThread extends Thread {
106 MyThread thread = new MyThread(); local
107 thread.start();
109 Thread.currentThread().sleep(TIME_UNIT);
110 thread.interrupt();
114 if (thread.errMsg != null) {
115 fail(thread.errMsg);
|
