2 * INET An implementation of the TCP/IP protocol suite for the LINUX
3 * operating system. INET is implemented using the BSD Socket
4 * interface as the means of communication with the user level.
6 * Support for INET6 connection oriented protocols.
8 * Authors: See the TCPv6 sources
10 * This program is free software; you can redistribute it and/or
11 * modify it under the terms of the GNU General Public License
12 * as published by the Free Software Foundation; either version
13 * 2 of the License, or(at your option) any later version.
16 #include <linux/module.h>
17 #include <linux/in6.h>
18 #include <linux/ipv6.h>
19 #include <linux/jhash.h>
20 #include <linux/slab.h>
22 #include <net/addrconf.h>
23 #include <net/inet_connection_sock.h>
24 #include <net/inet_ecn.h>
25 #include <net/inet_hashtables.h>
26 #include <net/ip6_route.h>
28 #include <net/inet6_connection_sock.h>
30 int inet6_csk_bind_conflict(const struct sock
*sk
,
31 const struct inet_bind_bucket
*tb
, bool relax
)
33 const struct sock
*sk2
;
34 const struct hlist_node
*node
;
35 int reuse
= sk
->sk_reuse
;
36 int reuseport
= sk
->sk_reuseport
;
37 kuid_t uid
= sock_i_uid((struct sock
*)sk
);
39 /* We must walk the whole port owner list in this case. -DaveM */
41 * See comment in inet_csk_bind_conflict about sock lookup
42 * vs net namespaces issues.
44 sk_for_each_bound(sk2
, node
, &tb
->owners
) {
46 (!sk
->sk_bound_dev_if
||
47 !sk2
->sk_bound_dev_if
||
48 sk
->sk_bound_dev_if
== sk2
->sk_bound_dev_if
)) {
49 if ((!reuse
|| !sk2
->sk_reuse
||
50 sk2
->sk_state
== TCP_LISTEN
) &&
51 (!reuseport
|| !sk2
->sk_reuseport
||
52 (sk2
->sk_state
!= TCP_TIME_WAIT
&&
54 sock_i_uid((struct sock
*)sk2
))))) {
55 if (ipv6_rcv_saddr_equal(sk
, sk2
))
64 EXPORT_SYMBOL_GPL(inet6_csk_bind_conflict
);
66 struct dst_entry
*inet6_csk_route_req(struct sock
*sk
,
68 const struct request_sock
*req
)
70 struct inet6_request_sock
*treq
= inet6_rsk(req
);
71 struct ipv6_pinfo
*np
= inet6_sk(sk
);
72 struct in6_addr
*final_p
, final
;
73 struct dst_entry
*dst
;
75 memset(fl6
, 0, sizeof(*fl6
));
76 fl6
->flowi6_proto
= IPPROTO_TCP
;
77 fl6
->daddr
= treq
->rmt_addr
;
78 final_p
= fl6_update_dst(fl6
, np
->opt
, &final
);
79 fl6
->saddr
= treq
->loc_addr
;
80 fl6
->flowi6_oif
= treq
->iif
;
81 fl6
->flowi6_mark
= sk
->sk_mark
;
82 fl6
->fl6_dport
= inet_rsk(req
)->rmt_port
;
83 fl6
->fl6_sport
= inet_rsk(req
)->loc_port
;
84 security_req_classify_flow(req
, flowi6_to_flowi(fl6
));
86 dst
= ip6_dst_lookup_flow(sk
, fl6
, final_p
, false);
94 * request_sock (formerly open request) hash tables.
96 static u32
inet6_synq_hash(const struct in6_addr
*raddr
, const __be16 rport
,
97 const u32 rnd
, const u32 synq_hsize
)
101 c
= jhash_3words((__force u32
)raddr
->s6_addr32
[0],
102 (__force u32
)raddr
->s6_addr32
[1],
103 (__force u32
)raddr
->s6_addr32
[2],
106 c
= jhash_2words((__force u32
)raddr
->s6_addr32
[3],
110 return c
& (synq_hsize
- 1);
113 struct request_sock
*inet6_csk_search_req(const struct sock
*sk
,
114 struct request_sock
***prevp
,
116 const struct in6_addr
*raddr
,
117 const struct in6_addr
*laddr
,
120 const struct inet_connection_sock
*icsk
= inet_csk(sk
);
121 struct listen_sock
*lopt
= icsk
->icsk_accept_queue
.listen_opt
;
122 struct request_sock
*req
, **prev
;
124 for (prev
= &lopt
->syn_table
[inet6_synq_hash(raddr
, rport
,
126 lopt
->nr_table_entries
)];
127 (req
= *prev
) != NULL
;
128 prev
= &req
->dl_next
) {
129 const struct inet6_request_sock
*treq
= inet6_rsk(req
);
131 if (inet_rsk(req
)->rmt_port
== rport
&&
132 req
->rsk_ops
->family
== AF_INET6
&&
133 ipv6_addr_equal(&treq
->rmt_addr
, raddr
) &&
134 ipv6_addr_equal(&treq
->loc_addr
, laddr
) &&
135 (!treq
->iif
|| treq
->iif
== iif
)) {
136 WARN_ON(req
->sk
!= NULL
);
145 EXPORT_SYMBOL_GPL(inet6_csk_search_req
);
147 void inet6_csk_reqsk_queue_hash_add(struct sock
*sk
,
148 struct request_sock
*req
,
149 const unsigned long timeout
)
151 struct inet_connection_sock
*icsk
= inet_csk(sk
);
152 struct listen_sock
*lopt
= icsk
->icsk_accept_queue
.listen_opt
;
153 const u32 h
= inet6_synq_hash(&inet6_rsk(req
)->rmt_addr
,
154 inet_rsk(req
)->rmt_port
,
155 lopt
->hash_rnd
, lopt
->nr_table_entries
);
157 reqsk_queue_hash_req(&icsk
->icsk_accept_queue
, h
, req
, timeout
);
158 inet_csk_reqsk_queue_added(sk
, timeout
);
161 EXPORT_SYMBOL_GPL(inet6_csk_reqsk_queue_hash_add
);
163 void inet6_csk_addr2sockaddr(struct sock
*sk
, struct sockaddr
* uaddr
)
165 struct ipv6_pinfo
*np
= inet6_sk(sk
);
166 struct sockaddr_in6
*sin6
= (struct sockaddr_in6
*) uaddr
;
168 sin6
->sin6_family
= AF_INET6
;
169 sin6
->sin6_addr
= np
->daddr
;
170 sin6
->sin6_port
= inet_sk(sk
)->inet_dport
;
171 /* We do not store received flowlabel for TCP */
172 sin6
->sin6_flowinfo
= 0;
173 sin6
->sin6_scope_id
= 0;
174 if (sk
->sk_bound_dev_if
&&
175 ipv6_addr_type(&sin6
->sin6_addr
) & IPV6_ADDR_LINKLOCAL
)
176 sin6
->sin6_scope_id
= sk
->sk_bound_dev_if
;
179 EXPORT_SYMBOL_GPL(inet6_csk_addr2sockaddr
);
182 void __inet6_csk_dst_store(struct sock
*sk
, struct dst_entry
*dst
,
183 const struct in6_addr
*daddr
,
184 const struct in6_addr
*saddr
)
186 __ip6_dst_store(sk
, dst
, daddr
, saddr
);
190 struct dst_entry
*__inet6_csk_dst_check(struct sock
*sk
, u32 cookie
)
192 return __sk_dst_check(sk
, cookie
);
195 static struct dst_entry
*inet6_csk_route_socket(struct sock
*sk
,
198 struct inet_sock
*inet
= inet_sk(sk
);
199 struct ipv6_pinfo
*np
= inet6_sk(sk
);
200 struct in6_addr
*final_p
, final
;
201 struct dst_entry
*dst
;
203 memset(fl6
, 0, sizeof(*fl6
));
204 fl6
->flowi6_proto
= sk
->sk_protocol
;
205 fl6
->daddr
= np
->daddr
;
206 fl6
->saddr
= np
->saddr
;
207 fl6
->flowlabel
= np
->flow_label
;
208 IP6_ECN_flow_xmit(sk
, fl6
->flowlabel
);
209 fl6
->flowi6_oif
= sk
->sk_bound_dev_if
;
210 fl6
->flowi6_mark
= sk
->sk_mark
;
211 fl6
->fl6_sport
= inet
->inet_sport
;
212 fl6
->fl6_dport
= inet
->inet_dport
;
213 security_sk_classify_flow(sk
, flowi6_to_flowi(fl6
));
215 final_p
= fl6_update_dst(fl6
, np
->opt
, &final
);
217 dst
= __inet6_csk_dst_check(sk
, np
->dst_cookie
);
219 dst
= ip6_dst_lookup_flow(sk
, fl6
, final_p
, false);
222 __inet6_csk_dst_store(sk
, dst
, NULL
, NULL
);
227 int inet6_csk_xmit(struct sk_buff
*skb
, struct flowi
*fl_unused
)
229 struct sock
*sk
= skb
->sk
;
230 struct ipv6_pinfo
*np
= inet6_sk(sk
);
232 struct dst_entry
*dst
;
235 dst
= inet6_csk_route_socket(sk
, &fl6
);
237 sk
->sk_err_soft
= -PTR_ERR(dst
);
238 sk
->sk_route_caps
= 0;
244 skb_dst_set_noref(skb
, dst
);
246 /* Restore final destination back after routing done */
247 fl6
.daddr
= np
->daddr
;
249 res
= ip6_xmit(sk
, skb
, &fl6
, np
->opt
, np
->tclass
);
253 EXPORT_SYMBOL_GPL(inet6_csk_xmit
);
255 struct dst_entry
*inet6_csk_update_pmtu(struct sock
*sk
, u32 mtu
)
258 struct dst_entry
*dst
= inet6_csk_route_socket(sk
, &fl6
);
262 dst
->ops
->update_pmtu(dst
, sk
, NULL
, mtu
);
264 dst
= inet6_csk_route_socket(sk
, &fl6
);
265 return IS_ERR(dst
) ? NULL
: dst
;
267 EXPORT_SYMBOL_GPL(inet6_csk_update_pmtu
);