Home
last modified time | relevance | path

Searched refs:th (Results 1 – 25 of 431) sorted by relevance

12345678910>>...18

/freebsd/stand/forth/
H A DMakefile3 MAN+= beastie.4th.8 \
4 brand.4th.8 \
5 check-password.4th.8 \
6 color.4th.8 \
7 delay.4th.8 \
8 loader.4th.8 \
9 menu.4th.8 \
10 menusets.4th.8 \
11 version.4th.8
13 FILES+= beastie.4th
[all …]
/freebsd/contrib/llvm-project/openmp/runtime/src/
H A Dz_Windows_NT_util.cpp203 kmp_info_t *th, C *flag) { in __kmp_win32_cond_wait()
245 TCW_PTR(th->th.th_sleep_loc, NULL); in __kmp_win32_cond_wait()
246 th->th.th_sleep_loc_type = flag_unset; in __kmp_win32_cond_wait()
317 void __kmp_suspend_initialize_thread(kmp_info_t *th) { in __kmp_suspend_initialize_thread()
318 int old_value = KMP_ATOMIC_LD_RLX(&th->th.th_suspend_init); in __kmp_suspend_initialize_thread()
325 !__kmp_atomic_compare_store(&th->th in __kmp_suspend_initialize_thread()
202 __kmp_win32_cond_wait(kmp_win32_cond_t * cv,kmp_win32_mutex_t * mx,kmp_info_t * th,C * flag) __kmp_win32_cond_wait() argument
316 __kmp_suspend_initialize_thread(kmp_info_t * th) __kmp_suspend_initialize_thread() argument
336 __kmp_suspend_uninitialize_thread(kmp_info_t * th) __kmp_suspend_uninitialize_thread() argument
346 __kmp_try_suspend_mx(kmp_info_t * th) __kmp_try_suspend_mx() argument
350 __kmp_lock_suspend_mx(kmp_info_t * th) __kmp_lock_suspend_mx() argument
354 __kmp_unlock_suspend_mx(kmp_info_t * th) __kmp_unlock_suspend_mx() argument
362 kmp_info_t *th = __kmp_threads[th_gtid]; __kmp_suspend_template() local
490 kmp_info_t *th = __kmp_threads[target_gtid]; __kmp_resume_template() local
925 kmp_info_t *th = __kmp_threads[gtid]; __kmp_terminate_thread() local
1143 __kmp_create_worker(int gtid,kmp_info_t * th,size_t stack_size) __kmp_create_worker() argument
1218 __kmp_still_running(kmp_info_t * th) __kmp_still_running() argument
1223 __kmp_create_monitor(kmp_info_t * th) __kmp_create_monitor() argument
1290 __kmp_is_thread_alive(kmp_info_t * th,DWORD * exit_val) __kmp_is_thread_alive() argument
1306 __kmp_reap_common(kmp_info_t * th) __kmp_reap_common() argument
1376 __kmp_reap_monitor(kmp_info_t * th) __kmp_reap_monitor() argument
1408 __kmp_reap_worker(kmp_info_t * th) __kmp_reap_worker() argument
[all...]
H A Dkmp_runtime.cpp121 int new_size = level + thr->th.th_set_nested_nth_sz; in __kmp_override_nested_nth()
126 new_nested_nth->nth[i] = thr->th.th_set_nested_nth[j]; in __kmp_override_nested_nth()
187 stack_size = (size_t)TCR_PTR(thr->th.th_info.ds.ds_stacksize); in __kmp_get_global_thread_id()
188 stack_base = (char *)TCR_PTR(thr->th.th_info.ds.ds_stackbase); in __kmp_get_global_thread_id()
229 if (!TCR_4(other_threads[i]->th.th_info.ds.ds_stackgrow)) { in __kmp_get_global_thread_id()
233 stack_base = (char *)other_threads[i]->th.th_info.ds.ds_stackbase; in __kmp_get_global_thread_id()
235 TCW_PTR(other_threads[i]->th.th_info.ds.ds_stackbase, stack_addr); in __kmp_get_global_thread_id()
236 TCW_PTR(other_threads[i]->th.th_info.ds.ds_stacksize, in __kmp_get_global_thread_id()
237 other_threads[i]->th.th_info.ds.ds_stacksize + stack_addr - in __kmp_get_global_thread_id()
240 TCW_PTR(other_threads[i]->th.th_info.ds.ds_stacksize, in __kmp_get_global_thread_id()
[all …]
H A Dz_Linux_util.cpp442 kmp_info_t *th = __kmp_threads[gtid]; in __kmp_terminate_thread() local
444 if (!th) in __kmp_terminate_thread()
449 status = pthread_cancel(th->th.th_info.ds.ds_thread); in __kmp_terminate_thread()
462 static kmp_int32 __kmp_set_stack_info(int gtid, kmp_info_t *th) { in __kmp_set_stack_info() argument
511 TCW_PTR(th->th.th_info.ds.ds_stackbase, (((char *)addr) + size)); in __kmp_set_stack_info()
512 TCW_PTR(th->th.th_info.ds.ds_stacksize, size); in __kmp_set_stack_info()
513 TCW_4(th->th.th_info.ds.ds_stackgrow, FALSE); in __kmp_set_stack_info()
519 TCW_PTR(th->th.th_info.ds.ds_stacksize, 0); in __kmp_set_stack_info()
520 TCW_PTR(th->th.th_info.ds.ds_stackbase, &stack_data); in __kmp_set_stack_info()
521 TCW_4(th->th.th_info.ds.ds_stackgrow, TRUE); in __kmp_set_stack_info()
[all …]
H A Dkmp_alloc.cpp46 static void bpool(kmp_info_t *th, void *buffer, bufsize len);
47 static void *bget(kmp_info_t *th, bufsize size);
48 static void *bgetz(kmp_info_t *th, bufsize size);
49 static void *bgetr(kmp_info_t *th, void *buffer, bufsize newsize);
50 static void brel(kmp_info_t *th, void *buf);
51 static void bectl(kmp_info_t *th, bget_compact_t compact,
227 static void set_thr_data(kmp_info_t *th) { in set_thr_data() argument
231 data = (thr_data_t *)((!th->th.th_local.bget_data) in set_thr_data()
233 : th->th.th_local.bget_data); in set_thr_data()
242 th->th.th_local.bget_data = data; in set_thr_data()
[all …]
H A Dkmp_barrier.cpp220 int gtid = other_threads[thr]->th.th_info.ds.ds_gtid; in __kmp_dist_barrier_wakeup()
237 team = this_thr->th.th_team; in __kmp_dist_barrier_gather()
238 nproc = this_thr->th.th_team_nproc; in __kmp_dist_barrier_gather()
252 this_thr->th.th_bar_arrive_time = this_thr->th.th_bar_min_time = in __kmp_dist_barrier_gather()
274 kmp_task_team_t *task_team = this_thr->th.th_task_team; in __kmp_dist_barrier_gather()
283 this_thr->th.th_reap_state = KMP_SAFE_TO_REAP; in __kmp_dist_barrier_gather()
286 this_thr->th.th_reap_state = KMP_SAFE_TO_REAP; in __kmp_dist_barrier_gather()
294 this_thr->th.th_reap_state == KMP_SAFE_TO_REAP) { in __kmp_dist_barrier_gather()
295 this_thr->th.th_reap_state = KMP_NOT_SAFE_TO_REAP; in __kmp_dist_barrier_gather()
304 (*reduce)(this_thr->th.th_local.reduce_data, in __kmp_dist_barrier_gather()
[all …]
H A Dkmp_dispatch.cpp43 kmp_info_t *th; in __kmp_dispatch_deo_error() local
48 th = __kmp_threads[*gtid_ref]; in __kmp_dispatch_deo_error()
49 if (th->th.th_root->r.r_active && in __kmp_dispatch_deo_error()
50 (th->th.th_dispatch->th_dispatch_pr_current->pushed_ws != ct_none)) { in __kmp_dispatch_deo_error()
61 kmp_info_t *th; in __kmp_dispatch_dxo_error() local
64 th = __kmp_threads[*gtid_ref]; in __kmp_dispatch_dxo_error()
65 if (th->th.th_dispatch->th_dispatch_pr_current->pushed_ws != ct_none) { in __kmp_dispatch_dxo_error()
113 kmp_info_t *th = __kmp_threads[__kmp_gtid_from_tid((int)id, team)]; in __kmp_initialize_self_buffer() local
115 (kmp_hw_core_type_t)th->th.th_topology_attrs.core_type; in __kmp_initialize_self_buffer()
198 kmp_info_t *th; in __kmp_dispatch_init_algorithm() local
[all …]
H A Dkmp_wait_release.h325 int ds_tid = this_thr->th.th_info.ds.ds_tid;
328 this_thr->th.ompt_thread_info.state = ompt_state_overhead;
332 if (this_thr->th.ompt_thread_info.parallel_flags & ompt_parallel_league)
345 int flags = this_thr->th.ompt_thread_info.parallel_flags;
352 this_thr->th.ompt_thread_info.state = ompt_state_idle;
354 this_thr->th.ompt_thread_info.state = ompt_state_overhead;
389 th_gtid = this_thr->th.th_info.ds.ds_gtid;
391 kmp_team_t *team = this_thr->th.th_team;
397 KMP_ATOMIC_ST_REL(&this_thr->th.th_blocking, true);
459 ompt_entry_state = this_thr->th.ompt_thread_info.state;
[all …]
/freebsd/lib/libthread_db/
H A Dthread_db.c94 td_ta_map_id2thr(const td_thragent_t *ta, thread_t id, td_thrhandle_t *th) in td_ta_map_id2thr() argument
96 return (ta->ta_ops->to_ta_map_id2thr(ta, id, th)); in td_ta_map_id2thr()
100 td_ta_map_lwp2thr(const td_thragent_t *ta, lwpid_t lwpid, td_thrhandle_t *th) in td_ta_map_lwp2thr() argument
102 return (ta->ta_ops->to_ta_map_lwp2thr(ta, lwpid, th)); in td_ta_map_lwp2thr()
144 td_thr_clear_event(const td_thrhandle_t *th, td_thr_events_t *events) in td_thr_clear_event() argument
146 const td_thragent_t *ta = th->th_ta; in td_thr_clear_event()
147 return (ta->ta_ops->to_thr_clear_event(th, events)); in td_thr_clear_event()
151 td_thr_dbresume(const td_thrhandle_t *th) in td_thr_dbresume() argument
153 const td_thragent_t *ta = th->th_ta; in td_thr_dbresume()
154 return (ta->ta_ops->to_thr_dbresume(th)); in td_thr_dbresume()
[all …]
H A Dlibthr_db.c76 static int pt_validate(const td_thrhandle_t *th);
202 pt_ta_map_id2thr(const td_thragent_t *ta, thread_t id, td_thrhandle_t *th) in pt_ta_map_id2thr() argument
229 th->th_ta = ta; in pt_ta_map_id2thr()
230 th->th_tid = id; in pt_ta_map_id2thr()
231 th->th_thread = pt; in pt_ta_map_id2thr()
236 pt_ta_map_lwp2thr(const td_thragent_t *ta, lwpid_t lwp, td_thrhandle_t *th) in pt_ta_map_lwp2thr() argument
238 return (pt_ta_map_id2thr(ta, lwp, th)); in pt_ta_map_lwp2thr()
246 td_thrhandle_t th; in pt_ta_thr_iter() local
261 th.th_ta = ta; in pt_ta_thr_iter()
262 th.th_tid = (thread_t)lwp; in pt_ta_thr_iter()
[all …]
H A Dlibpthread_db.c47 static int pt_validate(const td_thrhandle_t *th);
221 pt_ta_map_id2thr(const td_thragent_t *ta, thread_t id, td_thrhandle_t *th) in pt_ta_map_id2thr() argument
288 th->th_ta = ta; in pt_ta_map_id2thr()
289 th->th_tid = id; in pt_ta_map_id2thr()
290 th->th_thread = pt; in pt_ta_map_id2thr()
295 pt_ta_map_lwp2thr(const td_thragent_t *ta, lwpid_t lwp, td_thrhandle_t *th) in pt_ta_map_lwp2thr() argument
315 th->th_ta = ta; in pt_ta_map_lwp2thr()
316 th->th_tid = pt_map_thread(ta, pt, PT_USER); in pt_ta_map_lwp2thr()
317 if (th->th_tid == -1) in pt_ta_map_lwp2thr()
320 th->th_thread = pt; in pt_ta_map_lwp2thr()
[all …]
/freebsd/sys/netinet/tcp_stacks/
H A Drack_bbr_common.c138 struct tcphdr *th; in ctf_get_enet_type() local
171 if (m->m_len < (sizeof(*ip6) + sizeof(*th))) { in ctf_get_enet_type()
172 m = m_pullup(m, sizeof(*ip6) + sizeof(*th)); in ctf_get_enet_type()
179 th = (struct tcphdr *)(ip6 + 1); in ctf_get_enet_type()
184 th->th_sum = m->m_pkthdr.csum_data; in ctf_get_enet_type()
186 th->th_sum = in6_cksum_pseudo(ip6, tlen, in ctf_get_enet_type()
189 th->th_sum ^= 0xffff; in ctf_get_enet_type()
191 th->th_sum = in6_cksum(m, IPPROTO_TCP, drop_hdrlen, tlen); in ctf_get_enet_type()
192 if (th->th_sum) { in ctf_get_enet_type()
211 th = (struct tcphdr *)(ip + 1); in ctf_get_enet_type()
[all …]
/freebsd/usr.sbin/ppp/
H A Dslcompress.c164 register struct tcphdr *th; in sl_compress_tcp() local
181 th = (struct tcphdr *) & ((int *) ip)[hlen]; in sl_compress_tcp()
182 if ((__tcp_get_flags(th) & (TH_SYN | TH_FIN | TH_RST | TH_ACK)) != TH_ACK) { in sl_compress_tcp()
183 log_Printf(LogDEBUG, "??? 2 th_flags = %x\n", __tcp_get_flags(th)); in sl_compress_tcp()
198 *(int *) th != ((int *) &cs->cs_ip)[cs->cs_ip.ip_hl]) { in sl_compress_tcp()
219 && *(int *) th == ((int *) &cs->cs_ip)[cs->cs_ip.ip_hl]) in sl_compress_tcp()
232 #define THOFFSET(th) (th->th_off) in sl_compress_tcp() argument
233 hlen += th->th_off; in sl_compress_tcp()
265 hlen += th->th_off; in sl_compress_tcp()
273 THOFFSET(th) != THOFFSET(oth) || in sl_compress_tcp()
[all …]
/freebsd/sys/netinet/
H A Dtcp_input.c269 hhook_run_tcp_est_in(struct tcpcb *tp, struct tcphdr *th, struct tcpopt *to) in hhook_run_tcp_est_in() argument
275 hhook_data.th = th; in hhook_run_tcp_est_in()
288 cc_ack_received(struct tcpcb *tp, struct tcphdr *th, uint16_t nsegs, in cc_ack_received() argument
298 tp->t_ccv.bytes_this_ack = BYTES_THIS_ACK(tp, th); in cc_ack_received()
314 SEQ_GEQ(th->th_ack, tp->gput_ack)) { in cc_ack_received()
318 gput = (((int64_t)SEQ_SUB(th->th_ack, tp->gput_seq)) << 3) / in cc_ack_received()
350 tp->t_ccv.curack = th->th_ack; in cc_ack_received()
414 cc_cong_signal(struct tcpcb *tp, struct tcphdr *th, uint32_t type) in cc_cong_signal() argument
436 SEQ_GEQ(th->th_ack, tp->snd_recover)) { in cc_cong_signal()
472 if (th != NULL) in cc_cong_signal()
[all …]
H A Dtcp_reass.c315 struct mbuf *m, struct tcphdr *th, int tlen, in tcp_reass_append() argument
320 tcp_log_reassm(tp, last, NULL, th->th_seq, tlen, TCP_R_LOG_APPEND, 0); in tcp_reass_append()
325 last->tqe_flags |= (tcp_get_flags(th) & TH_FIN); in tcp_reass_append()
340 tcp_reass_prepend(struct tcpcb *tp, struct tseg_qent *first, struct mbuf *m, struct tcphdr *th, in tcp_reass_prepend() argument
346 tcp_log_reassm(tp, first, NULL, th->th_seq, tlen, TCP_R_LOG_PREPEND, 0); in tcp_reass_prepend()
348 if (SEQ_GT((th->th_seq + tlen), first->tqe_start)) { in tcp_reass_prepend()
350 i = (th->th_seq + tlen) - first->tqe_start; in tcp_reass_prepend()
362 first->tqe_start = th->th_seq; in tcp_reass_prepend()
516 tcp_reass(struct tcpcb *tp, struct tcphdr *th, tcp_seq *seq_start, in tcp_reass() argument
536 KASSERT(th == NULL || (seq_start != NULL && tlenp != NULL), in tcp_reass()
[all …]
H A Dtcp_timewait.c156 tcp_twcheck(struct inpcb *inp, struct tcpopt *to, struct tcphdr *th, in tcp_twcheck() argument
167 thflags = tcp_get_flags(th); in tcp_twcheck()
211 if ((s = tcp_log_addrs(&inp->inp_inc, th, NULL, NULL))) { in tcp_twcheck()
228 SEQ_GT(th->th_seq, tp->rcv_nxt)) { in tcp_twcheck()
245 if (tcp_get_flags(th) & TH_ACK) { in tcp_twcheck()
246 tcp_respond(tp, mtod(m, void *), th, m, in tcp_twcheck()
247 (tcp_seq)0, th->th_ack, TH_RST); in tcp_twcheck()
249 if (tcp_get_flags(th) & TH_SYN) in tcp_twcheck()
251 if (tcp_get_flags(th) & TH_FIN) in tcp_twcheck()
253 tcp_respond(tp, mtod(m, void *), th, in tcp_twcheck()
[all...]
/freebsd/sys/net/
H A Dslcompress.c157 struct tcphdr *th; in sl_compress_tcp() local
172 th = (struct tcphdr *)&((int32_t *)ip)[hlen]; in sl_compress_tcp()
173 if ((tcp_get_flags(th) & (TH_SYN|TH_FIN|TH_RST|TH_ACK)) != TH_ACK) in sl_compress_tcp()
185 *(int32_t *)th != ((int32_t *)&cs->cs_ip)[cs->cs_ip.ip_hl]) { in sl_compress_tcp()
206 && *(int32_t *)th == in sl_compress_tcp()
221 hlen += th->th_off; in sl_compress_tcp()
253 hlen += th->th_off; in sl_compress_tcp()
261 th->th_off != oth->th_off || in sl_compress_tcp()
264 (th->th_off > 5 && in sl_compress_tcp()
265 BCMP(th + 1, oth + 1, (th->th_off - 5) << 2))) in sl_compress_tcp()
[all …]
/freebsd/lib/libsys/
H A D__vdso_gettimeofday.c39 tc_delta(const struct vdso_timehands *th, u_int *delta) in tc_delta() argument
44 error = __vdso_gettc(th, &tc); in tc_delta()
46 *delta = (tc - th->th_offset_count) & th->th_counter_mask; in tc_delta()
62 struct vdso_timehands *th; in binuptime() local
73 th = &tk->tk_th[curr]; in binuptime()
74 gen = atomic_load_acq_32(&th->th_gen); in binuptime()
75 *bt = th->th_offset; in binuptime()
76 error = tc_delta(th, &delta); in binuptime()
81 scale = th->th_scale; in binuptime()
95 bintime_add(bt, &th->th_boottime); in binuptime()
[all …]
/freebsd/tools/test/stress2/misc/
H A Dsyzkaller68.sh77 pthread_t th;
83 if (pthread_create(&th, &attr, fn, arg) == 0) {
175 struct thread_t* th = (struct thread_t*)arg;
177 event_wait(&th->ready);
178 event_reset(&th->ready);
179 execute_call(th->call);
181 event_set(&th->done);
192 struct thread_t* th = &threads[thread];
193 if (!th->created) {
194 th->created = 1;
[all …]
H A Dsyzkaller1.sh60 pthread_t th;
66 if (pthread_create(&th, &attr, fn, arg) == 0) {
158 struct thread_t* th = (struct thread_t*)arg;
160 event_wait(&th->ready);
161 event_reset(&th->ready);
162 execute_call(th->call);
164 event_set(&th->done);
175 struct thread_t* th = &threads[thread];
176 if (!th->created) {
177 th->created = 1;
[all …]
H A Dsyzkaller39.sh65 pthread_t th;
71 if (pthread_create(&th, &attr, fn, arg) == 0) {
163 struct thread_t* th = (struct thread_t*)arg;
165 event_wait(&th->ready);
166 event_reset(&th->ready);
167 execute_call(th->call);
169 event_set(&th->done);
182 struct thread_t* th = &threads[thread];
183 if (!th->created) {
184 th->created = 1;
[all …]
/freebsd/crypto/openssl/doc/man7/
H A Dlife_cycle-kdf.pod92 <tr><th style="border:1px solid" align="left">Function Call</th>
93 <th style="border:1px solid" colspan="4">Current State</th></tr>
94 <tr><th style="border:1px solid"></th>
95 <th style="border:1px solid" align="center">start</th>
96 <th style="border:1px solid" align="center">newed</th>
97 <th style="border:1px solid" align="center">deriving</th>
98 <th style="border:1px solid" align="center">freed</th></tr>
99 <tr><th style="border:1px solid" align="left">EVP_KDF_CTX_new</th>
104 <tr><th style="border:1px solid" align="left">EVP_KDF_derive</th>
109 <tr><th style="border:1px solid" align="left">EVP_KDF_CTX_free</th>
[all …]
H A Dlife_cycle-digest.pod113 <tr><th style="border:1px solid" align="left">Function Call</th>
114 <th style="border:1px solid" colspan="6">Current State</th></tr>
115 <tr><th style="border:1px solid"></th>
116 <th style="border:1px solid" align="center">start</th>
117 <th style="border:1px solid" align="center">newed</th>
118 <th style="border:1px solid" align="center">initialised</th>
119 <th style="border:1px solid" align="center">updated</th>
120 <th style="border:1px solid" align="center">finaled</th>
121 <th style="border:1px solid" align="center">freed</th></tr>
122 <tr><th style="border:1px solid" align="left">EVP_MD_CTX_new</th>
[all …]
H A Dlife_cycle-mac.pod113 <tr><th style="border:1px solid" align="left">Function Call</th>
114 <th style="border:1px solid" colspan="6">Current State</th></tr>
115 <tr><th style="border:1px solid"></th>
116 <th style="border:1px solid" align="center">start</th>
117 <th style="border:1px solid" align="center">newed</th>
118 <th style="border:1px solid" align="center">initialised</th>
119 <th style="border:1px solid" align="center">updated</th>
120 <th style="border:1px solid" align="center">finaled</th>
121 <th style="border:1px solid" align="center">freed</th></tr>
122 <tr><th style="border:1px solid" align="left">EVP_MAC_CTX_new</th>
[all …]
/freebsd/sys/kern/
H A Dkern_tc.c206 tc_delta(struct timehands *th) in tc_delta() argument
210 tc = th->th_counter; in tc_delta()
211 return ((tc->tc_get_timecount(tc) - th->th_offset_count) & in tc_delta()
241 struct timehands *th; in bintime_off() local
247 th = timehands; in bintime_off()
248 gen = atomic_load_acq_int(&th->th_generation); in bintime_off()
249 btp = (struct bintime *)((vm_offset_t)th + off); in bintime_off()
251 scale = th->th_scale; in bintime_off()
252 delta = tc_delta(th); in bintime_off()
253 large_delta = th->th_large_delta; in bintime_off()
[all …]

12345678910>>...18