| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/test/ |
| test_sys.py | 306 import thread namespace
318 import threading, thread namespace
321 # Spawn a thread that blocks at a known place. Then the main
322 # thread does sys._current_frames(), and verifies that the frames
326 thread_info = [] # the thread's id
332 thread_info.append(thread.get_ident())
336 t = threading.Thread(target=f123)
348 main_id = thread.get_ident()
352 # Verify that the captured main-thread frame is _this_ frame.
356 # Verify that the captured thread frame is blocked in g456, calle
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/ |
| threading.py | 0 """Thread module emulating a subset of Java's threading model."""
6 import thread namespace
31 'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Thread',
34 _start_new_thread = thread.start_new_thread
35 _allocate_lock = thread.allocate_lock
36 _get_ident = thread.get_ident
37 ThreadError = thread.error
38 del thread
72 name = "<OS thread %d>" % ident
92 The func will be passed to sys.setprofile() for each thread, before it
[all...] |
| /frameworks/base/services/core/java/com/android/server/am/ |
| ActivityManagerService.java | 829 * Thread-local storage used to carry caller permissions over through
1607 Thread thread = new Thread() { local
[all...] |
| /external/guava/guava-tests/test/com/google/common/cache/ |
| CacheLoadingTest.java | 1986 Thread thread = new Thread(new Runnable() { local
[all...] |
| /frameworks/base/services/core/java/com/android/server/net/ |
| NetworkStatsService.java | 273 HandlerThread thread = new HandlerThread(TAG); local
274 thread.start();
275 mHandler = new Handler(thread.getLooper(), mHandlerCallback);
715 // on background handler thread, and verified CONNECTIVITY_INTERNAL
727 // on background handler thread, and verified CONNECTIVITY_INTERNAL
736 // on background handler thread, and verified UPDATE_DEVICE_STATS
748 // on background handler thread, and UID_REMOVED is protected
768 // On background handler thread, and USER_REMOVED is protected
[all...] |
| /frameworks/base/tests/CoreTests/android/core/ |
| SSLSocketTest.java | 161 Thread.sleep(delay * 1000);
333 * a different thread was sitting in a blocking read or write.
340 Thread reader = new Thread() {
354 Thread closer = new Thread() {
358 Thread.sleep(5000);
394 Thread[] threads = new Thread[10];
397 threads[i] = new Thread() {
841 Thread thread = new Thread() { local
871 Thread thread = new Thread() { local
[all...] |
| /frameworks/opt/net/voip/src/java/com/android/server/sip/ |
| SipService.java | 1213 HandlerThread thread = new HandlerThread("SipService.Executor"); local
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/ |
| SocketTest.java | 118 Thread t;
123 Thread serverThread = new Thread(server);
128 Thread clientThread = new Thread(client);
822 Thread thread = new Thread(runnable, "Socket.getOutputStream"); local
823 thread.start();
832 Thread.sleep(200)
[all...] |
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
| ScannerTest.java | 5519 Thread thread = new Thread(new Runnable() { local
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ThreadPoolExecutorSubclassTest.java | 27 Thread thread; field in class:ThreadPoolExecutorSubclassTest.CustomTask
50 if (mayInterrupt && thread != null)
51 thread.interrupt();
63 thread = Thread.currentThread();
79 thread = null;
167 protected void beforeExecute(Thread t, Runnable r) {
190 public Thread newThread(Runnable r) {
192 return new Thread(r)
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/avrcp/ |
| Avrcp.java | 172 HandlerThread thread = new HandlerThread("BluetoothAvrcpHandler"); local
173 thread.start();
174 Looper looper = thread.getLooper();
[all...] |
| /packages/apps/Bluetooth/src/com/android/bluetooth/gatt/ |
| ScanManager.java | 95 HandlerThread thread = new HandlerThread("BluetoothScanManager"); local
96 thread.start();
97 mHandler = new ClientHandler(thread.getLooper());
[all...] |
| /packages/apps/Calendar/src/com/android/calendar/alerts/ |
| AlertService.java | 213 Thread.sleep(5000);
1101 HandlerThread thread = new HandlerThread("AlertService", local
[all...] |
| /packages/apps/Mms/src/com/android/mms/data/ |
| Conversation.java | 83 // The thread ID of this conversation. Can be zero in the case of a
85 // types and we have not hit the database yet to create a thread.
140 * Find the conversation matching the provided thread ID.
249 // it's a thread id for a conversation
344 * work is dispatched to a background thread. This function should
345 * always be called from the UI thread.
392 LogTag.debug("markAsRead: update read/seen for thread uri: " +
400 // canceling the notification of the thread that was just marked read.
413 * can mark messages as read. Only call this function on the UI thread.
443 * Return the Uri for all messages in the given thread ID
1094 Thread thread = new Thread(new Runnable() { local
1109 Thread thread = new Thread(new Runnable() { local
[all...] |
| /art/runtime/gc/collector/ |
| mark_sweep.cc | 43 #include "thread-inl.h"
79 // If true, revoke the rosalloc thread-local buffers at the
85 WriterMutexLock mu(Thread::Current(), *Locks::heap_bitmap_lock_);
131 ReaderMutexLock mu(Thread::Current(), *Locks::heap_bitmap_lock_);
141 Thread* self = Thread::Current();
171 void MarkSweep::ProcessReferences(Thread* self) {
180 Thread* self = Thread::Current();
195 // Need to revoke all the thread local allocation stacks since we just swapped the allocatio
975 mark_sweep_->GetHeap()->RevokeRosAllocThreadLocalBuffers(thread); variable
[all...] |
| /dalvik/hit/src/com/android/hit/ |
| HprofParser.java | 356 ThreadObj thread = mState.getThread(threadSerialNumber); local
357 StackTrace trace = mState.getStackTraceAtDepth(thread.mStackTrace,
372 ThreadObj thread = mState.getThread(threadSerialNumber); local
373 StackTrace trace = mState.getStackTraceAtDepth(thread.mStackTrace,
387 ThreadObj thread = mState.getThread(threadSerialNumber); local
388 StackTrace trace = mState.getStackTrace(thread.mStackTrace);
411 ThreadObj thread = mState.getThread(threadSerialNumber); local
412 StackTrace stack = mState.getStackTrace(thread.mStackTrace);
426 ThreadObj thread = new ThreadObj(id, stackSerialNumber); local
428 mState.addThread(thread, threadSerialNumber)
577 ThreadObj thread = mState.getThread(threadSerialNumber); local
[all...] |
| /development/ndk/platforms/android-3/include/linux/raid/ |
| md_k.h | 102 struct mdk_thread_s *thread; member in struct:mddev_s
|
| /device/generic/goldfish/gps/ |
| gps_qemu.c | 575 /* commands sent to the gps thread */
588 pthread_t thread; member in struct:__anon3037
598 // tell the thread to quit, and wait for it
602 pthread_join(s->thread, &dummy);
673 /* this is the main thread, it waits for commands from gps_state_start/stop and,
693 D("gps thread running");
706 D("gps thread received %d events", nevents);
725 D("gps thread quitting on demand");
730 D("gps thread starting location_cb=%p", state->callbacks.location_cb);
737 D("gps thread stopping")
[all...] |
| /external/chromium_org/base/test/ |
| trace_event_analyzer.h | 52 // [Thread 1 tracing code]
54 // [Thread 2 tracing code]
94 // ProcessThreadID contains a Process ID and Thread ID.
142 // Process ID and Thread ID.
143 ProcessThreadID thread; member in struct:trace_analyzer::TraceEvent
233 static Query EventThreadIs(const TraceEvent::ProcessThreadID& thread) {
234 return EventPidIs(thread.process_id) && EventTidIs(thread.thread_id);
304 static Query OtherThreadIs(const TraceEvent::ProcessThreadID& thread) {
305 return OtherPidIs(thread.process_id) && OtherTidIs(thread.thread_id)
[all...] |
| /external/chromium_org/chrome/renderer/ |
| chrome_content_renderer_client.cc | 250 RenderThread* thread = RenderThread::Get(); local
272 thread->AddObserver(spellcheck_.get());
286 thread->AddObserver(chrome_observer_.get());
287 thread->AddObserver(extension_dispatcher_.get());
289 thread->AddObserver(phishing_classifier_.get());
291 thread->AddObserver(visited_link_slave_.get());
292 thread->AddObserver(prerender_dispatcher_.get());
293 thread->AddObserver(search_bouncer_.get());
296 thread->AddFilter(webrtc_logging_message_filter_.get());
298 thread->AddFilter(new CastIPCDispatcher
1335 RenderThread* thread = RenderThread::Get(); local
[all...] |
| /external/chromium_org/content/renderer/ |
| renderer_webkitplatformsupport_impl.cc | 382 RenderThread* thread = RenderThread::Get(); local
383 if (thread) // NULL in unittests.
384 thread->Send(new ViewHostMsg_SuddenTerminationChanged(enabled));
669 RenderThreadImpl* thread = RenderThreadImpl::current(); local
670 GpuChannelHost* host = thread->EstablishGpuChannelSync(
679 RenderThreadImpl* thread = RenderThreadImpl::current(); local
680 // thread can be NULL in tests.
681 return thread && thread->compositor_message_loop_proxy().get();
685 RenderThreadImpl* thread = RenderThreadImpl::current() local
690 RenderThreadImpl* thread = RenderThreadImpl::current(); local
695 RenderThreadImpl* thread = RenderThreadImpl::current(); local
[all...] |
| /external/chromium_org/third_party/WebKit/Source/devtools/front_end/timeline/ |
| TimelineModelImpl.js | 437 thread: function()
439 return this._record.thread;
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/layout_tests/ |
| run_webkit_tests_integrationtest.py | 40 import thread namespace
[all...] |
| /external/chromium_org/third_party/leveldatabase/src/db/ |
| db_bench.cc | 196 // Just keep the messages from one thread
246 // Rate is computed on actual elapsed time, not the sum of per-thread
274 // Each thread goes through the following states:
287 // Per-thread state for concurrent executions of the same benchmark.
488 num_threads++; // Add extra thread for writing
535 ThreadState* thread; member in struct:leveldb::__anon16089::RandomGenerator::Benchmark::ThreadArg
542 ThreadState* thread = arg->thread; local
554 thread->stats.Start();
555 (arg->bm->*(arg->method))(thread);
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| port.h | 41 #include "talk/base/thread.h"
118 Port(talk_base::Thread* thread, talk_base::PacketSocketFactory* factory,
121 Port(talk_base::Thread* thread, const std::string& type,
150 // The thread on which this port performs its I/O.
151 talk_base::Thread* thread() { return thread_; } function in class:cricket::Port
351 talk_base::Thread* thread_;
|
