Home
last modified time | relevance | path

Searched refs:thread (Results 1 – 25 of 1823) sorted by relevance

12345678910>>...73

/netbsd-src/lib/librumpuser/
H A Drumpfiber.c95 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; in schedule() local
151 TAILQ_FOREACH_SAFE(thread, &thread_list, thread_list, tmp) { in schedule()
152 if (!is_runnable(thread) && thread->wakeup_time >= 0) { in schedule()
153 if (thread->wakeup_time <= tm) { in schedule()
[all …]
H A Drumpfiber.h36 struct thread { struct
41 TAILQ_ENTRY(thread) thread_list; argument
57 void wake(struct thread *thread); argument
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 *);
68 void clear_runnable(struct thread *);
/netbsd-src/external/gpl2/lvm2/dist/daemons/dmeventd/
H A Ddmeventd.c64 #define LINK_THREAD(thread) LINK(thread, &_thread_registry) argument
174 pthread_t thread; member
248 static void _free_thread_status(struct thread_status *thread) in _free_thread_status() argument
250 if (thread->current_task) in _free_thread_status()
251 dm_task_destroy(thread->current_task); in _free_thread_status()
252 dm_free(thread->device.uuid); in _free_thread_status()
253 dm_free(thread->device.name); in _free_thread_status()
254 dm_free(thread); in _free_thread_status()
461 struct thread_status *thread; in _lookup_thread_status() local
463 dm_list_iterate_items(thread, &_thread_registry) in _lookup_thread_status()
[all …]
/netbsd-src/lib/libpthread/
H A Dpthread_misc.c64 pthread_getschedparam(pthread_t thread, int *policy, struct sched_param *param) in __strong_alias()
68 thread->pt_magic == PT_MAGIC); in __strong_alias()
70 if (pthread__find(thread) != 0) in __strong_alias()
73 if (_sched_getparam(getpid(), thread->pt_lid, policy, param) < 0) in __strong_alias()
80 pthread_setschedparam(pthread_t thread, int policy, in pthread_setschedparam() argument
86 thread->pt_magic == PT_MAGIC); in pthread_setschedparam()
88 if (pthread__find(thread) != 0) in pthread_setschedparam()
92 if (_sched_setparam(getpid(), thread->pt_lid, policy, &sp) < 0) in pthread_setschedparam()
99 pthread_getaffinity_np(pthread_t thread, size_t size, cpuset_t *cpuset) in pthread_getaffinity_np() argument
103 thread->pt_magic == PT_MAGIC); in pthread_getaffinity_np()
[all …]
H A Dpthread.c396 pthread_create(pthread_t *thread, const pthread_attr_t *attr, in pthread_create() argument
410 return __libc_thr_create_stub(thread, attr, startfunc, arg); in pthread_create()
561 *thread = newthread; in pthread_create()
604 pthread_suspend_np(pthread_t thread) in pthread_suspend_np() argument
609 thread->pt_magic == PT_MAGIC); in pthread_suspend_np()
612 if (self == thread) { in pthread_suspend_np()
615 if (pthread__find(thread) != 0) in pthread_suspend_np()
617 if (_lwp_suspend(thread->pt_lid) == 0) in pthread_suspend_np()
623 pthread_resume_np(pthread_t thread) in pthread_resume_np() argument
627 thread->pt_magic == PT_MAGIC); in pthread_resume_np()
[all …]
/netbsd-src/external/apache2/llvm/dist/libcxx/include/
H A Dthread2 //===--------------------------- thread -----------------------------------===//
15 thread synopsis
20 class thread
26 thread() noexcept;
27 template <class F, class ...Args> explicit thread(F&& f, Args&&... args);
28 ~thread();
30 thread(const thread&) = delete;
31 thread(thread&& t) noexcept;
33 thread& operator=(const thread&) = delete;
34 thread& operator=(thread&& t) noexcept;
[all …]
/netbsd-src/sys/fs/nfs/common/
H A Dnfs_fha.c255 fha_hash_entry_add_thread(struct fha_hash_entry *fhe, SVCTHREAD *thread) in fha_hash_entry_add_thread() argument
259 thread->st_p2 = 0; in fha_hash_entry_add_thread()
260 LIST_INSERT_HEAD(&fhe->threads, thread, st_alink); in fha_hash_entry_add_thread()
265 fha_hash_entry_remove_thread(struct fha_hash_entry *fhe, SVCTHREAD *thread) in fha_hash_entry_remove_thread() argument
269 KASSERT(thread->st_p2 == 0, in fha_hash_entry_remove_thread()
270 ("%d reqs on removed thread %p", thread->st_p2, thread)); in fha_hash_entry_remove_thread()
271 LIST_REMOVE(thread, st_alink); in fha_hash_entry_remove_thread()
297 SVCTHREAD *thread, *min_thread = NULL; in fha_hash_entry_choose_thread() local
304 LIST_FOREACH(thread, &fhe->threads, st_alink) { in fha_hash_entry_choose_thread()
305 req_count = thread->st_p2; in fha_hash_entry_choose_thread()
[all …]
/netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/unix/
H A Dsocket.c396 isc_thread_t thread; member
477 process_ctlfd(isc__socketthread_t *thread);
608 thread_log(isc__socketthread_t *thread, isc_logcategory_t *category,
612 thread_log(isc__socketthread_t *thread, isc_logcategory_t *category, in thread_log() argument
626 "sockmgr %p thread %d: %s", thread->manager, in thread_log()
627 thread->threadid, msgbuf); in thread_log()
685 watch_fd(isc__socketthread_t *thread, int fd, int msg) { in watch_fd() argument
699 if (kevent(thread->kqueue_fd, &evchange, 1, NULL, 0, NULL) != 0) { in watch_fd()
710 oldevents = thread->epoll_events[fd]; in watch_fd()
712 thread->epoll_events[fd] |= EPOLLIN; in watch_fd()
[all …]
/netbsd-src/external/gpl3/gcc.old/dist/gcc/cp/
H A Dcfns.gperf60 #fclose, 89 -- POSIX thread cancellation point
63 #fflush, 89 -- POSIX thread cancellation point
64 #fgetc, 89 -- POSIX thread cancellation point
65 #fgetpos, 89 -- POSIX thread cancellation point
66 #fgets, 89 -- POSIX thread cancellation point
67 #fgetwc, 89 -- POSIX thread cancellation point
68 #fgetws, 89 -- POSIX thread cancellation point
71 #fopen, 89 -- POSIX thread cancellation point
72 #fprintf, 89 -- POSIX thread cancellation point
73 #fputc, 89 -- POSIX thread cancellation point
[all …]
/netbsd-src/external/gpl3/gcc/dist/gcc/cp/
H A Dcfns.gperf60 #fclose, 89 -- POSIX thread cancellation point
63 #fflush, 89 -- POSIX thread cancellation point
64 #fgetc, 89 -- POSIX thread cancellation point
65 #fgetpos, 89 -- POSIX thread cancellation point
66 #fgets, 89 -- POSIX thread cancellation point
67 #fgetwc, 89 -- POSIX thread cancellation point
68 #fgetws, 89 -- POSIX thread cancellation point
71 #fopen, 89 -- POSIX thread cancellation point
72 #fprintf, 89 -- POSIX thread cancellation point
73 #fputc, 89 -- POSIX thread cancellation point
[all …]
/netbsd-src/external/gpl3/gcc/dist/libstdc++-v3/include/bits/
H A Dstd_thread.h78 class thread in _GLIBCXX_VISIBILITY()
112 friend class thread; in _GLIBCXX_VISIBILITY()
138 using __not_same = __not_<is_same<__remove_cvref_t<_Tp>, thread>>; in _GLIBCXX_VISIBILITY()
141 thread() noexcept = default; in _GLIBCXX_VISIBILITY()
147 thread(_Callable&& __f, _Args&&... __args) in _GLIBCXX_VISIBILITY()
169 ~thread() in _GLIBCXX_VISIBILITY()
175 thread(const thread&) = delete; in _GLIBCXX_VISIBILITY()
177 thread(thread&& __t) noexcept in _GLIBCXX_VISIBILITY()
180 thread& operator=(const thread&) = delete; in _GLIBCXX_VISIBILITY()
182 thread& operator=(thread&& __t) noexcept in _GLIBCXX_VISIBILITY()
[all …]
/netbsd-src/external/gpl3/gcc.old/dist/libstdc++-v3/include/std/
H A Dthread1 // <thread> -*- C++ -*-
25 /** @file include/thread
68 * Classes for thread support.
72 /// thread
73 class thread
77 // invoked in the new thread of execution.
87 /// thread::id
99 friend class thread;
123 // 3039. Unnecessary decay in thread and packaged_task
125 using __not_same = __not_<is_same<__remove_cvref_t<_Tp>, thread>>;
[all …]
/netbsd-src/external/gpl3/gcc.old/dist/libsanitizer/asan/
H A Dasan_rtems.cc103 AsanThread *thread = (AsanThread *)MmapOrDie(sizeof(AsanThread), __func__); in CreateAsanThread() local
104 AsanThreadContext::CreateThreadContextArgs args = {thread, stack}; in CreateAsanThread()
112 thread->Init(&options); in CreateAsanThread()
113 return thread; in CreateAsanThread()
135 return GetThreadContextByTidLocked(0)->thread; in CreateMainThread()
157 AsanThread *thread = static_cast<AsanThread *>(hook); in ThreadCreateHook() local
164 asanThreadRegistry().FinishThread(thread->tid()); in ThreadCreateHook()
165 UnmapOrDie(thread, sizeof(AsanThread)); in ThreadCreateHook()
176 AsanThread *thread = static_cast<AsanThread *>(hook); in ThreadStartHook() local
177 SetCurrentThread(thread); in ThreadStartHook()
[all …]
/netbsd-src/sys/external/bsd/compiler_rt/dist/lib/asan/
H A Dasan_rtems.cc105 AsanThread *thread = (AsanThread *)MmapOrDie(sizeof(AsanThread), __func__); in CreateAsanThread() local
106 AsanThreadContext::CreateThreadContextArgs args = {thread, stack}; in CreateAsanThread()
114 thread->Init(&options); in CreateAsanThread()
115 return thread; in CreateAsanThread()
137 return GetThreadContextByTidLocked(0)->thread; in CreateMainThread()
159 AsanThread *thread = static_cast<AsanThread *>(hook); in ThreadCreateHook() local
166 asanThreadRegistry().FinishThread(thread->tid()); in ThreadCreateHook()
167 UnmapOrDie(thread, sizeof(AsanThread)); in ThreadCreateHook()
178 AsanThread *thread = static_cast<AsanThread *>(hook); in ThreadStartHook() local
179 SetCurrentThread(thread); in ThreadStartHook()
[all …]
/netbsd-src/external/gpl3/gcc/dist/libstdc++-v3/include/std/
H A Dthread1 // <thread> -*- C++ -*-
25 /** @file include/thread
43 #include <bits/std_thread.h> // std::thread, get_id, yield
55 * Classes for thread support.
59 // std::thread is defined in <bits/std_thread.h>
61 /// @relates std::thread::id @{
65 operator<=>(thread::id __x, thread::id __y) noexcept
69 operator!=(thread::id __x, thread::id __y) noexcept
73 operator<(thread::id __x, thread::id __y) noexcept
81 operator<=(thread::id __x, thread::id __y) noexcept
[all …]
/netbsd-src/sys/external/bsd/drm2/dist/drm/i915/gem/selftests/
H A Di915_gem_object_blt.c210 struct igt_thread_arg *thread = arg; in igt_fill_blt_thread() local
211 struct drm_i915_private *i915 = thread->i915; in igt_fill_blt_thread()
212 struct rnd_state *prng = &thread->prng; in igt_fill_blt_thread()
220 ctx = thread->ctx; in igt_fill_blt_thread()
222 ctx = live_context(i915, thread->file); in igt_fill_blt_thread()
247 total = div64_u64(total, thread->n_cpus); in igt_fill_blt_thread()
319 struct igt_thread_arg *thread = arg; in igt_copy_blt_thread() local
320 struct drm_i915_private *i915 = thread->i915; in igt_copy_blt_thread()
321 struct rnd_state *prng = &thread->prng; in igt_copy_blt_thread()
329 ctx = thread->ctx; in igt_copy_blt_thread()
[all …]
/netbsd-src/external/gpl3/gcc/dist/libsanitizer/hwasan/
H A Dhwasan_fuchsia.cpp60 static void FinishThreadInitialization(Thread *thread);
115 Thread *thread = static_cast<Thread *>(hook); in ThreadCreateHook() local
123 hwasanThreadList().ReleaseThread(thread); in ThreadCreateHook()
131 Thread *thread = static_cast<Thread *>(hook); in ThreadStartHook() local
132 FinishThreadInitialization(thread); in ThreadStartHook()
133 thread->EnsureRandomStateInited(); in ThreadStartHook()
140 static void FinishThreadInitialization(Thread *thread) { in FinishThreadInitialization() argument
141 CHECK_NE(thread, nullptr); in FinishThreadInitialization()
145 uptr stack_buffer_start = reinterpret_cast<uptr>(thread) - stack_buffer_size; in FinishThreadInitialization()
146 thread->InitStackRingBuffer(stack_buffer_start, stack_buffer_size); in FinishThreadInitialization()
[all …]
/netbsd-src/external/mit/libuv/dist/test/
H A Dtest-thread.c120 struct test_thread* thread = arg; in do_work() local
140 thread->thread_called = 1; in do_work()
250 uv_thread_t thread; in TEST_IMPL() local
251 ASSERT(0 == uv_thread_create(&thread, thread_check_stack, NULL)); in TEST_IMPL()
252 ASSERT(0 == uv_thread_join(&thread)); in TEST_IMPL()
257 uv_thread_t thread; in TEST_IMPL() local
262 ASSERT(0 == uv_thread_create_ex(&thread, &options, in TEST_IMPL()
264 ASSERT(0 == uv_thread_join(&thread)); in TEST_IMPL()
267 ASSERT(0 == uv_thread_create_ex(&thread, &options, in TEST_IMPL()
269 ASSERT(0 == uv_thread_join(&thread)); in TEST_IMPL()
[all …]
/netbsd-src/external/apache2/llvm/dist/llvm/include/llvm/Support/
H A Dthread.h26 typedef std::thread thread; typedef
35 struct thread { struct
36 thread() {} in thread() argument
37 thread(thread &&other) {} in thread() function
39 explicit thread(Function &&f, Args &&... args) { in thread() argument
42 thread(const thread &) = delete;
/netbsd-src/external/gpl3/gcc.old/dist/libobjc/
H A DTHREADS2 Objective-C runtime needed to make it thread safe.
31 sarray data structures are freed while more than one thread is
34 is operating with a single thread. The programmer can also flush the
47 versions of thread-*.c.
50 SAFE : Implicitly thread safe.
51 SINGLE : Must only be used in single thread mode.
66 __objc_thread_exit_status SAFE thread.c
94 The design of the Objective-C runtime thread and mutex functions utilizes a
100 should use these structures and functions for their thread and mutex
105 example, __gthread_objc_mutex_lock(). The thread system is
[all …]
/netbsd-src/external/gpl3/gcc/dist/libobjc/
H A DTHREADS2 Objective-C runtime needed to make it thread safe.
31 sarray data structures are freed while more than one thread is
34 is operating with a single thread. The programmer can also flush the
47 versions of thread-*.c.
50 SAFE : Implicitly thread safe.
51 SINGLE : Must only be used in single thread mode.
66 __objc_thread_exit_status SAFE thread.c
94 The design of the Objective-C runtime thread and mutex functions utilizes a
100 should use these structures and functions for their thread and mutex
105 example, __gthread_objc_mutex_lock(). The thread system is
[all …]
/netbsd-src/crypto/external/bsd/openssl.old/dist/test/
H A Dthreadstest.c27 static int wait_for_thread(thread_t thread) in wait_for_thread() argument
52 static int wait_for_thread(thread_t thread) in wait_for_thread() argument
54 return WaitForSingleObject(thread, INFINITE) == 0; in wait_for_thread()
76 static int wait_for_thread(thread_t thread) in wait_for_thread() argument
78 return pthread_join(thread, NULL) == 0; in wait_for_thread()
111 thread_t thread; in test_once() local
113 if (!TEST_true(run_thread(&thread, once_run_thread_cb)) in test_once()
114 || !TEST_true(wait_for_thread(thread)) in test_once()
156 thread_t thread; in test_thread_local() local
165 || !TEST_true(run_thread(&thread, thread_local_thread_cb)) in test_thread_local()
[all …]
/netbsd-src/external/gpl3/gcc/dist/libsanitizer/asan/
H A Dasan_fuchsia.cpp124 AsanThread *thread = (AsanThread *)MmapOrDie(AsanThreadMmapSize(), __func__); in CreateAsanThread() local
126 AsanThreadContext::CreateThreadContextArgs args = {thread, stack}; in CreateAsanThread()
131 return thread; in CreateAsanThread()
185 AsanThread *thread = in BeforeThreadCreateHook() local
192 thread->Init(&options); in BeforeThreadCreateHook()
193 return thread; in BeforeThreadCreateHook()
199 AsanThread *thread = static_cast<AsanThread *>(hook); in ThreadCreateHook() local
206 asanThreadRegistry().FinishThread(thread->tid()); in ThreadCreateHook()
207 UnmapOrDie(thread, AsanThreadMmapSize()); in ThreadCreateHook()
215 AsanThread *thread = static_cast<AsanThread *>(hook); in ThreadStartHook() local
[all …]
/netbsd-src/external/cddl/dtracetoolkit/dist/Java/
H A Dj_thread.d50 hotspot*:::thread-start
52 this->thread = (char *)copyin(arg0, arg1 + 1);
53 this->thread[arg1] = '\0';
55 stringof(this->thread));
58 hotspot*:::thread-stop
60 this->thread = (char *)copyin(arg0, arg1 + 1);
61 this->thread[arg1] = '\0';
63 stringof(this->thread));
/netbsd-src/external/cddl/dtracetoolkit/dist/Bin/
H A Dj_thread.d50 hotspot*:::thread-start
52 this->thread = (char *)copyin(arg0, arg1 + 1);
53 this->thread[arg1] = '\0';
55 stringof(this->thread));
58 hotspot*:::thread-stop
60 this->thread = (char *)copyin(arg0, arg1 + 1);
61 this->thread[arg1] = '\0';
63 stringof(this->thread));

12345678910>>...73