| /src/tests/lib/libpthread/ |
| t_kill.c | 75 } 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/ |
| bswap64.c | 38 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/ |
| simplehook_tester.c | 215 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->th_idx))
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/ |
| tcp_debug.h | 49 struct tcphdr th; member in struct:tcp_debug::__anon5a78d2440108
57 struct tcphdr th; member in struct:tcp_debug::__anon5a78d2440208
|
| tcp_input.c | 290 tcp_setup_ack(struct tcpcb *tp, const struct tcphdr *th)
294 (tcp_ack_on_push && th->th_flags & TH_PUSH))
301 icmp_check(struct tcpcb *tp, const struct tcphdr *th, int acked)
309 SEQ_GT(th->th_ack, tp->t_pmtud_th_seq))
324 tcp_fields_to_host(struct tcphdr *th)
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)
1188 struct tcphdr *th; local in function:tcp_input
[all...] |
| tcp_debug.c | 115 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->th_flags&__CONCAT(TH_,f)) {
[all...] |
| tcp_congctl.c | 465 tcp_reno_do_fast_retransmit(struct tcpcb *tp, const struct tcphdr *th)
493 tp->snd_nxt = th->th_ack;
504 tcp_reno_fast_retransmit(struct tcpcb *tp, const struct tcphdr *th)
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)
604 int acked = th->th_ack - tp->snd_una;
657 tcp_newreno_fast_retransmit(struct tcpcb *tp, const struct tcphdr *th)
[all...] |
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/tests/rtl/ |
| tsan_posix.cc | 60 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[i], 0), 0)
137 pthread_t th; local in function:TEST
[all...] |
| /src/usr.sbin/npf/npftest/ |
| npfstream.c | 42 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/ |
| kern_tc.c | 426 tc_delta(struct timehands *th)
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++/ |
| t_tsan_signal_errno.sh | 75 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/ |
| t_tsan_signal_errno.sh | 75 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/ |
| slcompress.c | 180 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->th_off
477 struct tcphdr *th; local in function:sl_uncompress_tcp_core
[all...] |
| /src/sys/arch/hppa/spmath/ |
| divu.S | 84 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 divide ste
[all...] |
| /src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/ |
| sanitizer_posix.h | 73 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/ |
| cxgb_lro.c | 81 lro_match(struct mbuf *m, struct ip *ih, struct tcphdr *th)
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)
101 if (lro_match(s->head, ih, th))
131 can_lro_tcpsegment(struct tcphdr *th)
133 int olen = (th->th_off << 2) - sizeof (*th);
134 u8 control_bits = *((u8 *)th + 13);
140 uint32_t *ptr = (u32 *)(th + 1)
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/dev/ic/ |
| malovar.h | 116 struct malo_rx_radiotap_hdr th; member in union:malo_softc::__anon3b6e53cc010a
119 #define sc_rxtap sc_rxtapu.th
123 struct malo_tx_radiotap_hdr th; member in union:malo_softc::__anon3b6e53cc020a
126 #define sc_txtap sc_txtapu.th
|
| /src/sys/dev/usb/ |
| if_rumvar.h | 144 struct rum_rx_radiotap_header th; member in union:rum_softc::__anon41cc2323020a
147 #define sc_rxtap sc_rxtapu.th
151 struct rum_tx_radiotap_header th; member in union:rum_softc::__anon41cc2323030a
154 #define sc_txtap sc_txtapu.th
|
| if_uralvar.h | 137 struct ural_rx_radiotap_header th; member in union:ural_softc::__anon6265b6e3030a
140 #define sc_rxtap sc_rxtapu.th
144 struct ural_tx_radiotap_header th; member in union:ural_softc::__anon6265b6e3040a
147 #define sc_txtap sc_txtapu.th
|
| /src/sys/net/lagg/ |
| if_lagg_lacp.h | 76 tlv_set(struct tlvhdr *th, uint8_t t, uint8_t l)
79 th->tlv_type = t;
80 th->tlv_length = sizeof(*th) + l;
|
| /src/sys/dev/arcbios/ |
| arcbios_calls.S | 83 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 arg on stack (o32
[all...] |
| /src/sys/net/npf/ |
| npf_sendpkt.c | 98 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->th_sum = in_cksum(m, len)
[all...] |
| npf_ext_normalize.c | 150 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/ |
| main.c | 65 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/ |
| in6_offload.c | 59 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->th_sum = in6_cksum(n, 0, off + iphlen, thlen + mss)
[all...] |
