| /src/lib/librumpuser/ |
| rumpfiber.h | 36 struct thread { struct
41 TAILQ_ENTRY(thread) thread_list;
57 void wake(struct thread *thread);
58 void block(struct thread *thread);
59 struct thread *init_mainthread(void *);
63 struct thread* create_thread(const char *name, void *cookie,
66 int is_runnable(struct thread *);
67 void set_runnable(struct thread *);
[all...] |
| rumpfiber.c | 95 static void join_thread(struct thread *);
96 static void switch_threads(struct thread *prev, struct thread *next);
97 static struct thread *get_current(void);
102 TAILQ_HEAD(thread_list, thread);
106 static struct thread *current_thread = NULL;
120 static struct thread *
141 struct thread *prev, *next, *thread, *tmp; local in function:schedule
151 TAILQ_FOREACH_SAFE(thread, &thread_list, thread_list, tmp)
211 struct thread *thread = calloc(1, sizeof(struct thread)); local in function:create_thread
268 struct thread *thread = get_current(); local in function:exit_thread
303 struct thread *thread = get_current(); local in function:join_thread
327 struct thread *thread = get_current(); local in function:msleep
336 struct thread *thread = get_current(); local in function:abssleep
346 struct thread *thread = get_current(); local in function:abssleep_real
398 struct thread *thread = calloc(1, sizeof(struct thread)); local in function:init_sched
1018 struct thread *thread; local in function:rumpuser_curlwpop
[all...] |
| /src/lib/libpthread/ |
| pthread_misc.c | 64 pthread_getschedparam(pthread_t thread, int *policy, struct sched_param *param)
67 pthread__error(EINVAL, "Invalid thread",
68 thread->pt_magic == PT_MAGIC);
70 if (pthread__find(thread) != 0)
73 if (_sched_getparam(getpid(), thread->pt_lid, policy, param) < 0)
80 pthread_setschedparam(pthread_t thread, int policy,
85 pthread__error(EINVAL, "Invalid thread",
86 thread->pt_magic == PT_MAGIC);
88 if (pthread__find(thread) != 0)
92 if (_sched_setparam(getpid(), thread->pt_lid, policy, &sp) < 0
[all...] |
| pthread_getcpuclockid.c | 47 pthread_getcpuclockid(pthread_t thread, clockid_t *clock_id)
51 pthread__error(EINVAL, "Invalid thread",
52 thread->pt_magic == PT_MAGIC);
55 if (clock_getcpuclockid2(P_LWPID, (id_t)thread->pt_lid, clock_id) == -1)
|
| pthread.c | 132 * pointer to the thread data, it is safe to change the mapping from
133 * stack pointer to thread data afterwards.
202 * gets to run, for various things that use the state of the initial thread
203 * to work properly (thread-specific data is an application-visible example;
261 /* Create the thread structure corresponding to main() */
305 /* General-purpose thread data structure sanitization. */
406 pthread_create(pthread_t *thread, const pthread_attr_t *attr,
420 return __libc_thr_create_stub(thread, attr, startfunc, arg);
439 * _lwp_unpark from another thread pending in the
448 * For the very first thread, before pthread__starte
[all...] |
| /src/regress/sys/kern/softint1/ |
| softint1.c | 40 void *thread(void *);
45 thread(void *arg) function in typeref:typename:void *
62 pthread_create(&thr, NULL, thread, NULL);
|
| /src/sys/external/bsd/compiler_rt/dist/lib/asan/ |
| asan_rtems.cc | 83 // will never be called. Instead, our own thread destruction hook
92 // Thread registration. We provide an API similar to the Fushia port.
99 // Shared setup between thread creation and startup for the initial thread.
105 AsanThread *thread = (AsanThread *)MmapOrDie(sizeof(AsanThread), __func__); local in function:__asan::CreateAsanThread
106 AsanThreadContext::CreateThreadContextArgs args = {thread, stack};
110 // thread itself. But on RTEMS we already know the stack address
114 thread->Init(&options);
115 return thread;
119 // We're in the creator thread before the new thread is actually started, bu
159 AsanThread *thread = static_cast<AsanThread *>(hook); local in function:__asan::ThreadCreateHook
178 AsanThread *thread = static_cast<AsanThread *>(hook); local in function:__asan::ThreadStartHook
201 AsanThread *thread = static_cast<AsanThread *>(hook); local in function:__asan::ThreadExitHook
[all...] |
| asan_fuchsia.cc | 74 // will never be called. Instead, our own thread destruction hook
90 // Shared setup between thread creation and startup for the initial thread.
96 AsanThread *thread = (AsanThread *)MmapOrDie(AsanThreadMmapSize(), __func__); local in function:__asan::CreateAsanThread
98 AsanThreadContext::CreateThreadContextArgs args = {thread, stack};
104 // thread itself. But on Fuchsia we already know the stack address
107 thread->Init(&options);
109 return thread;
113 // We're in the creator thread before the new thread is actually started
162 AsanThread *thread = static_cast<AsanThread *>(hook); local in function:__asan::ThreadCreateHook
178 AsanThread *thread = static_cast<AsanThread *>(hook); local in function:__asan::ThreadStartHook
[all...] |
| asan_flags.inc | 27 "Size (in Kb) of thread local quarantine used to detect "
58 20, // 1Mb per size class, i.e. ~11Mb per thread
104 "If set, prints thread creation stacks for the threads involved in the "
105 "report and their ancestors up to the main thread.")
|
| /src/sys/fs/nfs/common/ |
| nfs_fha.c | 108 "single nfsd thread should be working on at any time");
255 fha_hash_entry_add_thread(struct fha_hash_entry *fhe, SVCTHREAD *thread)
259 thread->st_p2 = 0;
260 LIST_INSERT_HEAD(&fhe->threads, thread, st_alink);
265 fha_hash_entry_remove_thread(struct fha_hash_entry *fhe, SVCTHREAD *thread)
269 KASSERT(thread->st_p2 == 0,
270 ("%d reqs on removed thread %p", thread->st_p2, thread));
271 LIST_REMOVE(thread, st_alink)
297 SVCTHREAD *thread, *min_thread = NULL; local in function:fha_hash_entry_choose_thread
384 SVCTHREAD *thread; local in function:fha_assign
477 SVCTHREAD *thread; local in function:fhe_stats_sysctl
[all...] |
| /src/sys/arch/ia64/include/ |
| md_var.h | 68 struct thread;
80 int copyout_regstack(struct thread *, uint64_t *, uint64_t *);
85 void ia64_flush_dirty(struct thread *, struct _special *);
87 int ia64_highfp_drop(struct thread *);
88 int ia64_highfp_save(struct thread *);
100 int unaligned_fixup(struct trapframe *, struct thread *);
|
| /src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/tests/ |
| sanitizer_pthread_wrappers.h | 11 // It provides handy wrappers for thread manipulation, that:
44 inline void PTHREAD_CREATE(pthread_t *thread, void *attr,
46 ASSERT_EQ(0, attr) << "Thread attributes are not supported yet.";
50 *thread = CreateThread(0, 0, PthreadHelperThreadProc, data, 0, 0);
52 ASSERT_NE(nullptr, *thread) << "Failed to create a thread, got error 0x"
56 inline void PTHREAD_JOIN(pthread_t thread, void **value_ptr) {
58 ASSERT_EQ(WAIT_OBJECT_0, WaitForSingleObject(thread, INFINITE));
59 ASSERT_NE(0, CloseHandle(thread));
|
| malloc_stress_transfer_test.cc | 1 #include <thread>
10 void Thread() {
12 // std::cerr << "Thread starting, sp = " << &sp << std::endl;
29 // Thread();
31 std::thread *Threads[kNumThreads];
32 for (auto &T : Threads) T = new std::thread(&Thread);
|
| /src/tests/lib/libpthread/ |
| t_join.c | 63 pthread_t thread; local in function:ATF_TC_BODY
65 PTHREAD_REQUIRE(pthread_create(&thread, NULL, threadfunc1, NULL));
66 PTHREAD_REQUIRE(pthread_join(thread, NULL));
72 pthread_t thread[25]; local in function:threadfunc1
83 * Check alignment of thread stack, if supported.
90 * out, if we try to join the calling thread.
102 for (i = 0; i < __arraycount(thread); i++) {
109 rv = pthread_create(&thread[i], &attr, threadfunc2, (void *)i);
116 PTHREAD_REQUIRE(pthread_join(thread[i], &val));
124 * Once the thread has returned, ESRCH shoul
[all...] |
| h_thread_local_dtor.cpp | 30 #include <thread>
70 std::thread{thread_fn}.join();
|
| t_sleep.c | 72 pthread_t thread; local in function:ATF_TC_BODY
84 PTHREAD_REQUIRE(pthread_create(&thread, NULL, threadfunc, NULL));
86 /* make sure the signal is delivered to the child thread */
96 PTHREAD_REQUIRE(pthread_join(thread, NULL));
|
| t_swapcontext.c | 93 pthread_t thread; local in function:ATF_TC_BODY
102 PTHREAD_REQUIRE(pthread_create(&thread, NULL, threadfunc, NULL));
103 PTHREAD_REQUIRE(pthread_join(thread, NULL));
|
| /src/sys/external/bsd/compiler_rt/dist/lib/msan/ |
| msan_thread.cc | 14 MsanThread *thread = (MsanThread*)MmapOrDie(size, __func__); local in function:__msan::MsanThread::Create
15 thread->start_routine_ = start_routine;
16 thread->arg_ = arg;
17 thread->destructor_iterations_ = GetPthreadDestructorIterations();
19 return thread;
58 // We also clear the shadow on thread destruction because
71 // start_routine_ == 0 if we're on the main thread or on one of the
|
| /src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/ |
| sanitizer_stoptheworld_mac.cc | 28 thread_t thread; member in struct:__sanitizer::__anon22ed31e80108
38 bool ContainsThread(thread_t thread) const;
39 void Append(thread_t thread);
118 return threads_[index].thread;
125 bool SuspendedThreadsListMac::ContainsThread(thread_t thread) const {
127 if (threads_[i].thread == thread) return true;
132 void SuspendedThreadsListMac::Append(thread_t thread) {
135 kern_return_t err = thread_info(thread, THREAD_IDENTIFIER_INFO,
138 VReport(1, "Error - unable to get thread ident for a thread\n")
146 thread_t thread = GetThread(index); local in function:__sanitizer::SuspendedThreadsListMac::GetRegistersAndSP
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/i915/gem/selftests/ |
| i915_gem_object_blt.c | 210 struct igt_thread_arg *thread = arg; local in function:igt_fill_blt_thread
211 struct drm_i915_private *i915 = thread->i915;
212 struct rnd_state *prng = &thread->prng;
220 ctx = thread->ctx;
222 ctx = live_context(i915, thread->file);
247 total = div64_u64(total, thread->n_cpus);
319 struct igt_thread_arg *thread = arg; local in function:igt_copy_blt_thread
320 struct drm_i915_private *i915 = thread->i915;
321 struct rnd_state *prng = &thread->prng;
329 ctx = thread->ctx
447 struct igt_thread_arg *thread; local in function:igt_threaded_blt
[all...] |
| /src/tests/lib/libpthread/dlopen/ |
| t_main_pthread_create.c | 62 pthread_t thread; local in function:ATF_TC_BODY
65 ret = pthread_create(&thread, NULL, routine, arg);
80 pthread_t thread; local in function:ATF_TC_BODY
93 ret = testf_dso_pthread_create(&thread, NULL, routine, arg);
|
| /src/tests/lib/libpthread/dlopen/dso/ |
| h_pthread_dlopen.c | 77 testf_dso_pthread_create(pthread_t *thread, const pthread_attr_t *attr,
82 ret = pthread_create(thread, attr, routine, arg);
|
| /src/tests/rump/kernspace/ |
| Makefile | 7 SRCS= thread.c threadpool.c busypage.c tsleep.c alloc.c lockme.c \
|
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/rtl/ |
| tsan_posix_util.h | 46 extern "C" int __interceptor_pthread_create(pthread_t *thread,
50 extern "C" int __interceptor_pthread_join(pthread_t thread, void **value_ptr);
51 extern "C" int __interceptor_pthread_detach(pthread_t thread);
|
| /src/tests/libexec/ld.elf_so/ |
| h_thread_local_dtor.c | 61 pthread_t thread; local in function:main
72 if (pthread_create(&thread, NULL, thread_helper, testfunc))
90 if (pthread_join(thread, NULL))
|
