Searched refs:th (Results 1 - 25 of 119) sorted by relevance

12345

/src/tests/lib/libpthread/
H A Dt_kill.c75 } th[NTHREAD]; variable in typeref:struct:threadinfo[]
90 if (self == th[i].id)
95 th[i].gotsignal++;
125 PTHREAD_REQUIRE(pthread_create(&th[i].id, NULL, f, &th[i]));
134 PTHREAD_REQUIRE(pthread_kill(th[i].id, SIGUSR1));
138 PTHREAD_REQUIRE(pthread_join(th[i].id, NULL));
/src/common/lib/libc/gen/
H A Dbswap64.c38 uint32_t tl, th;
40 th = bswap32((uint32_t)(x & 0x00000000ffffffffULL));
42 return ((uint64_t)th << 32) | tl;
/src/sys/rump/kern/lib/libsimplehook_tester/
H A Dsimplehook_tester.c215 struct tester_hook *th; local in function:simplehook_tester_hook
217 th = xth;
218 ctx = th->th_ctx;
222 __func__, __LINE__, th->th_idx));
224 th->th_stopped = false;
226 while (th->th_stopping) {
228 __func__, __LINE__, th->th_idx));
229 th->th_stopped = true;
233 if (th->th_stopped) {
235 __func__, __LINE__, th
275 struct tester_hook *th; local in function:simplehook_tester_established
393 struct tester_hook *th; local in function:simplehook_tester_stopping
430 struct tester_hook *th; local in function:simplehook_tester_stopped
452 struct tester_hook *th; local in function:simplehook_tester_disestablish
491 struct tester_hook *th; local in function:simplehook_tester_count
671 struct tester_hook *th; local in function:simplehook_tester_fini
[all...]
/src/sys/netinet/
H A Dtcp_debug.h49 struct tcphdr th; member in struct:tcp_debug::__anon793df6ea0108
57 struct tcphdr th; member in struct:tcp_debug::__anon793df6ea0208
H A Dtcp_input.c290 tcp_setup_ack(struct tcpcb *tp, const struct tcphdr *th) argument
294 (tcp_ack_on_push && th->th_flags & TH_PUSH))
301 icmp_check(struct tcpcb *tp, const struct tcphdr *th, int acked) argument
309 SEQ_GT(th->th_ack, tp->t_pmtud_th_seq))
324 tcp_fields_to_host(struct tcphdr *th) argument
327 NTOHL(th->th_seq);
328 NTOHL(th->th_ack);
329 NTOHS(th->th_win);
330 NTOHS(th->th_urp);
337 tcp_fields_to_net(struct tcphdr *th) argument
347 tcp_urp_drop(struct tcphdr * th,int todrop,int * tiflags) argument
455 tcp_reass(struct tcpcb * tp,const struct tcphdr * th,struct mbuf * m,int tlen) argument
833 tcp4_log_refused(const struct ip * ip,const struct tcphdr * th) argument
853 tcp6_log_refused(const struct ip6_hdr * ip6,const struct tcphdr * th) argument
876 tcp_input_checksum(int af,struct mbuf * m,const struct tcphdr * th,int toff,int off,int tlen) argument
988 tcp_vtw_input(struct tcphdr * th,vestigial_inpcb_t * vp,struct mbuf * m,int tlen) argument
1188 struct tcphdr *th; local in function:tcp_input
3012 tcp_signature(struct mbuf * m,struct tcphdr * th,int thoff,struct secasvar * sav,char * sig) argument
3086 tcp_dooptions(struct tcpcb * tp,const u_char * cp,int cnt,struct tcphdr * th,struct mbuf * m,int toff,struct tcp_opt_info * oi) argument
3266 tcp_pulloutofband(struct socket * so,struct tcphdr * th,struct mbuf * m,int off) argument
[all...]
H A Dtcp_debug.c115 struct tcphdr *th; local in function:tcp_trace
133 th = NULL;
142 th = (struct tcphdr *)((char *)&td->td_ti +
151 th = (struct tcphdr *)((char *)&td->td_ti6 +
170 if (th == 0)
172 seq = th->th_seq;
173 ack = th->th_ack;
186 printf("@%x, urp=%x", ack, th->th_urp);
187 flags = th->th_flags;
191 #define pf(f) { if (th
[all...]
H A Dtcp_congctl.c465 tcp_reno_do_fast_retransmit(struct tcpcb *tp, const struct tcphdr *th) argument
493 tp->snd_nxt = th->th_ack;
504 tcp_reno_fast_retransmit(struct tcpcb *tp, const struct tcphdr *th) argument
516 return tcp_reno_do_fast_retransmit(tp, th);
565 const struct tcphdr *th)
583 if (TCP_SACK_ENABLED(tp) && SEQ_GT(th->th_ack, tp->snd_fack))
584 tp->snd_fack = th->th_ack;
589 tcp_reno_newack(struct tcpcb *tp, const struct tcphdr *th) argument
604 int acked = th->th_ack - tp->snd_una;
657 tcp_newreno_fast_retransmit(struct tcpcb *tp, const struct tcphdr *th) argument
564 tcp_reno_fast_retransmit_newack(struct tcpcb * tp,const struct tcphdr * th) argument
679 tcp_newreno_fast_retransmit_newack(struct tcpcb * tp,const struct tcphdr * th) argument
773 tcp_newreno_newack(struct tcpcb * tp,const struct tcphdr * th) argument
906 tcp_cubic_fast_retransmit(struct tcpcb * tp,const struct tcphdr * th) argument
925 tcp_cubic_newack(struct tcpcb * tp,const struct tcphdr * th) argument
[all...]
/src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/rtl/
H A Dtsan_posix.cc60 pthread_t th[3]; local in function:TEST
64 EXPECT_EQ(__interceptor_pthread_create(&th[0], 0, dtors_thread, &k1), 0);
65 EXPECT_EQ(__interceptor_pthread_create(&th[1], 0, dtors_thread, &k2), 0);
66 EXPECT_EQ(__interceptor_pthread_join(th[0], 0), 0);
67 EXPECT_EQ(__interceptor_pthread_create(&th[2], 0, dtors_thread, &k3), 0);
68 EXPECT_EQ(__interceptor_pthread_join(th[1], 0), 0);
69 EXPECT_EQ(__interceptor_pthread_join(th[2], 0), 0);
83 pthread_t th[kThreads]; local in function:local_thread
85 EXPECT_EQ(__interceptor_pthread_create(&th[i], 0, local_thread,
88 EXPECT_EQ(__interceptor_pthread_join(th[
137 pthread_t th; local in function:TEST
[all...]
/src/usr.sbin/npf/npftest/
H A Dnpfstream.c42 const struct tcphdr *th; local in function:process_tcpip
57 th = (const struct tcphdr *)p;
59 tcpdlen = ntohs(ip->ip_len) - hlen - (th->th_off << 2);
60 if (th->th_flags & TH_SYN) {
63 if (th->th_flags & TH_FIN) {
66 seq = ntohl(th->th_seq);
82 forw ? ">" : "<", (th->th_flags & (TH_SYN | TH_ACK | TH_FIN)),
83 packetno, error, (unsigned)seq, (unsigned)ntohl(th->th_ack),
84 tcpdlen, ntohs(th->th_win), (uintptr_t)result[0]);
/src/sys/kern/
H A Dkern_tc.c426 tc_delta(struct timehands *th) argument
430 tc = th->th_counter;
432 th->th_offset_count) & tc->tc_counter_mask;
444 struct timehands *th; local in function:binuptime
474 * th->th_generation, I'm all ears.
484 th = atomic_load_consume(&timehands);
485 gen = th->th_generation;
487 *bt = th->th_offset;
488 bintime_addx(bt, th->th_scale * tc_delta(th));
550 struct timehands *th; local in function:getbinuptime
566 struct timehands *th; local in function:getnanouptime
582 struct timehands *th; local in function:getmicrouptime
598 struct timehands *th; local in function:getbintime
617 struct timehands *th; local in function:dogetnanotime
649 struct timehands *th; local in function:getmicrotime
916 struct timehands *th, *tho; local in function:tc_windup
1136 struct timehands *th; local in function:pps_capture
1205 struct timehands *th; local in function:pps_ref_event
[all...]
/src/tests/usr.bin/c++/
H A Dt_tsan_signal_errno.sh75 pthread_t th;
76 pthread_create(&th, 0, sendsignal, 0);
77 pthread_join(th, 0);
103 pthread_t th;
104 pthread_create(&th, 0, sendsignal, 0);
105 pthread_join(th, 0);
137 pthread_t th;
138 pthread_create(&th, 0, sendsignal, 0);
139 pthread_join(th, 0);
171 pthread_t th;
[all...]
/src/tests/usr.bin/cc/
H A Dt_tsan_signal_errno.sh75 pthread_t th;
76 pthread_create(&th, 0, sendsignal, 0);
77 pthread_join(th, 0);
103 pthread_t th;
104 pthread_create(&th, 0, sendsignal, 0);
105 pthread_join(th, 0);
137 pthread_t th;
138 pthread_create(&th, 0, sendsignal, 0);
139 pthread_join(th, 0);
171 pthread_t th;
[all...]
/src/sys/net/
H A Dslcompress.c180 struct tcphdr *th; local in function:sl_compress_tcp
195 th = (struct tcphdr *)&((int32_t *)ip)[hlen];
196 if ((th->th_flags & (TH_SYN|TH_FIN|TH_RST|TH_ACK)) != TH_ACK)
208 *(int32_t *)th != ((int32_t *)&cs->cs_ip)[cs->cs_ip.ip_hl]) {
228 && *(int32_t *)th ==
243 hlen += th->th_off;
265 * check is unnecessary but costless). The 4th line checks the TCP
266 * header length. The 5th line checks IP options, if any. The 6th
273 hlen += th
477 struct tcphdr *th; local in function:sl_uncompress_tcp_core
[all...]
/src/sys/arch/hppa/spmath/
H A Ddivu.S84 ds rem,dvr,rem ; 4th divide step
86 ds rem,dvr,rem ; 5th divide step
88 ds rem,dvr,rem ; 6th divide step
90 ds rem,dvr,rem ; 7th divide step
92 ds rem,dvr,rem ; 8th divide step
94 ds rem,dvr,rem ; 9th divide step
96 ds rem,dvr,rem ; 10th divide step
98 ds rem,dvr,rem ; 11th divide step
100 ds rem,dvr,rem ; 12th divide step
102 ds rem,dvr,rem ; 13th divid
[all...]
/src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/
H A Dsanitizer_posix.h73 int real_pthread_create(void *th, void *attr, void *(*callback)(void *),
76 int real_pthread_join(void *th, void **ret);
80 int real_pthread_create(void *th, void *attr, void *(*callback)(void *), \
82 return REAL(pthread_create)(th, attr, callback, param); \
84 int real_pthread_join(void *th, void **ret) { \
85 return REAL(pthread_join(th, ret)); \
/src/sys/dev/pci/cxgb/
H A Dcxgb_lro.c81 lro_match(struct mbuf *m, struct ip *ih, struct tcphdr *th) argument
86 return (th->th_sport == sth->th_sport &&
87 th->th_dport == sth->th_dport &&
93 lro_lookup(struct lro_state *l, int idx, struct ip *ih, struct tcphdr *th) argument
101 if (lro_match(s->head, ih, th))
131 can_lro_tcpsegment(struct tcphdr *th) argument
133 int olen = (th->th_off << 2) - sizeof (*th);
134 u8 control_bits = *((u8 *)th + 13);
140 uint32_t *ptr = (u32 *)(th
159 struct tcphdr *th = (struct tcphdr *) (ih + 1); local in function:lro_new_session_init
250 struct tcphdr *th, *nth = (struct tcphdr *)(nih + 1); local in function:lro_update_session
331 struct tcphdr *th; local in function:t3_rx_eth_lro
[all...]
/src/sys/net/lagg/
H A Dif_lagg_lacp.h76 tlv_set(struct tlvhdr *th, uint8_t t, uint8_t l) argument
79 th->tlv_type = t;
80 th->tlv_length = sizeof(*th) + l;
/src/sys/dev/ic/
H A Dmalovar.h116 struct malo_rx_radiotap_hdr th; member in union:malo_softc::__anonb4174a32010a
119 #define sc_rxtap sc_rxtapu.th
123 struct malo_tx_radiotap_hdr th; member in union:malo_softc::__anonb4174a32020a
126 #define sc_txtap sc_txtapu.th
/src/sys/dev/usb/
H A Dif_rumvar.h144 struct rum_rx_radiotap_header th; member in union:rum_softc::__anon609147c9020a
147 #define sc_rxtap sc_rxtapu.th
151 struct rum_tx_radiotap_header th; member in union:rum_softc::__anon609147c9030a
154 #define sc_txtap sc_txtapu.th
H A Dif_uralvar.h137 struct ural_rx_radiotap_header th; member in union:ural_softc::__anon59cf7049030a
140 #define sc_rxtap sc_rxtapu.th
144 struct ural_tx_radiotap_header th; member in union:ural_softc::__anon59cf7049040a
147 #define sc_txtap sc_txtapu.th
/src/sys/dev/arcbios/
H A Darcbios_calls.S83 INT_L ta0, CALLFRAME2_SIZ+16(sp) # load 5th arg
84 INT_L ta1, CALLFRAME2_SIZ+20(sp) # load 6th arg
85 INT_L ta2, CALLFRAME2_SIZ+24(sp) # load 7th arg
86 INT_L ta3, CALLFRAME2_SIZ+28(sp) # load 8th arg
87 INT_S ta0, 16(sp) # save 5th arg on stack (o32)
88 INT_S ta1, 20(sp) # save 6th arg on stack (o32)
89 INT_S ta2, 24(sp) # save 7th arg on stack (o32)
90 INT_S ta3, 28(sp) # save 8th arg on stack (o32)
92 INT_S a4, 16(sp) # save 5th arg on stack (o32)
93 INT_S a5, 20(sp) # save 6th ar
[all...]
/src/sys/net/npf/
H A Dnpf_sendpkt.c98 struct tcphdr *oth, *th; local in function:npf_return_tcp
147 th = (struct tcphdr *)(ip + 1);
162 th = (struct tcphdr *)(ip6 + 1);
168 th->th_sport = oth->th_dport;
169 th->th_dport = oth->th_sport;
170 th->th_seq = htonl(ack);
174 th->th_ack = htonl(seq + tcpdlen);
175 th->th_off = sizeof(struct tcphdr) >> 2;
176 th->th_flags = TH_ACK | TH_RST;
179 th
[all...]
H A Dnpf_ext_normalize.c150 struct tcphdr *th; local in function:npf_normalize
163 th = npc->npc_l4.tcp;
170 (th->th_flags & TH_SYN) == 0) {
193 th = npc->npc_l4.tcp;
195 cksum = th->th_sum;
199 cksum = npf_fixup16_cksum(th->th_sum, mss, maxmss);
201 th->th_sum = cksum;
/src/usr.sbin/mscdlabel/
H A Dmain.c65 struct ioc_toc_header th; local in function:getcdtoc
69 memset(&th, 0, sizeof(th));
70 res = ioctl(fd, CDIOREADTOCHEADER, &th);
76 ntracks = th.ending_track - th.starting_track + 1;
84 te.starting_track = th.starting_track; /* always 1 ??? */
/src/sys/netinet6/
H A Din6_offload.c59 struct tcphdr *th; local in function:tcp6_segment
74 KASSERT(len >= off + sizeof(*iph) + sizeof(*th));
87 hlen = off + iphlen + sizeof(*th);
93 th = (void *)(mtod(m, char *) + off + iphlen);
94 tcpseq = ntohl(th->th_seq);
95 thlen = th->th_off * 4;
147 th = (void *)(mtod(n, char *) + off + iphlen);
148 th->th_seq = htonl(tcpseq);
149 th->th_sum = phsum;
150 th
[all...]

Completed in 24 milliseconds

12345