Commit da0420be authored by Vlad Yasevich's avatar Vlad Yasevich Committed by David S. Miller

sctp: clean up route lookup calls

Change the call to take the transport parameter and set the
cached 'dst' appropriately inside the get_dst() function calls.

This will allow us in the future  to clean up source address
storage as well.
Signed-off-by: default avatarVlad Yasevich <vladislav.yasevich@hp.com>
Signed-off-by: default avatarWei Yongjun <yjwei@cn.fujitsu.com>
Signed-off-by: default avatarDavid S. Miller <davem@davemloft.net>
parent af138470
...@@ -564,8 +564,7 @@ struct sctp_af { ...@@ -564,8 +564,7 @@ struct sctp_af {
int optname, int optname,
char __user *optval, char __user *optval,
int __user *optlen); int __user *optlen);
struct dst_entry *(*get_dst) (struct sctp_association *asoc, void (*get_dst) (struct sctp_transport *t,
union sctp_addr *daddr,
union sctp_addr *saddr, union sctp_addr *saddr,
struct flowi *fl, struct flowi *fl,
struct sock *sk); struct sock *sk);
......
...@@ -247,17 +247,16 @@ static int sctp_v6_xmit(struct sk_buff *skb, struct sctp_transport *transport) ...@@ -247,17 +247,16 @@ static int sctp_v6_xmit(struct sk_buff *skb, struct sctp_transport *transport)
/* Returns the dst cache entry for the given source and destination ip /* Returns the dst cache entry for the given source and destination ip
* addresses. * addresses.
*/ */
static struct dst_entry *sctp_v6_get_dst(struct sctp_association *asoc, static void sctp_v6_get_dst(struct sctp_transport *t, union sctp_addr *saddr,
union sctp_addr *daddr, struct flowi *fl, struct sock *sk)
union sctp_addr *saddr,
struct flowi *fl,
struct sock *sk)
{ {
struct sctp_association *asoc = t->asoc;
struct dst_entry *dst = NULL; struct dst_entry *dst = NULL;
struct flowi6 *fl6 = &fl->u.ip6; struct flowi6 *fl6 = &fl->u.ip6;
struct sctp_bind_addr *bp; struct sctp_bind_addr *bp;
struct sctp_sockaddr_entry *laddr; struct sctp_sockaddr_entry *laddr;
union sctp_addr *baddr = NULL; union sctp_addr *baddr = NULL;
union sctp_addr *daddr = &t->ipaddr;
union sctp_addr dst_saddr; union sctp_addr dst_saddr;
__u8 matchlen = 0; __u8 matchlen = 0;
__u8 bmatchlen; __u8 bmatchlen;
...@@ -270,7 +269,6 @@ static struct dst_entry *sctp_v6_get_dst(struct sctp_association *asoc, ...@@ -270,7 +269,6 @@ static struct dst_entry *sctp_v6_get_dst(struct sctp_association *asoc,
if (ipv6_addr_type(&daddr->v6.sin6_addr) & IPV6_ADDR_LINKLOCAL) if (ipv6_addr_type(&daddr->v6.sin6_addr) & IPV6_ADDR_LINKLOCAL)
fl6->flowi6_oif = daddr->v6.sin6_scope_id; fl6->flowi6_oif = daddr->v6.sin6_scope_id;
SCTP_DEBUG_PRINTK("%s: DST=%pI6 ", __func__, &fl6->daddr); SCTP_DEBUG_PRINTK("%s: DST=%pI6 ", __func__, &fl6->daddr);
if (asoc) if (asoc)
...@@ -343,12 +341,13 @@ static struct dst_entry *sctp_v6_get_dst(struct sctp_association *asoc, ...@@ -343,12 +341,13 @@ static struct dst_entry *sctp_v6_get_dst(struct sctp_association *asoc,
if (!IS_ERR(dst)) { if (!IS_ERR(dst)) {
struct rt6_info *rt; struct rt6_info *rt;
rt = (struct rt6_info *)dst; rt = (struct rt6_info *)dst;
t->dst = dst;
SCTP_DEBUG_PRINTK("rt6_dst:%pI6 rt6_src:%pI6\n", SCTP_DEBUG_PRINTK("rt6_dst:%pI6 rt6_src:%pI6\n",
&rt->rt6i_dst.addr, &fl6->saddr); &rt->rt6i_dst.addr, &fl6->saddr);
return dst; } else {
t->dst = NULL;
SCTP_DEBUG_PRINTK("NO ROUTE\n");
} }
SCTP_DEBUG_PRINTK("NO ROUTE\n");
return NULL;
} }
/* Returns the number of consecutive initial bits that match in the 2 ipv6 /* Returns the number of consecutive initial bits that match in the 2 ipv6
......
...@@ -463,17 +463,16 @@ static sctp_scope_t sctp_v4_scope(union sctp_addr *addr) ...@@ -463,17 +463,16 @@ static sctp_scope_t sctp_v4_scope(union sctp_addr *addr)
* addresses. If an association is passed, trys to get a dst entry with a * addresses. If an association is passed, trys to get a dst entry with a
* source address that matches an address in the bind address list. * source address that matches an address in the bind address list.
*/ */
static struct dst_entry *sctp_v4_get_dst(struct sctp_association *asoc, static void sctp_v4_get_dst(struct sctp_transport *t, union sctp_addr *saddr,
union sctp_addr *daddr, struct flowi *fl, struct sock *sk)
union sctp_addr *saddr,
struct flowi *fl,
struct sock *sk)
{ {
struct sctp_association *asoc = t->asoc;
struct rtable *rt; struct rtable *rt;
struct flowi4 *fl4 = &fl->u.ip4; struct flowi4 *fl4 = &fl->u.ip4;
struct sctp_bind_addr *bp; struct sctp_bind_addr *bp;
struct sctp_sockaddr_entry *laddr; struct sctp_sockaddr_entry *laddr;
struct dst_entry *dst = NULL; struct dst_entry *dst = NULL;
union sctp_addr *daddr = &t->ipaddr;
union sctp_addr dst_saddr; union sctp_addr dst_saddr;
memset(fl4, 0x0, sizeof(struct flowi4)); memset(fl4, 0x0, sizeof(struct flowi4));
...@@ -548,13 +547,12 @@ static struct dst_entry *sctp_v4_get_dst(struct sctp_association *asoc, ...@@ -548,13 +547,12 @@ static struct dst_entry *sctp_v4_get_dst(struct sctp_association *asoc,
out_unlock: out_unlock:
rcu_read_unlock(); rcu_read_unlock();
out: out:
t->dst = dst;
if (dst) if (dst)
SCTP_DEBUG_PRINTK("rt_dst:%pI4, rt_src:%pI4\n", SCTP_DEBUG_PRINTK("rt_dst:%pI4, rt_src:%pI4\n",
&rt->rt_dst, &rt->rt_src); &rt->rt_dst, &rt->rt_src);
else else
SCTP_DEBUG_PRINTK("NO ROUTE\n"); SCTP_DEBUG_PRINTK("NO ROUTE\n");
return dst;
} }
/* For v4, the source address is cached in the route entry(dst). So no need /* For v4, the source address is cached in the route entry(dst). So no need
......
...@@ -213,17 +213,17 @@ void sctp_transport_set_owner(struct sctp_transport *transport, ...@@ -213,17 +213,17 @@ void sctp_transport_set_owner(struct sctp_transport *transport,
/* Initialize the pmtu of a transport. */ /* Initialize the pmtu of a transport. */
void sctp_transport_pmtu(struct sctp_transport *transport, struct sock *sk) void sctp_transport_pmtu(struct sctp_transport *transport, struct sock *sk)
{ {
struct dst_entry *dst;
struct flowi fl; struct flowi fl;
dst = transport->af_specific->get_dst(transport->asoc, /* If we don't have a fresh route, look one up */
&transport->ipaddr, if (!transport->dst || transport->dst->obsolete > 1) {
&transport->saddr, dst_release(transport->dst);
transport->af_specific->get_dst(transport, &transport->saddr,
&fl, sk); &fl, sk);
}
if (dst) { if (transport->dst) {
transport->pathmtu = dst_mtu(dst); transport->pathmtu = dst_mtu(transport->dst);
dst_release(dst);
} else } else
transport->pathmtu = SCTP_DEFAULT_MAXSEGMENT; transport->pathmtu = SCTP_DEFAULT_MAXSEGMENT;
} }
...@@ -274,12 +274,9 @@ void sctp_transport_route(struct sctp_transport *transport, ...@@ -274,12 +274,9 @@ void sctp_transport_route(struct sctp_transport *transport,
{ {
struct sctp_association *asoc = transport->asoc; struct sctp_association *asoc = transport->asoc;
struct sctp_af *af = transport->af_specific; struct sctp_af *af = transport->af_specific;
union sctp_addr *daddr = &transport->ipaddr;
struct dst_entry *dst;
struct flowi fl; struct flowi fl;
dst = af->get_dst(asoc, daddr, saddr, &fl, sctp_opt2sk(opt)); af->get_dst(transport, saddr, &fl, sctp_opt2sk(opt));
transport->dst = dst;
if (saddr) if (saddr)
memcpy(&transport->saddr, saddr, sizeof(union sctp_addr)); memcpy(&transport->saddr, saddr, sizeof(union sctp_addr));
...@@ -289,8 +286,8 @@ void sctp_transport_route(struct sctp_transport *transport, ...@@ -289,8 +286,8 @@ void sctp_transport_route(struct sctp_transport *transport,
if ((transport->param_flags & SPP_PMTUD_DISABLE) && transport->pathmtu) { if ((transport->param_flags & SPP_PMTUD_DISABLE) && transport->pathmtu) {
return; return;
} }
if (dst) { if (transport->dst) {
transport->pathmtu = dst_mtu(dst); transport->pathmtu = dst_mtu(transport->dst);
/* Initialize sk->sk_rcv_saddr, if the transport is the /* Initialize sk->sk_rcv_saddr, if the transport is the
* association's active path for getsockname(). * association's active path for getsockname().
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment