| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| rawtransportchannel.h | 41 class Thread;
62 talk_base::Thread *worker_thread,
94 talk_base::Thread *worker_thread_;
|
| udpport.h | 36 class Thread;
48 static UDPPort* Create(talk_base::Thread* thread,
52 UDPPort* port = new UDPPort(thread, factory, network,
70 UDPPort(talk_base::Thread* thread, talk_base::PacketSocketFactory* factory,
|
| transport.h | 37 // be made on the signaling thread and all channel related calls (including
38 // signaling for a channel) will be made on the worker thread. When
59 class Thread;
110 Transport(talk_base::Thread* signaling_thread,
111 talk_base::Thread* worker_thread,
116 // Returns the signaling thread. The app talks to Transport on this thread.
117 talk_base::Thread* signaling_thread() { return signaling_thread_; }
118 // Returns the worker thread. The actual networking is done on this thread
[all...] |
| /external/llvm/lib/Support/ |
| Threading.cpp | 83 pthread_t Thread;
95 // Construct and execute the thread.
96 if (::pthread_create(&Thread, &Attr, ExecuteOnThread_Dispatch, &Info) != 0)
99 // Wait for the thread and clean up.
100 ::pthread_join(Thread, 0);
|
| /libcore/luni/src/test/java/libcore/java/net/ |
| ConcurrentCloseTest.java | 34 * Test that Socket.close called on another thread interrupts a thread that's blocked doing
91 new Thread(new Runnable() {
115 new Thread(new Runnable() {
131 final ArrayList<Thread> threads = new ArrayList<Thread>();
134 Thread t = new Thread(new Runnable() {
151 for (Thread t : threads) {
155 for (Thread t : threads)
[all...] |
| /libcore/luni/src/test/java/tests/support/ |
| ThreadPool.java | 79 Thread[] threads = new Thread[activeCount()];
90 private class PooledThread extends Thread {
|
| /libcore/support/src/test/java/tests/net/ |
| StuckServer.java | 44 Thread t = new Thread(new Runnable() {
47 Thread.sleep(ms);
|
| /packages/apps/Music/tests/src/com/android/music/ |
| MusicPlayerStability.java | 63 Thread.sleep(2000);
73 Thread.sleep(PLAY_TIME);
84 Thread.sleep(PLAY_TIME);
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| SingleThreadNamedTaskExecutor.java | 25 * Executor that uses a single thread and an unbounded work queue.
33 private final Thread mWorker;
73 Thread currentThread = Thread.currentThread();
|
| /external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/io/ |
| PipedWriterTest.java | 55 + Thread.currentThread().getName() + "): "
61 Thread rdrThread;
84 rdrThread = new Thread(reader = new PReader(rd), "Constructor(Reader)");
122 rdrThread = new Thread(reader = new PReader(rd), "connect");
139 rdrThread = new Thread(reader = new PReader(pw), "flush");
184 rdrThread = new Thread(reader = new PReader(pw), "writeCII");
329 // wait the reader thread dead
332 // should throw exception since reader thread
344 Thread writeThread = new Thread(writeRunnable)
[all...] |
| /dalvik/vm/ |
| Thread.cpp | 18 * Thread support.
57 // change this to LOGV/LOGD to debug thread activity
64 thread, are visible to code running in the VM and to the debugger. (We
65 don't want the debugger to try to manipulate the thread that listens for
80 Internal native VM threads, such as the finalizer thread, must explicitly
85 thread. The debugger may suspend or resume individual threads, while the
86 GC always suspends all threads. Each thread has a "suspend count" that
88 When the count is zero, the thread is runnable. This allows us to fulfill
89 a debugger requirement: if the debugger suspends a thread, the thread i
250 Thread* thread; local
679 Thread* thread; local
803 Thread* thread; local
[all...] |
| /external/valgrind/main/drd/tests/ |
| thread_name.stderr.exp | 5 Thread 2 (thread_func instance 1):
14 Thread 3 (thread_func instance 2):
23 Thread 4 (thread_func instance 3):
32 Thread 5 (thread_func instance 4):
41 Thread 6 (thread_func instance 5):
50 Thread 7 (thread_func instance 6):
59 Thread 8 (thread_func instance 7):
68 Thread 9 (thread_func instance 8):
77 Thread 10 (thread_func instance 9):
86 Thread 11 (thread_func instance 10)
[all...] |
| /frameworks/base/core/java/android/webkit/ |
| DeviceMotionService.java | 75 assert WebViewCore.THREAD_NAME.equals(Thread.currentThread().getName());
84 assert WebViewCore.THREAD_NAME.equals(Thread.currentThread().getName());
130 assert WebViewCore.THREAD_NAME.equals(Thread.currentThread().getName());
154 * Callbacks happen on the thread on which we registered - the WebCore thread.
158 assert WebViewCore.THREAD_NAME.equals(Thread.currentThread().getName());
174 assert WebViewCore.THREAD_NAME.equals(Thread.currentThread().getName());
|
| /frameworks/base/core/tests/coretests/src/android/content/pm/ |
| PackageHelperTests.java | 91 Thread thread = new Thread(r1); local
92 Thread thread2 = new Thread(r2);
94 thread.start();
104 Thread.sleep(5);
|
| /cts/tests/tests/app/src/android/app/cts/ |
| AlarmManagerTest.java | 88 Thread.sleep(SNOOZE_DELAY + TIME_DELAY);
96 Thread.sleep(SNOOZE_DELAY + TIME_DELAY);
104 Thread.sleep(SNOOZE_DELAY + TIME_DELAY);
112 Thread.sleep(SNOOZE_DELAY + TIME_DELAY);
131 Thread.sleep(TIME_DELAY);
146 Thread.sleep(SNOOZE_DELAY + TIME_DELAY);
149 Thread.sleep(TIME_DELAY);
163 Thread.sleep(SNOOZE_DELAY + TIME_DELAY);
166 Thread.sleep(TIME_DELAY);
169 Thread.sleep(TIME_DELAY)
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| AbstractQueuedLongSynchronizer.java | 56 * information about a thread in the predecessor of its node. A
57 * "status" field in each node keeps track of whether a thread
61 * thread. The status field does NOT control whether threads are
62 * granted locks etc though. A thread may try to acquire if it is
65 * contender thread may need to rewait.
91 * The thread id for each node is kept in its own node, so a
93 * next link to determine which thread it is. Determination of
134 /** waitStatus value to indicate thread has cancelled */
136 /** waitStatus value to indicate successor's thread needs unparking */
138 /** waitStatus value to indicate thread is waiting on condition *
214 volatile Thread thread; field in class:AbstractQueuedLongSynchronizer.Node
[all...] |
| AbstractQueuedSynchronizer.java | 47 * waiting thread (if one exists) must also determine whether it can
58 * held with respect to the current thread, method {@link #release}
75 * thread queues. Typical subclasses requiring serializability will
96 * must be internally thread-safe, and should in general be short and
102 * AbstractOwnableSynchronizer} useful to keep track of the thread
114 * <em>enqueue thread if it is not already queued</em>;
115 * <em>possibly block current thread</em>;
120 * <em>unblock the first queued thread</em>;
126 * enqueuing, a newly acquiring thread may <em>barge</em> ahead of
132 * #getFirstQueuedThread} does not return the current thread.
445 volatile Thread thread; field in class:AbstractQueuedSynchronizer.Node
[all...] |
| /dalvik/vm/native/ |
| java_lang_VMThread.cpp | 25 * static void create(Thread t, long stacksize)
27 * This is eventually called as a result of Thread.start().
42 * static Thread currentThread()
55 * Gets the Thread status. Result is in VM terms, has to be mapped to
56 * Thread.State by interpreted code.
61 Thread* thread; local
65 thread = dvmGetThreadFromThreadObject(thisPtr);
66 if (thread != NULL)
67 result = thread->status
85 Thread* thread; local
108 Thread* thread; local
146 Thread* thread; local
170 Thread* thread; local
200 Thread* thread; local
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| autodetectproxy.cc | 65 Thread::Current()->ProcessMessages(kForever);
66 // Clean up the autodetect socket, from the thread that created it
92 Thread::Current()->Clear(this, MSG_TIMEOUT);
94 Thread::Current()->Dispose(socket_);
98 socket_ = Thread::Current()->socketserver()->CreateAsyncSocket(SOCK_STREAM);
105 Thread::Current()->PostDelayed(2000, this, MSG_TIMEOUT);
109 Thread::Current()->Clear(this, MSG_TIMEOUT);
117 Thread::Current()->Quit();
|
| /external/chromium/third_party/libjingle/source/talk/p2p/client/ |
| socketmonitor.cc | 39 talk_base::Thread* worker_thread,
40 talk_base::Thread* monitor_thread) {
68 ASSERT(talk_base::Thread::Current() == channel_thread_);
80 ASSERT(talk_base::Thread::Current() == channel_thread_);
90 ASSERT(talk_base::Thread::Current() == channel_thread_);
96 ASSERT(talk_base::Thread::Current() == monitoring_thread_);
113 ASSERT(talk_base::Thread::Current() == channel_thread_);
147 // Signal the monitoring thread, start another poll timer
|
| /external/chromium/third_party/libjingle/source/talk/session/phone/ |
| channelmanager.h | 36 #include "talk/base/thread.h"
47 // ChannelManager allows the MediaEngine to run on a separate thread, and takes
58 // Creates the channel manager, and specifies the worker thread to use.
59 explicit ChannelManager(talk_base::Thread* worker);
62 ChannelManager(MediaEngine* me, DeviceManager* dm, talk_base::Thread* worker);
65 // Accessors for the worker thread, allowing it to be set after construction,
67 talk_base::Thread* worker_thread() const { return worker_thread_; }
68 bool set_worker_thread(talk_base::Thread* thread) {
70 worker_thread_ = thread;
[all...] |
| /cts/tests/tests/media/src/android/media/cts/ |
| SoundPoolTest.java | 224 Thread.sleep(waitMsec);
227 Thread.sleep(waitMsec);
229 Thread.sleep(waitMsec);
231 Thread.sleep(waitMsec);
233 Thread.sleep(waitMsec);
240 Thread.sleep(waitMsec);
244 Thread.sleep(waitMsec);
249 Thread.sleep(waitMsec * 10);
282 Thread.sleep(waitMsec);
287 Thread.sleep(waitMsec * 4)
[all...] |
| /external/v8/src/ |
| platform-openbsd.cc | 61 // 0 is never a valid thread id on OpenBSD since tids and pids share a
362 class Thread::PlatformData : public Malloced {
366 pthread_t thread_; // Thread handle for pthread.
370 Thread::Thread(Isolate* isolate, const Options& options)
378 Thread::Thread(Isolate* isolate, const char* name)
386 Thread::~Thread() {
392 Thread* thread = reinterpret_cast<Thread*>(arg) local
[all...] |
| platform-cygwin.cc | 52 // 0 is never a valid thread id
365 class Thread::PlatformData : public Malloced {
368 pthread_t thread_; // Thread handle for pthread.
374 Thread::Thread(Isolate* isolate, const Options& options)
382 Thread::Thread(Isolate* isolate, const char* name)
390 Thread::~Thread() {
396 Thread* thread = reinterpret_cast<Thread*>(arg) local
[all...] |
| platform-macos.cc | 78 // 0 is never a valid thread id on MacOSX since a ptread_t is
395 class Thread::PlatformData : public Malloced {
398 pthread_t thread_; // Thread handle for pthread.
401 Thread::Thread(Isolate* isolate, const Options& options)
409 Thread::Thread(Isolate* isolate, const char* name)
417 Thread::~Thread() {
434 ASSERT(Thread::kMaxThreadNameLength <= kMaxNameLength)
440 Thread* thread = reinterpret_cast<Thread*>(arg); local
[all...] |
