summaryrefslogtreecommitdiff
path: root/sys
diff options
context:
space:
mode:
Diffstat (limited to 'sys')
-rw-r--r--sys/netinet/tcp_input.c10
-rw-r--r--sys/netinet/tcp_subr.c116
-rw-r--r--sys/netinet/tcp_timer.c4
-rw-r--r--sys/netinet/tcp_var.h4
4 files changed, 62 insertions, 72 deletions
diff --git a/sys/netinet/tcp_input.c b/sys/netinet/tcp_input.c
index a5b0b39b2b0..ebbff633605 100644
--- a/sys/netinet/tcp_input.c
+++ b/sys/netinet/tcp_input.c
@@ -1,4 +1,4 @@
-/* $OpenBSD: tcp_input.c,v 1.211 2008/02/11 18:03:16 bluhm Exp $ */
+/* $OpenBSD: tcp_input.c,v 1.212 2008/02/20 11:24:02 markus Exp $ */
/* $NetBSD: tcp_input.c,v 1.23 1996/02/13 23:43:44 christos Exp $ */
/*
@@ -2209,14 +2209,15 @@ dropwithreset:
if (tiflags & TH_RST)
goto drop;
if (tiflags & TH_ACK) {
- tcp_respond(tp, mtod(m, caddr_t), m, (tcp_seq)0, th->th_ack,
+ tcp_respond(tp, mtod(m, caddr_t), th, (tcp_seq)0, th->th_ack,
TH_RST);
} else {
if (tiflags & TH_SYN)
tlen++;
- tcp_respond(tp, mtod(m, caddr_t), m, th->th_seq + tlen,
+ tcp_respond(tp, mtod(m, caddr_t), th, th->th_seq + tlen,
(tcp_seq)0, TH_RST|TH_ACK);
}
+ m_freem(m);
return;
drop:
@@ -3863,7 +3864,8 @@ syn_cache_get(src, dst, th, hlen, tlen, so, m)
return (so);
resetandabort:
- tcp_respond(NULL, mtod(m, caddr_t), m, (tcp_seq)0, th->th_ack, TH_RST);
+ tcp_respond(NULL, mtod(m, caddr_t), th, (tcp_seq)0, th->th_ack, TH_RST);
+ m_freem(m);
abort:
if (so != NULL)
(void) soabort(so);
diff --git a/sys/netinet/tcp_subr.c b/sys/netinet/tcp_subr.c
index 66ac661607e..8c345605167 100644
--- a/sys/netinet/tcp_subr.c
+++ b/sys/netinet/tcp_subr.c
@@ -1,4 +1,4 @@
-/* $OpenBSD: tcp_subr.c,v 1.101 2007/11/27 17:23:23 deraadt Exp $ */
+/* $OpenBSD: tcp_subr.c,v 1.102 2008/02/20 11:24:03 markus Exp $ */
/* $NetBSD: tcp_subr.c,v 1.22 1996/02/13 23:44:00 christos Exp $ */
/*
@@ -318,18 +318,23 @@ tcp_template(tp)
/* This function looks hairy, because it was so IPv4-dependent. */
#endif /* INET6 */
void
-tcp_respond(tp, template, m, ack, seq, flags)
+tcp_respond(tp, template, th0, ack, seq, flags)
struct tcpcb *tp;
caddr_t template;
- struct mbuf *m;
+ struct tcphdr *th0;
tcp_seq ack, seq;
int flags;
{
int tlen;
int win = 0;
+ struct mbuf *m = 0;
struct route *ro = 0;
struct tcphdr *th;
- struct tcpiphdr *ti = (struct tcpiphdr *)template;
+ struct ip *ip;
+ struct ipovly *ih;
+#ifdef INET6
+ struct ip6_hdr *ip6;
+#endif
int af; /* af on wire */
if (tp) {
@@ -346,65 +351,48 @@ tcp_respond(tp, template, m, ack, seq, flags)
*/
ro = &tp->t_inpcb->inp_route;
} else
- af = (((struct ip *)ti)->ip_v == 6) ? AF_INET6 : AF_INET;
- if (m == 0) {
- m = m_gethdr(M_DONTWAIT, MT_HEADER);
- if (m == NULL)
- return;
- tlen = 0;
- m->m_data += max_linkhdr;
- switch (af) {
-#ifdef INET6
- case AF_INET6:
- bcopy(ti, mtod(m, caddr_t), sizeof(struct tcphdr) +
- sizeof(struct ip6_hdr));
- break;
-#endif /* INET6 */
- case AF_INET:
- bcopy(ti, mtod(m, caddr_t), sizeof(struct tcphdr) +
- sizeof(struct ip));
- break;
- }
+ af = (((struct ip *)template)->ip_v == 6) ? AF_INET6 : AF_INET;
+
+ m = m_gethdr(M_DONTWAIT, MT_HEADER);
+ if (m == NULL)
+ return;
+ m->m_data += max_linkhdr;
+ tlen = 0;
- ti = mtod(m, struct tcpiphdr *);
- flags = TH_ACK;
- } else {
- m_freem(m->m_next);
- m->m_next = 0;
- m->m_data = (caddr_t)ti;
- tlen = 0;
#define xchg(a,b,type) do { type t; t=a; a=b; b=t; } while (0)
- switch (af) {
-#ifdef INET6
- case AF_INET6:
- m->m_len = sizeof(struct tcphdr) + sizeof(struct ip6_hdr);
- xchg(((struct ip6_hdr *)ti)->ip6_dst,
- ((struct ip6_hdr *)ti)->ip6_src, struct in6_addr);
- th = (void *)((caddr_t)ti + sizeof(struct ip6_hdr));
- break;
-#endif /* INET6 */
- case AF_INET:
- m->m_len = sizeof (struct tcpiphdr);
- xchg(ti->ti_dst.s_addr, ti->ti_src.s_addr, u_int32_t);
- th = (void *)((caddr_t)ti + sizeof(struct ip));
- break;
- }
- xchg(th->th_dport, th->th_sport, u_int16_t);
-#undef xchg
- }
switch (af) {
#ifdef INET6
case AF_INET6:
- tlen += sizeof(struct tcphdr) + sizeof(struct ip6_hdr);
- th = (struct tcphdr *)((caddr_t)ti + sizeof(struct ip6_hdr));
+ ip6 = mtod(m, struct ip6_hdr *);
+ th = (struct tcphdr *)(ip6 + 1);
+ tlen = sizeof(*ip6) + sizeof(*th);
+ if (th0) {
+ bcopy(template, ip6, sizeof(*ip6));
+ bcopy(th0, th, sizeof(*th));
+ xchg(ip6->ip6_dst, ip6->ip6_src, struct in6_addr);
+ } else {
+ bcopy(template, ip6, tlen);
+ }
break;
#endif /* INET6 */
case AF_INET:
- ti->ti_len = htons((u_int16_t)(sizeof (struct tcphdr) + tlen));
- tlen += sizeof (struct tcpiphdr);
- th = (struct tcphdr *)((caddr_t)ti + sizeof(struct ip));
+ ip = mtod(m, struct ip *);
+ th = (struct tcphdr *)(ip + 1);
+ tlen = sizeof(*ip) + sizeof(*th);
+ if (th0) {
+ bcopy(template, ip, sizeof(*ip));
+ bcopy(th0, th, sizeof(*th));
+ xchg(ip->ip_dst.s_addr, ip->ip_src.s_addr, u_int32_t);
+ } else {
+ bcopy(template, ip, tlen);
+ }
break;
}
+ if (th0)
+ xchg(th->th_dport, th->th_sport, u_int16_t);
+ else
+ flags = TH_ACK;
+#undef xchg
m->m_len = tlen;
m->m_pkthdr.len = tlen;
@@ -424,23 +412,23 @@ tcp_respond(tp, template, m, ack, seq, flags)
switch (af) {
#ifdef INET6
case AF_INET6:
- ((struct ip6_hdr *)ti)->ip6_flow = htonl(0x60000000);
- ((struct ip6_hdr *)ti)->ip6_nxt = IPPROTO_TCP;
- ((struct ip6_hdr *)ti)->ip6_hlim =
- in6_selecthlim(tp ? tp->t_inpcb : NULL, NULL); /*XXX*/
- ((struct ip6_hdr *)ti)->ip6_plen = tlen - sizeof(struct ip6_hdr);
+ ip6->ip6_flow = htonl(0x60000000);
+ ip6->ip6_nxt = IPPROTO_TCP;
+ ip6->ip6_hlim = in6_selecthlim(tp ? tp->t_inpcb : NULL, NULL); /*XXX*/
+ ip6->ip6_plen = tlen - sizeof(struct ip6_hdr);
th->th_sum = 0;
th->th_sum = in6_cksum(m, IPPROTO_TCP,
- sizeof(struct ip6_hdr), ((struct ip6_hdr *)ti)->ip6_plen);
- HTONS(((struct ip6_hdr *)ti)->ip6_plen);
+ sizeof(struct ip6_hdr), ip6->ip6_plen);
+ HTONS(ip6->ip6_plen);
ip6_output(m, tp ? tp->t_inpcb->inp_outputopts6 : NULL,
(struct route_in6 *)ro, 0, NULL, NULL,
tp ? tp->t_inpcb : NULL);
break;
#endif /* INET6 */
case AF_INET:
- bzero(ti->ti_x1, sizeof ti->ti_x1);
- ti->ti_len = htons((u_short)tlen - sizeof(struct ip));
+ ih = (struct ipovly *)ip;
+ bzero(ih->ih_x1, sizeof ih->ih_x1);
+ ih->ih_len = htons((u_short)tlen - sizeof(struct ip));
/*
* There's no point deferring to hardware checksum processing
@@ -449,8 +437,8 @@ tcp_respond(tp, template, m, ack, seq, flags)
*/
th->th_sum = 0;
th->th_sum = in_cksum(m, tlen);
- ((struct ip *)ti)->ip_len = htons(tlen);
- ((struct ip *)ti)->ip_ttl = ip_defttl;
+ ip->ip_len = htons(tlen);
+ ip->ip_ttl = ip_defttl;
ip_output(m, (void *)NULL, ro, ip_mtudisc ? IP_MTUDISC : 0,
(void *)NULL, tp ? tp->t_inpcb : (void *)NULL);
}
diff --git a/sys/netinet/tcp_timer.c b/sys/netinet/tcp_timer.c
index f313b4b1857..69c70b9cc29 100644
--- a/sys/netinet/tcp_timer.c
+++ b/sys/netinet/tcp_timer.c
@@ -1,4 +1,4 @@
-/* $OpenBSD: tcp_timer.c,v 1.41 2007/11/27 17:23:23 deraadt Exp $ */
+/* $OpenBSD: tcp_timer.c,v 1.42 2008/02/20 11:24:03 markus Exp $ */
/* $NetBSD: tcp_timer.c,v 1.14 1996/02/13 23:44:09 christos Exp $ */
/*
@@ -453,7 +453,7 @@ tcp_timer_keep(void *arg)
*/
tcpstat.tcps_keepprobe++;
tcp_respond(tp, mtod(tp->t_template, caddr_t),
- (struct mbuf *)NULL, tp->rcv_nxt, tp->snd_una - 1, 0);
+ NULL, tp->rcv_nxt, tp->snd_una - 1, 0);
TCP_TIMER_ARM(tp, TCPT_KEEP, tcp_keepintvl);
} else
TCP_TIMER_ARM(tp, TCPT_KEEP, tcp_keepidle);
diff --git a/sys/netinet/tcp_var.h b/sys/netinet/tcp_var.h
index cf2859b19d2..e3d7ab710cb 100644
--- a/sys/netinet/tcp_var.h
+++ b/sys/netinet/tcp_var.h
@@ -1,4 +1,4 @@
-/* $OpenBSD: tcp_var.h,v 1.84 2007/12/13 20:00:53 reyk Exp $ */
+/* $OpenBSD: tcp_var.h,v 1.85 2008/02/20 11:24:03 markus Exp $ */
/* $NetBSD: tcp_var.h,v 1.17 1996/02/13 23:44:24 christos Exp $ */
/*
@@ -616,7 +616,7 @@ int tcp_output(struct tcpcb *);
void tcp_pulloutofband(struct socket *, u_int, struct mbuf *, int);
int tcp_reass(struct tcpcb *, struct tcphdr *, struct mbuf *, int *);
void tcp_rscale(struct tcpcb *, u_long);
-void tcp_respond(struct tcpcb *, caddr_t, struct mbuf *, tcp_seq,
+void tcp_respond(struct tcpcb *, caddr_t, struct tcphdr *, tcp_seq,
tcp_seq, int);
void tcp_setpersist(struct tcpcb *);
void tcp_slowtimo(void);
generated by cgit v1.2.3 (git 2.25.1) at 2024-12-29 06:58:35 +0000