diff options
author | Linus Torvalds <torvalds@woody.linux-foundation.org> | 2007-05-04 22:36:58 -0400 |
---|---|---|
committer | Linus Torvalds <torvalds@woody.linux-foundation.org> | 2007-05-04 22:36:58 -0400 |
commit | 7e20ef030dde0e52dd5a57220ee82fa9facbea4e (patch) | |
tree | 5006db4f85a2d7be2777748aaff2966e79dddc6f /net/ipv4 | |
parent | a3d52136ee8f7399859f9a0824470fd49b1d1a00 (diff) | |
parent | 07d939677166cc4f000c767196872a9becc2697b (diff) |
Merge master.kernel.org:/pub/scm/linux/kernel/git/davem/net-2.6
* master.kernel.org:/pub/scm/linux/kernel/git/davem/net-2.6: (49 commits)
[SCTP]: Set assoc_id correctly during INIT collision.
[SCTP]: Re-order SCTP initializations to avoid race with sctp_rcv()
[SCTP]: Fix the SO_REUSEADDR handling to be similar to TCP.
[SCTP]: Verify all destination ports in sctp_connectx.
[XFRM] SPD info TLV aggregation
[XFRM] SAD info TLV aggregationx
[AF_RXRPC]: Sort out MTU handling.
[AF_IUCV/IUCV] : Add missing section annotations
[AF_IUCV]: Implementation of a skb backlog queue
[NETLINK]: Remove bogus BUG_ON
[IPV6]: Some cleanups in include/net/ipv6.h
[TCP]: zero out rx_opt in tcp_disconnect()
[BNX2]: Fix TSO problem with small MSS.
[NET]: Rework dev_base via list_head (v3)
[TCP] Highspeed: Limited slow-start is nowadays in tcp_slow_start
[BNX2]: Update version and reldate.
[BNX2]: Print bus information for PCIE devices.
[BNX2]: Add 1-shot MSI handler for 5709.
[BNX2]: Restructure PHY event handling.
[BNX2]: Add indirect spinlock.
...
Diffstat (limited to 'net/ipv4')
-rw-r--r-- | net/ipv4/devinet.c | 17 | ||||
-rw-r--r-- | net/ipv4/igmp.c | 15 | ||||
-rw-r--r-- | net/ipv4/ipconfig.c | 2 | ||||
-rw-r--r-- | net/ipv4/netfilter/nf_nat_proto_gre.c | 20 | ||||
-rw-r--r-- | net/ipv4/netfilter/nf_nat_rule.c | 4 | ||||
-rw-r--r-- | net/ipv4/netfilter/nf_nat_sip.c | 26 | ||||
-rw-r--r-- | net/ipv4/tcp.c | 3 | ||||
-rw-r--r-- | net/ipv4/tcp_highspeed.c | 24 | ||||
-rw-r--r-- | net/ipv4/tcp_yeah.h | 7 |
9 files changed, 55 insertions, 63 deletions
diff --git a/net/ipv4/devinet.c b/net/ipv4/devinet.c index 088888db8b..7f95e6e9be 100644 --- a/net/ipv4/devinet.c +++ b/net/ipv4/devinet.c | |||
@@ -910,7 +910,7 @@ no_in_dev: | |||
910 | */ | 910 | */ |
911 | read_lock(&dev_base_lock); | 911 | read_lock(&dev_base_lock); |
912 | rcu_read_lock(); | 912 | rcu_read_lock(); |
913 | for (dev = dev_base; dev; dev = dev->next) { | 913 | for_each_netdev(dev) { |
914 | if ((in_dev = __in_dev_get_rcu(dev)) == NULL) | 914 | if ((in_dev = __in_dev_get_rcu(dev)) == NULL) |
915 | continue; | 915 | continue; |
916 | 916 | ||
@@ -989,7 +989,7 @@ __be32 inet_confirm_addr(const struct net_device *dev, __be32 dst, __be32 local, | |||
989 | 989 | ||
990 | read_lock(&dev_base_lock); | 990 | read_lock(&dev_base_lock); |
991 | rcu_read_lock(); | 991 | rcu_read_lock(); |
992 | for (dev = dev_base; dev; dev = dev->next) { | 992 | for_each_netdev(dev) { |
993 | if ((in_dev = __in_dev_get_rcu(dev))) { | 993 | if ((in_dev = __in_dev_get_rcu(dev))) { |
994 | addr = confirm_addr_indev(in_dev, dst, local, scope); | 994 | addr = confirm_addr_indev(in_dev, dst, local, scope); |
995 | if (addr) | 995 | if (addr) |
@@ -1182,23 +1182,26 @@ static int inet_dump_ifaddr(struct sk_buff *skb, struct netlink_callback *cb) | |||
1182 | int s_ip_idx, s_idx = cb->args[0]; | 1182 | int s_ip_idx, s_idx = cb->args[0]; |
1183 | 1183 | ||
1184 | s_ip_idx = ip_idx = cb->args[1]; | 1184 | s_ip_idx = ip_idx = cb->args[1]; |
1185 | for (dev = dev_base, idx = 0; dev; dev = dev->next, idx++) { | 1185 | idx = 0; |
1186 | for_each_netdev(dev) { | ||
1186 | if (idx < s_idx) | 1187 | if (idx < s_idx) |
1187 | continue; | 1188 | goto cont; |
1188 | if (idx > s_idx) | 1189 | if (idx > s_idx) |
1189 | s_ip_idx = 0; | 1190 | s_ip_idx = 0; |
1190 | if ((in_dev = __in_dev_get_rtnl(dev)) == NULL) | 1191 | if ((in_dev = __in_dev_get_rtnl(dev)) == NULL) |
1191 | continue; | 1192 | goto cont; |
1192 | 1193 | ||
1193 | for (ifa = in_dev->ifa_list, ip_idx = 0; ifa; | 1194 | for (ifa = in_dev->ifa_list, ip_idx = 0; ifa; |
1194 | ifa = ifa->ifa_next, ip_idx++) { | 1195 | ifa = ifa->ifa_next, ip_idx++) { |
1195 | if (ip_idx < s_ip_idx) | 1196 | if (ip_idx < s_ip_idx) |
1196 | continue; | 1197 | goto cont; |
1197 | if (inet_fill_ifaddr(skb, ifa, NETLINK_CB(cb->skb).pid, | 1198 | if (inet_fill_ifaddr(skb, ifa, NETLINK_CB(cb->skb).pid, |
1198 | cb->nlh->nlmsg_seq, | 1199 | cb->nlh->nlmsg_seq, |
1199 | RTM_NEWADDR, NLM_F_MULTI) <= 0) | 1200 | RTM_NEWADDR, NLM_F_MULTI) <= 0) |
1200 | goto done; | 1201 | goto done; |
1201 | } | 1202 | } |
1203 | cont: | ||
1204 | idx++; | ||
1202 | } | 1205 | } |
1203 | 1206 | ||
1204 | done: | 1207 | done: |
@@ -1243,7 +1246,7 @@ void inet_forward_change(void) | |||
1243 | ipv4_devconf_dflt.forwarding = on; | 1246 | ipv4_devconf_dflt.forwarding = on; |
1244 | 1247 | ||
1245 | read_lock(&dev_base_lock); | 1248 | read_lock(&dev_base_lock); |
1246 | for (dev = dev_base; dev; dev = dev->next) { | 1249 | for_each_netdev(dev) { |
1247 | struct in_device *in_dev; | 1250 | struct in_device *in_dev; |
1248 | rcu_read_lock(); | 1251 | rcu_read_lock(); |
1249 | in_dev = __in_dev_get_rcu(dev); | 1252 | in_dev = __in_dev_get_rcu(dev); |
diff --git a/net/ipv4/igmp.c b/net/ipv4/igmp.c index 2506021c29..f4dd474531 100644 --- a/net/ipv4/igmp.c +++ b/net/ipv4/igmp.c | |||
@@ -2288,9 +2288,8 @@ static inline struct ip_mc_list *igmp_mc_get_first(struct seq_file *seq) | |||
2288 | struct ip_mc_list *im = NULL; | 2288 | struct ip_mc_list *im = NULL; |
2289 | struct igmp_mc_iter_state *state = igmp_mc_seq_private(seq); | 2289 | struct igmp_mc_iter_state *state = igmp_mc_seq_private(seq); |
2290 | 2290 | ||
2291 | for (state->dev = dev_base, state->in_dev = NULL; | 2291 | state->in_dev = NULL; |
2292 | state->dev; | 2292 | for_each_netdev(state->dev) { |
2293 | state->dev = state->dev->next) { | ||
2294 | struct in_device *in_dev; | 2293 | struct in_device *in_dev; |
2295 | in_dev = in_dev_get(state->dev); | 2294 | in_dev = in_dev_get(state->dev); |
2296 | if (!in_dev) | 2295 | if (!in_dev) |
@@ -2316,7 +2315,7 @@ static struct ip_mc_list *igmp_mc_get_next(struct seq_file *seq, struct ip_mc_li | |||
2316 | read_unlock(&state->in_dev->mc_list_lock); | 2315 | read_unlock(&state->in_dev->mc_list_lock); |
2317 | in_dev_put(state->in_dev); | 2316 | in_dev_put(state->in_dev); |
2318 | } | 2317 | } |
2319 | state->dev = state->dev->next; | 2318 | state->dev = next_net_device(state->dev); |
2320 | if (!state->dev) { | 2319 | if (!state->dev) { |
2321 | state->in_dev = NULL; | 2320 | state->in_dev = NULL; |
2322 | break; | 2321 | break; |
@@ -2450,9 +2449,9 @@ static inline struct ip_sf_list *igmp_mcf_get_first(struct seq_file *seq) | |||
2450 | struct ip_mc_list *im = NULL; | 2449 | struct ip_mc_list *im = NULL; |
2451 | struct igmp_mcf_iter_state *state = igmp_mcf_seq_private(seq); | 2450 | struct igmp_mcf_iter_state *state = igmp_mcf_seq_private(seq); |
2452 | 2451 | ||
2453 | for (state->dev = dev_base, state->idev = NULL, state->im = NULL; | 2452 | state->idev = NULL; |
2454 | state->dev; | 2453 | state->im = NULL; |
2455 | state->dev = state->dev->next) { | 2454 | for_each_netdev(state->dev) { |
2456 | struct in_device *idev; | 2455 | struct in_device *idev; |
2457 | idev = in_dev_get(state->dev); | 2456 | idev = in_dev_get(state->dev); |
2458 | if (unlikely(idev == NULL)) | 2457 | if (unlikely(idev == NULL)) |
@@ -2488,7 +2487,7 @@ static struct ip_sf_list *igmp_mcf_get_next(struct seq_file *seq, struct ip_sf_l | |||
2488 | read_unlock(&state->idev->mc_list_lock); | 2487 | read_unlock(&state->idev->mc_list_lock); |
2489 | in_dev_put(state->idev); | 2488 | in_dev_put(state->idev); |
2490 | } | 2489 | } |
2491 | state->dev = state->dev->next; | 2490 | state->dev = next_net_device(state->dev); |
2492 | if (!state->dev) { | 2491 | if (!state->dev) { |
2493 | state->idev = NULL; | 2492 | state->idev = NULL; |
2494 | goto out; | 2493 | goto out; |
diff --git a/net/ipv4/ipconfig.c b/net/ipv4/ipconfig.c index 597c800b2f..342ca8d894 100644 --- a/net/ipv4/ipconfig.c +++ b/net/ipv4/ipconfig.c | |||
@@ -192,7 +192,7 @@ static int __init ic_open_devs(void) | |||
192 | if (dev_change_flags(&loopback_dev, loopback_dev.flags | IFF_UP) < 0) | 192 | if (dev_change_flags(&loopback_dev, loopback_dev.flags | IFF_UP) < 0) |
193 | printk(KERN_ERR "IP-Config: Failed to open %s\n", loopback_dev.name); | 193 | printk(KERN_ERR "IP-Config: Failed to open %s\n", loopback_dev.name); |
194 | 194 | ||
195 | for (dev = dev_base; dev; dev = dev->next) { | 195 | for_each_netdev(dev) { |
196 | if (dev == &loopback_dev) | 196 | if (dev == &loopback_dev) |
197 | continue; | 197 | continue; |
198 | if (user_dev_name[0] ? !strcmp(dev->name, user_dev_name) : | 198 | if (user_dev_name[0] ? !strcmp(dev->name, user_dev_name) : |
diff --git a/net/ipv4/netfilter/nf_nat_proto_gre.c b/net/ipv4/netfilter/nf_nat_proto_gre.c index e5a34c17d9..c3908bc5a7 100644 --- a/net/ipv4/netfilter/nf_nat_proto_gre.c +++ b/net/ipv4/netfilter/nf_nat_proto_gre.c | |||
@@ -72,6 +72,11 @@ gre_unique_tuple(struct nf_conntrack_tuple *tuple, | |||
72 | __be16 *keyptr; | 72 | __be16 *keyptr; |
73 | unsigned int min, i, range_size; | 73 | unsigned int min, i, range_size; |
74 | 74 | ||
75 | /* If there is no master conntrack we are not PPTP, | ||
76 | do not change tuples */ | ||
77 | if (!conntrack->master) | ||
78 | return 0; | ||
79 | |||
75 | if (maniptype == IP_NAT_MANIP_SRC) | 80 | if (maniptype == IP_NAT_MANIP_SRC) |
76 | keyptr = &tuple->src.u.gre.key; | 81 | keyptr = &tuple->src.u.gre.key; |
77 | else | 82 | else |
@@ -122,18 +127,9 @@ gre_manip_pkt(struct sk_buff **pskb, unsigned int iphdroff, | |||
122 | if (maniptype != IP_NAT_MANIP_DST) | 127 | if (maniptype != IP_NAT_MANIP_DST) |
123 | return 1; | 128 | return 1; |
124 | switch (greh->version) { | 129 | switch (greh->version) { |
125 | case 0: | 130 | case GRE_VERSION_1701: |
126 | if (!greh->key) { | 131 | /* We do not currently NAT any GREv0 packets. |
127 | DEBUGP("can't nat GRE w/o key\n"); | 132 | * Try to behave like "nf_nat_proto_unknown" */ |
128 | break; | ||
129 | } | ||
130 | if (greh->csum) { | ||
131 | /* FIXME: Never tested this code... */ | ||
132 | nf_proto_csum_replace4(gre_csum(greh), *pskb, | ||
133 | *(gre_key(greh)), | ||
134 | tuple->dst.u.gre.key, 0); | ||
135 | } | ||
136 | *(gre_key(greh)) = tuple->dst.u.gre.key; | ||
137 | break; | 133 | break; |
138 | case GRE_VERSION_PPTP: | 134 | case GRE_VERSION_PPTP: |
139 | DEBUGP("call_id -> 0x%04x\n", ntohs(tuple->dst.u.gre.key)); | 135 | DEBUGP("call_id -> 0x%04x\n", ntohs(tuple->dst.u.gre.key)); |
diff --git a/net/ipv4/netfilter/nf_nat_rule.c b/net/ipv4/netfilter/nf_nat_rule.c index 2a283397a8..2534f718ab 100644 --- a/net/ipv4/netfilter/nf_nat_rule.c +++ b/net/ipv4/netfilter/nf_nat_rule.c | |||
@@ -226,10 +226,6 @@ static int ipt_dnat_checkentry(const char *tablename, | |||
226 | printk("DNAT: multiple ranges no longer supported\n"); | 226 | printk("DNAT: multiple ranges no longer supported\n"); |
227 | return 0; | 227 | return 0; |
228 | } | 228 | } |
229 | if (mr->range[0].flags & IP_NAT_RANGE_PROTO_RANDOM) { | ||
230 | printk("DNAT: port randomization not supported\n"); | ||
231 | return 0; | ||
232 | } | ||
233 | return 1; | 229 | return 1; |
234 | } | 230 | } |
235 | 231 | ||
diff --git a/net/ipv4/netfilter/nf_nat_sip.c b/net/ipv4/netfilter/nf_nat_sip.c index bfd88e4e06..fac97cf51a 100644 --- a/net/ipv4/netfilter/nf_nat_sip.c +++ b/net/ipv4/netfilter/nf_nat_sip.c | |||
@@ -222,6 +222,29 @@ static unsigned int mangle_sdp(struct sk_buff **pskb, | |||
222 | return mangle_content_len(pskb, ctinfo, ct, dptr); | 222 | return mangle_content_len(pskb, ctinfo, ct, dptr); |
223 | } | 223 | } |
224 | 224 | ||
225 | static void ip_nat_sdp_expect(struct nf_conn *ct, | ||
226 | struct nf_conntrack_expect *exp) | ||
227 | { | ||
228 | struct nf_nat_range range; | ||
229 | |||
230 | /* This must be a fresh one. */ | ||
231 | BUG_ON(ct->status & IPS_NAT_DONE_MASK); | ||
232 | |||
233 | /* Change src to where master sends to */ | ||
234 | range.flags = IP_NAT_RANGE_MAP_IPS; | ||
235 | range.min_ip = range.max_ip | ||
236 | = ct->master->tuplehash[!exp->dir].tuple.dst.u3.ip; | ||
237 | /* hook doesn't matter, but it has to do source manip */ | ||
238 | nf_nat_setup_info(ct, &range, NF_IP_POST_ROUTING); | ||
239 | |||
240 | /* For DST manip, map port here to where it's expected. */ | ||
241 | range.flags = (IP_NAT_RANGE_MAP_IPS | IP_NAT_RANGE_PROTO_SPECIFIED); | ||
242 | range.min = range.max = exp->saved_proto; | ||
243 | range.min_ip = range.max_ip = exp->saved_ip; | ||
244 | /* hook doesn't matter, but it has to do destination manip */ | ||
245 | nf_nat_setup_info(ct, &range, NF_IP_PRE_ROUTING); | ||
246 | } | ||
247 | |||
225 | /* So, this packet has hit the connection tracking matching code. | 248 | /* So, this packet has hit the connection tracking matching code. |
226 | Mangle it, and change the expectation to match the new version. */ | 249 | Mangle it, and change the expectation to match the new version. */ |
227 | static unsigned int ip_nat_sdp(struct sk_buff **pskb, | 250 | static unsigned int ip_nat_sdp(struct sk_buff **pskb, |
@@ -239,13 +262,14 @@ static unsigned int ip_nat_sdp(struct sk_buff **pskb, | |||
239 | /* Connection will come from reply */ | 262 | /* Connection will come from reply */ |
240 | newip = ct->tuplehash[!dir].tuple.dst.u3.ip; | 263 | newip = ct->tuplehash[!dir].tuple.dst.u3.ip; |
241 | 264 | ||
265 | exp->saved_ip = exp->tuple.dst.u3.ip; | ||
242 | exp->tuple.dst.u3.ip = newip; | 266 | exp->tuple.dst.u3.ip = newip; |
243 | exp->saved_proto.udp.port = exp->tuple.dst.u.udp.port; | 267 | exp->saved_proto.udp.port = exp->tuple.dst.u.udp.port; |
244 | exp->dir = !dir; | 268 | exp->dir = !dir; |
245 | 269 | ||
246 | /* When you see the packet, we need to NAT it the same as the | 270 | /* When you see the packet, we need to NAT it the same as the |
247 | this one. */ | 271 | this one. */ |
248 | exp->expectfn = nf_nat_follow_master; | 272 | exp->expectfn = ip_nat_sdp_expect; |
249 | 273 | ||
250 | /* Try to get same port: if not, try to change it. */ | 274 | /* Try to get same port: if not, try to change it. */ |
251 | for (port = ntohs(exp->saved_proto.udp.port); port != 0; port++) { | 275 | for (port = ntohs(exp->saved_proto.udp.port); port != 0; port++) { |
diff --git a/net/ipv4/tcp.c b/net/ipv4/tcp.c index d6e4886681..8b124eafbb 100644 --- a/net/ipv4/tcp.c +++ b/net/ipv4/tcp.c | |||
@@ -1760,8 +1760,7 @@ int tcp_disconnect(struct sock *sk, int flags) | |||
1760 | tcp_clear_retrans(tp); | 1760 | tcp_clear_retrans(tp); |
1761 | inet_csk_delack_init(sk); | 1761 | inet_csk_delack_init(sk); |
1762 | tcp_init_send_head(sk); | 1762 | tcp_init_send_head(sk); |
1763 | tp->rx_opt.saw_tstamp = 0; | 1763 | memset(&tp->rx_opt, 0, sizeof(tp->rx_opt)); |
1764 | tcp_sack_reset(&tp->rx_opt); | ||
1765 | __sk_dst_reset(sk); | 1764 | __sk_dst_reset(sk); |
1766 | 1765 | ||
1767 | BUG_TRAP(!inet->num || icsk->icsk_bind_hash); | 1766 | BUG_TRAP(!inet->num || icsk->icsk_bind_hash); |
diff --git a/net/ipv4/tcp_highspeed.c b/net/ipv4/tcp_highspeed.c index a291097fcc..43d624e504 100644 --- a/net/ipv4/tcp_highspeed.c +++ b/net/ipv4/tcp_highspeed.c | |||
@@ -97,10 +97,6 @@ struct hstcp { | |||
97 | u32 ai; | 97 | u32 ai; |
98 | }; | 98 | }; |
99 | 99 | ||
100 | static int max_ssthresh = 100; | ||
101 | module_param(max_ssthresh, int, 0644); | ||
102 | MODULE_PARM_DESC(max_ssthresh, "limited slow start threshold (RFC3742)"); | ||
103 | |||
104 | static void hstcp_init(struct sock *sk) | 100 | static void hstcp_init(struct sock *sk) |
105 | { | 101 | { |
106 | struct tcp_sock *tp = tcp_sk(sk); | 102 | struct tcp_sock *tp = tcp_sk(sk); |
@@ -122,23 +118,9 @@ static void hstcp_cong_avoid(struct sock *sk, u32 adk, u32 rtt, | |||
122 | if (!tcp_is_cwnd_limited(sk, in_flight)) | 118 | if (!tcp_is_cwnd_limited(sk, in_flight)) |
123 | return; | 119 | return; |
124 | 120 | ||
125 | if (tp->snd_cwnd <= tp->snd_ssthresh) { | 121 | if (tp->snd_cwnd <= tp->snd_ssthresh) |
126 | /* RFC3742: limited slow start | 122 | tcp_slow_start(tp); |
127 | * the window is increased by 1/K MSS for each arriving ACK, | 123 | else { |
128 | * for K = int(cwnd/(0.5 max_ssthresh)) | ||
129 | */ | ||
130 | if (max_ssthresh > 0 && tp->snd_cwnd > max_ssthresh) { | ||
131 | u32 k = max(tp->snd_cwnd / (max_ssthresh >> 1), 1U); | ||
132 | if (++tp->snd_cwnd_cnt >= k) { | ||
133 | if (tp->snd_cwnd < tp->snd_cwnd_clamp) | ||
134 | tp->snd_cwnd++; | ||
135 | tp->snd_cwnd_cnt = 0; | ||
136 | } | ||
137 | } else { | ||
138 | if (tp->snd_cwnd < tp->snd_cwnd_clamp) | ||
139 | tp->snd_cwnd++; | ||
140 | } | ||
141 | } else { | ||
142 | /* Update AIMD parameters. | 124 | /* Update AIMD parameters. |
143 | * | 125 | * |
144 | * We want to guarantee that: | 126 | * We want to guarantee that: |
diff --git a/net/ipv4/tcp_yeah.h b/net/ipv4/tcp_yeah.h deleted file mode 100644 index ed3b7198f2..0000000000 --- a/net/ipv4/tcp_yeah.h +++ /dev/null | |||
@@ -1,7 +0,0 @@ | |||
1 | #include <linux/mm.h> | ||
2 | #include <linux/module.h> | ||
3 | #include <linux/skbuff.h> | ||
4 | #include <linux/inet_diag.h> | ||
5 | #include <asm/div64.h> | ||
6 | |||
7 | #include <net/tcp.h> | ||