2 * xfrm6_policy.c: based on xfrm4_policy.c
6 * Kazunori MIYAZAWA @USAGI
7 * Kunihiro Ishiguro <kunihiro@ipinfusion.com>
10 * Split up af-specific portion
15 #include <linux/compiler.h>
16 #include <linux/config.h>
17 #include <linux/netdevice.h>
18 #include <net/addrconf.h>
22 #include <net/ip6_route.h>
24 static struct dst_ops xfrm6_dst_ops
;
25 static struct xfrm_policy_afinfo xfrm6_policy_afinfo
;
27 static struct xfrm_type_map xfrm6_type_map
= { .lock
= RW_LOCK_UNLOCKED
};
29 static int xfrm6_dst_lookup(struct xfrm_dst
**dst
, struct flowi
*fl
)
32 *dst
= (struct xfrm_dst
*)ip6_route_output(NULL
, fl
);
38 static struct dst_entry
*
39 __xfrm6_find_bundle(struct flowi
*fl
, struct xfrm_policy
*policy
)
41 struct dst_entry
*dst
;
43 /* Still not clear if we should set fl->fl6_{src,dst}... */
44 read_lock_bh(&policy
->lock
);
45 for (dst
= policy
->bundles
; dst
; dst
= dst
->next
) {
46 struct xfrm_dst
*xdst
= (struct xfrm_dst
*)dst
;
47 struct in6_addr fl_dst_prefix
, fl_src_prefix
;
49 ipv6_addr_prefix(&fl_dst_prefix
,
51 xdst
->u
.rt6
.rt6i_dst
.plen
);
52 ipv6_addr_prefix(&fl_src_prefix
,
54 xdst
->u
.rt6
.rt6i_src
.plen
);
55 if (ipv6_addr_equal(&xdst
->u
.rt6
.rt6i_dst
.addr
, &fl_dst_prefix
) &&
56 ipv6_addr_equal(&xdst
->u
.rt6
.rt6i_src
.addr
, &fl_src_prefix
) &&
57 xfrm_bundle_ok(xdst
, fl
, AF_INET6
)) {
62 read_unlock_bh(&policy
->lock
);
66 /* Allocate chain of dst_entry's, attach known xfrm's, calculate
67 * all the metrics... Shortly, bundle a bundle.
71 __xfrm6_bundle_create(struct xfrm_policy
*policy
, struct xfrm_state
**xfrm
, int nx
,
72 struct flowi
*fl
, struct dst_entry
**dst_p
)
74 struct dst_entry
*dst
, *dst_prev
;
75 struct rt6_info
*rt0
= (struct rt6_info
*)(*dst_p
);
76 struct rt6_info
*rt
= rt0
;
77 struct in6_addr
*remote
= &fl
->fl6_dst
;
78 struct in6_addr
*local
= &fl
->fl6_src
;
79 struct flowi fl_tunnel
= {
92 dst
= dst_prev
= NULL
;
95 for (i
= 0; i
< nx
; i
++) {
96 struct dst_entry
*dst1
= dst_alloc(&xfrm6_dst_ops
);
97 struct xfrm_dst
*xdst
;
100 if (unlikely(dst1
== NULL
)) {
102 dst_release(&rt
->u
.dst
);
109 dst_prev
->child
= dst1
;
110 dst1
->flags
|= DST_NOHASH
;
114 xdst
= (struct xfrm_dst
*)dst1
;
115 xdst
->route
= &rt
->u
.dst
;
117 dst1
->next
= dst_prev
;
119 if (xfrm
[i
]->props
.mode
) {
120 remote
= (struct in6_addr
*)&xfrm
[i
]->id
.daddr
;
121 local
= (struct in6_addr
*)&xfrm
[i
]->props
.saddr
;
124 header_len
+= xfrm
[i
]->props
.header_len
;
125 trailer_len
+= xfrm
[i
]->props
.trailer_len
;
128 ipv6_addr_copy(&fl_tunnel
.fl6_dst
, remote
);
129 ipv6_addr_copy(&fl_tunnel
.fl6_src
, local
);
130 err
= xfrm_dst_lookup((struct xfrm_dst
**) &rt
,
131 &fl_tunnel
, AF_INET6
);
135 dst_hold(&rt
->u
.dst
);
138 dst_prev
->child
= &rt
->u
.dst
;
139 dst
->path
= &rt
->u
.dst
;
146 for (; dst_prev
!= &rt
->u
.dst
; dst_prev
= dst_prev
->child
) {
147 struct xfrm_dst
*x
= (struct xfrm_dst
*)dst_prev
;
149 dst_prev
->xfrm
= xfrm
[i
++];
150 dst_prev
->dev
= rt
->u
.dst
.dev
;
152 dev_hold(rt
->u
.dst
.dev
);
153 dst_prev
->obsolete
= -1;
154 dst_prev
->flags
|= DST_HOST
;
155 dst_prev
->lastuse
= jiffies
;
156 dst_prev
->header_len
= header_len
;
157 dst_prev
->trailer_len
= trailer_len
;
158 memcpy(&dst_prev
->metrics
, &x
->route
->metrics
, sizeof(dst_prev
->metrics
));
160 /* Copy neighbour for reachability confirmation */
161 dst_prev
->neighbour
= neigh_clone(rt
->u
.dst
.neighbour
);
162 dst_prev
->input
= rt
->u
.dst
.input
;
163 dst_prev
->output
= xfrm6_output
;
164 /* Sheit... I remember I did this right. Apparently,
165 * it was magically lost, so this code needs audit */
166 x
->u
.rt6
.rt6i_flags
= rt0
->rt6i_flags
&(RTCF_BROADCAST
|RTCF_MULTICAST
|RTCF_LOCAL
);
167 x
->u
.rt6
.rt6i_metric
= rt0
->rt6i_metric
;
168 x
->u
.rt6
.rt6i_node
= rt0
->rt6i_node
;
169 x
->u
.rt6
.rt6i_gateway
= rt0
->rt6i_gateway
;
170 memcpy(&x
->u
.rt6
.rt6i_gateway
, &rt0
->rt6i_gateway
, sizeof(x
->u
.rt6
.rt6i_gateway
));
171 x
->u
.rt6
.rt6i_dst
= rt0
->rt6i_dst
;
172 x
->u
.rt6
.rt6i_src
= rt0
->rt6i_src
;
173 x
->u
.rt6
.rt6i_idev
= rt0
->rt6i_idev
;
174 in6_dev_hold(rt0
->rt6i_idev
);
175 header_len
-= x
->u
.dst
.xfrm
->props
.header_len
;
176 trailer_len
-= x
->u
.dst
.xfrm
->props
.trailer_len
;
189 _decode_session6(struct sk_buff
*skb
, struct flowi
*fl
)
191 u16 offset
= sizeof(struct ipv6hdr
);
192 struct ipv6hdr
*hdr
= skb
->nh
.ipv6h
;
193 struct ipv6_opt_hdr
*exthdr
= (struct ipv6_opt_hdr
*)(skb
->nh
.raw
+ offset
);
194 u8 nexthdr
= skb
->nh
.ipv6h
->nexthdr
;
196 memset(fl
, 0, sizeof(struct flowi
));
197 ipv6_addr_copy(&fl
->fl6_dst
, &hdr
->daddr
);
198 ipv6_addr_copy(&fl
->fl6_src
, &hdr
->saddr
);
200 while (pskb_may_pull(skb
, skb
->nh
.raw
+ offset
+ 1 - skb
->data
)) {
202 case NEXTHDR_ROUTING
:
205 offset
+= ipv6_optlen(exthdr
);
206 nexthdr
= exthdr
->nexthdr
;
207 exthdr
= (struct ipv6_opt_hdr
*)(skb
->nh
.raw
+ offset
);
213 if (pskb_may_pull(skb
, skb
->nh
.raw
+ offset
+ 4 - skb
->data
)) {
214 u16
*ports
= (u16
*)exthdr
;
216 fl
->fl_ip_sport
= ports
[0];
217 fl
->fl_ip_dport
= ports
[1];
223 if (pskb_may_pull(skb
, skb
->nh
.raw
+ offset
+ 2 - skb
->data
)) {
224 u8
*icmp
= (u8
*)exthdr
;
226 fl
->fl_icmp_type
= icmp
[0];
227 fl
->fl_icmp_code
= icmp
[1];
232 /* XXX Why are there these headers? */
237 fl
->fl_ipsec_spi
= 0;
244 static inline int xfrm6_garbage_collect(void)
246 read_lock(&xfrm6_policy_afinfo
.lock
);
247 xfrm6_policy_afinfo
.garbage_collect();
248 read_unlock(&xfrm6_policy_afinfo
.lock
);
249 return (atomic_read(&xfrm6_dst_ops
.entries
) > xfrm6_dst_ops
.gc_thresh
*2);
252 static void xfrm6_update_pmtu(struct dst_entry
*dst
, u32 mtu
)
254 struct xfrm_dst
*xdst
= (struct xfrm_dst
*)dst
;
255 struct dst_entry
*path
= xdst
->route
;
257 path
->ops
->update_pmtu(path
, mtu
);
260 static void xfrm6_dst_destroy(struct dst_entry
*dst
)
262 struct xfrm_dst
*xdst
= (struct xfrm_dst
*)dst
;
264 if (likely(xdst
->u
.rt6
.rt6i_idev
))
265 in6_dev_put(xdst
->u
.rt6
.rt6i_idev
);
266 xfrm_dst_destroy(xdst
);
269 static void xfrm6_dst_ifdown(struct dst_entry
*dst
, struct net_device
*dev
,
272 struct xfrm_dst
*xdst
;
277 xdst
= (struct xfrm_dst
*)dst
;
278 if (xdst
->u
.rt6
.rt6i_idev
->dev
== dev
) {
279 struct inet6_dev
*loopback_idev
= in6_dev_get(&loopback_dev
);
280 BUG_ON(!loopback_idev
);
283 in6_dev_put(xdst
->u
.rt6
.rt6i_idev
);
284 xdst
->u
.rt6
.rt6i_idev
= loopback_idev
;
285 in6_dev_hold(loopback_idev
);
286 xdst
= (struct xfrm_dst
*)xdst
->u
.dst
.child
;
287 } while (xdst
->u
.dst
.xfrm
);
289 __in6_dev_put(loopback_idev
);
292 xfrm_dst_ifdown(dst
, dev
);
295 static struct dst_ops xfrm6_dst_ops
= {
297 .protocol
= __constant_htons(ETH_P_IPV6
),
298 .gc
= xfrm6_garbage_collect
,
299 .update_pmtu
= xfrm6_update_pmtu
,
300 .destroy
= xfrm6_dst_destroy
,
301 .ifdown
= xfrm6_dst_ifdown
,
303 .entry_size
= sizeof(struct xfrm_dst
),
306 static struct xfrm_policy_afinfo xfrm6_policy_afinfo
= {
308 .lock
= RW_LOCK_UNLOCKED
,
309 .type_map
= &xfrm6_type_map
,
310 .dst_ops
= &xfrm6_dst_ops
,
311 .dst_lookup
= xfrm6_dst_lookup
,
312 .find_bundle
= __xfrm6_find_bundle
,
313 .bundle_create
= __xfrm6_bundle_create
,
314 .decode_session
= _decode_session6
,
317 static void __init
xfrm6_policy_init(void)
319 xfrm_policy_register_afinfo(&xfrm6_policy_afinfo
);
322 static void xfrm6_policy_fini(void)
324 xfrm_policy_unregister_afinfo(&xfrm6_policy_afinfo
);
327 void __init
xfrm6_init(void)
333 void xfrm6_fini(void)
335 //xfrm6_input_fini();