| /external/valgrind/memcheck/tests/ |
| D | err_disable4.stderr.exp | 4 WARNING: exiting thread has error reporting disabled.
7 WARNING: exiting thread has error reporting disabled.
10 WARNING: exiting thread has error reporting disabled.
13 WARNING: exiting thread has error reporting disabled.
16 WARNING: exiting thread has error reporting disabled.
19 WARNING: exiting thread has error reporting disabled.
22 WARNING: exiting thread has error reporting disabled.
25 WARNING: exiting thread has error reporting disabled.
28 WARNING: exiting thread has error reporting disabled.
31 WARNING: exiting thread has error reporting disabled.
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | thread_unittest.cc | 17 #include "webrtc/base/thread.h"
52 Thread* post_thread, MessageHandler* phandler) in SocketClient()
77 Thread* post_thread_;
84 MessageClient(Thread* pth, Socket* socket) in MessageClient()
103 class CustomThread : public rtc::Thread {
110 return Thread::WrapCurrent(); in WrapCurrent()
113 Thread::UnwrapCurrent(); in UnwrapCurrent()
118 // A thread that does nothing when it runs and signals an event
120 class SignalWhenDestroyedThread : public Thread {
171 // Function objects to test Thread::Invoke.
[all …]
|
| D | thread.cc | 11 #include "webrtc/base/thread.h"
44 Thread* Thread::Current() { in Current()
57 // maintaining thread safety using immutability within context of GCD dispatch in ThreadManager()
78 Thread *ThreadManager::CurrentThread() { in CurrentThread()
79 return static_cast<Thread *>(pthread_getspecific(key_)); in CurrentThread()
82 void ThreadManager::SetCurrentThread(Thread *thread) { in SetCurrentThread() argument
83 pthread_setspecific(key_, thread); in SetCurrentThread()
100 Thread *ThreadManager::CurrentThread() { in CurrentThread()
101 return static_cast<Thread *>(TlsGetValue(key_)); in CurrentThread()
104 void ThreadManager::SetCurrentThread(Thread *thread) { in SetCurrentThread() argument
[all …]
|
| D | thread.h | 32 class Thread; variable
43 Thread* CurrentThread();
44 void SetCurrentThread(Thread* thread);
46 // Returns a thread object with its thread_ ivar set
47 // to whatever the OS uses to represent the thread.
48 // If there already *is* a Thread object corresponding to this thread,
49 // this method will return that. Otherwise it creates a new Thread
59 Thread *WrapCurrentThread();
76 Thread *thread; member
84 virtual void Run(Thread* thread) = 0;
[all …]
|
| D | asyncinvoker.h | 18 #include "webrtc/base/thread.h"
22 // Invokes function objects (aka functors) asynchronously on a Thread, and
28 // AsyncInvoker does not own the thread it calls functors on.
39 // class that owns the Thread and AsyncInvoker objects, and then call its
45 // void FireAsyncTaskWithResult(Thread* thread, int x) {
48 // thread, Bind(&MyClass::AsyncTaskWithResult, this, x),
51 // void FireAnotherAsyncTask(Thread* thread) {
54 // thread, Bind(&MyClass::AnotherAsyncTask, this));
74 // Call |functor| asynchronously on |thread|, with no callback upon
77 void AsyncInvoke(Thread* thread, const FunctorT& functor, uint32_t id = 0) {
[all …]
|
| /external/chromium-trace/catapult/systrace/systrace/test_data/ |
| D | atrace_thread_names | 1 …thread poo', 13679: 'Heap thread poo', 13680: 'Signal Catcher', 13681: 'JDWP', 169: '/system/bin/l…
|
| /external/mockito/src/main/java/org/mockito/internal/util/concurrent/ |
| D | DetachedThreadLocal.java | 9 …* A detached local that allows for explicit control of setting and removing values from a thread-l…
12 * Instances of this class are non-blocking and fully thread safe.
16 final WeakConcurrentMap<Thread, T> map;
20 case THREAD: in DetachedThreadLocal()
22 map = new WeakConcurrentMap<Thread, T>(cleaner == Cleaner.THREAD) { in DetachedThreadLocal()
24 protected T defaultValue(Thread key) { in DetachedThreadLocal()
30 map = new WeakConcurrentMap.WithInlinedExpunction<Thread, T>() { in DetachedThreadLocal()
32 protected T defaultValue(Thread key) { in DetachedThreadLocal()
43 return map.get(Thread.currentThread()); in get()
47 map.put(Thread.currentThread(), value); in set()
[all …]
|
| /external/libchrome/base/threading/ |
| D | platform_thread_unittest.cc | 24 // Trivial tests that thread runs and doesn't crash on create, join, or detach -
46 TrivialThread thread; in TEST() local
49 ASSERT_FALSE(thread.run_event().IsSignaled()); in TEST()
50 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle)); in TEST()
52 ASSERT_TRUE(thread.run_event().IsSignaled()); in TEST()
56 TrivialThread thread[10]; in TEST() local
57 PlatformThreadHandle handle[arraysize(thread)]; in TEST()
59 for (size_t n = 0; n < arraysize(thread); n++) in TEST()
60 ASSERT_FALSE(thread[n].run_event().IsSignaled()); in TEST()
61 for (size_t n = 0; n < arraysize(thread); n++) in TEST()
[all …]
|
| D | thread.h | 28 // A simple thread abstraction that establishes a MessageLoop on a new thread.
29 // The consumer uses the MessageLoop of the thread to cause code to execute on
30 // the thread. When this object is destroyed the thread is terminated. All
31 // pending tasks queued on the thread's message loop will run to completion
32 // before the thread is terminated.
34 // WARNING! SUBCLASSES MUST CALL Stop() IN THEIR DESTRUCTORS! See ~Thread().
36 // After the thread is stopped, the destruction sequence is:
38 // (1) Thread::CleanUp()
41 class BASE_EXPORT Thread : PlatformThread::Delegate {
51 // Specifies the type of message loop that will be allocated on the thread.
[all …]
|
| D | thread.cc | 5 #include "base/threading/thread.h"
25 // We use this thread-local variable to record whether or not a thread exited
28 // using a Thread to setup and run a MessageLoop.
37 Thread::SetThreadWasQuitProperly(true); in ThreadQuitHelper()
40 Thread::Options::Options() in Options()
47 Thread::Options::Options(MessageLoop::Type type, in Options()
55 Thread::Options::Options(const Options& other) = default;
57 Thread::Options::~Options() { in ~Options()
60 Thread::Thread(const std::string& name) in Thread() function in base::Thread
78 Thread::~Thread() { in ~Thread()
[all …]
|
| D | platform_thread.h | 7 // You should instead be using a message-loop driven Thread, see thread.h.
35 // Used for thread checking and debugging.
38 // check if we are on the same thread or not by using ==. These are safe
41 // after a thread dies, so a PlatformThreadRef cannot be reliably used
42 // to distinguish a new thread from an old, dead thread.
100 // Valid values for priority of Thread::Options and SimpleThread::Options, and
113 // A namespace for low-level thread functions.
116 // Implement this interface to run code on a background thread. Your
117 // ThreadMain method will be called on the newly created thread.
126 // Gets the current thread id, which may be useful for logging purposes.
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ThreadFactoryBuilderTest.java | 25 import java.lang.Thread.UncaughtExceptionHandler;
44 @Override public void uncaughtException(Thread t, Throwable e) {
58 Thread thread = threadFactory.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults() local
59 checkThreadPoolName(thread, 1); in testThreadFactoryBuilder_defaults()
61 Thread defaultThread = in testThreadFactoryBuilder_defaults()
63 assertEquals(defaultThread.isDaemon(), thread.isDaemon()); in testThreadFactoryBuilder_defaults()
64 assertEquals(defaultThread.getPriority(), thread.getPriority()); in testThreadFactoryBuilder_defaults()
65 assertSame(defaultThread.getThreadGroup(), thread.getThreadGroup()); in testThreadFactoryBuilder_defaults()
67 thread.getUncaughtExceptionHandler()); in testThreadFactoryBuilder_defaults()
70 thread.start(); in testThreadFactoryBuilder_defaults()
[all …]
|
| /external/libmojo/third_party/catapult/devil/devil/utils/ |
| D | reraiser_thread.py | 5 """Thread and ThreadGroup that reraise exceptions on the main thread."""
22 def LogThreadStack(thread, error_log_func=logging.critical): argument
23 """Log the stack for the given thread.
26 thread: a threading.Thread instance.
29 stack = sys._current_frames()[thread.ident]
31 error_log_func('Stack dump for thread %r', thread.name)
40 class ReraiserThread(threading.Thread):
41 """Thread class that can reraise exceptions."""
44 """Initialize thread.
47 func: callable to call on a new thread.
[all …]
|
| /external/chromium-trace/catapult/devil/devil/utils/ |
| D | reraiser_thread.py | 5 """Thread and ThreadGroup that reraise exceptions on the main thread."""
22 def LogThreadStack(thread, error_log_func=logging.critical): argument
23 """Log the stack for the given thread.
26 thread: a threading.Thread instance.
29 stack = sys._current_frames()[thread.ident]
31 error_log_func('Stack dump for thread %r', thread.name)
40 class ReraiserThread(threading.Thread):
41 """Thread class that can reraise exceptions."""
44 """Initialize thread.
47 func: callable to call on a new thread.
[all …]
|
| /external/libmojo/mojo/edk/system/ |
| D | waiter_unittest.cc | 80 Waiter waiter_; // Thread-safe.
98 // Awake immediately after thread start. in TEST()
100 WaitingThread thread(10 * test::EpsilonDeadline()); in TEST() local
101 thread.Start(); in TEST()
102 thread.waiter()->Awake(MOJO_RESULT_OK, 1); in TEST()
103 thread.WaitUntilDone(&result, &context, &elapsed); in TEST()
109 // Awake before after thread start. in TEST()
111 WaitingThread thread(10 * test::EpsilonDeadline()); in TEST() local
112 thread.waiter()->Awake(MOJO_RESULT_CANCELLED, 2); in TEST()
113 thread.Start(); in TEST()
[all …]
|
| D | awakable_list_unittest.cc | 26 // Cancel immediately after thread start. in TEST()
29 test::SimpleWaiterThread thread(&result, &context); in TEST() local
30 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_READABLE, 1); in TEST()
31 thread.Start(); in TEST()
34 awakable_list.Remove(thread.waiter()); in TEST()
35 } // Join |thread|. in TEST()
39 // Cancel before after thread start. in TEST()
42 test::SimpleWaiterThread thread(&result, &context); in TEST() local
43 awakable_list.Add(thread.waiter(), MOJO_HANDLE_SIGNAL_WRITABLE, 2); in TEST()
45 thread.Start(); in TEST()
[all …]
|
| /external/deqp/framework/delibs/dethread/unix/ |
| D | deThreadUnix.c | 2 * drawElements Thread Library
21 * \brief Unix implementation of thread management.
51 pthread_t thread; member
54 } Thread; typedef
56 DE_STATIC_ASSERT(sizeof(deThread) >= sizeof(Thread*));
60 Thread* thread = (Thread*)entryPtr; in startThread() local
61 deThreadFunc func = thread->func; in startThread()
62 void* arg = thread->arg; in startThread()
64 /* Start actual thread. */ in startThread()
73 Thread* thread = (Thread*)deCalloc(sizeof(Thread)); in deThread_create() local
[all …]
|
| /external/elfutils/libdwfl/ |
| D | dwfl_frame.c | 46 Ebl *ebl = state->thread->process->ebl; in state_fetch_pc()
73 Dwfl_Thread *thread = state->thread; in state_free() local
74 assert (thread->unwound == state); in state_free()
75 thread->unwound = state->unwound; in state_free()
80 thread_free_all_states (Dwfl_Thread *thread) in thread_free_all_states() argument
82 while (thread->unwound) in thread_free_all_states()
83 state_free (thread->unwound); in thread_free_all_states()
87 state_alloc (Dwfl_Thread *thread) in state_alloc() argument
89 assert (thread->unwound == NULL); in state_alloc()
90 Ebl *ebl = thread->process->ebl; in state_alloc()
[all …]
|
| /external/libcxx/include/ |
| D | thread | 2 //===--------------------------- thread -----------------------------------===//
16 thread synopsis
23 class thread
29 thread() noexcept;
30 template <class F, class ...Args> explicit thread(F&& f, Args&&... args);
31 ~thread();
33 thread(const thread&) = delete;
34 thread(thread&& t) noexcept;
36 thread& operator=(const thread&) = delete;
37 thread& operator=(thread&& t) noexcept;
[all …]
|
| /external/nist-sip/java/gov/nist/core/ |
| D | ThreadAuditor.java | 6 * Thread Auditor class:
15 * the thread can periodically ping the auditor.
25 private Map<Thread,ThreadHandle> threadHandles = new HashMap<Thread,ThreadHandle>();
32 /// Set to true when the thread pings, periodically reset to false by the auditor
35 /// Thread being monitored
36 private Thread thread; field in ThreadAuditor.ThreadHandle
38 /// Thread auditor monitoring this thread
44 thread = Thread.currentThread(); in ThreadHandle()
48 /// Called by the auditor thread to check the ping status of the thread
53 /// Called by the auditor thread to reset the ping status of the thread
[all …]
|
| /external/valgrind/drd/tests/ |
| D | tc22_exit_w_lock.stderr.exp-32bit | 2 Conflicting load by thread 1 at 0x........ size 4
9 Other segment start (thread 2)
10 (thread finished, call stack no longer available)
11 Other segment end (thread 2)
12 (thread finished, call stack no longer available)
14 Conflicting store by thread 1 at 0x........ size 4
21 Other segment start (thread 2)
22 (thread finished, call stack no longer available)
23 Other segment end (thread 2)
24 (thread finished, call stack no longer available)
[all …]
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/pthread_rwlock_unlock/ |
| D | 1-1.c | 19 * 2. Main thread read lock 'rwlock'
20 * 3. Create a child thread, the thread read lock 'rwlock', should not block
21 * 4. Child thread unlock 'rwlock', while the main thread still hold the read lock.
22 * 5. Child thread read lock 'rwlock' again, should succeed, then unlock again
23 * 6. Child thread write lock 'rwlock', should block
24 * 7. Main thread unlock the read lock, the 'rwlock' is in unlocked state
25 * 8. Child thread should get the lock for writing.
37 /* thread_state indicates child thread state:
38 1: not in child thread yet;
39 2: just enter child thread ;
[all …]
|
| /external/webrtc/webrtc/modules/utility/source/ |
| D | process_thread_impl_unittest.cc | 57 ProcessThreadImpl thread("ProcessThread"); in TEST() local
58 thread.Start(); in TEST()
59 thread.Stop(); in TEST()
63 ProcessThreadImpl thread("ProcessThread"); in TEST() local
65 thread.Start(); in TEST()
66 thread.Stop(); in TEST()
70 // Verifies that we get at least call back to Process() on the worker thread.
72 ProcessThreadImpl thread("ProcessThread"); in TEST() local
73 thread.Start(); in TEST()
82 EXPECT_CALL(module, ProcessThreadAttached(&thread)).Times(1); in TEST()
[all …]
|
| /external/libchrome/base/memory/ |
| D | weak_ptr_unittest.cc | 15 #include "base/threading/thread.h"
31 Thread creator_thread("creator_thread"); in NewObject()
36 DCHECK(result); // We synchronized on thread destruction above. in NewObject()
64 // and delete objects on a background thread.
65 class BackgroundThread : public Thread {
67 BackgroundThread() : Thread("owner_thread") {} in BackgroundThread()
366 // Test that it is OK to create an object that supports WeakPtr on one thread, in TEST()
376 // thread, but use it on another. This tests that we do not trip runtime in TEST()
385 // Move object ownership to another thread by releasing all weak pointers in TEST()
386 // on the original thread first, and then establish WeakPtr on a different in TEST()
[all …]
|
| /external/google-breakpad/src/tools/linux/md2core/ |
| D | minidump-2-core.cc | 142 typedef struct prstatus { /* Information about thread; includes CPU reg*/
209 struct Thread { struct
222 std::vector<Thread> threads;
252 ParseThreadRegisters(CrashedProcess::Thread* thread, in ParseThreadRegisters() argument
256 thread->regs.ebx = rawregs->ebx; in ParseThreadRegisters()
257 thread->regs.ecx = rawregs->ecx; in ParseThreadRegisters()
258 thread->regs.edx = rawregs->edx; in ParseThreadRegisters()
259 thread->regs.esi = rawregs->esi; in ParseThreadRegisters()
260 thread->regs.edi = rawregs->edi; in ParseThreadRegisters()
261 thread->regs.ebp = rawregs->ebp; in ParseThreadRegisters()
[all …]
|