sock.c 56 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276
  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. * Generic socket support routines. Memory allocators, socket lock/release
  7. * handler for protocols to use and generic option handler.
  8. *
  9. *
  10. * Authors: Ross Biro
  11. * Fred N. van Kempen, <waltje@uWalt.NL.Mugnet.ORG>
  12. * Florian La Roche, <flla@stud.uni-sb.de>
  13. * Alan Cox, <A.Cox@swansea.ac.uk>
  14. *
  15. * Fixes:
  16. * Alan Cox : Numerous verify_area() problems
  17. * Alan Cox : Connecting on a connecting socket
  18. * now returns an error for tcp.
  19. * Alan Cox : sock->protocol is set correctly.
  20. * and is not sometimes left as 0.
  21. * Alan Cox : connect handles icmp errors on a
  22. * connect properly. Unfortunately there
  23. * is a restart syscall nasty there. I
  24. * can't match BSD without hacking the C
  25. * library. Ideas urgently sought!
  26. * Alan Cox : Disallow bind() to addresses that are
  27. * not ours - especially broadcast ones!!
  28. * Alan Cox : Socket 1024 _IS_ ok for users. (fencepost)
  29. * Alan Cox : sock_wfree/sock_rfree don't destroy sockets,
  30. * instead they leave that for the DESTROY timer.
  31. * Alan Cox : Clean up error flag in accept
  32. * Alan Cox : TCP ack handling is buggy, the DESTROY timer
  33. * was buggy. Put a remove_sock() in the handler
  34. * for memory when we hit 0. Also altered the timer
  35. * code. The ACK stuff can wait and needs major
  36. * TCP layer surgery.
  37. * Alan Cox : Fixed TCP ack bug, removed remove sock
  38. * and fixed timer/inet_bh race.
  39. * Alan Cox : Added zapped flag for TCP
  40. * Alan Cox : Move kfree_skb into skbuff.c and tidied up surplus code
  41. * Alan Cox : for new sk_buff allocations wmalloc/rmalloc now call alloc_skb
  42. * Alan Cox : kfree_s calls now are kfree_skbmem so we can track skb resources
  43. * Alan Cox : Supports socket option broadcast now as does udp. Packet and raw need fixing.
  44. * Alan Cox : Added RCVBUF,SNDBUF size setting. It suddenly occurred to me how easy it was so...
  45. * Rick Sladkey : Relaxed UDP rules for matching packets.
  46. * C.E.Hawkins : IFF_PROMISC/SIOCGHWADDR support
  47. * Pauline Middelink : identd support
  48. * Alan Cox : Fixed connect() taking signals I think.
  49. * Alan Cox : SO_LINGER supported
  50. * Alan Cox : Error reporting fixes
  51. * Anonymous : inet_create tidied up (sk->reuse setting)
  52. * Alan Cox : inet sockets don't set sk->type!
  53. * Alan Cox : Split socket option code
  54. * Alan Cox : Callbacks
  55. * Alan Cox : Nagle flag for Charles & Johannes stuff
  56. * Alex : Removed restriction on inet fioctl
  57. * Alan Cox : Splitting INET from NET core
  58. * Alan Cox : Fixed bogus SO_TYPE handling in getsockopt()
  59. * Adam Caldwell : Missing return in SO_DONTROUTE/SO_DEBUG code
  60. * Alan Cox : Split IP from generic code
  61. * Alan Cox : New kfree_skbmem()
  62. * Alan Cox : Make SO_DEBUG superuser only.
  63. * Alan Cox : Allow anyone to clear SO_DEBUG
  64. * (compatibility fix)
  65. * Alan Cox : Added optimistic memory grabbing for AF_UNIX throughput.
  66. * Alan Cox : Allocator for a socket is settable.
  67. * Alan Cox : SO_ERROR includes soft errors.
  68. * Alan Cox : Allow NULL arguments on some SO_ opts
  69. * Alan Cox : Generic socket allocation to make hooks
  70. * easier (suggested by Craig Metz).
  71. * Michael Pall : SO_ERROR returns positive errno again
  72. * Steve Whitehouse: Added default destructor to free
  73. * protocol private data.
  74. * Steve Whitehouse: Added various other default routines
  75. * common to several socket families.
  76. * Chris Evans : Call suser() check last on F_SETOWN
  77. * Jay Schulist : Added SO_ATTACH_FILTER and SO_DETACH_FILTER.
  78. * Andi Kleen : Add sock_kmalloc()/sock_kfree_s()
  79. * Andi Kleen : Fix write_space callback
  80. * Chris Evans : Security fixes - signedness again
  81. * Arnaldo C. Melo : cleanups, use skb_queue_purge
  82. *
  83. * To Fix:
  84. *
  85. *
  86. * This program is free software; you can redistribute it and/or
  87. * modify it under the terms of the GNU General Public License
  88. * as published by the Free Software Foundation; either version
  89. * 2 of the License, or (at your option) any later version.
  90. */
  91. #include <linux/capability.h>
  92. #include <linux/errno.h>
  93. #include <linux/types.h>
  94. #include <linux/socket.h>
  95. #include <linux/in.h>
  96. #include <linux/kernel.h>
  97. #include <linux/module.h>
  98. #include <linux/proc_fs.h>
  99. #include <linux/seq_file.h>
  100. #include <linux/sched.h>
  101. #include <linux/timer.h>
  102. #include <linux/string.h>
  103. #include <linux/sockios.h>
  104. #include <linux/net.h>
  105. #include <linux/mm.h>
  106. #include <linux/slab.h>
  107. #include <linux/interrupt.h>
  108. #include <linux/poll.h>
  109. #include <linux/tcp.h>
  110. #include <linux/init.h>
  111. #include <linux/highmem.h>
  112. #include <asm/uaccess.h>
  113. #include <asm/system.h>
  114. #include <linux/netdevice.h>
  115. #include <net/protocol.h>
  116. #include <linux/skbuff.h>
  117. #include <net/net_namespace.h>
  118. #include <net/request_sock.h>
  119. #include <net/sock.h>
  120. #include <net/xfrm.h>
  121. #include <linux/ipsec.h>
  122. #include <linux/filter.h>
  123. #ifdef CONFIG_INET
  124. #include <net/tcp.h>
  125. #endif
  126. /*
  127. * Each address family might have different locking rules, so we have
  128. * one slock key per address family:
  129. */
  130. static struct lock_class_key af_family_keys[AF_MAX];
  131. static struct lock_class_key af_family_slock_keys[AF_MAX];
  132. #ifdef CONFIG_DEBUG_LOCK_ALLOC
  133. /*
  134. * Make lock validator output more readable. (we pre-construct these
  135. * strings build-time, so that runtime initialization of socket
  136. * locks is fast):
  137. */
  138. static const char *af_family_key_strings[AF_MAX+1] = {
  139. "sk_lock-AF_UNSPEC", "sk_lock-AF_UNIX" , "sk_lock-AF_INET" ,
  140. "sk_lock-AF_AX25" , "sk_lock-AF_IPX" , "sk_lock-AF_APPLETALK",
  141. "sk_lock-AF_NETROM", "sk_lock-AF_BRIDGE" , "sk_lock-AF_ATMPVC" ,
  142. "sk_lock-AF_X25" , "sk_lock-AF_INET6" , "sk_lock-AF_ROSE" ,
  143. "sk_lock-AF_DECnet", "sk_lock-AF_NETBEUI" , "sk_lock-AF_SECURITY" ,
  144. "sk_lock-AF_KEY" , "sk_lock-AF_NETLINK" , "sk_lock-AF_PACKET" ,
  145. "sk_lock-AF_ASH" , "sk_lock-AF_ECONET" , "sk_lock-AF_ATMSVC" ,
  146. "sk_lock-21" , "sk_lock-AF_SNA" , "sk_lock-AF_IRDA" ,
  147. "sk_lock-AF_PPPOX" , "sk_lock-AF_WANPIPE" , "sk_lock-AF_LLC" ,
  148. "sk_lock-27" , "sk_lock-28" , "sk_lock-AF_CAN" ,
  149. "sk_lock-AF_TIPC" , "sk_lock-AF_BLUETOOTH", "sk_lock-IUCV" ,
  150. "sk_lock-AF_RXRPC" , "sk_lock-AF_MAX"
  151. };
  152. static const char *af_family_slock_key_strings[AF_MAX+1] = {
  153. "slock-AF_UNSPEC", "slock-AF_UNIX" , "slock-AF_INET" ,
  154. "slock-AF_AX25" , "slock-AF_IPX" , "slock-AF_APPLETALK",
  155. "slock-AF_NETROM", "slock-AF_BRIDGE" , "slock-AF_ATMPVC" ,
  156. "slock-AF_X25" , "slock-AF_INET6" , "slock-AF_ROSE" ,
  157. "slock-AF_DECnet", "slock-AF_NETBEUI" , "slock-AF_SECURITY" ,
  158. "slock-AF_KEY" , "slock-AF_NETLINK" , "slock-AF_PACKET" ,
  159. "slock-AF_ASH" , "slock-AF_ECONET" , "slock-AF_ATMSVC" ,
  160. "slock-21" , "slock-AF_SNA" , "slock-AF_IRDA" ,
  161. "slock-AF_PPPOX" , "slock-AF_WANPIPE" , "slock-AF_LLC" ,
  162. "slock-27" , "slock-28" , "slock-AF_CAN" ,
  163. "slock-AF_TIPC" , "slock-AF_BLUETOOTH", "slock-AF_IUCV" ,
  164. "slock-AF_RXRPC" , "slock-AF_MAX"
  165. };
  166. static const char *af_family_clock_key_strings[AF_MAX+1] = {
  167. "clock-AF_UNSPEC", "clock-AF_UNIX" , "clock-AF_INET" ,
  168. "clock-AF_AX25" , "clock-AF_IPX" , "clock-AF_APPLETALK",
  169. "clock-AF_NETROM", "clock-AF_BRIDGE" , "clock-AF_ATMPVC" ,
  170. "clock-AF_X25" , "clock-AF_INET6" , "clock-AF_ROSE" ,
  171. "clock-AF_DECnet", "clock-AF_NETBEUI" , "clock-AF_SECURITY" ,
  172. "clock-AF_KEY" , "clock-AF_NETLINK" , "clock-AF_PACKET" ,
  173. "clock-AF_ASH" , "clock-AF_ECONET" , "clock-AF_ATMSVC" ,
  174. "clock-21" , "clock-AF_SNA" , "clock-AF_IRDA" ,
  175. "clock-AF_PPPOX" , "clock-AF_WANPIPE" , "clock-AF_LLC" ,
  176. "clock-27" , "clock-28" , "clock-AF_CAN" ,
  177. "clock-AF_TIPC" , "clock-AF_BLUETOOTH", "clock-AF_IUCV" ,
  178. "clock-AF_RXRPC" , "clock-AF_MAX"
  179. };
  180. #endif
  181. /*
  182. * sk_callback_lock locking rules are per-address-family,
  183. * so split the lock classes by using a per-AF key:
  184. */
  185. static struct lock_class_key af_callback_keys[AF_MAX];
  186. /* Take into consideration the size of the struct sk_buff overhead in the
  187. * determination of these values, since that is non-constant across
  188. * platforms. This makes socket queueing behavior and performance
  189. * not depend upon such differences.
  190. */
  191. #define _SK_MEM_PACKETS 256
  192. #define _SK_MEM_OVERHEAD (sizeof(struct sk_buff) + 256)
  193. #define SK_WMEM_MAX (_SK_MEM_OVERHEAD * _SK_MEM_PACKETS)
  194. #define SK_RMEM_MAX (_SK_MEM_OVERHEAD * _SK_MEM_PACKETS)
  195. /* Run time adjustable parameters. */
  196. __u32 sysctl_wmem_max __read_mostly = SK_WMEM_MAX;
  197. __u32 sysctl_rmem_max __read_mostly = SK_RMEM_MAX;
  198. __u32 sysctl_wmem_default __read_mostly = SK_WMEM_MAX;
  199. __u32 sysctl_rmem_default __read_mostly = SK_RMEM_MAX;
  200. /* Maximal space eaten by iovec or ancilliary data plus some space */
  201. int sysctl_optmem_max __read_mostly = sizeof(unsigned long)*(2*UIO_MAXIOV+512);
  202. static int sock_set_timeout(long *timeo_p, char __user *optval, int optlen)
  203. {
  204. struct timeval tv;
  205. if (optlen < sizeof(tv))
  206. return -EINVAL;
  207. if (copy_from_user(&tv, optval, sizeof(tv)))
  208. return -EFAULT;
  209. if (tv.tv_usec < 0 || tv.tv_usec >= USEC_PER_SEC)
  210. return -EDOM;
  211. if (tv.tv_sec < 0) {
  212. static int warned __read_mostly;
  213. *timeo_p = 0;
  214. if (warned < 10 && net_ratelimit()) {
  215. warned++;
  216. printk(KERN_INFO "sock_set_timeout: `%s' (pid %d) "
  217. "tries to set negative timeout\n",
  218. current->comm, task_pid_nr(current));
  219. }
  220. return 0;
  221. }
  222. *timeo_p = MAX_SCHEDULE_TIMEOUT;
  223. if (tv.tv_sec == 0 && tv.tv_usec == 0)
  224. return 0;
  225. if (tv.tv_sec < (MAX_SCHEDULE_TIMEOUT/HZ - 1))
  226. *timeo_p = tv.tv_sec*HZ + (tv.tv_usec+(1000000/HZ-1))/(1000000/HZ);
  227. return 0;
  228. }
  229. static void sock_warn_obsolete_bsdism(const char *name)
  230. {
  231. static int warned;
  232. static char warncomm[TASK_COMM_LEN];
  233. if (strcmp(warncomm, current->comm) && warned < 5) {
  234. strcpy(warncomm, current->comm);
  235. printk(KERN_WARNING "process `%s' is using obsolete "
  236. "%s SO_BSDCOMPAT\n", warncomm, name);
  237. warned++;
  238. }
  239. }
  240. static void sock_disable_timestamp(struct sock *sk)
  241. {
  242. if (sock_flag(sk, SOCK_TIMESTAMP)) {
  243. sock_reset_flag(sk, SOCK_TIMESTAMP);
  244. net_disable_timestamp();
  245. }
  246. }
  247. int sock_queue_rcv_skb(struct sock *sk, struct sk_buff *skb)
  248. {
  249. int err = 0;
  250. int skb_len;
  251. /* Cast sk->rcvbuf to unsigned... It's pointless, but reduces
  252. number of warnings when compiling with -W --ANK
  253. */
  254. if (atomic_read(&sk->sk_rmem_alloc) + skb->truesize >=
  255. (unsigned)sk->sk_rcvbuf) {
  256. err = -ENOMEM;
  257. goto out;
  258. }
  259. err = sk_filter(sk, skb);
  260. if (err)
  261. goto out;
  262. if (!sk_rmem_schedule(sk, skb->truesize)) {
  263. err = -ENOBUFS;
  264. goto out;
  265. }
  266. skb->dev = NULL;
  267. skb_set_owner_r(skb, sk);
  268. /* Cache the SKB length before we tack it onto the receive
  269. * queue. Once it is added it no longer belongs to us and
  270. * may be freed by other threads of control pulling packets
  271. * from the queue.
  272. */
  273. skb_len = skb->len;
  274. skb_queue_tail(&sk->sk_receive_queue, skb);
  275. if (!sock_flag(sk, SOCK_DEAD))
  276. sk->sk_data_ready(sk, skb_len);
  277. out:
  278. return err;
  279. }
  280. EXPORT_SYMBOL(sock_queue_rcv_skb);
  281. int sk_receive_skb(struct sock *sk, struct sk_buff *skb, const int nested)
  282. {
  283. int rc = NET_RX_SUCCESS;
  284. if (sk_filter(sk, skb))
  285. goto discard_and_relse;
  286. skb->dev = NULL;
  287. if (nested)
  288. bh_lock_sock_nested(sk);
  289. else
  290. bh_lock_sock(sk);
  291. if (!sock_owned_by_user(sk)) {
  292. /*
  293. * trylock + unlock semantics:
  294. */
  295. mutex_acquire(&sk->sk_lock.dep_map, 0, 1, _RET_IP_);
  296. rc = sk->sk_backlog_rcv(sk, skb);
  297. mutex_release(&sk->sk_lock.dep_map, 1, _RET_IP_);
  298. } else
  299. sk_add_backlog(sk, skb);
  300. bh_unlock_sock(sk);
  301. out:
  302. sock_put(sk);
  303. return rc;
  304. discard_and_relse:
  305. kfree_skb(skb);
  306. goto out;
  307. }
  308. EXPORT_SYMBOL(sk_receive_skb);
  309. struct dst_entry *__sk_dst_check(struct sock *sk, u32 cookie)
  310. {
  311. struct dst_entry *dst = sk->sk_dst_cache;
  312. if (dst && dst->obsolete && dst->ops->check(dst, cookie) == NULL) {
  313. sk->sk_dst_cache = NULL;
  314. dst_release(dst);
  315. return NULL;
  316. }
  317. return dst;
  318. }
  319. EXPORT_SYMBOL(__sk_dst_check);
  320. struct dst_entry *sk_dst_check(struct sock *sk, u32 cookie)
  321. {
  322. struct dst_entry *dst = sk_dst_get(sk);
  323. if (dst && dst->obsolete && dst->ops->check(dst, cookie) == NULL) {
  324. sk_dst_reset(sk);
  325. dst_release(dst);
  326. return NULL;
  327. }
  328. return dst;
  329. }
  330. EXPORT_SYMBOL(sk_dst_check);
  331. static int sock_bindtodevice(struct sock *sk, char __user *optval, int optlen)
  332. {
  333. int ret = -ENOPROTOOPT;
  334. #ifdef CONFIG_NETDEVICES
  335. struct net *net = sock_net(sk);
  336. char devname[IFNAMSIZ];
  337. int index;
  338. /* Sorry... */
  339. ret = -EPERM;
  340. if (!capable(CAP_NET_RAW))
  341. goto out;
  342. ret = -EINVAL;
  343. if (optlen < 0)
  344. goto out;
  345. /* Bind this socket to a particular device like "eth0",
  346. * as specified in the passed interface name. If the
  347. * name is "" or the option length is zero the socket
  348. * is not bound.
  349. */
  350. if (optlen > IFNAMSIZ - 1)
  351. optlen = IFNAMSIZ - 1;
  352. memset(devname, 0, sizeof(devname));
  353. ret = -EFAULT;
  354. if (copy_from_user(devname, optval, optlen))
  355. goto out;
  356. if (devname[0] == '\0') {
  357. index = 0;
  358. } else {
  359. struct net_device *dev = dev_get_by_name(net, devname);
  360. ret = -ENODEV;
  361. if (!dev)
  362. goto out;
  363. index = dev->ifindex;
  364. dev_put(dev);
  365. }
  366. lock_sock(sk);
  367. sk->sk_bound_dev_if = index;
  368. sk_dst_reset(sk);
  369. release_sock(sk);
  370. ret = 0;
  371. out:
  372. #endif
  373. return ret;
  374. }
  375. static inline void sock_valbool_flag(struct sock *sk, int bit, int valbool)
  376. {
  377. if (valbool)
  378. sock_set_flag(sk, bit);
  379. else
  380. sock_reset_flag(sk, bit);
  381. }
  382. /*
  383. * This is meant for all protocols to use and covers goings on
  384. * at the socket level. Everything here is generic.
  385. */
  386. int sock_setsockopt(struct socket *sock, int level, int optname,
  387. char __user *optval, int optlen)
  388. {
  389. struct sock *sk=sock->sk;
  390. int val;
  391. int valbool;
  392. struct linger ling;
  393. int ret = 0;
  394. /*
  395. * Options without arguments
  396. */
  397. if (optname == SO_BINDTODEVICE)
  398. return sock_bindtodevice(sk, optval, optlen);
  399. if (optlen < sizeof(int))
  400. return -EINVAL;
  401. if (get_user(val, (int __user *)optval))
  402. return -EFAULT;
  403. valbool = val?1:0;
  404. lock_sock(sk);
  405. switch(optname) {
  406. case SO_DEBUG:
  407. if (val && !capable(CAP_NET_ADMIN)) {
  408. ret = -EACCES;
  409. } else
  410. sock_valbool_flag(sk, SOCK_DBG, valbool);
  411. break;
  412. case SO_REUSEADDR:
  413. sk->sk_reuse = valbool;
  414. break;
  415. case SO_TYPE:
  416. case SO_ERROR:
  417. ret = -ENOPROTOOPT;
  418. break;
  419. case SO_DONTROUTE:
  420. sock_valbool_flag(sk, SOCK_LOCALROUTE, valbool);
  421. break;
  422. case SO_BROADCAST:
  423. sock_valbool_flag(sk, SOCK_BROADCAST, valbool);
  424. break;
  425. case SO_SNDBUF:
  426. /* Don't error on this BSD doesn't and if you think
  427. about it this is right. Otherwise apps have to
  428. play 'guess the biggest size' games. RCVBUF/SNDBUF
  429. are treated in BSD as hints */
  430. if (val > sysctl_wmem_max)
  431. val = sysctl_wmem_max;
  432. set_sndbuf:
  433. sk->sk_userlocks |= SOCK_SNDBUF_LOCK;
  434. if ((val * 2) < SOCK_MIN_SNDBUF)
  435. sk->sk_sndbuf = SOCK_MIN_SNDBUF;
  436. else
  437. sk->sk_sndbuf = val * 2;
  438. /*
  439. * Wake up sending tasks if we
  440. * upped the value.
  441. */
  442. sk->sk_write_space(sk);
  443. break;
  444. case SO_SNDBUFFORCE:
  445. if (!capable(CAP_NET_ADMIN)) {
  446. ret = -EPERM;
  447. break;
  448. }
  449. goto set_sndbuf;
  450. case SO_RCVBUF:
  451. /* Don't error on this BSD doesn't and if you think
  452. about it this is right. Otherwise apps have to
  453. play 'guess the biggest size' games. RCVBUF/SNDBUF
  454. are treated in BSD as hints */
  455. if (val > sysctl_rmem_max)
  456. val = sysctl_rmem_max;
  457. set_rcvbuf:
  458. sk->sk_userlocks |= SOCK_RCVBUF_LOCK;
  459. /*
  460. * We double it on the way in to account for
  461. * "struct sk_buff" etc. overhead. Applications
  462. * assume that the SO_RCVBUF setting they make will
  463. * allow that much actual data to be received on that
  464. * socket.
  465. *
  466. * Applications are unaware that "struct sk_buff" and
  467. * other overheads allocate from the receive buffer
  468. * during socket buffer allocation.
  469. *
  470. * And after considering the possible alternatives,
  471. * returning the value we actually used in getsockopt
  472. * is the most desirable behavior.
  473. */
  474. if ((val * 2) < SOCK_MIN_RCVBUF)
  475. sk->sk_rcvbuf = SOCK_MIN_RCVBUF;
  476. else
  477. sk->sk_rcvbuf = val * 2;
  478. break;
  479. case SO_RCVBUFFORCE:
  480. if (!capable(CAP_NET_ADMIN)) {
  481. ret = -EPERM;
  482. break;
  483. }
  484. goto set_rcvbuf;
  485. case SO_KEEPALIVE:
  486. #ifdef CONFIG_INET
  487. if (sk->sk_protocol == IPPROTO_TCP)
  488. tcp_set_keepalive(sk, valbool);
  489. #endif
  490. sock_valbool_flag(sk, SOCK_KEEPOPEN, valbool);
  491. break;
  492. case SO_OOBINLINE:
  493. sock_valbool_flag(sk, SOCK_URGINLINE, valbool);
  494. break;
  495. case SO_NO_CHECK:
  496. sk->sk_no_check = valbool;
  497. break;
  498. case SO_PRIORITY:
  499. if ((val >= 0 && val <= 6) || capable(CAP_NET_ADMIN))
  500. sk->sk_priority = val;
  501. else
  502. ret = -EPERM;
  503. break;
  504. case SO_LINGER:
  505. if (optlen < sizeof(ling)) {
  506. ret = -EINVAL; /* 1003.1g */
  507. break;
  508. }
  509. if (copy_from_user(&ling,optval,sizeof(ling))) {
  510. ret = -EFAULT;
  511. break;
  512. }
  513. if (!ling.l_onoff)
  514. sock_reset_flag(sk, SOCK_LINGER);
  515. else {
  516. #if (BITS_PER_LONG == 32)
  517. if ((unsigned int)ling.l_linger >= MAX_SCHEDULE_TIMEOUT/HZ)
  518. sk->sk_lingertime = MAX_SCHEDULE_TIMEOUT;
  519. else
  520. #endif
  521. sk->sk_lingertime = (unsigned int)ling.l_linger * HZ;
  522. sock_set_flag(sk, SOCK_LINGER);
  523. }
  524. break;
  525. case SO_BSDCOMPAT:
  526. sock_warn_obsolete_bsdism("setsockopt");
  527. break;
  528. case SO_PASSCRED:
  529. if (valbool)
  530. set_bit(SOCK_PASSCRED, &sock->flags);
  531. else
  532. clear_bit(SOCK_PASSCRED, &sock->flags);
  533. break;
  534. case SO_TIMESTAMP:
  535. case SO_TIMESTAMPNS:
  536. if (valbool) {
  537. if (optname == SO_TIMESTAMP)
  538. sock_reset_flag(sk, SOCK_RCVTSTAMPNS);
  539. else
  540. sock_set_flag(sk, SOCK_RCVTSTAMPNS);
  541. sock_set_flag(sk, SOCK_RCVTSTAMP);
  542. sock_enable_timestamp(sk);
  543. } else {
  544. sock_reset_flag(sk, SOCK_RCVTSTAMP);
  545. sock_reset_flag(sk, SOCK_RCVTSTAMPNS);
  546. }
  547. break;
  548. case SO_RCVLOWAT:
  549. if (val < 0)
  550. val = INT_MAX;
  551. sk->sk_rcvlowat = val ? : 1;
  552. break;
  553. case SO_RCVTIMEO:
  554. ret = sock_set_timeout(&sk->sk_rcvtimeo, optval, optlen);
  555. break;
  556. case SO_SNDTIMEO:
  557. ret = sock_set_timeout(&sk->sk_sndtimeo, optval, optlen);
  558. break;
  559. case SO_ATTACH_FILTER:
  560. ret = -EINVAL;
  561. if (optlen == sizeof(struct sock_fprog)) {
  562. struct sock_fprog fprog;
  563. ret = -EFAULT;
  564. if (copy_from_user(&fprog, optval, sizeof(fprog)))
  565. break;
  566. ret = sk_attach_filter(&fprog, sk);
  567. }
  568. break;
  569. case SO_DETACH_FILTER:
  570. ret = sk_detach_filter(sk);
  571. break;
  572. case SO_PASSSEC:
  573. if (valbool)
  574. set_bit(SOCK_PASSSEC, &sock->flags);
  575. else
  576. clear_bit(SOCK_PASSSEC, &sock->flags);
  577. break;
  578. case SO_MARK:
  579. if (!capable(CAP_NET_ADMIN))
  580. ret = -EPERM;
  581. else {
  582. sk->sk_mark = val;
  583. }
  584. break;
  585. /* We implement the SO_SNDLOWAT etc to
  586. not be settable (1003.1g 5.3) */
  587. default:
  588. ret = -ENOPROTOOPT;
  589. break;
  590. }
  591. release_sock(sk);
  592. return ret;
  593. }
  594. int sock_getsockopt(struct socket *sock, int level, int optname,
  595. char __user *optval, int __user *optlen)
  596. {
  597. struct sock *sk = sock->sk;
  598. union {
  599. int val;
  600. struct linger ling;
  601. struct timeval tm;
  602. } v;
  603. unsigned int lv = sizeof(int);
  604. int len;
  605. if (get_user(len, optlen))
  606. return -EFAULT;
  607. if (len < 0)
  608. return -EINVAL;
  609. switch(optname) {
  610. case SO_DEBUG:
  611. v.val = sock_flag(sk, SOCK_DBG);
  612. break;
  613. case SO_DONTROUTE:
  614. v.val = sock_flag(sk, SOCK_LOCALROUTE);
  615. break;
  616. case SO_BROADCAST:
  617. v.val = !!sock_flag(sk, SOCK_BROADCAST);
  618. break;
  619. case SO_SNDBUF:
  620. v.val = sk->sk_sndbuf;
  621. break;
  622. case SO_RCVBUF:
  623. v.val = sk->sk_rcvbuf;
  624. break;
  625. case SO_REUSEADDR:
  626. v.val = sk->sk_reuse;
  627. break;
  628. case SO_KEEPALIVE:
  629. v.val = !!sock_flag(sk, SOCK_KEEPOPEN);
  630. break;
  631. case SO_TYPE:
  632. v.val = sk->sk_type;
  633. break;
  634. case SO_ERROR:
  635. v.val = -sock_error(sk);
  636. if (v.val==0)
  637. v.val = xchg(&sk->sk_err_soft, 0);
  638. break;
  639. case SO_OOBINLINE:
  640. v.val = !!sock_flag(sk, SOCK_URGINLINE);
  641. break;
  642. case SO_NO_CHECK:
  643. v.val = sk->sk_no_check;
  644. break;
  645. case SO_PRIORITY:
  646. v.val = sk->sk_priority;
  647. break;
  648. case SO_LINGER:
  649. lv = sizeof(v.ling);
  650. v.ling.l_onoff = !!sock_flag(sk, SOCK_LINGER);
  651. v.ling.l_linger = sk->sk_lingertime / HZ;
  652. break;
  653. case SO_BSDCOMPAT:
  654. sock_warn_obsolete_bsdism("getsockopt");
  655. break;
  656. case SO_TIMESTAMP:
  657. v.val = sock_flag(sk, SOCK_RCVTSTAMP) &&
  658. !sock_flag(sk, SOCK_RCVTSTAMPNS);
  659. break;
  660. case SO_TIMESTAMPNS:
  661. v.val = sock_flag(sk, SOCK_RCVTSTAMPNS);
  662. break;
  663. case SO_RCVTIMEO:
  664. lv=sizeof(struct timeval);
  665. if (sk->sk_rcvtimeo == MAX_SCHEDULE_TIMEOUT) {
  666. v.tm.tv_sec = 0;
  667. v.tm.tv_usec = 0;
  668. } else {
  669. v.tm.tv_sec = sk->sk_rcvtimeo / HZ;
  670. v.tm.tv_usec = ((sk->sk_rcvtimeo % HZ) * 1000000) / HZ;
  671. }
  672. break;
  673. case SO_SNDTIMEO:
  674. lv=sizeof(struct timeval);
  675. if (sk->sk_sndtimeo == MAX_SCHEDULE_TIMEOUT) {
  676. v.tm.tv_sec = 0;
  677. v.tm.tv_usec = 0;
  678. } else {
  679. v.tm.tv_sec = sk->sk_sndtimeo / HZ;
  680. v.tm.tv_usec = ((sk->sk_sndtimeo % HZ) * 1000000) / HZ;
  681. }
  682. break;
  683. case SO_RCVLOWAT:
  684. v.val = sk->sk_rcvlowat;
  685. break;
  686. case SO_SNDLOWAT:
  687. v.val=1;
  688. break;
  689. case SO_PASSCRED:
  690. v.val = test_bit(SOCK_PASSCRED, &sock->flags) ? 1 : 0;
  691. break;
  692. case SO_PEERCRED:
  693. if (len > sizeof(sk->sk_peercred))
  694. len = sizeof(sk->sk_peercred);
  695. if (copy_to_user(optval, &sk->sk_peercred, len))
  696. return -EFAULT;
  697. goto lenout;
  698. case SO_PEERNAME:
  699. {
  700. char address[128];
  701. if (sock->ops->getname(sock, (struct sockaddr *)address, &lv, 2))
  702. return -ENOTCONN;
  703. if (lv < len)
  704. return -EINVAL;
  705. if (copy_to_user(optval, address, len))
  706. return -EFAULT;
  707. goto lenout;
  708. }
  709. /* Dubious BSD thing... Probably nobody even uses it, but
  710. * the UNIX standard wants it for whatever reason... -DaveM
  711. */
  712. case SO_ACCEPTCONN:
  713. v.val = sk->sk_state == TCP_LISTEN;
  714. break;
  715. case SO_PASSSEC:
  716. v.val = test_bit(SOCK_PASSSEC, &sock->flags) ? 1 : 0;
  717. break;
  718. case SO_PEERSEC:
  719. return security_socket_getpeersec_stream(sock, optval, optlen, len);
  720. case SO_MARK:
  721. v.val = sk->sk_mark;
  722. break;
  723. default:
  724. return -ENOPROTOOPT;
  725. }
  726. if (len > lv)
  727. len = lv;
  728. if (copy_to_user(optval, &v, len))
  729. return -EFAULT;
  730. lenout:
  731. if (put_user(len, optlen))
  732. return -EFAULT;
  733. return 0;
  734. }
  735. /*
  736. * Initialize an sk_lock.
  737. *
  738. * (We also register the sk_lock with the lock validator.)
  739. */
  740. static inline void sock_lock_init(struct sock *sk)
  741. {
  742. sock_lock_init_class_and_name(sk,
  743. af_family_slock_key_strings[sk->sk_family],
  744. af_family_slock_keys + sk->sk_family,
  745. af_family_key_strings[sk->sk_family],
  746. af_family_keys + sk->sk_family);
  747. }
  748. static void sock_copy(struct sock *nsk, const struct sock *osk)
  749. {
  750. #ifdef CONFIG_SECURITY_NETWORK
  751. void *sptr = nsk->sk_security;
  752. #endif
  753. memcpy(nsk, osk, osk->sk_prot->obj_size);
  754. #ifdef CONFIG_SECURITY_NETWORK
  755. nsk->sk_security = sptr;
  756. security_sk_clone(osk, nsk);
  757. #endif
  758. }
  759. static struct sock *sk_prot_alloc(struct proto *prot, gfp_t priority,
  760. int family)
  761. {
  762. struct sock *sk;
  763. struct kmem_cache *slab;
  764. slab = prot->slab;
  765. if (slab != NULL)
  766. sk = kmem_cache_alloc(slab, priority);
  767. else
  768. sk = kmalloc(prot->obj_size, priority);
  769. if (sk != NULL) {
  770. if (security_sk_alloc(sk, family, priority))
  771. goto out_free;
  772. if (!try_module_get(prot->owner))
  773. goto out_free_sec;
  774. }
  775. return sk;
  776. out_free_sec:
  777. security_sk_free(sk);
  778. out_free:
  779. if (slab != NULL)
  780. kmem_cache_free(slab, sk);
  781. else
  782. kfree(sk);
  783. return NULL;
  784. }
  785. static void sk_prot_free(struct proto *prot, struct sock *sk)
  786. {
  787. struct kmem_cache *slab;
  788. struct module *owner;
  789. owner = prot->owner;
  790. slab = prot->slab;
  791. security_sk_free(sk);
  792. if (slab != NULL)
  793. kmem_cache_free(slab, sk);
  794. else
  795. kfree(sk);
  796. module_put(owner);
  797. }
  798. /**
  799. * sk_alloc - All socket objects are allocated here
  800. * @net: the applicable net namespace
  801. * @family: protocol family
  802. * @priority: for allocation (%GFP_KERNEL, %GFP_ATOMIC, etc)
  803. * @prot: struct proto associated with this new sock instance
  804. */
  805. struct sock *sk_alloc(struct net *net, int family, gfp_t priority,
  806. struct proto *prot)
  807. {
  808. struct sock *sk;
  809. sk = sk_prot_alloc(prot, priority | __GFP_ZERO, family);
  810. if (sk) {
  811. sk->sk_family = family;
  812. /*
  813. * See comment in struct sock definition to understand
  814. * why we need sk_prot_creator -acme
  815. */
  816. sk->sk_prot = sk->sk_prot_creator = prot;
  817. sock_lock_init(sk);
  818. sock_net_set(sk, get_net(net));
  819. }
  820. return sk;
  821. }
  822. void sk_free(struct sock *sk)
  823. {
  824. struct sk_filter *filter;
  825. if (sk->sk_destruct)
  826. sk->sk_destruct(sk);
  827. filter = rcu_dereference(sk->sk_filter);
  828. if (filter) {
  829. sk_filter_uncharge(sk, filter);
  830. rcu_assign_pointer(sk->sk_filter, NULL);
  831. }
  832. sock_disable_timestamp(sk);
  833. if (atomic_read(&sk->sk_omem_alloc))
  834. printk(KERN_DEBUG "%s: optmem leakage (%d bytes) detected.\n",
  835. __func__, atomic_read(&sk->sk_omem_alloc));
  836. put_net(sock_net(sk));
  837. sk_prot_free(sk->sk_prot_creator, sk);
  838. }
  839. /*
  840. * Last sock_put should drop referrence to sk->sk_net. It has already
  841. * been dropped in sk_change_net. Taking referrence to stopping namespace
  842. * is not an option.
  843. * Take referrence to a socket to remove it from hash _alive_ and after that
  844. * destroy it in the context of init_net.
  845. */
  846. void sk_release_kernel(struct sock *sk)
  847. {
  848. if (sk == NULL || sk->sk_socket == NULL)
  849. return;
  850. sock_hold(sk);
  851. sock_release(sk->sk_socket);
  852. release_net(sock_net(sk));
  853. sock_net_set(sk, get_net(&init_net));
  854. sock_put(sk);
  855. }
  856. EXPORT_SYMBOL(sk_release_kernel);
  857. struct sock *sk_clone(const struct sock *sk, const gfp_t priority)
  858. {
  859. struct sock *newsk;
  860. newsk = sk_prot_alloc(sk->sk_prot, priority, sk->sk_family);
  861. if (newsk != NULL) {
  862. struct sk_filter *filter;
  863. sock_copy(newsk, sk);
  864. /* SANITY */
  865. get_net(sock_net(newsk));
  866. sk_node_init(&newsk->sk_node);
  867. sock_lock_init(newsk);
  868. bh_lock_sock(newsk);
  869. newsk->sk_backlog.head = newsk->sk_backlog.tail = NULL;
  870. atomic_set(&newsk->sk_rmem_alloc, 0);
  871. atomic_set(&newsk->sk_wmem_alloc, 0);
  872. atomic_set(&newsk->sk_omem_alloc, 0);
  873. skb_queue_head_init(&newsk->sk_receive_queue);
  874. skb_queue_head_init(&newsk->sk_write_queue);
  875. #ifdef CONFIG_NET_DMA
  876. skb_queue_head_init(&newsk->sk_async_wait_queue);
  877. #endif
  878. rwlock_init(&newsk->sk_dst_lock);
  879. rwlock_init(&newsk->sk_callback_lock);
  880. lockdep_set_class_and_name(&newsk->sk_callback_lock,
  881. af_callback_keys + newsk->sk_family,
  882. af_family_clock_key_strings[newsk->sk_family]);
  883. newsk->sk_dst_cache = NULL;
  884. newsk->sk_wmem_queued = 0;
  885. newsk->sk_forward_alloc = 0;
  886. newsk->sk_send_head = NULL;
  887. newsk->sk_userlocks = sk->sk_userlocks & ~SOCK_BINDPORT_LOCK;
  888. sock_reset_flag(newsk, SOCK_DONE);
  889. skb_queue_head_init(&newsk->sk_error_queue);
  890. filter = newsk->sk_filter;
  891. if (filter != NULL)
  892. sk_filter_charge(newsk, filter);
  893. if (unlikely(xfrm_sk_clone_policy(newsk))) {
  894. /* It is still raw copy of parent, so invalidate
  895. * destructor and make plain sk_free() */
  896. newsk->sk_destruct = NULL;
  897. sk_free(newsk);
  898. newsk = NULL;
  899. goto out;
  900. }
  901. newsk->sk_err = 0;
  902. newsk->sk_priority = 0;
  903. atomic_set(&newsk->sk_refcnt, 2);
  904. /*
  905. * Increment the counter in the same struct proto as the master
  906. * sock (sk_refcnt_debug_inc uses newsk->sk_prot->socks, that
  907. * is the same as sk->sk_prot->socks, as this field was copied
  908. * with memcpy).
  909. *
  910. * This _changes_ the previous behaviour, where
  911. * tcp_create_openreq_child always was incrementing the
  912. * equivalent to tcp_prot->socks (inet_sock_nr), so this have
  913. * to be taken into account in all callers. -acme
  914. */
  915. sk_refcnt_debug_inc(newsk);
  916. sk_set_socket(newsk, NULL);
  917. newsk->sk_sleep = NULL;
  918. if (newsk->sk_prot->sockets_allocated)
  919. atomic_inc(newsk->sk_prot->sockets_allocated);
  920. }
  921. out:
  922. return newsk;
  923. }
  924. EXPORT_SYMBOL_GPL(sk_clone);
  925. void sk_setup_caps(struct sock *sk, struct dst_entry *dst)
  926. {
  927. __sk_dst_set(sk, dst);
  928. sk->sk_route_caps = dst->dev->features;
  929. if (sk->sk_route_caps & NETIF_F_GSO)
  930. sk->sk_route_caps |= NETIF_F_GSO_SOFTWARE;
  931. if (sk_can_gso(sk)) {
  932. if (dst->header_len) {
  933. sk->sk_route_caps &= ~NETIF_F_GSO_MASK;
  934. } else {
  935. sk->sk_route_caps |= NETIF_F_SG | NETIF_F_HW_CSUM;
  936. sk->sk_gso_max_size = dst->dev->gso_max_size;
  937. }
  938. }
  939. }
  940. EXPORT_SYMBOL_GPL(sk_setup_caps);
  941. void __init sk_init(void)
  942. {
  943. if (num_physpages <= 4096) {
  944. sysctl_wmem_max = 32767;
  945. sysctl_rmem_max = 32767;
  946. sysctl_wmem_default = 32767;
  947. sysctl_rmem_default = 32767;
  948. } else if (num_physpages >= 131072) {
  949. sysctl_wmem_max = 131071;
  950. sysctl_rmem_max = 131071;
  951. }
  952. }
  953. /*
  954. * Simple resource managers for sockets.
  955. */
  956. /*
  957. * Write buffer destructor automatically called from kfree_skb.
  958. */
  959. void sock_wfree(struct sk_buff *skb)
  960. {
  961. struct sock *sk = skb->sk;
  962. /* In case it might be waiting for more memory. */
  963. atomic_sub(skb->truesize, &sk->sk_wmem_alloc);
  964. if (!sock_flag(sk, SOCK_USE_WRITE_QUEUE))
  965. sk->sk_write_space(sk);
  966. sock_put(sk);
  967. }
  968. /*
  969. * Read buffer destructor automatically called from kfree_skb.
  970. */
  971. void sock_rfree(struct sk_buff *skb)
  972. {
  973. struct sock *sk = skb->sk;
  974. skb_truesize_check(skb);
  975. atomic_sub(skb->truesize, &sk->sk_rmem_alloc);
  976. sk_mem_uncharge(skb->sk, skb->truesize);
  977. }
  978. int sock_i_uid(struct sock *sk)
  979. {
  980. int uid;
  981. read_lock(&sk->sk_callback_lock);
  982. uid = sk->sk_socket ? SOCK_INODE(sk->sk_socket)->i_uid : 0;
  983. read_unlock(&sk->sk_callback_lock);
  984. return uid;
  985. }
  986. unsigned long sock_i_ino(struct sock *sk)
  987. {
  988. unsigned long ino;
  989. read_lock(&sk->sk_callback_lock);
  990. ino = sk->sk_socket ? SOCK_INODE(sk->sk_socket)->i_ino : 0;
  991. read_unlock(&sk->sk_callback_lock);
  992. return ino;
  993. }
  994. /*
  995. * Allocate a skb from the socket's send buffer.
  996. */
  997. struct sk_buff *sock_wmalloc(struct sock *sk, unsigned long size, int force,
  998. gfp_t priority)
  999. {
  1000. if (force || atomic_read(&sk->sk_wmem_alloc) < sk->sk_sndbuf) {
  1001. struct sk_buff * skb = alloc_skb(size, priority);
  1002. if (skb) {
  1003. skb_set_owner_w(skb, sk);
  1004. return skb;
  1005. }
  1006. }
  1007. return NULL;
  1008. }
  1009. /*
  1010. * Allocate a skb from the socket's receive buffer.
  1011. */
  1012. struct sk_buff *sock_rmalloc(struct sock *sk, unsigned long size, int force,
  1013. gfp_t priority)
  1014. {
  1015. if (force || atomic_read(&sk->sk_rmem_alloc) < sk->sk_rcvbuf) {
  1016. struct sk_buff *skb = alloc_skb(size, priority);
  1017. if (skb) {
  1018. skb_set_owner_r(skb, sk);
  1019. return skb;
  1020. }
  1021. }
  1022. return NULL;
  1023. }
  1024. /*
  1025. * Allocate a memory block from the socket's option memory buffer.
  1026. */
  1027. void *sock_kmalloc(struct sock *sk, int size, gfp_t priority)
  1028. {
  1029. if ((unsigned)size <= sysctl_optmem_max &&
  1030. atomic_read(&sk->sk_omem_alloc) + size < sysctl_optmem_max) {
  1031. void *mem;
  1032. /* First do the add, to avoid the race if kmalloc
  1033. * might sleep.
  1034. */
  1035. atomic_add(size, &sk->sk_omem_alloc);
  1036. mem = kmalloc(size, priority);
  1037. if (mem)
  1038. return mem;
  1039. atomic_sub(size, &sk->sk_omem_alloc);
  1040. }
  1041. return NULL;
  1042. }
  1043. /*
  1044. * Free an option memory block.
  1045. */
  1046. void sock_kfree_s(struct sock *sk, void *mem, int size)
  1047. {
  1048. kfree(mem);
  1049. atomic_sub(size, &sk->sk_omem_alloc);
  1050. }
  1051. /* It is almost wait_for_tcp_memory minus release_sock/lock_sock.
  1052. I think, these locks should be removed for datagram sockets.
  1053. */
  1054. static long sock_wait_for_wmem(struct sock * sk, long timeo)
  1055. {
  1056. DEFINE_WAIT(wait);
  1057. clear_bit(SOCK_ASYNC_NOSPACE, &sk->sk_socket->flags);
  1058. for (;;) {
  1059. if (!timeo)
  1060. break;
  1061. if (signal_pending(current))
  1062. break;
  1063. set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);
  1064. prepare_to_wait(sk->sk_sleep, &wait, TASK_INTERRUPTIBLE);
  1065. if (atomic_read(&sk->sk_wmem_alloc) < sk->sk_sndbuf)
  1066. break;
  1067. if (sk->sk_shutdown & SEND_SHUTDOWN)
  1068. break;
  1069. if (sk->sk_err)
  1070. break;
  1071. timeo = schedule_timeout(timeo);
  1072. }
  1073. finish_wait(sk->sk_sleep, &wait);
  1074. return timeo;
  1075. }
  1076. /*
  1077. * Generic send/receive buffer handlers
  1078. */
  1079. static struct sk_buff *sock_alloc_send_pskb(struct sock *sk,
  1080. unsigned long header_len,
  1081. unsigned long data_len,
  1082. int noblock, int *errcode)
  1083. {
  1084. struct sk_buff *skb;
  1085. gfp_t gfp_mask;
  1086. long timeo;
  1087. int err;
  1088. gfp_mask = sk->sk_allocation;
  1089. if (gfp_mask & __GFP_WAIT)
  1090. gfp_mask |= __GFP_REPEAT;
  1091. timeo = sock_sndtimeo(sk, noblock);
  1092. while (1) {
  1093. err = sock_error(sk);
  1094. if (err != 0)
  1095. goto failure;
  1096. err = -EPIPE;
  1097. if (sk->sk_shutdown & SEND_SHUTDOWN)
  1098. goto failure;
  1099. if (atomic_read(&sk->sk_wmem_alloc) < sk->sk_sndbuf) {
  1100. skb = alloc_skb(header_len, gfp_mask);
  1101. if (skb) {
  1102. int npages;
  1103. int i;
  1104. /* No pages, we're done... */
  1105. if (!data_len)
  1106. break;
  1107. npages = (data_len + (PAGE_SIZE - 1)) >> PAGE_SHIFT;
  1108. skb->truesize += data_len;
  1109. skb_shinfo(skb)->nr_frags = npages;
  1110. for (i = 0; i < npages; i++) {
  1111. struct page *page;
  1112. skb_frag_t *frag;
  1113. page = alloc_pages(sk->sk_allocation, 0);
  1114. if (!page) {
  1115. err = -ENOBUFS;
  1116. skb_shinfo(skb)->nr_frags = i;
  1117. kfree_skb(skb);
  1118. goto failure;
  1119. }
  1120. frag = &skb_shinfo(skb)->frags[i];
  1121. frag->page = page;
  1122. frag->page_offset = 0;
  1123. frag->size = (data_len >= PAGE_SIZE ?
  1124. PAGE_SIZE :
  1125. data_len);
  1126. data_len -= PAGE_SIZE;
  1127. }
  1128. /* Full success... */
  1129. break;
  1130. }
  1131. err = -ENOBUFS;
  1132. goto failure;
  1133. }
  1134. set_bit(SOCK_ASYNC_NOSPACE, &sk->sk_socket->flags);
  1135. set_bit(SOCK_NOSPACE, &sk->sk_socket->flags);
  1136. err = -EAGAIN;
  1137. if (!timeo)
  1138. goto failure;
  1139. if (signal_pending(current))
  1140. goto interrupted;
  1141. timeo = sock_wait_for_wmem(sk, timeo);
  1142. }
  1143. skb_set_owner_w(skb, sk);
  1144. return skb;
  1145. interrupted:
  1146. err = sock_intr_errno(timeo);
  1147. failure:
  1148. *errcode = err;
  1149. return NULL;
  1150. }
  1151. struct sk_buff *sock_alloc_send_skb(struct sock *sk, unsigned long size,
  1152. int noblock, int *errcode)
  1153. {
  1154. return sock_alloc_send_pskb(sk, size, 0, noblock, errcode);
  1155. }
  1156. static void __lock_sock(struct sock *sk)
  1157. {
  1158. DEFINE_WAIT(wait);
  1159. for (;;) {
  1160. prepare_to_wait_exclusive(&sk->sk_lock.wq, &wait,
  1161. TASK_UNINTERRUPTIBLE);
  1162. spin_unlock_bh(&sk->sk_lock.slock);
  1163. schedule();
  1164. spin_lock_bh(&sk->sk_lock.slock);
  1165. if (!sock_owned_by_user(sk))
  1166. break;
  1167. }
  1168. finish_wait(&sk->sk_lock.wq, &wait);
  1169. }
  1170. static void __release_sock(struct sock *sk)
  1171. {
  1172. struct sk_buff *skb = sk->sk_backlog.head;
  1173. do {
  1174. sk->sk_backlog.head = sk->sk_backlog.tail = NULL;
  1175. bh_unlock_sock(sk);
  1176. do {
  1177. struct sk_buff *next = skb->next;
  1178. skb->next = NULL;
  1179. sk->sk_backlog_rcv(sk, skb);
  1180. /*
  1181. * We are in process context here with softirqs
  1182. * disabled, use cond_resched_softirq() to preempt.
  1183. * This is safe to do because we've taken the backlog
  1184. * queue private:
  1185. */
  1186. cond_resched_softirq();
  1187. skb = next;
  1188. } while (skb != NULL);
  1189. bh_lock_sock(sk);
  1190. } while ((skb = sk->sk_backlog.head) != NULL);
  1191. }
  1192. /**
  1193. * sk_wait_data - wait for data to arrive at sk_receive_queue
  1194. * @sk: sock to wait on
  1195. * @timeo: for how long
  1196. *
  1197. * Now socket state including sk->sk_err is changed only under lock,
  1198. * hence we may omit checks after joining wait queue.
  1199. * We check receive queue before schedule() only as optimization;
  1200. * it is very likely that release_sock() added new data.
  1201. */
  1202. int sk_wait_data(struct sock *sk, long *timeo)
  1203. {
  1204. int rc;
  1205. DEFINE_WAIT(wait);
  1206. prepare_to_wait(sk->sk_sleep, &wait, TASK_INTERRUPTIBLE);
  1207. set_bit(SOCK_ASYNC_WAITDATA, &sk->sk_socket->flags);
  1208. rc = sk_wait_event(sk, timeo, !skb_queue_empty(&sk->sk_receive_queue));
  1209. clear_bit(SOCK_ASYNC_WAITDATA, &sk->sk_socket->flags);
  1210. finish_wait(sk->sk_sleep, &wait);
  1211. return rc;
  1212. }
  1213. EXPORT_SYMBOL(sk_wait_data);
  1214. /**
  1215. * __sk_mem_schedule - increase sk_forward_alloc and memory_allocated
  1216. * @sk: socket
  1217. * @size: memory size to allocate
  1218. * @kind: allocation type
  1219. *
  1220. * If kind is SK_MEM_SEND, it means wmem allocation. Otherwise it means
  1221. * rmem allocation. This function assumes that protocols which have
  1222. * memory_pressure use sk_wmem_queued as write buffer accounting.
  1223. */
  1224. int __sk_mem_schedule(struct sock *sk, int size, int kind)
  1225. {
  1226. struct proto *prot = sk->sk_prot;
  1227. int amt = sk_mem_pages(size);
  1228. int allocated;
  1229. sk->sk_forward_alloc += amt * SK_MEM_QUANTUM;
  1230. allocated = atomic_add_return(amt, prot->memory_allocated);
  1231. /* Under limit. */
  1232. if (allocated <= prot->sysctl_mem[0]) {
  1233. if (prot->memory_pressure && *prot->memory_pressure)
  1234. *prot->memory_pressure = 0;
  1235. return 1;
  1236. }
  1237. /* Under pressure. */
  1238. if (allocated > prot->sysctl_mem[1])
  1239. if (prot->enter_memory_pressure)
  1240. prot->enter_memory_pressure(sk);
  1241. /* Over hard limit. */
  1242. if (allocated > prot->sysctl_mem[2])
  1243. goto suppress_allocation;
  1244. /* guarantee minimum buffer size under pressure */
  1245. if (kind == SK_MEM_RECV) {
  1246. if (atomic_read(&sk->sk_rmem_alloc) < prot->sysctl_rmem[0])
  1247. return 1;
  1248. } else { /* SK_MEM_SEND */
  1249. if (sk->sk_type == SOCK_STREAM) {
  1250. if (sk->sk_wmem_queued < prot->sysctl_wmem[0])
  1251. return 1;
  1252. } else if (atomic_read(&sk->sk_wmem_alloc) <
  1253. prot->sysctl_wmem[0])
  1254. return 1;
  1255. }
  1256. if (prot->memory_pressure) {
  1257. if (!*prot->memory_pressure ||
  1258. prot->sysctl_mem[2] > atomic_read(prot->sockets_allocated) *
  1259. sk_mem_pages(sk->sk_wmem_queued +
  1260. atomic_read(&sk->sk_rmem_alloc) +
  1261. sk->sk_forward_alloc))
  1262. return 1;
  1263. }
  1264. suppress_allocation:
  1265. if (kind == SK_MEM_SEND && sk->sk_type == SOCK_STREAM) {
  1266. sk_stream_moderate_sndbuf(sk);
  1267. /* Fail only if socket is _under_ its sndbuf.
  1268. * In this case we cannot block, so that we have to fail.
  1269. */
  1270. if (sk->sk_wmem_queued + size >= sk->sk_sndbuf)
  1271. return 1;
  1272. }
  1273. /* Alas. Undo changes. */
  1274. sk->sk_forward_alloc -= amt * SK_MEM_QUANTUM;
  1275. atomic_sub(amt, prot->memory_allocated);
  1276. return 0;
  1277. }
  1278. EXPORT_SYMBOL(__sk_mem_schedule);
  1279. /**
  1280. * __sk_reclaim - reclaim memory_allocated
  1281. * @sk: socket
  1282. */
  1283. void __sk_mem_reclaim(struct sock *sk)
  1284. {
  1285. struct proto *prot = sk->sk_prot;
  1286. atomic_sub(sk->sk_forward_alloc >> SK_MEM_QUANTUM_SHIFT,
  1287. prot->memory_allocated);
  1288. sk->sk_forward_alloc &= SK_MEM_QUANTUM - 1;
  1289. if (prot->memory_pressure && *prot->memory_pressure &&
  1290. (atomic_read(prot->memory_allocated) < prot->sysctl_mem[0]))
  1291. *prot->memory_pressure = 0;
  1292. }
  1293. EXPORT_SYMBOL(__sk_mem_reclaim);
  1294. /*
  1295. * Set of default routines for initialising struct proto_ops when
  1296. * the protocol does not support a particular function. In certain
  1297. * cases where it makes no sense for a protocol to have a "do nothing"
  1298. * function, some default processing is provided.
  1299. */
  1300. int sock_no_bind(struct socket *sock, struct sockaddr *saddr, int len)
  1301. {
  1302. return -EOPNOTSUPP;
  1303. }
  1304. int sock_no_connect(struct socket *sock, struct sockaddr *saddr,
  1305. int len, int flags)
  1306. {
  1307. return -EOPNOTSUPP;
  1308. }
  1309. int sock_no_socketpair(struct socket *sock1, struct socket *sock2)
  1310. {
  1311. return -EOPNOTSUPP;
  1312. }
  1313. int sock_no_accept(struct socket *sock, struct socket *newsock, int flags)
  1314. {
  1315. return -EOPNOTSUPP;
  1316. }
  1317. int sock_no_getname(struct socket *sock, struct sockaddr *saddr,
  1318. int *len, int peer)
  1319. {
  1320. return -EOPNOTSUPP;
  1321. }
  1322. unsigned int sock_no_poll(struct file * file, struct socket *sock, poll_table *pt)
  1323. {
  1324. return 0;
  1325. }
  1326. int sock_no_ioctl(struct socket *sock, unsigned int cmd, unsigned long arg)
  1327. {
  1328. return -EOPNOTSUPP;
  1329. }
  1330. int sock_no_listen(struct socket *sock, int backlog)
  1331. {
  1332. return -EOPNOTSUPP;
  1333. }
  1334. int sock_no_shutdown(struct socket *sock, int how)
  1335. {
  1336. return -EOPNOTSUPP;
  1337. }
  1338. int sock_no_setsockopt(struct socket *sock, int level, int optname,
  1339. char __user *optval, int optlen)
  1340. {
  1341. return -EOPNOTSUPP;
  1342. }
  1343. int sock_no_getsockopt(struct socket *sock, int level, int optname,
  1344. char __user *optval, int __user *optlen)
  1345. {
  1346. return -EOPNOTSUPP;
  1347. }
  1348. int sock_no_sendmsg(struct kiocb *iocb, struct socket *sock, struct msghdr *m,
  1349. size_t len)
  1350. {
  1351. return -EOPNOTSUPP;
  1352. }
  1353. int sock_no_recvmsg(struct kiocb *iocb, struct socket *sock, struct msghdr *m,
  1354. size_t len, int flags)
  1355. {
  1356. return -EOPNOTSUPP;
  1357. }
  1358. int sock_no_mmap(struct file *file, struct socket *sock, struct vm_area_struct *vma)
  1359. {
  1360. /* Mirror missing mmap method error code */
  1361. return -ENODEV;
  1362. }
  1363. ssize_t sock_no_sendpage(struct socket *sock, struct page *page, int offset, size_t size, int flags)
  1364. {
  1365. ssize_t res;
  1366. struct msghdr msg = {.msg_flags = flags};
  1367. struct kvec iov;
  1368. char *kaddr = kmap(page);
  1369. iov.iov_base = kaddr + offset;
  1370. iov.iov_len = size;
  1371. res = kernel_sendmsg(sock, &msg, &iov, 1, size);
  1372. kunmap(page);
  1373. return res;
  1374. }
  1375. /*
  1376. * Default Socket Callbacks
  1377. */
  1378. static void sock_def_wakeup(struct sock *sk)
  1379. {
  1380. read_lock(&sk->sk_callback_lock);
  1381. if (sk->sk_sleep && waitqueue_active(sk->sk_sleep))
  1382. wake_up_interruptible_all(sk->sk_sleep);
  1383. read_unlock(&sk->sk_callback_lock);
  1384. }
  1385. static void sock_def_error_report(struct sock *sk)
  1386. {
  1387. read_lock(&sk->sk_callback_lock);
  1388. if (sk->sk_sleep && waitqueue_active(sk->sk_sleep))
  1389. wake_up_interruptible(sk->sk_sleep);
  1390. sk_wake_async(sk, SOCK_WAKE_IO, POLL_ERR);
  1391. read_unlock(&sk->sk_callback_lock);
  1392. }
  1393. static void sock_def_readable(struct sock *sk, int len)
  1394. {
  1395. read_lock(&sk->sk_callback_lock);
  1396. if (sk->sk_sleep && waitqueue_active(sk->sk_sleep))
  1397. wake_up_interruptible_sync(sk->sk_sleep);
  1398. sk_wake_async(sk, SOCK_WAKE_WAITD, POLL_IN);
  1399. read_unlock(&sk->sk_callback_lock);
  1400. }
  1401. static void sock_def_write_space(struct sock *sk)
  1402. {
  1403. read_lock(&sk->sk_callback_lock);
  1404. /* Do not wake up a writer until he can make "significant"
  1405. * progress. --DaveM
  1406. */
  1407. if ((atomic_read(&sk->sk_wmem_alloc) << 1) <= sk->sk_sndbuf) {
  1408. if (sk->sk_sleep && waitqueue_active(sk->sk_sleep))
  1409. wake_up_interruptible_sync(sk->sk_sleep);
  1410. /* Should agree with poll, otherwise some programs break */
  1411. if (sock_writeable(sk))
  1412. sk_wake_async(sk, SOCK_WAKE_SPACE, POLL_OUT);
  1413. }
  1414. read_unlock(&sk->sk_callback_lock);
  1415. }
  1416. static void sock_def_destruct(struct sock *sk)
  1417. {
  1418. kfree(sk->sk_protinfo);
  1419. }
  1420. void sk_send_sigurg(struct sock *sk)
  1421. {
  1422. if (sk->sk_socket && sk->sk_socket->file)
  1423. if (send_sigurg(&sk->sk_socket->file->f_owner))
  1424. sk_wake_async(sk, SOCK_WAKE_URG, POLL_PRI);
  1425. }
  1426. void sk_reset_timer(struct sock *sk, struct timer_list* timer,
  1427. unsigned long expires)
  1428. {
  1429. if (!mod_timer(timer, expires))
  1430. sock_hold(sk);
  1431. }
  1432. EXPORT_SYMBOL(sk_reset_timer);
  1433. void sk_stop_timer(struct sock *sk, struct timer_list* timer)
  1434. {
  1435. if (timer_pending(timer) && del_timer(timer))
  1436. __sock_put(sk);
  1437. }
  1438. EXPORT_SYMBOL(sk_stop_timer);
  1439. void sock_init_data(struct socket *sock, struct sock *sk)
  1440. {
  1441. skb_queue_head_init(&sk->sk_receive_queue);
  1442. skb_queue_head_init(&sk->sk_write_queue);
  1443. skb_queue_head_init(&sk->sk_error_queue);
  1444. #ifdef CONFIG_NET_DMA
  1445. skb_queue_head_init(&sk->sk_async_wait_queue);
  1446. #endif
  1447. sk->sk_send_head = NULL;
  1448. init_timer(&sk->sk_timer);
  1449. sk->sk_allocation = GFP_KERNEL;
  1450. sk->sk_rcvbuf = sysctl_rmem_default;
  1451. sk->sk_sndbuf = sysctl_wmem_default;
  1452. sk->sk_state = TCP_CLOSE;
  1453. sk_set_socket(sk, sock);
  1454. sock_set_flag(sk, SOCK_ZAPPED);
  1455. if (sock) {
  1456. sk->sk_type = sock->type;
  1457. sk->sk_sleep = &sock->wait;
  1458. sock->sk = sk;
  1459. } else
  1460. sk->sk_sleep = NULL;
  1461. rwlock_init(&sk->sk_dst_lock);
  1462. rwlock_init(&sk->sk_callback_lock);
  1463. lockdep_set_class_and_name(&sk->sk_callback_lock,
  1464. af_callback_keys + sk->sk_family,
  1465. af_family_clock_key_strings[sk->sk_family]);
  1466. sk->sk_state_change = sock_def_wakeup;
  1467. sk->sk_data_ready = sock_def_readable;
  1468. sk->sk_write_space = sock_def_write_space;
  1469. sk->sk_error_report = sock_def_error_report;
  1470. sk->sk_destruct = sock_def_destruct;
  1471. sk->sk_sndmsg_page = NULL;
  1472. sk->sk_sndmsg_off = 0;
  1473. sk->sk_peercred.pid = 0;
  1474. sk->sk_peercred.uid = -1;
  1475. sk->sk_peercred.gid = -1;
  1476. sk->sk_write_pending = 0;
  1477. sk->sk_rcvlowat = 1;
  1478. sk->sk_rcvtimeo = MAX_SCHEDULE_TIMEOUT;
  1479. sk->sk_sndtimeo = MAX_SCHEDULE_TIMEOUT;
  1480. sk->sk_stamp = ktime_set(-1L, 0);
  1481. atomic_set(&sk->sk_refcnt, 1);
  1482. atomic_set(&sk->sk_drops, 0);
  1483. }
  1484. void lock_sock_nested(struct sock *sk, int subclass)
  1485. {
  1486. might_sleep();
  1487. spin_lock_bh(&sk->sk_lock.slock);
  1488. if (sk->sk_lock.owned)
  1489. __lock_sock(sk);
  1490. sk->sk_lock.owned = 1;
  1491. spin_unlock(&sk->sk_lock.slock);
  1492. /*
  1493. * The sk_lock has mutex_lock() semantics here:
  1494. */
  1495. mutex_acquire(&sk->sk_lock.dep_map, subclass, 0, _RET_IP_);
  1496. local_bh_enable();
  1497. }
  1498. EXPORT_SYMBOL(lock_sock_nested);
  1499. void release_sock(struct sock *sk)
  1500. {
  1501. /*
  1502. * The sk_lock has mutex_unlock() semantics:
  1503. */
  1504. mutex_release(&sk->sk_lock.dep_map, 1, _RET_IP_);
  1505. spin_lock_bh(&sk->sk_lock.slock);
  1506. if (sk->sk_backlog.tail)
  1507. __release_sock(sk);
  1508. sk->sk_lock.owned = 0;
  1509. if (waitqueue_active(&sk->sk_lock.wq))
  1510. wake_up(&sk->sk_lock.wq);
  1511. spin_unlock_bh(&sk->sk_lock.slock);
  1512. }
  1513. EXPORT_SYMBOL(release_sock);
  1514. int sock_get_timestamp(struct sock *sk, struct timeval __user *userstamp)
  1515. {
  1516. struct timeval tv;
  1517. if (!sock_flag(sk, SOCK_TIMESTAMP))
  1518. sock_enable_timestamp(sk);
  1519. tv = ktime_to_timeval(sk->sk_stamp);
  1520. if (tv.tv_sec == -1)
  1521. return -ENOENT;
  1522. if (tv.tv_sec == 0) {
  1523. sk->sk_stamp = ktime_get_real();
  1524. tv = ktime_to_timeval(sk->sk_stamp);
  1525. }
  1526. return copy_to_user(userstamp, &tv, sizeof(tv)) ? -EFAULT : 0;
  1527. }
  1528. EXPORT_SYMBOL(sock_get_timestamp);
  1529. int sock_get_timestampns(struct sock *sk, struct timespec __user *userstamp)
  1530. {
  1531. struct timespec ts;
  1532. if (!sock_flag(sk, SOCK_TIMESTAMP))
  1533. sock_enable_timestamp(sk);
  1534. ts = ktime_to_timespec(sk->sk_stamp);
  1535. if (ts.tv_sec == -1)
  1536. return -ENOENT;
  1537. if (ts.tv_sec == 0) {
  1538. sk->sk_stamp = ktime_get_real();
  1539. ts = ktime_to_timespec(sk->sk_stamp);
  1540. }
  1541. return copy_to_user(userstamp, &ts, sizeof(ts)) ? -EFAULT : 0;
  1542. }
  1543. EXPORT_SYMBOL(sock_get_timestampns);
  1544. void sock_enable_timestamp(struct sock *sk)
  1545. {
  1546. if (!sock_flag(sk, SOCK_TIMESTAMP)) {
  1547. sock_set_flag(sk, SOCK_TIMESTAMP);
  1548. net_enable_timestamp();
  1549. }
  1550. }
  1551. /*
  1552. * Get a socket option on an socket.
  1553. *
  1554. * FIX: POSIX 1003.1g is very ambiguous here. It states that
  1555. * asynchronous errors should be reported by getsockopt. We assume
  1556. * this means if you specify SO_ERROR (otherwise whats the point of it).
  1557. */
  1558. int sock_common_getsockopt(struct socket *sock, int level, int optname,
  1559. char __user *optval, int __user *optlen)
  1560. {
  1561. struct sock *sk = sock->sk;
  1562. return sk->sk_prot->getsockopt(sk, level, optname, optval, optlen);
  1563. }
  1564. EXPORT_SYMBOL(sock_common_getsockopt);
  1565. #ifdef CONFIG_COMPAT
  1566. int compat_sock_common_getsockopt(struct socket *sock, int level, int optname,
  1567. char __user *optval, int __user *optlen)
  1568. {
  1569. struct sock *sk = sock->sk;
  1570. if (sk->sk_prot->compat_getsockopt != NULL)
  1571. return sk->sk_prot->compat_getsockopt(sk, level, optname,
  1572. optval, optlen);
  1573. return sk->sk_prot->getsockopt(sk, level, optname, optval, optlen);
  1574. }
  1575. EXPORT_SYMBOL(compat_sock_common_getsockopt);
  1576. #endif
  1577. int sock_common_recvmsg(struct kiocb *iocb, struct socket *sock,
  1578. struct msghdr *msg, size_t size, int flags)
  1579. {
  1580. struct sock *sk = sock->sk;
  1581. int addr_len = 0;
  1582. int err;
  1583. err = sk->sk_prot->recvmsg(iocb, sk, msg, size, flags & MSG_DONTWAIT,
  1584. flags & ~MSG_DONTWAIT, &addr_len);
  1585. if (err >= 0)
  1586. msg->msg_namelen = addr_len;
  1587. return err;
  1588. }
  1589. EXPORT_SYMBOL(sock_common_recvmsg);
  1590. /*
  1591. * Set socket options on an inet socket.
  1592. */
  1593. int sock_common_setsockopt(struct socket *sock, int level, int optname,
  1594. char __user *optval, int optlen)
  1595. {
  1596. struct sock *sk = sock->sk;
  1597. return sk->sk_prot->setsockopt(sk, level, optname, optval, optlen);
  1598. }
  1599. EXPORT_SYMBOL(sock_common_setsockopt);
  1600. #ifdef CONFIG_COMPAT
  1601. int compat_sock_common_setsockopt(struct socket *sock, int level, int optname,
  1602. char __user *optval, int optlen)
  1603. {
  1604. struct sock *sk = sock->sk;
  1605. if (sk->sk_prot->compat_setsockopt != NULL)
  1606. return sk->sk_prot->compat_setsockopt(sk, level, optname,
  1607. optval, optlen);
  1608. return sk->sk_prot->setsockopt(sk, level, optname, optval, optlen);
  1609. }
  1610. EXPORT_SYMBOL(compat_sock_common_setsockopt);
  1611. #endif
  1612. void sk_common_release(struct sock *sk)
  1613. {
  1614. if (sk->sk_prot->destroy)
  1615. sk->sk_prot->destroy(sk);
  1616. /*
  1617. * Observation: when sock_common_release is called, processes have
  1618. * no access to socket. But net still has.
  1619. * Step one, detach it from networking:
  1620. *
  1621. * A. Remove from hash tables.
  1622. */
  1623. sk->sk_prot->unhash(sk);
  1624. /*
  1625. * In this point socket cannot receive new packets, but it is possible
  1626. * that some packets are in flight because some CPU runs receiver and
  1627. * did hash table lookup before we unhashed socket. They will achieve
  1628. * receive queue and will be purged by socket destructor.
  1629. *
  1630. * Also we still have packets pending on receive queue and probably,
  1631. * our own packets waiting in device queues. sock_destroy will drain
  1632. * receive queue, but transmitted packets will delay socket destruction
  1633. * until the last reference will be released.
  1634. */
  1635. sock_orphan(sk);
  1636. xfrm_sk_free_policy(sk);
  1637. sk_refcnt_debug_release(sk);
  1638. sock_put(sk);
  1639. }
  1640. EXPORT_SYMBOL(sk_common_release);
  1641. static DEFINE_RWLOCK(proto_list_lock);
  1642. static LIST_HEAD(proto_list);
  1643. #ifdef CONFIG_PROC_FS
  1644. #define PROTO_INUSE_NR 64 /* should be enough for the first time */
  1645. struct prot_inuse {
  1646. int val[PROTO_INUSE_NR];
  1647. };
  1648. static DECLARE_BITMAP(proto_inuse_idx, PROTO_INUSE_NR);
  1649. #ifdef CONFIG_NET_NS
  1650. void sock_prot_inuse_add(struct net *net, struct proto *prot, int val)
  1651. {
  1652. int cpu = smp_processor_id();
  1653. per_cpu_ptr(net->core.inuse, cpu)->val[prot->inuse_idx] += val;
  1654. }
  1655. EXPORT_SYMBOL_GPL(sock_prot_inuse_add);
  1656. int sock_prot_inuse_get(struct net *net, struct proto *prot)
  1657. {
  1658. int cpu, idx = prot->inuse_idx;
  1659. int res = 0;
  1660. for_each_possible_cpu(cpu)
  1661. res += per_cpu_ptr(net->core.inuse, cpu)->val[idx];
  1662. return res >= 0 ? res : 0;
  1663. }
  1664. EXPORT_SYMBOL_GPL(sock_prot_inuse_get);
  1665. static int sock_inuse_init_net(struct net *net)
  1666. {
  1667. net->core.inuse = alloc_percpu(struct prot_inuse);
  1668. return net->core.inuse ? 0 : -ENOMEM;
  1669. }
  1670. static void sock_inuse_exit_net(struct net *net)
  1671. {
  1672. free_percpu(net->core.inuse);
  1673. }
  1674. static struct pernet_operations net_inuse_ops = {
  1675. .init = sock_inuse_init_net,
  1676. .exit = sock_inuse_exit_net,
  1677. };
  1678. static __init int net_inuse_init(void)
  1679. {
  1680. if (register_pernet_subsys(&net_inuse_ops))
  1681. panic("Cannot initialize net inuse counters");
  1682. return 0;
  1683. }
  1684. core_initcall(net_inuse_init);
  1685. #else
  1686. static DEFINE_PER_CPU(struct prot_inuse, prot_inuse);
  1687. void sock_prot_inuse_add(struct net *net, struct proto *prot, int val)
  1688. {
  1689. __get_cpu_var(prot_inuse).val[prot->inuse_idx] += val;
  1690. }
  1691. EXPORT_SYMBOL_GPL(sock_prot_inuse_add);
  1692. int sock_prot_inuse_get(struct net *net, struct proto *prot)
  1693. {
  1694. int cpu, idx = prot->inuse_idx;
  1695. int res = 0;
  1696. for_each_possible_cpu(cpu)
  1697. res += per_cpu(prot_inuse, cpu).val[idx];
  1698. return res >= 0 ? res : 0;
  1699. }
  1700. EXPORT_SYMBOL_GPL(sock_prot_inuse_get);
  1701. #endif
  1702. static void assign_proto_idx(struct proto *prot)
  1703. {
  1704. prot->inuse_idx = find_first_zero_bit(proto_inuse_idx, PROTO_INUSE_NR);
  1705. if (unlikely(prot->inuse_idx == PROTO_INUSE_NR - 1)) {
  1706. printk(KERN_ERR "PROTO_INUSE_NR exhausted\n");
  1707. return;
  1708. }
  1709. set_bit(prot->inuse_idx, proto_inuse_idx);
  1710. }
  1711. static void release_proto_idx(struct proto *prot)
  1712. {
  1713. if (prot->inuse_idx != PROTO_INUSE_NR - 1)
  1714. clear_bit(prot->inuse_idx, proto_inuse_idx);
  1715. }
  1716. #else
  1717. static inline void assign_proto_idx(struct proto *prot)
  1718. {
  1719. }
  1720. static inline void release_proto_idx(struct proto *prot)
  1721. {
  1722. }
  1723. #endif
  1724. int proto_register(struct proto *prot, int alloc_slab)
  1725. {
  1726. char *request_sock_slab_name = NULL;
  1727. char *timewait_sock_slab_name;
  1728. if (alloc_slab) {
  1729. prot->slab = kmem_cache_create(prot->name, prot->obj_size, 0,
  1730. SLAB_HWCACHE_ALIGN, NULL);
  1731. if (prot->slab == NULL) {
  1732. printk(KERN_CRIT "%s: Can't create sock SLAB cache!\n",
  1733. prot->name);
  1734. goto out;
  1735. }
  1736. if (prot->rsk_prot != NULL) {
  1737. static const char mask[] = "request_sock_%s";
  1738. request_sock_slab_name = kmalloc(strlen(prot->name) + sizeof(mask) - 1, GFP_KERNEL);
  1739. if (request_sock_slab_name == NULL)
  1740. goto out_free_sock_slab;
  1741. sprintf(request_sock_slab_name, mask, prot->name);
  1742. prot->rsk_prot->slab = kmem_cache_create(request_sock_slab_name,
  1743. prot->rsk_prot->obj_size, 0,
  1744. SLAB_HWCACHE_ALIGN, NULL);
  1745. if (prot->rsk_prot->slab == NULL) {
  1746. printk(KERN_CRIT "%s: Can't create request sock SLAB cache!\n",
  1747. prot->name);
  1748. goto out_free_request_sock_slab_name;
  1749. }
  1750. }
  1751. if (prot->twsk_prot != NULL) {
  1752. static const char mask[] = "tw_sock_%s";
  1753. timewait_sock_slab_name = kmalloc(strlen(prot->name) + sizeof(mask) - 1, GFP_KERNEL);
  1754. if (timewait_sock_slab_name == NULL)
  1755. goto out_free_request_sock_slab;
  1756. sprintf(timewait_sock_slab_name, mask, prot->name);
  1757. prot->twsk_prot->twsk_slab =
  1758. kmem_cache_create(timewait_sock_slab_name,
  1759. prot->twsk_prot->twsk_obj_size,
  1760. 0, SLAB_HWCACHE_ALIGN,
  1761. NULL);
  1762. if (prot->twsk_prot->twsk_slab == NULL)
  1763. goto out_free_timewait_sock_slab_name;
  1764. }
  1765. }
  1766. write_lock(&proto_list_lock);
  1767. list_add(&prot->node, &proto_list);
  1768. assign_proto_idx(prot);
  1769. write_unlock(&proto_list_lock);
  1770. return 0;
  1771. out_free_timewait_sock_slab_name:
  1772. kfree(timewait_sock_slab_name);
  1773. out_free_request_sock_slab:
  1774. if (prot->rsk_prot && prot->rsk_prot->slab) {
  1775. kmem_cache_destroy(prot->rsk_prot->slab);
  1776. prot->rsk_prot->slab = NULL;
  1777. }
  1778. out_free_request_sock_slab_name:
  1779. kfree(request_sock_slab_name);
  1780. out_free_sock_slab:
  1781. kmem_cache_destroy(prot->slab);
  1782. prot->slab = NULL;
  1783. out:
  1784. return -ENOBUFS;
  1785. }
  1786. EXPORT_SYMBOL(proto_register);
  1787. void proto_unregister(struct proto *prot)
  1788. {
  1789. write_lock(&proto_list_lock);
  1790. release_proto_idx(prot);
  1791. list_del(&prot->node);
  1792. write_unlock(&proto_list_lock);
  1793. if (prot->slab != NULL) {
  1794. kmem_cache_destroy(prot->slab);
  1795. prot->slab = NULL;
  1796. }
  1797. if (prot->rsk_prot != NULL && prot->rsk_prot->slab != NULL) {
  1798. const char *name = kmem_cache_name(prot->rsk_prot->slab);
  1799. kmem_cache_destroy(prot->rsk_prot->slab);
  1800. kfree(name);
  1801. prot->rsk_prot->slab = NULL;
  1802. }
  1803. if (prot->twsk_prot != NULL && prot->twsk_prot->twsk_slab != NULL) {
  1804. const char *name = kmem_cache_name(prot->twsk_prot->twsk_slab);
  1805. kmem_cache_destroy(prot->twsk_prot->twsk_slab);
  1806. kfree(name);
  1807. prot->twsk_prot->twsk_slab = NULL;
  1808. }
  1809. }
  1810. EXPORT_SYMBOL(proto_unregister);
  1811. #ifdef CONFIG_PROC_FS
  1812. static void *proto_seq_start(struct seq_file *seq, loff_t *pos)
  1813. __acquires(proto_list_lock)
  1814. {
  1815. read_lock(&proto_list_lock);
  1816. return seq_list_start_head(&proto_list, *pos);
  1817. }
  1818. static void *proto_seq_next(struct seq_file *seq, void *v, loff_t *pos)
  1819. {
  1820. return seq_list_next(v, &proto_list, pos);
  1821. }
  1822. static void proto_seq_stop(struct seq_file *seq, void *v)
  1823. __releases(proto_list_lock)
  1824. {
  1825. read_unlock(&proto_list_lock);
  1826. }
  1827. static char proto_method_implemented(const void *method)
  1828. {
  1829. return method == NULL ? 'n' : 'y';
  1830. }
  1831. static void proto_seq_printf(struct seq_file *seq, struct proto *proto)
  1832. {
  1833. seq_printf(seq, "%-9s %4u %6d %6d %-3s %6u %-3s %-10s "
  1834. "%2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c %2c\n",
  1835. proto->name,
  1836. proto->obj_size,
  1837. proto->sockets_allocated != NULL ? atomic_read(proto->sockets_allocated) : -1,
  1838. proto->memory_allocated != NULL ? atomic_read(proto->memory_allocated) : -1,
  1839. proto->memory_pressure != NULL ? *proto->memory_pressure ? "yes" : "no" : "NI",
  1840. proto->max_header,
  1841. proto->slab == NULL ? "no" : "yes",
  1842. module_name(proto->owner),
  1843. proto_method_implemented(proto->close),
  1844. proto_method_implemented(proto->connect),
  1845. proto_method_implemented(proto->disconnect),
  1846. proto_method_implemented(proto->accept),
  1847. proto_method_implemented(proto->ioctl),
  1848. proto_method_implemented(proto->init),
  1849. proto_method_implemented(proto->destroy),
  1850. proto_method_implemented(proto->shutdown),
  1851. proto_method_implemented(proto->setsockopt),
  1852. proto_method_implemented(proto->getsockopt),
  1853. proto_method_implemented(proto->sendmsg),
  1854. proto_method_implemented(proto->recvmsg),
  1855. proto_method_implemented(proto->sendpage),
  1856. proto_method_implemented(proto->bind),
  1857. proto_method_implemented(proto->backlog_rcv),
  1858. proto_method_implemented(proto->hash),
  1859. proto_method_implemented(proto->unhash),
  1860. proto_method_implemented(proto->get_port),
  1861. proto_method_implemented(proto->enter_memory_pressure));
  1862. }
  1863. static int proto_seq_show(struct seq_file *seq, void *v)
  1864. {
  1865. if (v == &proto_list)
  1866. seq_printf(seq, "%-9s %-4s %-8s %-6s %-5s %-7s %-4s %-10s %s",
  1867. "protocol",
  1868. "size",
  1869. "sockets",
  1870. "memory",
  1871. "press",
  1872. "maxhdr",
  1873. "slab",
  1874. "module",
  1875. "cl co di ac io in de sh ss gs se re sp bi br ha uh gp em\n");
  1876. else
  1877. proto_seq_printf(seq, list_entry(v, struct proto, node));
  1878. return 0;
  1879. }
  1880. static const struct seq_operations proto_seq_ops = {
  1881. .start = proto_seq_start,
  1882. .next = proto_seq_next,
  1883. .stop = proto_seq_stop,
  1884. .show = proto_seq_show,
  1885. };
  1886. static int proto_seq_open(struct inode *inode, struct file *file)
  1887. {
  1888. return seq_open(file, &proto_seq_ops);
  1889. }
  1890. static const struct file_operations proto_seq_fops = {
  1891. .owner = THIS_MODULE,
  1892. .open = proto_seq_open,
  1893. .read = seq_read,
  1894. .llseek = seq_lseek,
  1895. .release = seq_release,
  1896. };
  1897. static int __init proto_init(void)
  1898. {
  1899. /* register /proc/net/protocols */
  1900. return proc_net_fops_create(&init_net, "protocols", S_IRUGO, &proto_seq_fops) == NULL ? -ENOBUFS : 0;
  1901. }
  1902. subsys_initcall(proto_init);
  1903. #endif /* PROC_FS */
  1904. EXPORT_SYMBOL(sk_alloc);
  1905. EXPORT_SYMBOL(sk_free);
  1906. EXPORT_SYMBOL(sk_send_sigurg);
  1907. EXPORT_SYMBOL(sock_alloc_send_skb);
  1908. EXPORT_SYMBOL(sock_init_data);
  1909. EXPORT_SYMBOL(sock_kfree_s);
  1910. EXPORT_SYMBOL(sock_kmalloc);
  1911. EXPORT_SYMBOL(sock_no_accept);
  1912. EXPORT_SYMBOL(sock_no_bind);
  1913. EXPORT_SYMBOL(sock_no_connect);
  1914. EXPORT_SYMBOL(sock_no_getname);
  1915. EXPORT_SYMBOL(sock_no_getsockopt);
  1916. EXPORT_SYMBOL(sock_no_ioctl);
  1917. EXPORT_SYMBOL(sock_no_listen);
  1918. EXPORT_SYMBOL(sock_no_mmap);
  1919. EXPORT_SYMBOL(sock_no_poll);
  1920. EXPORT_SYMBOL(sock_no_recvmsg);
  1921. EXPORT_SYMBOL(sock_no_sendmsg);
  1922. EXPORT_SYMBOL(sock_no_sendpage);
  1923. EXPORT_SYMBOL(sock_no_setsockopt);
  1924. EXPORT_SYMBOL(sock_no_shutdown);
  1925. EXPORT_SYMBOL(sock_no_socketpair);
  1926. EXPORT_SYMBOL(sock_rfree);
  1927. EXPORT_SYMBOL(sock_setsockopt);
  1928. EXPORT_SYMBOL(sock_wfree);
  1929. EXPORT_SYMBOL(sock_wmalloc);
  1930. EXPORT_SYMBOL(sock_i_uid);
  1931. EXPORT_SYMBOL(sock_i_ino);
  1932. EXPORT_SYMBOL(sysctl_optmem_max);