datagram.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929
  1. /*
  2. * common UDP/RAW code
  3. * Linux INET6 implementation
  4. *
  5. * Authors:
  6. * Pedro Roque <roque@di.fc.ul.pt>
  7. *
  8. * This program is free software; you can redistribute it and/or
  9. * modify it under the terms of the GNU General Public License
  10. * as published by the Free Software Foundation; either version
  11. * 2 of the License, or (at your option) any later version.
  12. */
  13. #include <linux/capability.h>
  14. #include <linux/errno.h>
  15. #include <linux/types.h>
  16. #include <linux/kernel.h>
  17. #include <linux/interrupt.h>
  18. #include <linux/socket.h>
  19. #include <linux/sockios.h>
  20. #include <linux/in6.h>
  21. #include <linux/ipv6.h>
  22. #include <linux/route.h>
  23. #include <linux/slab.h>
  24. #include <linux/export.h>
  25. #include <net/ipv6.h>
  26. #include <net/ndisc.h>
  27. #include <net/addrconf.h>
  28. #include <net/transp_v6.h>
  29. #include <net/ip6_route.h>
  30. #include <net/tcp_states.h>
  31. #include <net/dsfield.h>
  32. #include <linux/errqueue.h>
  33. #include <asm/uaccess.h>
  34. static bool ipv6_mapped_addr_any(const struct in6_addr *a)
  35. {
  36. return ipv6_addr_v4mapped(a) && (a->s6_addr32[3] == 0);
  37. }
  38. int ip6_datagram_connect(struct sock *sk, struct sockaddr *uaddr, int addr_len)
  39. {
  40. struct sockaddr_in6 *usin = (struct sockaddr_in6 *) uaddr;
  41. struct inet_sock *inet = inet_sk(sk);
  42. struct ipv6_pinfo *np = inet6_sk(sk);
  43. struct in6_addr *daddr, *final_p, final;
  44. struct dst_entry *dst;
  45. struct flowi6 fl6;
  46. struct ip6_flowlabel *flowlabel = NULL;
  47. struct ipv6_txoptions *opt;
  48. int addr_type;
  49. int err;
  50. if (usin->sin6_family == AF_INET) {
  51. if (__ipv6_only_sock(sk))
  52. return -EAFNOSUPPORT;
  53. err = ip4_datagram_connect(sk, uaddr, addr_len);
  54. goto ipv4_connected;
  55. }
  56. if (addr_len < SIN6_LEN_RFC2133)
  57. return -EINVAL;
  58. if (usin->sin6_family != AF_INET6)
  59. return -EAFNOSUPPORT;
  60. memset(&fl6, 0, sizeof(fl6));
  61. if (np->sndflow) {
  62. fl6.flowlabel = usin->sin6_flowinfo&IPV6_FLOWINFO_MASK;
  63. if (fl6.flowlabel&IPV6_FLOWLABEL_MASK) {
  64. flowlabel = fl6_sock_lookup(sk, fl6.flowlabel);
  65. if (flowlabel == NULL)
  66. return -EINVAL;
  67. }
  68. }
  69. addr_type = ipv6_addr_type(&usin->sin6_addr);
  70. if (addr_type == IPV6_ADDR_ANY) {
  71. /*
  72. * connect to self
  73. */
  74. usin->sin6_addr.s6_addr[15] = 0x01;
  75. }
  76. daddr = &usin->sin6_addr;
  77. if (addr_type == IPV6_ADDR_MAPPED) {
  78. struct sockaddr_in sin;
  79. if (__ipv6_only_sock(sk)) {
  80. err = -ENETUNREACH;
  81. goto out;
  82. }
  83. sin.sin_family = AF_INET;
  84. sin.sin_addr.s_addr = daddr->s6_addr32[3];
  85. sin.sin_port = usin->sin6_port;
  86. err = ip4_datagram_connect(sk,
  87. (struct sockaddr *) &sin,
  88. sizeof(sin));
  89. ipv4_connected:
  90. if (err)
  91. goto out;
  92. ipv6_addr_set_v4mapped(inet->inet_daddr, &sk->sk_v6_daddr);
  93. if (ipv6_addr_any(&np->saddr) ||
  94. ipv6_mapped_addr_any(&np->saddr))
  95. ipv6_addr_set_v4mapped(inet->inet_saddr, &np->saddr);
  96. if (ipv6_addr_any(&sk->sk_v6_rcv_saddr) ||
  97. ipv6_mapped_addr_any(&sk->sk_v6_rcv_saddr)) {
  98. ipv6_addr_set_v4mapped(inet->inet_rcv_saddr,
  99. &sk->sk_v6_rcv_saddr);
  100. if (sk->sk_prot->rehash)
  101. sk->sk_prot->rehash(sk);
  102. }
  103. goto out;
  104. }
  105. if (__ipv6_addr_needs_scope_id(addr_type)) {
  106. if (addr_len >= sizeof(struct sockaddr_in6) &&
  107. usin->sin6_scope_id) {
  108. if (sk->sk_bound_dev_if &&
  109. sk->sk_bound_dev_if != usin->sin6_scope_id) {
  110. err = -EINVAL;
  111. goto out;
  112. }
  113. sk->sk_bound_dev_if = usin->sin6_scope_id;
  114. }
  115. if (!sk->sk_bound_dev_if && (addr_type & IPV6_ADDR_MULTICAST))
  116. sk->sk_bound_dev_if = np->mcast_oif;
  117. /* Connect to link-local address requires an interface */
  118. if (!sk->sk_bound_dev_if) {
  119. err = -EINVAL;
  120. goto out;
  121. }
  122. }
  123. sk->sk_v6_daddr = *daddr;
  124. np->flow_label = fl6.flowlabel;
  125. inet->inet_dport = usin->sin6_port;
  126. /*
  127. * Check for a route to destination an obtain the
  128. * destination cache for it.
  129. */
  130. fl6.flowi6_proto = sk->sk_protocol;
  131. fl6.daddr = sk->sk_v6_daddr;
  132. fl6.saddr = np->saddr;
  133. fl6.flowi6_oif = sk->sk_bound_dev_if;
  134. fl6.flowi6_mark = sk->sk_mark;
  135. fl6.fl6_dport = inet->inet_dport;
  136. fl6.fl6_sport = inet->inet_sport;
  137. fl6.flowi6_uid = sock_i_uid(sk);
  138. if (!fl6.flowi6_oif && (addr_type&IPV6_ADDR_MULTICAST))
  139. fl6.flowi6_oif = np->mcast_oif;
  140. security_sk_classify_flow(sk, flowi6_to_flowi(&fl6));
  141. opt = flowlabel ? flowlabel->opt : np->opt;
  142. final_p = fl6_update_dst(&fl6, opt, &final);
  143. dst = ip6_dst_lookup_flow(sk, &fl6, final_p);
  144. err = 0;
  145. if (IS_ERR(dst)) {
  146. err = PTR_ERR(dst);
  147. goto out;
  148. }
  149. /* source address lookup done in ip6_dst_lookup */
  150. if (ipv6_addr_any(&np->saddr))
  151. np->saddr = fl6.saddr;
  152. if (ipv6_addr_any(&sk->sk_v6_rcv_saddr)) {
  153. sk->sk_v6_rcv_saddr = fl6.saddr;
  154. inet->inet_rcv_saddr = LOOPBACK4_IPV6;
  155. if (sk->sk_prot->rehash)
  156. sk->sk_prot->rehash(sk);
  157. }
  158. ip6_dst_store(sk, dst,
  159. ipv6_addr_equal(&fl6.daddr, &sk->sk_v6_daddr) ?
  160. &sk->sk_v6_daddr : NULL,
  161. #ifdef CONFIG_IPV6_SUBTREES
  162. ipv6_addr_equal(&fl6.saddr, &np->saddr) ?
  163. &np->saddr :
  164. #endif
  165. NULL);
  166. sk->sk_state = TCP_ESTABLISHED;
  167. ip6_set_txhash(sk);
  168. out:
  169. fl6_sock_release(flowlabel);
  170. return err;
  171. }
  172. EXPORT_SYMBOL_GPL(ip6_datagram_connect);
  173. int ip6_datagram_connect_v6_only(struct sock *sk, struct sockaddr *uaddr,
  174. int addr_len)
  175. {
  176. DECLARE_SOCKADDR(struct sockaddr_in6 *, sin6, uaddr);
  177. if (sin6->sin6_family != AF_INET6)
  178. return -EAFNOSUPPORT;
  179. return ip6_datagram_connect(sk, uaddr, addr_len);
  180. }
  181. EXPORT_SYMBOL_GPL(ip6_datagram_connect_v6_only);
  182. void ipv6_icmp_error(struct sock *sk, struct sk_buff *skb, int err,
  183. __be16 port, u32 info, u8 *payload)
  184. {
  185. struct ipv6_pinfo *np = inet6_sk(sk);
  186. struct icmp6hdr *icmph = icmp6_hdr(skb);
  187. struct sock_exterr_skb *serr;
  188. if (!np->recverr)
  189. return;
  190. skb = skb_clone(skb, GFP_ATOMIC);
  191. if (!skb)
  192. return;
  193. skb->protocol = htons(ETH_P_IPV6);
  194. serr = SKB_EXT_ERR(skb);
  195. serr->ee.ee_errno = err;
  196. serr->ee.ee_origin = SO_EE_ORIGIN_ICMP6;
  197. serr->ee.ee_type = icmph->icmp6_type;
  198. serr->ee.ee_code = icmph->icmp6_code;
  199. serr->ee.ee_pad = 0;
  200. serr->ee.ee_info = info;
  201. serr->ee.ee_data = 0;
  202. serr->addr_offset = (u8 *)&(((struct ipv6hdr *)(icmph + 1))->daddr) -
  203. skb_network_header(skb);
  204. serr->port = port;
  205. __skb_pull(skb, payload - skb->data);
  206. skb_reset_transport_header(skb);
  207. if (sock_queue_err_skb(sk, skb))
  208. kfree_skb(skb);
  209. }
  210. void ipv6_local_error(struct sock *sk, int err, struct flowi6 *fl6, u32 info)
  211. {
  212. struct ipv6_pinfo *np = inet6_sk(sk);
  213. struct sock_exterr_skb *serr;
  214. struct ipv6hdr *iph;
  215. struct sk_buff *skb;
  216. if (!np->recverr)
  217. return;
  218. skb = alloc_skb(sizeof(struct ipv6hdr), GFP_ATOMIC);
  219. if (!skb)
  220. return;
  221. skb->protocol = htons(ETH_P_IPV6);
  222. skb_put(skb, sizeof(struct ipv6hdr));
  223. skb_reset_network_header(skb);
  224. iph = ipv6_hdr(skb);
  225. iph->daddr = fl6->daddr;
  226. serr = SKB_EXT_ERR(skb);
  227. serr->ee.ee_errno = err;
  228. serr->ee.ee_origin = SO_EE_ORIGIN_LOCAL;
  229. serr->ee.ee_type = 0;
  230. serr->ee.ee_code = 0;
  231. serr->ee.ee_pad = 0;
  232. serr->ee.ee_info = info;
  233. serr->ee.ee_data = 0;
  234. serr->addr_offset = (u8 *)&iph->daddr - skb_network_header(skb);
  235. serr->port = fl6->fl6_dport;
  236. __skb_pull(skb, skb_tail_pointer(skb) - skb->data);
  237. skb_reset_transport_header(skb);
  238. if (sock_queue_err_skb(sk, skb))
  239. kfree_skb(skb);
  240. }
  241. void ipv6_local_rxpmtu(struct sock *sk, struct flowi6 *fl6, u32 mtu)
  242. {
  243. struct ipv6_pinfo *np = inet6_sk(sk);
  244. struct ipv6hdr *iph;
  245. struct sk_buff *skb;
  246. struct ip6_mtuinfo *mtu_info;
  247. if (!np->rxopt.bits.rxpmtu)
  248. return;
  249. skb = alloc_skb(sizeof(struct ipv6hdr), GFP_ATOMIC);
  250. if (!skb)
  251. return;
  252. skb_put(skb, sizeof(struct ipv6hdr));
  253. skb_reset_network_header(skb);
  254. iph = ipv6_hdr(skb);
  255. iph->daddr = fl6->daddr;
  256. mtu_info = IP6CBMTU(skb);
  257. mtu_info->ip6m_mtu = mtu;
  258. mtu_info->ip6m_addr.sin6_family = AF_INET6;
  259. mtu_info->ip6m_addr.sin6_port = 0;
  260. mtu_info->ip6m_addr.sin6_flowinfo = 0;
  261. mtu_info->ip6m_addr.sin6_scope_id = fl6->flowi6_oif;
  262. mtu_info->ip6m_addr.sin6_addr = ipv6_hdr(skb)->daddr;
  263. __skb_pull(skb, skb_tail_pointer(skb) - skb->data);
  264. skb_reset_transport_header(skb);
  265. skb = xchg(&np->rxpmtu, skb);
  266. kfree_skb(skb);
  267. }
  268. /*
  269. * Handle MSG_ERRQUEUE
  270. */
  271. int ipv6_recv_error(struct sock *sk, struct msghdr *msg, int len, int *addr_len)
  272. {
  273. struct ipv6_pinfo *np = inet6_sk(sk);
  274. struct sock_exterr_skb *serr;
  275. struct sk_buff *skb;
  276. DECLARE_SOCKADDR(struct sockaddr_in6 *, sin, msg->msg_name);
  277. struct {
  278. struct sock_extended_err ee;
  279. struct sockaddr_in6 offender;
  280. } errhdr;
  281. int err;
  282. int copied;
  283. err = -EAGAIN;
  284. skb = sock_dequeue_err_skb(sk);
  285. if (skb == NULL)
  286. goto out;
  287. copied = skb->len;
  288. if (copied > len) {
  289. msg->msg_flags |= MSG_TRUNC;
  290. copied = len;
  291. }
  292. err = skb_copy_datagram_iovec(skb, 0, msg->msg_iov, copied);
  293. if (err)
  294. goto out_free_skb;
  295. sock_recv_timestamp(msg, sk, skb);
  296. serr = SKB_EXT_ERR(skb);
  297. if (sin) {
  298. const unsigned char *nh = skb_network_header(skb);
  299. sin->sin6_family = AF_INET6;
  300. sin->sin6_flowinfo = 0;
  301. sin->sin6_port = serr->port;
  302. if (skb->protocol == htons(ETH_P_IPV6)) {
  303. const struct ipv6hdr *ip6h = container_of((struct in6_addr *)(nh + serr->addr_offset),
  304. struct ipv6hdr, daddr);
  305. sin->sin6_addr = ip6h->daddr;
  306. if (np->sndflow)
  307. sin->sin6_flowinfo = ip6_flowinfo(ip6h);
  308. sin->sin6_scope_id =
  309. ipv6_iface_scope_id(&sin->sin6_addr,
  310. IP6CB(skb)->iif);
  311. } else {
  312. ipv6_addr_set_v4mapped(*(__be32 *)(nh + serr->addr_offset),
  313. &sin->sin6_addr);
  314. sin->sin6_scope_id = 0;
  315. }
  316. *addr_len = sizeof(*sin);
  317. }
  318. memcpy(&errhdr.ee, &serr->ee, sizeof(struct sock_extended_err));
  319. sin = &errhdr.offender;
  320. memset(sin, 0, sizeof(*sin));
  321. if (serr->ee.ee_origin != SO_EE_ORIGIN_LOCAL) {
  322. sin->sin6_family = AF_INET6;
  323. if (np->rxopt.all)
  324. ip6_datagram_recv_common_ctl(sk, msg, skb);
  325. if (skb->protocol == htons(ETH_P_IPV6)) {
  326. sin->sin6_addr = ipv6_hdr(skb)->saddr;
  327. if (np->rxopt.all)
  328. ip6_datagram_recv_specific_ctl(sk, msg, skb);
  329. sin->sin6_scope_id =
  330. ipv6_iface_scope_id(&sin->sin6_addr,
  331. IP6CB(skb)->iif);
  332. } else {
  333. ipv6_addr_set_v4mapped(ip_hdr(skb)->saddr,
  334. &sin->sin6_addr);
  335. if (inet_sk(sk)->cmsg_flags)
  336. ip_cmsg_recv(msg, skb);
  337. }
  338. }
  339. put_cmsg(msg, SOL_IPV6, IPV6_RECVERR, sizeof(errhdr), &errhdr);
  340. /* Now we could try to dump offended packet options */
  341. msg->msg_flags |= MSG_ERRQUEUE;
  342. err = copied;
  343. out_free_skb:
  344. kfree_skb(skb);
  345. out:
  346. return err;
  347. }
  348. EXPORT_SYMBOL_GPL(ipv6_recv_error);
  349. /*
  350. * Handle IPV6_RECVPATHMTU
  351. */
  352. int ipv6_recv_rxpmtu(struct sock *sk, struct msghdr *msg, int len,
  353. int *addr_len)
  354. {
  355. struct ipv6_pinfo *np = inet6_sk(sk);
  356. struct sk_buff *skb;
  357. struct ip6_mtuinfo mtu_info;
  358. DECLARE_SOCKADDR(struct sockaddr_in6 *, sin, msg->msg_name);
  359. int err;
  360. int copied;
  361. err = -EAGAIN;
  362. skb = xchg(&np->rxpmtu, NULL);
  363. if (skb == NULL)
  364. goto out;
  365. copied = skb->len;
  366. if (copied > len) {
  367. msg->msg_flags |= MSG_TRUNC;
  368. copied = len;
  369. }
  370. err = skb_copy_datagram_iovec(skb, 0, msg->msg_iov, copied);
  371. if (err)
  372. goto out_free_skb;
  373. sock_recv_timestamp(msg, sk, skb);
  374. memcpy(&mtu_info, IP6CBMTU(skb), sizeof(mtu_info));
  375. if (sin) {
  376. sin->sin6_family = AF_INET6;
  377. sin->sin6_flowinfo = 0;
  378. sin->sin6_port = 0;
  379. sin->sin6_scope_id = mtu_info.ip6m_addr.sin6_scope_id;
  380. sin->sin6_addr = mtu_info.ip6m_addr.sin6_addr;
  381. *addr_len = sizeof(*sin);
  382. }
  383. put_cmsg(msg, SOL_IPV6, IPV6_PATHMTU, sizeof(mtu_info), &mtu_info);
  384. err = copied;
  385. out_free_skb:
  386. kfree_skb(skb);
  387. out:
  388. return err;
  389. }
  390. void ip6_datagram_recv_common_ctl(struct sock *sk, struct msghdr *msg,
  391. struct sk_buff *skb)
  392. {
  393. struct ipv6_pinfo *np = inet6_sk(sk);
  394. bool is_ipv6 = skb->protocol == htons(ETH_P_IPV6);
  395. if (np->rxopt.bits.rxinfo) {
  396. struct in6_pktinfo src_info;
  397. if (is_ipv6) {
  398. src_info.ipi6_ifindex = IP6CB(skb)->iif;
  399. src_info.ipi6_addr = ipv6_hdr(skb)->daddr;
  400. } else {
  401. src_info.ipi6_ifindex =
  402. PKTINFO_SKB_CB(skb)->ipi_ifindex;
  403. ipv6_addr_set_v4mapped(ip_hdr(skb)->daddr,
  404. &src_info.ipi6_addr);
  405. }
  406. put_cmsg(msg, SOL_IPV6, IPV6_PKTINFO, sizeof(src_info), &src_info);
  407. }
  408. }
  409. void ip6_datagram_recv_specific_ctl(struct sock *sk, struct msghdr *msg,
  410. struct sk_buff *skb)
  411. {
  412. struct ipv6_pinfo *np = inet6_sk(sk);
  413. struct inet6_skb_parm *opt = IP6CB(skb);
  414. unsigned char *nh = skb_network_header(skb);
  415. if (np->rxopt.bits.rxhlim) {
  416. int hlim = ipv6_hdr(skb)->hop_limit;
  417. put_cmsg(msg, SOL_IPV6, IPV6_HOPLIMIT, sizeof(hlim), &hlim);
  418. }
  419. if (np->rxopt.bits.rxtclass) {
  420. int tclass = ipv6_get_dsfield(ipv6_hdr(skb));
  421. put_cmsg(msg, SOL_IPV6, IPV6_TCLASS, sizeof(tclass), &tclass);
  422. }
  423. if (np->rxopt.bits.rxflow) {
  424. __be32 flowinfo = ip6_flowinfo((struct ipv6hdr *)nh);
  425. if (flowinfo)
  426. put_cmsg(msg, SOL_IPV6, IPV6_FLOWINFO, sizeof(flowinfo), &flowinfo);
  427. }
  428. /* HbH is allowed only once */
  429. if (np->rxopt.bits.hopopts && opt->hop) {
  430. u8 *ptr = nh + opt->hop;
  431. put_cmsg(msg, SOL_IPV6, IPV6_HOPOPTS, (ptr[1]+1)<<3, ptr);
  432. }
  433. if (opt->lastopt &&
  434. (np->rxopt.bits.dstopts || np->rxopt.bits.srcrt)) {
  435. /*
  436. * Silly enough, but we need to reparse in order to
  437. * report extension headers (except for HbH)
  438. * in order.
  439. *
  440. * Also note that IPV6_RECVRTHDRDSTOPTS is NOT
  441. * (and WILL NOT be) defined because
  442. * IPV6_RECVDSTOPTS is more generic. --yoshfuji
  443. */
  444. unsigned int off = sizeof(struct ipv6hdr);
  445. u8 nexthdr = ipv6_hdr(skb)->nexthdr;
  446. while (off <= opt->lastopt) {
  447. unsigned int len;
  448. u8 *ptr = nh + off;
  449. switch (nexthdr) {
  450. case IPPROTO_DSTOPTS:
  451. nexthdr = ptr[0];
  452. len = (ptr[1] + 1) << 3;
  453. if (np->rxopt.bits.dstopts)
  454. put_cmsg(msg, SOL_IPV6, IPV6_DSTOPTS, len, ptr);
  455. break;
  456. case IPPROTO_ROUTING:
  457. nexthdr = ptr[0];
  458. len = (ptr[1] + 1) << 3;
  459. if (np->rxopt.bits.srcrt)
  460. put_cmsg(msg, SOL_IPV6, IPV6_RTHDR, len, ptr);
  461. break;
  462. case IPPROTO_AH:
  463. nexthdr = ptr[0];
  464. len = (ptr[1] + 2) << 2;
  465. break;
  466. default:
  467. nexthdr = ptr[0];
  468. len = (ptr[1] + 1) << 3;
  469. break;
  470. }
  471. off += len;
  472. }
  473. }
  474. /* socket options in old style */
  475. if (np->rxopt.bits.rxoinfo) {
  476. struct in6_pktinfo src_info;
  477. src_info.ipi6_ifindex = opt->iif;
  478. src_info.ipi6_addr = ipv6_hdr(skb)->daddr;
  479. put_cmsg(msg, SOL_IPV6, IPV6_2292PKTINFO, sizeof(src_info), &src_info);
  480. }
  481. if (np->rxopt.bits.rxohlim) {
  482. int hlim = ipv6_hdr(skb)->hop_limit;
  483. put_cmsg(msg, SOL_IPV6, IPV6_2292HOPLIMIT, sizeof(hlim), &hlim);
  484. }
  485. if (np->rxopt.bits.ohopopts && opt->hop) {
  486. u8 *ptr = nh + opt->hop;
  487. put_cmsg(msg, SOL_IPV6, IPV6_2292HOPOPTS, (ptr[1]+1)<<3, ptr);
  488. }
  489. if (np->rxopt.bits.odstopts && opt->dst0) {
  490. u8 *ptr = nh + opt->dst0;
  491. put_cmsg(msg, SOL_IPV6, IPV6_2292DSTOPTS, (ptr[1]+1)<<3, ptr);
  492. }
  493. if (np->rxopt.bits.osrcrt && opt->srcrt) {
  494. struct ipv6_rt_hdr *rthdr = (struct ipv6_rt_hdr *)(nh + opt->srcrt);
  495. put_cmsg(msg, SOL_IPV6, IPV6_2292RTHDR, (rthdr->hdrlen+1) << 3, rthdr);
  496. }
  497. if (np->rxopt.bits.odstopts && opt->dst1) {
  498. u8 *ptr = nh + opt->dst1;
  499. put_cmsg(msg, SOL_IPV6, IPV6_2292DSTOPTS, (ptr[1]+1)<<3, ptr);
  500. }
  501. if (np->rxopt.bits.rxorigdstaddr) {
  502. struct sockaddr_in6 sin6;
  503. __be16 *ports = (__be16 *) skb_transport_header(skb);
  504. if (skb_transport_offset(skb) + 4 <= skb->len) {
  505. /* All current transport protocols have the port numbers in the
  506. * first four bytes of the transport header and this function is
  507. * written with this assumption in mind.
  508. */
  509. sin6.sin6_family = AF_INET6;
  510. sin6.sin6_addr = ipv6_hdr(skb)->daddr;
  511. sin6.sin6_port = ports[1];
  512. sin6.sin6_flowinfo = 0;
  513. sin6.sin6_scope_id =
  514. ipv6_iface_scope_id(&ipv6_hdr(skb)->daddr,
  515. opt->iif);
  516. put_cmsg(msg, SOL_IPV6, IPV6_ORIGDSTADDR, sizeof(sin6), &sin6);
  517. }
  518. }
  519. }
  520. void ip6_datagram_recv_ctl(struct sock *sk, struct msghdr *msg,
  521. struct sk_buff *skb)
  522. {
  523. ip6_datagram_recv_common_ctl(sk, msg, skb);
  524. ip6_datagram_recv_specific_ctl(sk, msg, skb);
  525. }
  526. EXPORT_SYMBOL_GPL(ip6_datagram_recv_ctl);
  527. int ip6_datagram_send_ctl(struct net *net, struct sock *sk,
  528. struct msghdr *msg, struct flowi6 *fl6,
  529. struct ipv6_txoptions *opt,
  530. int *hlimit, int *tclass, int *dontfrag)
  531. {
  532. struct in6_pktinfo *src_info;
  533. struct cmsghdr *cmsg;
  534. struct ipv6_rt_hdr *rthdr;
  535. struct ipv6_opt_hdr *hdr;
  536. int len;
  537. int err = 0;
  538. for (cmsg = CMSG_FIRSTHDR(msg); cmsg; cmsg = CMSG_NXTHDR(msg, cmsg)) {
  539. int addr_type;
  540. if (!CMSG_OK(msg, cmsg)) {
  541. err = -EINVAL;
  542. goto exit_f;
  543. }
  544. if (cmsg->cmsg_level != SOL_IPV6)
  545. continue;
  546. switch (cmsg->cmsg_type) {
  547. case IPV6_PKTINFO:
  548. case IPV6_2292PKTINFO:
  549. {
  550. struct net_device *dev = NULL;
  551. if (cmsg->cmsg_len < CMSG_LEN(sizeof(struct in6_pktinfo))) {
  552. err = -EINVAL;
  553. goto exit_f;
  554. }
  555. src_info = (struct in6_pktinfo *)CMSG_DATA(cmsg);
  556. if (src_info->ipi6_ifindex) {
  557. if (fl6->flowi6_oif &&
  558. src_info->ipi6_ifindex != fl6->flowi6_oif)
  559. return -EINVAL;
  560. fl6->flowi6_oif = src_info->ipi6_ifindex;
  561. }
  562. addr_type = __ipv6_addr_type(&src_info->ipi6_addr);
  563. rcu_read_lock();
  564. if (fl6->flowi6_oif) {
  565. dev = dev_get_by_index_rcu(net, fl6->flowi6_oif);
  566. if (!dev) {
  567. rcu_read_unlock();
  568. return -ENODEV;
  569. }
  570. } else if (addr_type & IPV6_ADDR_LINKLOCAL) {
  571. rcu_read_unlock();
  572. return -EINVAL;
  573. }
  574. if (addr_type != IPV6_ADDR_ANY) {
  575. int strict = __ipv6_addr_src_scope(addr_type) <= IPV6_ADDR_SCOPE_LINKLOCAL;
  576. if (!(inet_sk(sk)->freebind || inet_sk(sk)->transparent) &&
  577. !ipv6_chk_addr(net, &src_info->ipi6_addr,
  578. strict ? dev : NULL, 0) &&
  579. !ipv6_chk_acast_addr_src(net, dev,
  580. &src_info->ipi6_addr))
  581. err = -EINVAL;
  582. else
  583. fl6->saddr = src_info->ipi6_addr;
  584. }
  585. rcu_read_unlock();
  586. if (err)
  587. goto exit_f;
  588. break;
  589. }
  590. case IPV6_FLOWINFO:
  591. if (cmsg->cmsg_len < CMSG_LEN(4)) {
  592. err = -EINVAL;
  593. goto exit_f;
  594. }
  595. if (fl6->flowlabel&IPV6_FLOWINFO_MASK) {
  596. if ((fl6->flowlabel^*(__be32 *)CMSG_DATA(cmsg))&~IPV6_FLOWINFO_MASK) {
  597. err = -EINVAL;
  598. goto exit_f;
  599. }
  600. }
  601. fl6->flowlabel = IPV6_FLOWINFO_MASK & *(__be32 *)CMSG_DATA(cmsg);
  602. break;
  603. case IPV6_2292HOPOPTS:
  604. case IPV6_HOPOPTS:
  605. if (opt->hopopt || cmsg->cmsg_len < CMSG_LEN(sizeof(struct ipv6_opt_hdr))) {
  606. err = -EINVAL;
  607. goto exit_f;
  608. }
  609. hdr = (struct ipv6_opt_hdr *)CMSG_DATA(cmsg);
  610. len = ((hdr->hdrlen + 1) << 3);
  611. if (cmsg->cmsg_len < CMSG_LEN(len)) {
  612. err = -EINVAL;
  613. goto exit_f;
  614. }
  615. if (!ns_capable(net->user_ns, CAP_NET_RAW)) {
  616. err = -EPERM;
  617. goto exit_f;
  618. }
  619. opt->opt_nflen += len;
  620. opt->hopopt = hdr;
  621. break;
  622. case IPV6_2292DSTOPTS:
  623. if (cmsg->cmsg_len < CMSG_LEN(sizeof(struct ipv6_opt_hdr))) {
  624. err = -EINVAL;
  625. goto exit_f;
  626. }
  627. hdr = (struct ipv6_opt_hdr *)CMSG_DATA(cmsg);
  628. len = ((hdr->hdrlen + 1) << 3);
  629. if (cmsg->cmsg_len < CMSG_LEN(len)) {
  630. err = -EINVAL;
  631. goto exit_f;
  632. }
  633. if (!ns_capable(net->user_ns, CAP_NET_RAW)) {
  634. err = -EPERM;
  635. goto exit_f;
  636. }
  637. if (opt->dst1opt) {
  638. err = -EINVAL;
  639. goto exit_f;
  640. }
  641. opt->opt_flen += len;
  642. opt->dst1opt = hdr;
  643. break;
  644. case IPV6_DSTOPTS:
  645. case IPV6_RTHDRDSTOPTS:
  646. if (cmsg->cmsg_len < CMSG_LEN(sizeof(struct ipv6_opt_hdr))) {
  647. err = -EINVAL;
  648. goto exit_f;
  649. }
  650. hdr = (struct ipv6_opt_hdr *)CMSG_DATA(cmsg);
  651. len = ((hdr->hdrlen + 1) << 3);
  652. if (cmsg->cmsg_len < CMSG_LEN(len)) {
  653. err = -EINVAL;
  654. goto exit_f;
  655. }
  656. if (!ns_capable(net->user_ns, CAP_NET_RAW)) {
  657. err = -EPERM;
  658. goto exit_f;
  659. }
  660. if (cmsg->cmsg_type == IPV6_DSTOPTS) {
  661. opt->opt_flen += len;
  662. opt->dst1opt = hdr;
  663. } else {
  664. opt->opt_nflen += len;
  665. opt->dst0opt = hdr;
  666. }
  667. break;
  668. case IPV6_2292RTHDR:
  669. case IPV6_RTHDR:
  670. if (cmsg->cmsg_len < CMSG_LEN(sizeof(struct ipv6_rt_hdr))) {
  671. err = -EINVAL;
  672. goto exit_f;
  673. }
  674. rthdr = (struct ipv6_rt_hdr *)CMSG_DATA(cmsg);
  675. switch (rthdr->type) {
  676. #if IS_ENABLED(CONFIG_IPV6_MIP6)
  677. case IPV6_SRCRT_TYPE_2:
  678. if (rthdr->hdrlen != 2 ||
  679. rthdr->segments_left != 1) {
  680. err = -EINVAL;
  681. goto exit_f;
  682. }
  683. break;
  684. #endif
  685. default:
  686. err = -EINVAL;
  687. goto exit_f;
  688. }
  689. len = ((rthdr->hdrlen + 1) << 3);
  690. if (cmsg->cmsg_len < CMSG_LEN(len)) {
  691. err = -EINVAL;
  692. goto exit_f;
  693. }
  694. /* segments left must also match */
  695. if ((rthdr->hdrlen >> 1) != rthdr->segments_left) {
  696. err = -EINVAL;
  697. goto exit_f;
  698. }
  699. opt->opt_nflen += len;
  700. opt->srcrt = rthdr;
  701. if (cmsg->cmsg_type == IPV6_2292RTHDR && opt->dst1opt) {
  702. int dsthdrlen = ((opt->dst1opt->hdrlen+1)<<3);
  703. opt->opt_nflen += dsthdrlen;
  704. opt->dst0opt = opt->dst1opt;
  705. opt->dst1opt = NULL;
  706. opt->opt_flen -= dsthdrlen;
  707. }
  708. break;
  709. case IPV6_2292HOPLIMIT:
  710. case IPV6_HOPLIMIT:
  711. if (cmsg->cmsg_len != CMSG_LEN(sizeof(int))) {
  712. err = -EINVAL;
  713. goto exit_f;
  714. }
  715. *hlimit = *(int *)CMSG_DATA(cmsg);
  716. if (*hlimit < -1 || *hlimit > 0xff) {
  717. err = -EINVAL;
  718. goto exit_f;
  719. }
  720. break;
  721. case IPV6_TCLASS:
  722. {
  723. int tc;
  724. err = -EINVAL;
  725. if (cmsg->cmsg_len != CMSG_LEN(sizeof(int)))
  726. goto exit_f;
  727. tc = *(int *)CMSG_DATA(cmsg);
  728. if (tc < -1 || tc > 0xff)
  729. goto exit_f;
  730. err = 0;
  731. *tclass = tc;
  732. break;
  733. }
  734. case IPV6_DONTFRAG:
  735. {
  736. int df;
  737. err = -EINVAL;
  738. if (cmsg->cmsg_len != CMSG_LEN(sizeof(int)))
  739. goto exit_f;
  740. df = *(int *)CMSG_DATA(cmsg);
  741. if (df < 0 || df > 1)
  742. goto exit_f;
  743. err = 0;
  744. *dontfrag = df;
  745. break;
  746. }
  747. default:
  748. LIMIT_NETDEBUG(KERN_DEBUG "invalid cmsg type: %d\n",
  749. cmsg->cmsg_type);
  750. err = -EINVAL;
  751. goto exit_f;
  752. }
  753. }
  754. exit_f:
  755. return err;
  756. }
  757. EXPORT_SYMBOL_GPL(ip6_datagram_send_ctl);
  758. void ip6_dgram_sock_seq_show(struct seq_file *seq, struct sock *sp,
  759. __u16 srcp, __u16 destp, int bucket)
  760. {
  761. const struct in6_addr *dest, *src;
  762. dest = &sp->sk_v6_daddr;
  763. src = &sp->sk_v6_rcv_saddr;
  764. seq_printf(seq,
  765. "%5d: %08X%08X%08X%08X:%04X %08X%08X%08X%08X:%04X "
  766. "%02X %08X:%08X %02X:%08lX %08X %5u %8d %lu %d %pK %d\n",
  767. bucket,
  768. src->s6_addr32[0], src->s6_addr32[1],
  769. src->s6_addr32[2], src->s6_addr32[3], srcp,
  770. dest->s6_addr32[0], dest->s6_addr32[1],
  771. dest->s6_addr32[2], dest->s6_addr32[3], destp,
  772. sp->sk_state,
  773. sk_wmem_alloc_get(sp),
  774. sk_rmem_alloc_get(sp),
  775. 0, 0L, 0,
  776. from_kuid_munged(seq_user_ns(seq), sock_i_uid(sp)),
  777. 0,
  778. sock_i_ino(sp),
  779. atomic_read(&sp->sk_refcnt), sp,
  780. atomic_read(&sp->sk_drops));
  781. }