ip_sockglue.c 25 KB

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