| /external/elfutils/libdwfl/ |
| D | dwfl_frame.c | 49 Ebl *ebl = state->thread->process->ebl; in state_fetch_pc()
76 Dwfl_Thread *thread = state->thread; in state_free() local
77 assert (thread->unwound == state); in state_free()
78 thread->unwound = state->unwound; in state_free()
83 thread_free_all_states (Dwfl_Thread *thread) in thread_free_all_states() argument
85 while (thread->unwound) in thread_free_all_states()
86 state_free (thread->unwound); in thread_free_all_states()
90 state_alloc (Dwfl_Thread *thread) in state_alloc() argument
92 assert (thread->unwound == NULL); in state_alloc()
93 Ebl *ebl = thread->process->ebl; in state_alloc()
[all …]
|
| /external/adhd/cras/src/server/ |
| D | audio_thread.c | 180 static int audio_thread_send_response(struct audio_thread *thread, int rc) in audio_thread_send_response() argument
182 return write(thread->to_main_fds[1], &rc, sizeof(rc)); in audio_thread_send_response()
224 static int audio_thread_read_command(struct audio_thread *thread, in audio_thread_read_command() argument
233 thread->to_thread_fds[0], buf, sizeof(msg->length)); in audio_thread_read_command()
241 rc = read_until_finished(thread->to_thread_fds[0], in audio_thread_read_command()
255 static int append_stream(struct audio_thread *thread, in append_stream() argument
270 DL_SEARCH_SCALAR(thread->open_devs[stream->direction], open_dev, in append_stream()
347 DL_FOREACH(thread->open_devs[stream->direction], open_dev) { in append_stream()
362 static int thread_add_open_dev(struct audio_thread *thread, in thread_add_open_dev() argument
367 DL_SEARCH_SCALAR(thread->open_devs[iodev->direction], in thread_add_open_dev()
[all …]
|
| /external/deqp/framework/delibs/dethread/unix/ |
| D | deThreadUnix.c | 53 pthread_t thread; member
62 Thread* thread = (Thread*)entryPtr; in startThread() local
63 deThreadFunc func = thread->func; in startThread()
64 void* arg = thread->arg; in startThread()
75 Thread* thread = (Thread*)deCalloc(sizeof(Thread)); in deThread_create() local
77 if (!thread) in deThread_create()
80 thread->func = func; in deThread_create()
81 thread->arg = arg; in deThread_create()
85 deFree(thread); in deThread_create()
95 deFree(thread); in deThread_create()
[all …]
|
| /external/libchrome/base/threading/ |
| D | platform_thread_unittest.cc | 44 TrivialThread thread; in TEST() local
47 ASSERT_FALSE(thread.run_event().IsSignaled()); in TEST()
48 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle)); in TEST()
50 ASSERT_TRUE(thread.run_event().IsSignaled()); in TEST()
54 TrivialThread thread[10]; in TEST() local
55 PlatformThreadHandle handle[arraysize(thread)]; in TEST()
57 for (size_t n = 0; n < arraysize(thread); n++) in TEST()
58 ASSERT_FALSE(thread[n].run_event().IsSignaled()); in TEST()
59 for (size_t n = 0; n < arraysize(thread); n++) in TEST()
60 ASSERT_TRUE(PlatformThread::Create(0, &thread[n], &handle[n])); in TEST()
[all …]
|
| D | simple_thread_unittest.cc | 131 DelegateSimpleThread thread(&runner, "int_setter"); in TEST() local
132 EXPECT_FALSE(thread.HasBeenStarted()); in TEST()
133 EXPECT_FALSE(thread.HasBeenJoined()); in TEST()
136 thread.Start(); in TEST()
137 EXPECT_TRUE(thread.HasBeenStarted()); in TEST()
138 EXPECT_FALSE(thread.HasBeenJoined()); in TEST()
140 thread.Join(); in TEST()
141 EXPECT_TRUE(thread.HasBeenStarted()); in TEST()
142 EXPECT_TRUE(thread.HasBeenJoined()); in TEST()
152 DelegateSimpleThread thread(&runner, "event_waiter"); in TEST() local
[all …]
|
| /external/oj-libjdwp/src/share/back/ |
| D | threadControl.c | 65 jthread thread; member
112 static jvmtiError threadControl_removeDebugThread(jthread thread);
129 jthread thread; member
141 getStackDepth(jthread thread) in getStackDepth() argument
147 (gdata->jvmti, thread, &count); in getStackDepth()
156 threadState(jthread thread, jint *pstate) in threadState() argument
160 (gdata->jvmti, thread, pstate); in threadState()
165 setThreadLocalStorage(jthread thread, ThreadNode *node) in setThreadLocalStorage() argument
170 (gdata->jvmti, thread, (void*)node); in setThreadLocalStorage()
182 getThreadLocalStorage(jthread thread) in getThreadLocalStorage() argument
[all …]
|
| D | stepControl.c | 36 getFrameCount(jthread thread) in getFrameCount() argument
42 (gdata->jvmti, thread, &count); in getFrameCount()
62 enableStepping(jthread thread) in enableStepping() argument
66 LOG_STEP(("enableStepping: thread=%p", thread)); in enableStepping()
69 thread); in enableStepping()
76 disableStepping(jthread thread) in disableStepping() argument
80 LOG_STEP(("disableStepping: thread=%p", thread)); in disableStepping()
83 thread); in disableStepping()
90 getFrameLocation(jthread thread, in getFrameLocation() argument
100 (gdata->jvmti, thread, 0, pmethod, plocation); in getFrameLocation()
[all …]
|
| D | ThreadReferenceImpl.c | 38 jthread thread; in name() local
42 thread = inStream_readThreadRef(env, in); in name()
47 if (threadControl_isDebugThread(thread)) { in name()
60 (gdata->jvmti, thread, &info); in name()
80 jthread thread; in suspend() local
82 thread = inStream_readThreadRef(getEnv(), in); in suspend()
87 if (threadControl_isDebugThread(thread)) { in suspend()
91 error = threadControl_suspendThread(thread, JNI_FALSE); in suspend()
102 jthread thread; in resume() local
104 thread = inStream_readThreadRef(getEnv(), in); in resume()
[all …]
|
| D | eventHandler.c | 323 deferEventReport(JNIEnv *env, jthread thread, in deferEventReport() argument
337 threadControl_getInstructionStepMode(thread) in deferEventReport()
340 threadControl_saveCLEInfo(env, thread, ei, in deferEventReport()
349 threadControl_saveCLEInfo(env, thread, ei, in deferEventReport()
368 skipEventReport(JNIEnv *env, jthread thread, EventIndex ei, in skipEventReport() argument
374 if (threadControl_cmpCLEInfo(env, thread, clazz, method, location)) { in skipEventReport()
377 eventText(ei), thread, clazz, method, location)); in skipEventReport()
382 threadControl_clearCLEInfo(env, thread); in skipEventReport()
388 reportEvents(JNIEnv *env, jbyte sessionID, jthread thread, EventIndex ei, in reportEvents() argument
410 if (thread != NULL && in reportEvents()
[all …]
|
| D | threadControl.h | 41 jvmtiError threadControl_popFrames(jthread thread, FrameNumber fnum);
44 EventIndex ei, jthread thread, jobject currentException);
45 void threadControl_onEventHandlerExit(EventIndex ei, jthread thread, struct bag *);
48 jvmtiError threadControl_suspendThread(jthread thread, jboolean deferred);
49 jvmtiError threadControl_resumeThread(jthread thread, jboolean do_unblock);
50 jvmtiError threadControl_suspendCount(jthread thread, jint *count);
58 jboolean threadControl_isDebugThread(jthread thread);
59 jvmtiError threadControl_addDebugThread(jthread thread);
61 jvmtiError threadControl_applicationThreadStatus(jthread thread, jdwpThreadStatus *pstatus, jint *s…
62 jvmtiError threadControl_interrupt(jthread thread);
[all …]
|
| D | StackFrameImpl.c | 34 validateThreadFrame(jthread thread, FrameID frame) in validateThreadFrame() argument
39 error = threadControl_suspendCount(thread, &count); in validateThreadFrame()
42 serror = validateFrameID(thread, frame); in validateThreadFrame()
53 writeVariableValue(JNIEnv *env, PacketOutputStream *out, jthread thread, in writeVariableValue() argument
64 (gdata->jvmti, thread, fnum, slot, &value.l); in writeVariableValue()
84 (gdata->jvmti, thread, fnum, slot, &intValue); in writeVariableValue()
92 (gdata->jvmti, thread, fnum, slot, &intValue); in writeVariableValue()
99 (gdata->jvmti, thread, fnum, slot, &value.f); in writeVariableValue()
105 (gdata->jvmti, thread, fnum, slot, &value.d); in writeVariableValue()
111 (gdata->jvmti, thread, fnum, slot, &value.i); in writeVariableValue()
[all …]
|
| /external/autotest/client/tests/monotonic_time/src/ |
| D | threads.c | 19 typedef struct thread { struct
20 pthread_t thread; 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()
67 CPU_ZERO(&thread->cpus); in create_per_cpu_threads()
[all …]
|
| /external/deqp/framework/delibs/destream/ |
| D | deStreamCpyThread.c | 30 deStreamCpyThread* thread = (deStreamCpyThread*)arg; in cpyStream() local
31 deUint8* buffer = malloc(sizeof(deUint8) * (size_t)thread->bufferSize); in cpyStream()
39 readResult = deInStream_read(thread->input, buffer, thread->bufferSize, &read); in cpyStream()
44 deOutStream_write(thread->output, buffer, read - written, &wrote); in cpyStream()
56 deOutStream_flush(thread->output); in cpyStream()
62 deStreamCpyThread* thread = malloc(sizeof(deStreamCpyThread)); in deStreamCpyThread_create() local
64 DE_ASSERT(thread); in deStreamCpyThread_create()
68 thread->input = input; in deStreamCpyThread_create()
69 thread->output = output; in deStreamCpyThread_create()
70 thread->bufferSize = bufferSize; in deStreamCpyThread_create()
[all …]
|
| /external/ltp/testcases/realtime/func/async_handler/ |
| D | async_handler_jk.c | 82 struct thread *thread = ((struct thread *)arg); in async_event_server() local
84 thread->func = NULL; // entrypoint in async_event_server()
85 thread->flags |= THREAD_FLAG_SUSPENDED; in async_event_server()
88 if ((err = pthread_mutex_lock(&thread->mutex))) in async_event_server()
92 while (thread->flags & THREAD_FLAG_SUSPENDED) in async_event_server()
93 pthread_cond_wait(&thread->cond, &thread->mutex); in async_event_server()
95 pthread_mutex_unlock(&thread->mutex); in async_event_server()
98 thread->func = handler1; in async_event_server()
100 if (thread->func != NULL) in async_event_server()
101 thread->func(arg); in async_event_server()
[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()
72 ProcessThreadImpl thread("ProcessThread"); in TEST() local
73 thread.Start(); in TEST()
82 EXPECT_CALL(module, ProcessThreadAttached(&thread)).Times(1); in TEST()
84 thread.RegisterModule(&module); in TEST()
[all …]
|
| /external/webrtc/webrtc/base/ |
| D | thread_unittest.cc | 235 Thread *thread; in TEST() local
236 thread = new Thread(); in TEST()
237 EXPECT_TRUE(thread->Start()); in TEST()
238 thread->Stop(); in TEST()
239 delete thread; in TEST()
240 thread = new Thread(); in TEST()
242 EXPECT_TRUE(thread->SetName("No object", NULL)); in TEST()
243 EXPECT_TRUE(thread->Start()); in TEST()
244 thread->Stop(); in TEST()
245 delete thread; in TEST()
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ThreadFactoryBuilderTest.java | 58 Thread thread = threadFactory.newThread(monitoredRunnable); in testThreadFactoryBuilder_defaults() local
59 checkThreadPoolName(thread, 1); 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()
71 thread.join(); in testThreadFactoryBuilder_defaults()
79 thread.getName().substring(0, thread.getName().lastIndexOf('-')), in testThreadFactoryBuilder_defaults()
80 thread2.getName().substring(0, thread.getName().lastIndexOf('-'))); in testThreadFactoryBuilder_defaults()
[all …]
|
| /external/clang/test/SemaCXX/ |
| D | declspec-thread.cpp | 4 __thread __declspec(thread) int a; // expected-error {{already has a thread-local storage specifier…
5 __declspec(thread) __thread int b; // expected-error {{already has a thread-local storage specifier…
6 __declspec(thread) int c(); // expected-warning {{only applies to variables}}
7 __declspec(thread) int d;
10 __declspec(thread) int e = foo();
12 __declspec(thread) int e = foo(); // expected-error {{must be a constant expression}} expected-note…
17 __declspec(thread) HasCtor f;
19 __declspec(thread) HasCtor f; // expected-error {{must be a constant expression}} expected-note {{t…
24 __declspec(thread) HasDtor g;
26 __declspec(thread) HasCtor g; // expected-error {{must be a constant expression}} expected-note {{t…
[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/google-breakpad/src/tools/linux/md2core/ |
| D | minidump-2-core.cc | 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()
262 thread->regs.eax = rawregs->eax; in ParseThreadRegisters()
263 thread->regs.xds = rawregs->ds; in ParseThreadRegisters()
264 thread->regs.xes = rawregs->es; in ParseThreadRegisters()
[all …]
|
| /external/lzma/CPP/Windows/ |
| D | Thread.h | 14 ::CThread thread;
16 CThread() { Thread_Construct(&thread); } in CThread()
18 bool IsCreated() { return Thread_WasCreated(&thread) != 0; } in IsCreated()
19 WRes Close() { return Thread_Close(&thread); } in Close()
21 { return Thread_Create(&thread, startAddress, parameter); } in Create()
22 WRes Wait() { return Thread_Wait(&thread); } in Wait()
25 operator HANDLE() { return thread; } in HANDLE()
26 void Attach(HANDLE handle) { thread = handle; } in Attach()
27 HANDLE Detach() { HANDLE h = thread; thread = NULL; return h; } in Detach()
28 DWORD Resume() { return ::ResumeThread(thread); } in Resume()
[all …]
|
| /external/libcups/cups/ |
| D | thread.c | 159 _cupsThreadCancel(_cups_thread_t thread)/* I - Thread ID */ in _cupsThreadCancel() argument
161 pthread_cancel(thread); in _cupsThreadCancel()
174 pthread_t thread; in _cupsThreadCreate() local
176 if (pthread_create(&thread, NULL, (void *(*)(void *))func, arg)) in _cupsThreadCreate()
179 return (thread); in _cupsThreadCreate()
188 _cupsThreadDetach(_cups_thread_t thread)/* I - Thread ID */ in _cupsThreadDetach() argument
190 pthread_detach(thread); in _cupsThreadDetach()
199 _cupsThreadWait(_cups_thread_t thread) /* I - Thread ID */ in _cupsThreadWait() argument
204 if (pthread_join(thread, &ret)) in _cupsThreadWait()
346 _cupsThreadCancel(_cups_thread_t thread)/* I - Thread ID */ in _cupsThreadCancel() argument
[all …]
|
| /external/libchrome/base/task_scheduler/ |
| D | scheduler_lock_unittest.cc | 90 BasicLockTestThread thread(&lock); in TEST() local
92 thread.Start(); in TEST()
113 thread.Join(); in TEST()
116 EXPECT_EQ(thread.acquired(), 20); in TEST()
181 BasicLockAcquireAndWaitThread thread(&lock1); in TEST() local
182 thread.Start(); in TEST()
185 thread.WaitForLockAcquisition(); in TEST()
186 thread.ContinueMain(); in TEST()
187 thread.Join(); in TEST()
202 BasicLockAcquireAndWaitThread thread(&lock); in TEST() local
[all …]
|
| /external/python/cpython2/Lib/test/ |
| D | test_thread.py | 5 thread = support.import_module('thread') variable
16 _print_mutex = thread.allocate_lock()
29 self.done_mutex = thread.allocate_lock()
31 self.running_mutex = thread.allocate_lock()
32 self.random_mutex = thread.allocate_lock()
47 thread.start_new_thread(self.task, (self.next_ident,))
73 self.assertEqual(thread.stack_size(), 0, "initial stack size is not 0")
75 thread.stack_size(0)
76 self.assertEqual(thread.stack_size(), 0, "stack_size not reset to default")
81 thread.stack_size(4096)
[all …]
|
| /external/deqp/framework/delibs/deutil/ |
| D | deTimer.c | 297 deThread thread; /*!< Thread. */ member
313 deTimerThread* thread = (deTimerThread*)arg; in timerThread() local
322 deMutex_lock(thread->lock); in timerThread()
324 if (thread->state == TIMERSTATE_SINGLE && numCallbacks > 0) in timerThread()
327 thread->state = TIMERSTATE_DISABLED; in timerThread()
330 else if (thread->state == TIMERSTATE_DISABLED) in timerThread()
333 deMutex_unlock(thread->lock); in timerThread()
335 sleepTime = thread->interval - (int)(((deInt64)deGetMicroseconds()-lastCallback)/1000); in timerThread()
340 thread->callback(thread->callbackArg); in timerThread()
345 deMutex_unlock(thread->lock); in timerThread()
[all …]
|