/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/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/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/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/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/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/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/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/python/cpython2/Lib/test/ |
D | test_threading.py | 10 thread = test.test_support.import_module('thread') variable 35 class TestThread(threading.Thread): 37 threading.Thread.__init__(self, name=name) 93 t = TestThread("<thread %d>"%i, self, sema, mutex, numrunning) 112 # The ident still must work for the main thread and dummy threads. 119 thread.start_new_thread(f, ()) 125 # run with a small(ish) thread stack size (256kB) 128 print 'with 256kB thread stack size...' 131 except thread.error: 132 self.skipTest('platform does not support changing thread stack size') [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/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/python/cpython2/Doc/library/ |
D | threading.rst | 12 level :mod:`thread` module. 16 :mod:`threading` cannot be used because :mod:`thread` is missing. 29 Starting with Python 2.5, several Thread methods raise :exc:`RuntimeError` 34 In CPython, due to the :term:`Global Interpreter Lock`, only one thread 48 Return the number of :class:`Thread` objects currently alive. The returned 60 thread. 68 Return the current :class:`Thread` object, corresponding to the caller's thread 69 of control. If the caller's thread of control was not created through the 70 :mod:`threading` module, a dummy thread object with limited functionality is 79 Return a list of all :class:`Thread` objects currently alive. The list [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/python/cpython2/Lib/ |
D | threading.py | 1 """Thread module emulating a subset of Java's threading model.""" 6 import thread 32 'Lock', 'RLock', 'Semaphore', 'BoundedSemaphore', 'Thread', 35 _start_new_thread = thread.start_new_thread 36 _allocate_lock = thread.allocate_lock 37 _get_ident = thread.get_ident 38 ThreadError = thread.error 39 del thread 73 name = "<OS thread %d>" % ident 93 The func will be passed to sys.setprofile() for each thread, before its [all …]
|
/external/autotest/client/tests/monotonic_time/src/ |
D | threads.c | 19 typedef struct thread { struct 20 pthread_t thread; member 31 * Helper function to run a thread on a specific set of CPUs. argument 35 thread_t *thread = arg; in run_thread() local 38 if (sched_setaffinity(0, sizeof thread->cpus, &thread->cpus) < 0) in run_thread() 41 result = thread->func(thread->arg); in run_thread() 58 thread_t *thread; in create_per_cpu_threads() local 64 thread = &threads[num_threads++]; in create_per_cpu_threads() 65 thread->func = func; in create_per_cpu_threads() 66 thread->arg = arg; in create_per_cpu_threads() [all …]
|