ip_sockglue.c 27 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211
  1. /*
  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.
  5. *
  6. * The IP to API glue.
  7. *
  8. * Version: $Id: ip_sockglue.c,v 1.62 2002/02/01 22:01:04 davem Exp $
  9. *
  10. * Authors: see ip.c
  11. *
  12. * Fixes:
  13. * Many : Split from ip.c , see ip.c for history.
  14. * Martin Mares : TOS setting fixed.
  15. * Alan Cox : Fixed a couple of oopses in Martin's
  16. * TOS tweaks.
  17. * Mike McLagan : Routing by source
  18. */
  19. #include <linux/module.h>
  20. #include <linux/types.h>
  21. #include <linux/mm.h>
  22. #include <linux/skbuff.h>
  23. #include <linux/ip.h>
  24. #include <linux/icmp.h>
  25. #include <linux/inetdevice.h>
  26. #include <linux/netdevice.h>
  27. #include <net/sock.h>
  28. #include <net/ip.h>
  29. #include <net/icmp.h>
  30. #include <net/tcp_states.h>
  31. #include <linux/udp.h>
  32. #include <linux/igmp.h>
  33. #include <linux/netfilter.h>
  34. #include <linux/route.h>
  35. #include <linux/mroute.h>
  36. #include <net/route.h>
  37. #include <net/xfrm.h>
  38. #if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
  39. #include <net/transp_v6.h>
  40. #endif
  41. #include <linux/errqueue.h>
  42. #include <asm/uaccess.h>
  43. #define IP_CMSG_PKTINFO 1
  44. #define IP_CMSG_TTL 2
  45. #define IP_CMSG_TOS 4
  46. #define IP_CMSG_RECVOPTS 8
  47. #define IP_CMSG_RETOPTS 16
  48. #define IP_CMSG_PASSSEC 32
  49. /*
  50. * SOL_IP control messages.
  51. */
  52. static void ip_cmsg_recv_pktinfo(struct msghdr *msg, struct sk_buff *skb)
  53. {
  54. struct in_pktinfo info;
  55. struct rtable *rt = skb->rtable;
  56. info.ipi_addr.s_addr = ip_hdr(skb)->daddr;
  57. if (rt) {
  58. info.ipi_ifindex = rt->rt_iif;
  59. info.ipi_spec_dst.s_addr = rt->rt_spec_dst;
  60. } else {
  61. info.ipi_ifindex = 0;
  62. info.ipi_spec_dst.s_addr = 0;
  63. }
  64. put_cmsg(msg, SOL_IP, IP_PKTINFO, sizeof(info), &info);
  65. }
  66. static void ip_cmsg_recv_ttl(struct msghdr *msg, struct sk_buff *skb)
  67. {
  68. int ttl = ip_hdr(skb)->ttl;
  69. put_cmsg(msg, SOL_IP, IP_TTL, sizeof(int), &ttl);
  70. }
  71. static void ip_cmsg_recv_tos(struct msghdr *msg, struct sk_buff *skb)
  72. {
  73. put_cmsg(msg, SOL_IP, IP_TOS, 1, &ip_hdr(skb)->tos);
  74. }
  75. static void ip_cmsg_recv_opts(struct msghdr *msg, struct sk_buff *skb)
  76. {
  77. if (IPCB(skb)->opt.optlen == 0)
  78. return;
  79. put_cmsg(msg, SOL_IP, IP_RECVOPTS, IPCB(skb)->opt.optlen,
  80. ip_hdr(skb) + 1);
  81. }
  82. static void ip_cmsg_recv_retopts(struct msghdr *msg, struct sk_buff *skb)
  83. {
  84. unsigned char optbuf[sizeof(struct ip_options) + 40];
  85. struct ip_options * opt = (struct ip_options*)optbuf;
  86. if (IPCB(skb)->opt.optlen == 0)
  87. return;
  88. if (ip_options_echo(opt, skb)) {
  89. msg->msg_flags |= MSG_CTRUNC;
  90. return;
  91. }
  92. ip_options_undo(opt);
  93. put_cmsg(msg, SOL_IP, IP_RETOPTS, opt->optlen, opt->__data);
  94. }
  95. static void ip_cmsg_recv_security(struct msghdr *msg, struct sk_buff *skb)
  96. {
  97. char *secdata;
  98. u32 seclen, secid;
  99. int err;
  100. err = security_socket_getpeersec_dgram(NULL, skb, &secid);
  101. if (err)
  102. return;
  103. err = security_secid_to_secctx(secid, &secdata, &seclen);
  104. if (err)
  105. return;
  106. put_cmsg(msg, SOL_IP, SCM_SECURITY, seclen, secdata);
  107. security_release_secctx(secdata, seclen);
  108. }
  109. void ip_cmsg_recv(struct msghdr *msg, struct sk_buff *skb)
  110. {
  111. struct inet_sock *inet = inet_sk(skb->sk);
  112. unsigned flags = inet->cmsg_flags;
  113. /* Ordered by supposed usage frequency */
  114. if (flags & 1)
  115. ip_cmsg_recv_pktinfo(msg, skb);
  116. if ((flags>>=1) == 0)
  117. return;
  118. if (flags & 1)
  119. ip_cmsg_recv_ttl(msg, skb);
  120. if ((flags>>=1) == 0)
  121. return;
  122. if (flags & 1)
  123. ip_cmsg_recv_tos(msg, skb);
  124. if ((flags>>=1) == 0)
  125. return;
  126. if (flags & 1)
  127. ip_cmsg_recv_opts(msg, skb);
  128. if ((flags>>=1) == 0)
  129. return;
  130. if (flags & 1)
  131. ip_cmsg_recv_retopts(msg, skb);
  132. if ((flags>>=1) == 0)
  133. return;
  134. if (flags & 1)
  135. ip_cmsg_recv_security(msg, skb);
  136. }
  137. int ip_cmsg_send(struct net *net, struct msghdr *msg, struct ipcm_cookie *ipc)
  138. {
  139. int err;
  140. struct cmsghdr *cmsg;
  141. for (cmsg = CMSG_FIRSTHDR(msg); cmsg; cmsg = CMSG_NXTHDR(msg, cmsg)) {
  142. if (!CMSG_OK(msg, cmsg))
  143. return -EINVAL;
  144. if (cmsg->cmsg_level != SOL_IP)
  145. continue;
  146. switch (cmsg->cmsg_type) {
  147. case IP_RETOPTS:
  148. err = cmsg->cmsg_len - CMSG_ALIGN(sizeof(struct cmsghdr));
  149. err = ip_options_get(net, &ipc->opt, CMSG_DATA(cmsg), err < 40 ? err : 40);
  150. if (err)
  151. return err;
  152. break;
  153. case IP_PKTINFO:
  154. {
  155. struct in_pktinfo *info;
  156. if (cmsg->cmsg_len != CMSG_LEN(sizeof(struct in_pktinfo)))
  157. return -EINVAL;
  158. info = (struct in_pktinfo *)CMSG_DATA(cmsg);
  159. ipc->oif = info->ipi_ifindex;
  160. ipc->addr = info->ipi_spec_dst.s_addr;
  161. break;
  162. }
  163. default:
  164. return -EINVAL;
  165. }
  166. }
  167. return 0;
  168. }
  169. /* Special input handler for packets caught by router alert option.
  170. They are selected only by protocol field, and then processed likely
  171. local ones; but only if someone wants them! Otherwise, router
  172. not running rsvpd will kill RSVP.
  173. It is user level problem, what it will make with them.
  174. I have no idea, how it will masquearde or NAT them (it is joke, joke :-)),
  175. but receiver should be enough clever f.e. to forward mtrace requests,
  176. sent to multicast group to reach destination designated router.
  177. */
  178. struct ip_ra_chain *ip_ra_chain;
  179. DEFINE_RWLOCK(ip_ra_lock);
  180. int ip_ra_control(struct sock *sk, unsigned char on, void (*destructor)(struct sock *))
  181. {
  182. struct ip_ra_chain *ra, *new_ra, **rap;
  183. if (sk->sk_type != SOCK_RAW || inet_sk(sk)->num == IPPROTO_RAW)
  184. return -EINVAL;
  185. new_ra = on ? kmalloc(sizeof(*new_ra), GFP_KERNEL) : NULL;
  186. write_lock_bh(&ip_ra_lock);
  187. for (rap = &ip_ra_chain; (ra=*rap) != NULL; rap = &ra->next) {
  188. if (ra->sk == sk) {
  189. if (on) {
  190. write_unlock_bh(&ip_ra_lock);
  191. kfree(new_ra);
  192. return -EADDRINUSE;
  193. }
  194. *rap = ra->next;
  195. write_unlock_bh(&ip_ra_lock);
  196. if (ra->destructor)
  197. ra->destructor(sk);
  198. sock_put(sk);
  199. kfree(ra);
  200. return 0;
  201. }
  202. }
  203. if (new_ra == NULL) {
  204. write_unlock_bh(&ip_ra_lock);
  205. return -ENOBUFS;
  206. }
  207. new_ra->sk = sk;
  208. new_ra->destructor = destructor;
  209. new_ra->next = ra;
  210. *rap = new_ra;
  211. sock_hold(sk);
  212. write_unlock_bh(&ip_ra_lock);
  213. return 0;
  214. }
  215. void ip_icmp_error(struct sock *sk, struct sk_buff *skb, int err,
  216. __be16 port, u32 info, u8 *payload)
  217. {
  218. struct inet_sock *inet = inet_sk(sk);
  219. struct sock_exterr_skb *serr;
  220. if (!inet->recverr)
  221. return;
  222. skb = skb_clone(skb, GFP_ATOMIC);
  223. if (!skb)
  224. return;
  225. serr = SKB_EXT_ERR(skb);
  226. serr->ee.ee_errno = err;
  227. serr->ee.ee_origin = SO_EE_ORIGIN_ICMP;
  228. serr->ee.ee_type = icmp_hdr(skb)->type;
  229. serr->ee.ee_code = icmp_hdr(skb)->code;
  230. serr->ee.ee_pad = 0;
  231. serr->ee.ee_info = info;
  232. serr->ee.ee_data = 0;
  233. serr->addr_offset = (u8 *)&(((struct iphdr *)(icmp_hdr(skb) + 1))->daddr) -
  234. skb_network_header(skb);
  235. serr->port = port;
  236. if (skb_pull(skb, payload - skb->data) != NULL) {
  237. skb_reset_transport_header(skb);
  238. if (sock_queue_err_skb(sk, skb) == 0)
  239. return;
  240. }
  241. kfree_skb(skb);
  242. }
  243. void ip_local_error(struct sock *sk, int err, __be32 daddr, __be16 port, u32 info)
  244. {
  245. struct inet_sock *inet = inet_sk(sk);
  246. struct sock_exterr_skb *serr;
  247. struct iphdr *iph;
  248. struct sk_buff *skb;
  249. if (!inet->recverr)
  250. return;
  251. skb = alloc_skb(sizeof(struct iphdr), GFP_ATOMIC);
  252. if (!skb)
  253. return;
  254. skb_put(skb, sizeof(struct iphdr));
  255. skb_reset_network_header(skb);
  256. iph = ip_hdr(skb);
  257. iph->daddr = daddr;
  258. serr = SKB_EXT_ERR(skb);
  259. serr->ee.ee_errno = err;
  260. serr->ee.ee_origin = SO_EE_ORIGIN_LOCAL;
  261. serr->ee.ee_type = 0;
  262. serr->ee.ee_code = 0;
  263. serr->ee.ee_pad = 0;
  264. serr->ee.ee_info = info;
  265. serr->ee.ee_data = 0;
  266. serr->addr_offset = (u8 *)&iph->daddr - skb_network_header(skb);
  267. serr->port = port;
  268. __skb_pull(skb, skb_tail_pointer(skb) - skb->data);
  269. skb_reset_transport_header(skb);
  270. if (sock_queue_err_skb(sk, skb))
  271. kfree_skb(skb);
  272. }
  273. /*
  274. * Handle MSG_ERRQUEUE
  275. */
  276. int ip_recv_error(struct sock *sk, struct msghdr *msg, int len)
  277. {
  278. struct sock_exterr_skb *serr;
  279. struct sk_buff *skb, *skb2;
  280. struct sockaddr_in *sin;
  281. struct {
  282. struct sock_extended_err ee;
  283. struct sockaddr_in offender;
  284. } errhdr;
  285. int err;
  286. int copied;
  287. err = -EAGAIN;
  288. skb = skb_dequeue(&sk->sk_error_queue);
  289. if (skb == NULL)
  290. goto out;
  291. copied = skb->len;
  292. if (copied > len) {
  293. msg->msg_flags |= MSG_TRUNC;
  294. copied = len;
  295. }
  296. err = skb_copy_datagram_iovec(skb, 0, msg->msg_iov, copied);
  297. if (err)
  298. goto out_free_skb;
  299. sock_recv_timestamp(msg, sk, skb);
  300. serr = SKB_EXT_ERR(skb);
  301. sin = (struct sockaddr_in *)msg->msg_name;
  302. if (sin) {
  303. sin->sin_family = AF_INET;
  304. sin->sin_addr.s_addr = *(__be32 *)(skb_network_header(skb) +
  305. serr->addr_offset);
  306. sin->sin_port = serr->port;
  307. memset(&sin->sin_zero, 0, sizeof(sin->sin_zero));
  308. }
  309. memcpy(&errhdr.ee, &serr->ee, sizeof(struct sock_extended_err));
  310. sin = &errhdr.offender;
  311. sin->sin_family = AF_UNSPEC;
  312. if (serr->ee.ee_origin == SO_EE_ORIGIN_ICMP) {
  313. struct inet_sock *inet = inet_sk(sk);
  314. sin->sin_family = AF_INET;
  315. sin->sin_addr.s_addr = ip_hdr(skb)->saddr;
  316. sin->sin_port = 0;
  317. memset(&sin->sin_zero, 0, sizeof(sin->sin_zero));
  318. if (inet->cmsg_flags)
  319. ip_cmsg_recv(msg, skb);
  320. }
  321. put_cmsg(msg, SOL_IP, IP_RECVERR, sizeof(errhdr), &errhdr);
  322. /* Now we could try to dump offended packet options */
  323. msg->msg_flags |= MSG_ERRQUEUE;
  324. err = copied;
  325. /* Reset and regenerate socket error */
  326. spin_lock_bh(&sk->sk_error_queue.lock);
  327. sk->sk_err = 0;
  328. if ((skb2 = skb_peek(&sk->sk_error_queue)) != NULL) {
  329. sk->sk_err = SKB_EXT_ERR(skb2)->ee.ee_errno;
  330. spin_unlock_bh(&sk->sk_error_queue.lock);
  331. sk->sk_error_report(sk);
  332. } else
  333. spin_unlock_bh(&sk->sk_error_queue.lock);
  334. out_free_skb:
  335. kfree_skb(skb);
  336. out:
  337. return err;
  338. }
  339. /*
  340. * Socket option code for IP. This is the end of the line after any TCP,UDP etc options on
  341. * an IP socket.
  342. */
  343. static int do_ip_setsockopt(struct sock *sk, int level,
  344. int optname, char __user *optval, int optlen)
  345. {
  346. struct inet_sock *inet = inet_sk(sk);
  347. int val=0,err;
  348. if (((1<<optname) & ((1<<IP_PKTINFO) | (1<<IP_RECVTTL) |
  349. (1<<IP_RECVOPTS) | (1<<IP_RECVTOS) |
  350. (1<<IP_RETOPTS) | (1<<IP_TOS) |
  351. (1<<IP_TTL) | (1<<IP_HDRINCL) |
  352. (1<<IP_MTU_DISCOVER) | (1<<IP_RECVERR) |
  353. (1<<IP_ROUTER_ALERT) | (1<<IP_FREEBIND) |
  354. (1<<IP_PASSSEC))) ||
  355. optname == IP_MULTICAST_TTL ||
  356. optname == IP_MULTICAST_LOOP) {
  357. if (optlen >= sizeof(int)) {
  358. if (get_user(val, (int __user *) optval))
  359. return -EFAULT;
  360. } else if (optlen >= sizeof(char)) {
  361. unsigned char ucval;
  362. if (get_user(ucval, (unsigned char __user *) optval))
  363. return -EFAULT;
  364. val = (int) ucval;
  365. }
  366. }
  367. /* If optlen==0, it is equivalent to val == 0 */
  368. if (ip_mroute_opt(optname))
  369. return ip_mroute_setsockopt(sk,optname,optval,optlen);
  370. err = 0;
  371. lock_sock(sk);
  372. switch (optname) {
  373. case IP_OPTIONS:
  374. {
  375. struct ip_options * opt = NULL;
  376. if (optlen > 40 || optlen < 0)
  377. goto e_inval;
  378. err = ip_options_get_from_user(sock_net(sk), &opt,
  379. optval, optlen);
  380. if (err)
  381. break;
  382. if (inet->is_icsk) {
  383. struct inet_connection_sock *icsk = inet_csk(sk);
  384. #if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
  385. if (sk->sk_family == PF_INET ||
  386. (!((1 << sk->sk_state) &
  387. (TCPF_LISTEN | TCPF_CLOSE)) &&
  388. inet->daddr != LOOPBACK4_IPV6)) {
  389. #endif
  390. if (inet->opt)
  391. icsk->icsk_ext_hdr_len -= inet->opt->optlen;
  392. if (opt)
  393. icsk->icsk_ext_hdr_len += opt->optlen;
  394. icsk->icsk_sync_mss(sk, icsk->icsk_pmtu_cookie);
  395. #if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
  396. }
  397. #endif
  398. }
  399. opt = xchg(&inet->opt, opt);
  400. kfree(opt);
  401. break;
  402. }
  403. case IP_PKTINFO:
  404. if (val)
  405. inet->cmsg_flags |= IP_CMSG_PKTINFO;
  406. else
  407. inet->cmsg_flags &= ~IP_CMSG_PKTINFO;
  408. break;
  409. case IP_RECVTTL:
  410. if (val)
  411. inet->cmsg_flags |= IP_CMSG_TTL;
  412. else
  413. inet->cmsg_flags &= ~IP_CMSG_TTL;
  414. break;
  415. case IP_RECVTOS:
  416. if (val)
  417. inet->cmsg_flags |= IP_CMSG_TOS;
  418. else
  419. inet->cmsg_flags &= ~IP_CMSG_TOS;
  420. break;
  421. case IP_RECVOPTS:
  422. if (val)
  423. inet->cmsg_flags |= IP_CMSG_RECVOPTS;
  424. else
  425. inet->cmsg_flags &= ~IP_CMSG_RECVOPTS;
  426. break;
  427. case IP_RETOPTS:
  428. if (val)
  429. inet->cmsg_flags |= IP_CMSG_RETOPTS;
  430. else
  431. inet->cmsg_flags &= ~IP_CMSG_RETOPTS;
  432. break;
  433. case IP_PASSSEC:
  434. if (val)
  435. inet->cmsg_flags |= IP_CMSG_PASSSEC;
  436. else
  437. inet->cmsg_flags &= ~IP_CMSG_PASSSEC;
  438. break;
  439. case IP_TOS: /* This sets both TOS and Precedence */
  440. if (sk->sk_type == SOCK_STREAM) {
  441. val &= ~3;
  442. val |= inet->tos & 3;
  443. }
  444. if (inet->tos != val) {
  445. inet->tos = val;
  446. sk->sk_priority = rt_tos2priority(val);
  447. sk_dst_reset(sk);
  448. }
  449. break;
  450. case IP_TTL:
  451. if (optlen<1)
  452. goto e_inval;
  453. if (val != -1 && (val < 1 || val>255))
  454. goto e_inval;
  455. inet->uc_ttl = val;
  456. break;
  457. case IP_HDRINCL:
  458. if (sk->sk_type != SOCK_RAW) {
  459. err = -ENOPROTOOPT;
  460. break;
  461. }
  462. inet->hdrincl = val ? 1 : 0;
  463. break;
  464. case IP_MTU_DISCOVER:
  465. if (val<0 || val>3)
  466. goto e_inval;
  467. inet->pmtudisc = val;
  468. break;
  469. case IP_RECVERR:
  470. inet->recverr = !!val;
  471. if (!val)
  472. skb_queue_purge(&sk->sk_error_queue);
  473. break;
  474. case IP_MULTICAST_TTL:
  475. if (sk->sk_type == SOCK_STREAM)
  476. goto e_inval;
  477. if (optlen<1)
  478. goto e_inval;
  479. if (val==-1)
  480. val = 1;
  481. if (val < 0 || val > 255)
  482. goto e_inval;
  483. inet->mc_ttl = val;
  484. break;
  485. case IP_MULTICAST_LOOP:
  486. if (optlen<1)
  487. goto e_inval;
  488. inet->mc_loop = !!val;
  489. break;
  490. case IP_MULTICAST_IF:
  491. {
  492. struct ip_mreqn mreq;
  493. struct net_device *dev = NULL;
  494. if (sk->sk_type == SOCK_STREAM)
  495. goto e_inval;
  496. /*
  497. * Check the arguments are allowable
  498. */
  499. err = -EFAULT;
  500. if (optlen >= sizeof(struct ip_mreqn)) {
  501. if (copy_from_user(&mreq,optval,sizeof(mreq)))
  502. break;
  503. } else {
  504. memset(&mreq, 0, sizeof(mreq));
  505. if (optlen >= sizeof(struct in_addr) &&
  506. copy_from_user(&mreq.imr_address,optval,sizeof(struct in_addr)))
  507. break;
  508. }
  509. if (!mreq.imr_ifindex) {
  510. if (mreq.imr_address.s_addr == htonl(INADDR_ANY)) {
  511. inet->mc_index = 0;
  512. inet->mc_addr = 0;
  513. err = 0;
  514. break;
  515. }
  516. dev = ip_dev_find(sock_net(sk), mreq.imr_address.s_addr);
  517. if (dev) {
  518. mreq.imr_ifindex = dev->ifindex;
  519. dev_put(dev);
  520. }
  521. } else
  522. dev = __dev_get_by_index(sock_net(sk), mreq.imr_ifindex);
  523. err = -EADDRNOTAVAIL;
  524. if (!dev)
  525. break;
  526. err = -EINVAL;
  527. if (sk->sk_bound_dev_if &&
  528. mreq.imr_ifindex != sk->sk_bound_dev_if)
  529. break;
  530. inet->mc_index = mreq.imr_ifindex;
  531. inet->mc_addr = mreq.imr_address.s_addr;
  532. err = 0;
  533. break;
  534. }
  535. case IP_ADD_MEMBERSHIP:
  536. case IP_DROP_MEMBERSHIP:
  537. {
  538. struct ip_mreqn mreq;
  539. err = -EPROTO;
  540. if (inet_sk(sk)->is_icsk)
  541. break;
  542. if (optlen < sizeof(struct ip_mreq))
  543. goto e_inval;
  544. err = -EFAULT;
  545. if (optlen >= sizeof(struct ip_mreqn)) {
  546. if (copy_from_user(&mreq,optval,sizeof(mreq)))
  547. break;
  548. } else {
  549. memset(&mreq, 0, sizeof(mreq));
  550. if (copy_from_user(&mreq,optval,sizeof(struct ip_mreq)))
  551. break;
  552. }
  553. if (optname == IP_ADD_MEMBERSHIP)
  554. err = ip_mc_join_group(sk, &mreq);
  555. else
  556. err = ip_mc_leave_group(sk, &mreq);
  557. break;
  558. }
  559. case IP_MSFILTER:
  560. {
  561. extern int sysctl_igmp_max_msf;
  562. struct ip_msfilter *msf;
  563. if (optlen < IP_MSFILTER_SIZE(0))
  564. goto e_inval;
  565. if (optlen > sysctl_optmem_max) {
  566. err = -ENOBUFS;
  567. break;
  568. }
  569. msf = kmalloc(optlen, GFP_KERNEL);
  570. if (!msf) {
  571. err = -ENOBUFS;
  572. break;
  573. }
  574. err = -EFAULT;
  575. if (copy_from_user(msf, optval, optlen)) {
  576. kfree(msf);
  577. break;
  578. }
  579. /* numsrc >= (1G-4) overflow in 32 bits */
  580. if (msf->imsf_numsrc >= 0x3ffffffcU ||
  581. msf->imsf_numsrc > sysctl_igmp_max_msf) {
  582. kfree(msf);
  583. err = -ENOBUFS;
  584. break;
  585. }
  586. if (IP_MSFILTER_SIZE(msf->imsf_numsrc) > optlen) {
  587. kfree(msf);
  588. err = -EINVAL;
  589. break;
  590. }
  591. err = ip_mc_msfilter(sk, msf, 0);
  592. kfree(msf);
  593. break;
  594. }
  595. case IP_BLOCK_SOURCE:
  596. case IP_UNBLOCK_SOURCE:
  597. case IP_ADD_SOURCE_MEMBERSHIP:
  598. case IP_DROP_SOURCE_MEMBERSHIP:
  599. {
  600. struct ip_mreq_source mreqs;
  601. int omode, add;
  602. if (optlen != sizeof(struct ip_mreq_source))
  603. goto e_inval;
  604. if (copy_from_user(&mreqs, optval, sizeof(mreqs))) {
  605. err = -EFAULT;
  606. break;
  607. }
  608. if (optname == IP_BLOCK_SOURCE) {
  609. omode = MCAST_EXCLUDE;
  610. add = 1;
  611. } else if (optname == IP_UNBLOCK_SOURCE) {
  612. omode = MCAST_EXCLUDE;
  613. add = 0;
  614. } else if (optname == IP_ADD_SOURCE_MEMBERSHIP) {
  615. struct ip_mreqn mreq;
  616. mreq.imr_multiaddr.s_addr = mreqs.imr_multiaddr;
  617. mreq.imr_address.s_addr = mreqs.imr_interface;
  618. mreq.imr_ifindex = 0;
  619. err = ip_mc_join_group(sk, &mreq);
  620. if (err && err != -EADDRINUSE)
  621. break;
  622. omode = MCAST_INCLUDE;
  623. add = 1;
  624. } else /* IP_DROP_SOURCE_MEMBERSHIP */ {
  625. omode = MCAST_INCLUDE;
  626. add = 0;
  627. }
  628. err = ip_mc_source(add, omode, sk, &mreqs, 0);
  629. break;
  630. }
  631. case MCAST_JOIN_GROUP:
  632. case MCAST_LEAVE_GROUP:
  633. {
  634. struct group_req greq;
  635. struct sockaddr_in *psin;
  636. struct ip_mreqn mreq;
  637. if (optlen < sizeof(struct group_req))
  638. goto e_inval;
  639. err = -EFAULT;
  640. if (copy_from_user(&greq, optval, sizeof(greq)))
  641. break;
  642. psin = (struct sockaddr_in *)&greq.gr_group;
  643. if (psin->sin_family != AF_INET)
  644. goto e_inval;
  645. memset(&mreq, 0, sizeof(mreq));
  646. mreq.imr_multiaddr = psin->sin_addr;
  647. mreq.imr_ifindex = greq.gr_interface;
  648. if (optname == MCAST_JOIN_GROUP)
  649. err = ip_mc_join_group(sk, &mreq);
  650. else
  651. err = ip_mc_leave_group(sk, &mreq);
  652. break;
  653. }
  654. case MCAST_JOIN_SOURCE_GROUP:
  655. case MCAST_LEAVE_SOURCE_GROUP:
  656. case MCAST_BLOCK_SOURCE:
  657. case MCAST_UNBLOCK_SOURCE:
  658. {
  659. struct group_source_req greqs;
  660. struct ip_mreq_source mreqs;
  661. struct sockaddr_in *psin;
  662. int omode, add;
  663. if (optlen != sizeof(struct group_source_req))
  664. goto e_inval;
  665. if (copy_from_user(&greqs, optval, sizeof(greqs))) {
  666. err = -EFAULT;
  667. break;
  668. }
  669. if (greqs.gsr_group.ss_family != AF_INET ||
  670. greqs.gsr_source.ss_family != AF_INET) {
  671. err = -EADDRNOTAVAIL;
  672. break;
  673. }
  674. psin = (struct sockaddr_in *)&greqs.gsr_group;
  675. mreqs.imr_multiaddr = psin->sin_addr.s_addr;
  676. psin = (struct sockaddr_in *)&greqs.gsr_source;
  677. mreqs.imr_sourceaddr = psin->sin_addr.s_addr;
  678. mreqs.imr_interface = 0; /* use index for mc_source */
  679. if (optname == MCAST_BLOCK_SOURCE) {
  680. omode = MCAST_EXCLUDE;
  681. add = 1;
  682. } else if (optname == MCAST_UNBLOCK_SOURCE) {
  683. omode = MCAST_EXCLUDE;
  684. add = 0;
  685. } else if (optname == MCAST_JOIN_SOURCE_GROUP) {
  686. struct ip_mreqn mreq;
  687. psin = (struct sockaddr_in *)&greqs.gsr_group;
  688. mreq.imr_multiaddr = psin->sin_addr;
  689. mreq.imr_address.s_addr = 0;
  690. mreq.imr_ifindex = greqs.gsr_interface;
  691. err = ip_mc_join_group(sk, &mreq);
  692. if (err && err != -EADDRINUSE)
  693. break;
  694. greqs.gsr_interface = mreq.imr_ifindex;
  695. omode = MCAST_INCLUDE;
  696. add = 1;
  697. } else /* MCAST_LEAVE_SOURCE_GROUP */ {
  698. omode = MCAST_INCLUDE;
  699. add = 0;
  700. }
  701. err = ip_mc_source(add, omode, sk, &mreqs,
  702. greqs.gsr_interface);
  703. break;
  704. }
  705. case MCAST_MSFILTER:
  706. {
  707. extern int sysctl_igmp_max_msf;
  708. struct sockaddr_in *psin;
  709. struct ip_msfilter *msf = NULL;
  710. struct group_filter *gsf = NULL;
  711. int msize, i, ifindex;
  712. if (optlen < GROUP_FILTER_SIZE(0))
  713. goto e_inval;
  714. if (optlen > sysctl_optmem_max) {
  715. err = -ENOBUFS;
  716. break;
  717. }
  718. gsf = kmalloc(optlen,GFP_KERNEL);
  719. if (!gsf) {
  720. err = -ENOBUFS;
  721. break;
  722. }
  723. err = -EFAULT;
  724. if (copy_from_user(gsf, optval, optlen)) {
  725. goto mc_msf_out;
  726. }
  727. /* numsrc >= (4G-140)/128 overflow in 32 bits */
  728. if (gsf->gf_numsrc >= 0x1ffffff ||
  729. gsf->gf_numsrc > sysctl_igmp_max_msf) {
  730. err = -ENOBUFS;
  731. goto mc_msf_out;
  732. }
  733. if (GROUP_FILTER_SIZE(gsf->gf_numsrc) > optlen) {
  734. err = -EINVAL;
  735. goto mc_msf_out;
  736. }
  737. msize = IP_MSFILTER_SIZE(gsf->gf_numsrc);
  738. msf = kmalloc(msize,GFP_KERNEL);
  739. if (!msf) {
  740. err = -ENOBUFS;
  741. goto mc_msf_out;
  742. }
  743. ifindex = gsf->gf_interface;
  744. psin = (struct sockaddr_in *)&gsf->gf_group;
  745. if (psin->sin_family != AF_INET) {
  746. err = -EADDRNOTAVAIL;
  747. goto mc_msf_out;
  748. }
  749. msf->imsf_multiaddr = psin->sin_addr.s_addr;
  750. msf->imsf_interface = 0;
  751. msf->imsf_fmode = gsf->gf_fmode;
  752. msf->imsf_numsrc = gsf->gf_numsrc;
  753. err = -EADDRNOTAVAIL;
  754. for (i=0; i<gsf->gf_numsrc; ++i) {
  755. psin = (struct sockaddr_in *)&gsf->gf_slist[i];
  756. if (psin->sin_family != AF_INET)
  757. goto mc_msf_out;
  758. msf->imsf_slist[i] = psin->sin_addr.s_addr;
  759. }
  760. kfree(gsf);
  761. gsf = NULL;
  762. err = ip_mc_msfilter(sk, msf, ifindex);
  763. mc_msf_out:
  764. kfree(msf);
  765. kfree(gsf);
  766. break;
  767. }
  768. case IP_ROUTER_ALERT:
  769. err = ip_ra_control(sk, val ? 1 : 0, NULL);
  770. break;
  771. case IP_FREEBIND:
  772. if (optlen<1)
  773. goto e_inval;
  774. inet->freebind = !!val;
  775. break;
  776. case IP_IPSEC_POLICY:
  777. case IP_XFRM_POLICY:
  778. err = -EPERM;
  779. if (!capable(CAP_NET_ADMIN))
  780. break;
  781. err = xfrm_user_policy(sk, optname, optval, optlen);
  782. break;
  783. default:
  784. err = -ENOPROTOOPT;
  785. break;
  786. }
  787. release_sock(sk);
  788. return err;
  789. e_inval:
  790. release_sock(sk);
  791. return -EINVAL;
  792. }
  793. int ip_setsockopt(struct sock *sk, int level,
  794. int optname, char __user *optval, int optlen)
  795. {
  796. int err;
  797. if (level != SOL_IP)
  798. return -ENOPROTOOPT;
  799. err = do_ip_setsockopt(sk, level, optname, optval, optlen);
  800. #ifdef CONFIG_NETFILTER
  801. /* we need to exclude all possible ENOPROTOOPTs except default case */
  802. if (err == -ENOPROTOOPT && optname != IP_HDRINCL &&
  803. optname != IP_IPSEC_POLICY &&
  804. optname != IP_XFRM_POLICY &&
  805. !ip_mroute_opt(optname)) {
  806. lock_sock(sk);
  807. err = nf_setsockopt(sk, PF_INET, optname, optval, optlen);
  808. release_sock(sk);
  809. }
  810. #endif
  811. return err;
  812. }
  813. #ifdef CONFIG_COMPAT
  814. int compat_ip_setsockopt(struct sock *sk, int level, int optname,
  815. char __user *optval, int optlen)
  816. {
  817. int err;
  818. if (level != SOL_IP)
  819. return -ENOPROTOOPT;
  820. err = do_ip_setsockopt(sk, level, optname, optval, optlen);
  821. #ifdef CONFIG_NETFILTER
  822. /* we need to exclude all possible ENOPROTOOPTs except default case */
  823. if (err == -ENOPROTOOPT && optname != IP_HDRINCL &&
  824. optname != IP_IPSEC_POLICY &&
  825. optname != IP_XFRM_POLICY &&
  826. !ip_mroute_opt(optname)) {
  827. lock_sock(sk);
  828. err = compat_nf_setsockopt(sk, PF_INET, optname,
  829. optval, optlen);
  830. release_sock(sk);
  831. }
  832. #endif
  833. return err;
  834. }
  835. EXPORT_SYMBOL(compat_ip_setsockopt);
  836. #endif
  837. /*
  838. * Get the options. Note for future reference. The GET of IP options gets the
  839. * _received_ ones. The set sets the _sent_ ones.
  840. */
  841. static int do_ip_getsockopt(struct sock *sk, int level, int optname,
  842. char __user *optval, int __user *optlen)
  843. {
  844. struct inet_sock *inet = inet_sk(sk);
  845. int val;
  846. int len;
  847. if (level != SOL_IP)
  848. return -EOPNOTSUPP;
  849. if (ip_mroute_opt(optname))
  850. return ip_mroute_getsockopt(sk,optname,optval,optlen);
  851. if (get_user(len,optlen))
  852. return -EFAULT;
  853. if (len < 0)
  854. return -EINVAL;
  855. lock_sock(sk);
  856. switch (optname) {
  857. case IP_OPTIONS:
  858. {
  859. unsigned char optbuf[sizeof(struct ip_options)+40];
  860. struct ip_options * opt = (struct ip_options*)optbuf;
  861. opt->optlen = 0;
  862. if (inet->opt)
  863. memcpy(optbuf, inet->opt,
  864. sizeof(struct ip_options)+
  865. inet->opt->optlen);
  866. release_sock(sk);
  867. if (opt->optlen == 0)
  868. return put_user(0, optlen);
  869. ip_options_undo(opt);
  870. len = min_t(unsigned int, len, opt->optlen);
  871. if (put_user(len, optlen))
  872. return -EFAULT;
  873. if (copy_to_user(optval, opt->__data, len))
  874. return -EFAULT;
  875. return 0;
  876. }
  877. case IP_PKTINFO:
  878. val = (inet->cmsg_flags & IP_CMSG_PKTINFO) != 0;
  879. break;
  880. case IP_RECVTTL:
  881. val = (inet->cmsg_flags & IP_CMSG_TTL) != 0;
  882. break;
  883. case IP_RECVTOS:
  884. val = (inet->cmsg_flags & IP_CMSG_TOS) != 0;
  885. break;
  886. case IP_RECVOPTS:
  887. val = (inet->cmsg_flags & IP_CMSG_RECVOPTS) != 0;
  888. break;
  889. case IP_RETOPTS:
  890. val = (inet->cmsg_flags & IP_CMSG_RETOPTS) != 0;
  891. break;
  892. case IP_PASSSEC:
  893. val = (inet->cmsg_flags & IP_CMSG_PASSSEC) != 0;
  894. break;
  895. case IP_TOS:
  896. val = inet->tos;
  897. break;
  898. case IP_TTL:
  899. val = (inet->uc_ttl == -1 ?
  900. sysctl_ip_default_ttl :
  901. inet->uc_ttl);
  902. break;
  903. case IP_HDRINCL:
  904. val = inet->hdrincl;
  905. break;
  906. case IP_MTU_DISCOVER:
  907. val = inet->pmtudisc;
  908. break;
  909. case IP_MTU:
  910. {
  911. struct dst_entry *dst;
  912. val = 0;
  913. dst = sk_dst_get(sk);
  914. if (dst) {
  915. val = dst_mtu(dst);
  916. dst_release(dst);
  917. }
  918. if (!val) {
  919. release_sock(sk);
  920. return -ENOTCONN;
  921. }
  922. break;
  923. }
  924. case IP_RECVERR:
  925. val = inet->recverr;
  926. break;
  927. case IP_MULTICAST_TTL:
  928. val = inet->mc_ttl;
  929. break;
  930. case IP_MULTICAST_LOOP:
  931. val = inet->mc_loop;
  932. break;
  933. case IP_MULTICAST_IF:
  934. {
  935. struct in_addr addr;
  936. len = min_t(unsigned int, len, sizeof(struct in_addr));
  937. addr.s_addr = inet->mc_addr;
  938. release_sock(sk);
  939. if (put_user(len, optlen))
  940. return -EFAULT;
  941. if (copy_to_user(optval, &addr, len))
  942. return -EFAULT;
  943. return 0;
  944. }
  945. case IP_MSFILTER:
  946. {
  947. struct ip_msfilter msf;
  948. int err;
  949. if (len < IP_MSFILTER_SIZE(0)) {
  950. release_sock(sk);
  951. return -EINVAL;
  952. }
  953. if (copy_from_user(&msf, optval, IP_MSFILTER_SIZE(0))) {
  954. release_sock(sk);
  955. return -EFAULT;
  956. }
  957. err = ip_mc_msfget(sk, &msf,
  958. (struct ip_msfilter __user *)optval, optlen);
  959. release_sock(sk);
  960. return err;
  961. }
  962. case MCAST_MSFILTER:
  963. {
  964. struct group_filter gsf;
  965. int err;
  966. if (len < GROUP_FILTER_SIZE(0)) {
  967. release_sock(sk);
  968. return -EINVAL;
  969. }
  970. if (copy_from_user(&gsf, optval, GROUP_FILTER_SIZE(0))) {
  971. release_sock(sk);
  972. return -EFAULT;
  973. }
  974. err = ip_mc_gsfget(sk, &gsf,
  975. (struct group_filter __user *)optval, optlen);
  976. release_sock(sk);
  977. return err;
  978. }
  979. case IP_PKTOPTIONS:
  980. {
  981. struct msghdr msg;
  982. release_sock(sk);
  983. if (sk->sk_type != SOCK_STREAM)
  984. return -ENOPROTOOPT;
  985. msg.msg_control = optval;
  986. msg.msg_controllen = len;
  987. msg.msg_flags = 0;
  988. if (inet->cmsg_flags & IP_CMSG_PKTINFO) {
  989. struct in_pktinfo info;
  990. info.ipi_addr.s_addr = inet->rcv_saddr;
  991. info.ipi_spec_dst.s_addr = inet->rcv_saddr;
  992. info.ipi_ifindex = inet->mc_index;
  993. put_cmsg(&msg, SOL_IP, IP_PKTINFO, sizeof(info), &info);
  994. }
  995. if (inet->cmsg_flags & IP_CMSG_TTL) {
  996. int hlim = inet->mc_ttl;
  997. put_cmsg(&msg, SOL_IP, IP_TTL, sizeof(hlim), &hlim);
  998. }
  999. len -= msg.msg_controllen;
  1000. return put_user(len, optlen);
  1001. }
  1002. case IP_FREEBIND:
  1003. val = inet->freebind;
  1004. break;
  1005. default:
  1006. release_sock(sk);
  1007. return -ENOPROTOOPT;
  1008. }
  1009. release_sock(sk);
  1010. if (len < sizeof(int) && len > 0 && val>=0 && val<=255) {
  1011. unsigned char ucval = (unsigned char)val;
  1012. len = 1;
  1013. if (put_user(len, optlen))
  1014. return -EFAULT;
  1015. if (copy_to_user(optval,&ucval,1))
  1016. return -EFAULT;
  1017. } else {
  1018. len = min_t(unsigned int, sizeof(int), len);
  1019. if (put_user(len, optlen))
  1020. return -EFAULT;
  1021. if (copy_to_user(optval,&val,len))
  1022. return -EFAULT;
  1023. }
  1024. return 0;
  1025. }
  1026. int ip_getsockopt(struct sock *sk, int level,
  1027. int optname, char __user *optval, int __user *optlen)
  1028. {
  1029. int err;
  1030. err = do_ip_getsockopt(sk, level, optname, optval, optlen);
  1031. #ifdef CONFIG_NETFILTER
  1032. /* we need to exclude all possible ENOPROTOOPTs except default case */
  1033. if (err == -ENOPROTOOPT && optname != IP_PKTOPTIONS &&
  1034. !ip_mroute_opt(optname)) {
  1035. int len;
  1036. if (get_user(len,optlen))
  1037. return -EFAULT;
  1038. lock_sock(sk);
  1039. err = nf_getsockopt(sk, PF_INET, optname, optval,
  1040. &len);
  1041. release_sock(sk);
  1042. if (err >= 0)
  1043. err = put_user(len, optlen);
  1044. return err;
  1045. }
  1046. #endif
  1047. return err;
  1048. }
  1049. #ifdef CONFIG_COMPAT
  1050. int compat_ip_getsockopt(struct sock *sk, int level, int optname,
  1051. char __user *optval, int __user *optlen)
  1052. {
  1053. int err = do_ip_getsockopt(sk, level, optname, optval, optlen);
  1054. #ifdef CONFIG_NETFILTER
  1055. /* we need to exclude all possible ENOPROTOOPTs except default case */
  1056. if (err == -ENOPROTOOPT && optname != IP_PKTOPTIONS &&
  1057. !ip_mroute_opt(optname)) {
  1058. int len;
  1059. if (get_user(len, optlen))
  1060. return -EFAULT;
  1061. lock_sock(sk);
  1062. err = compat_nf_getsockopt(sk, PF_INET, optname, optval, &len);
  1063. release_sock(sk);
  1064. if (err >= 0)
  1065. err = put_user(len, optlen);
  1066. return err;
  1067. }
  1068. #endif
  1069. return err;
  1070. }
  1071. EXPORT_SYMBOL(compat_ip_getsockopt);
  1072. #endif
  1073. EXPORT_SYMBOL(ip_cmsg_recv);
  1074. EXPORT_SYMBOL(ip_getsockopt);
  1075. EXPORT_SYMBOL(ip_setsockopt);