xprtsock.c 87 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332
  1. /*
  2. * linux/net/sunrpc/xprtsock.c
  3. *
  4. * Client-side transport implementation for sockets.
  5. *
  6. * TCP callback races fixes (C) 1998 Red Hat
  7. * TCP send fixes (C) 1998 Red Hat
  8. * TCP NFS related read + write fixes
  9. * (C) 1999 Dave Airlie, University of Limerick, Ireland <airlied@linux.ie>
  10. *
  11. * Rewrite of larges part of the code in order to stabilize TCP stuff.
  12. * Fix behaviour when socket buffer is full.
  13. * (C) 1999 Trond Myklebust <trond.myklebust@fys.uio.no>
  14. *
  15. * IP socket transport implementation, (C) 2005 Chuck Lever <cel@netapp.com>
  16. *
  17. * IPv6 support contributed by Gilles Quillard, Bull Open Source, 2005.
  18. * <gilles.quillard@bull.net>
  19. */
  20. #include <linux/types.h>
  21. #include <linux/string.h>
  22. #include <linux/slab.h>
  23. #include <linux/module.h>
  24. #include <linux/capability.h>
  25. #include <linux/pagemap.h>
  26. #include <linux/errno.h>
  27. #include <linux/socket.h>
  28. #include <linux/in.h>
  29. #include <linux/net.h>
  30. #include <linux/mm.h>
  31. #include <linux/un.h>
  32. #include <linux/udp.h>
  33. #include <linux/tcp.h>
  34. #include <linux/sunrpc/clnt.h>
  35. #include <linux/sunrpc/addr.h>
  36. #include <linux/sunrpc/sched.h>
  37. #include <linux/sunrpc/svcsock.h>
  38. #include <linux/sunrpc/xprtsock.h>
  39. #include <linux/file.h>
  40. #ifdef CONFIG_SUNRPC_BACKCHANNEL
  41. #include <linux/sunrpc/bc_xprt.h>
  42. #endif
  43. #include <net/sock.h>
  44. #include <net/checksum.h>
  45. #include <net/udp.h>
  46. #include <net/tcp.h>
  47. #include <trace/events/sunrpc.h>
  48. #include "sunrpc.h"
  49. static void xs_close(struct rpc_xprt *xprt);
  50. static void xs_tcp_set_socket_timeouts(struct rpc_xprt *xprt,
  51. struct socket *sock);
  52. /*
  53. * xprtsock tunables
  54. */
  55. static unsigned int xprt_udp_slot_table_entries = RPC_DEF_SLOT_TABLE;
  56. static unsigned int xprt_tcp_slot_table_entries = RPC_MIN_SLOT_TABLE;
  57. static unsigned int xprt_max_tcp_slot_table_entries = RPC_MAX_SLOT_TABLE;
  58. static unsigned int xprt_min_resvport = RPC_DEF_MIN_RESVPORT;
  59. static unsigned int xprt_max_resvport = RPC_DEF_MAX_RESVPORT;
  60. #if IS_ENABLED(CONFIG_SUNRPC_DEBUG)
  61. #define XS_TCP_LINGER_TO (15U * HZ)
  62. static unsigned int xs_tcp_fin_timeout __read_mostly = XS_TCP_LINGER_TO;
  63. /*
  64. * We can register our own files under /proc/sys/sunrpc by
  65. * calling register_sysctl_table() again. The files in that
  66. * directory become the union of all files registered there.
  67. *
  68. * We simply need to make sure that we don't collide with
  69. * someone else's file names!
  70. */
  71. static unsigned int min_slot_table_size = RPC_MIN_SLOT_TABLE;
  72. static unsigned int max_slot_table_size = RPC_MAX_SLOT_TABLE;
  73. static unsigned int max_tcp_slot_table_limit = RPC_MAX_SLOT_TABLE_LIMIT;
  74. static unsigned int xprt_min_resvport_limit = RPC_MIN_RESVPORT;
  75. static unsigned int xprt_max_resvport_limit = RPC_MAX_RESVPORT;
  76. static struct ctl_table_header *sunrpc_table_header;
  77. /*
  78. * FIXME: changing the UDP slot table size should also resize the UDP
  79. * socket buffers for existing UDP transports
  80. */
  81. static struct ctl_table xs_tunables_table[] = {
  82. {
  83. .procname = "udp_slot_table_entries",
  84. .data = &xprt_udp_slot_table_entries,
  85. .maxlen = sizeof(unsigned int),
  86. .mode = 0644,
  87. .proc_handler = proc_dointvec_minmax,
  88. .extra1 = &min_slot_table_size,
  89. .extra2 = &max_slot_table_size
  90. },
  91. {
  92. .procname = "tcp_slot_table_entries",
  93. .data = &xprt_tcp_slot_table_entries,
  94. .maxlen = sizeof(unsigned int),
  95. .mode = 0644,
  96. .proc_handler = proc_dointvec_minmax,
  97. .extra1 = &min_slot_table_size,
  98. .extra2 = &max_slot_table_size
  99. },
  100. {
  101. .procname = "tcp_max_slot_table_entries",
  102. .data = &xprt_max_tcp_slot_table_entries,
  103. .maxlen = sizeof(unsigned int),
  104. .mode = 0644,
  105. .proc_handler = proc_dointvec_minmax,
  106. .extra1 = &min_slot_table_size,
  107. .extra2 = &max_tcp_slot_table_limit
  108. },
  109. {
  110. .procname = "min_resvport",
  111. .data = &xprt_min_resvport,
  112. .maxlen = sizeof(unsigned int),
  113. .mode = 0644,
  114. .proc_handler = proc_dointvec_minmax,
  115. .extra1 = &xprt_min_resvport_limit,
  116. .extra2 = &xprt_max_resvport
  117. },
  118. {
  119. .procname = "max_resvport",
  120. .data = &xprt_max_resvport,
  121. .maxlen = sizeof(unsigned int),
  122. .mode = 0644,
  123. .proc_handler = proc_dointvec_minmax,
  124. .extra1 = &xprt_min_resvport,
  125. .extra2 = &xprt_max_resvport_limit
  126. },
  127. {
  128. .procname = "tcp_fin_timeout",
  129. .data = &xs_tcp_fin_timeout,
  130. .maxlen = sizeof(xs_tcp_fin_timeout),
  131. .mode = 0644,
  132. .proc_handler = proc_dointvec_jiffies,
  133. },
  134. { },
  135. };
  136. static struct ctl_table sunrpc_table[] = {
  137. {
  138. .procname = "sunrpc",
  139. .mode = 0555,
  140. .child = xs_tunables_table
  141. },
  142. { },
  143. };
  144. #endif
  145. /*
  146. * Wait duration for a reply from the RPC portmapper.
  147. */
  148. #define XS_BIND_TO (60U * HZ)
  149. /*
  150. * Delay if a UDP socket connect error occurs. This is most likely some
  151. * kind of resource problem on the local host.
  152. */
  153. #define XS_UDP_REEST_TO (2U * HZ)
  154. /*
  155. * The reestablish timeout allows clients to delay for a bit before attempting
  156. * to reconnect to a server that just dropped our connection.
  157. *
  158. * We implement an exponential backoff when trying to reestablish a TCP
  159. * transport connection with the server. Some servers like to drop a TCP
  160. * connection when they are overworked, so we start with a short timeout and
  161. * increase over time if the server is down or not responding.
  162. */
  163. #define XS_TCP_INIT_REEST_TO (3U * HZ)
  164. /*
  165. * TCP idle timeout; client drops the transport socket if it is idle
  166. * for this long. Note that we also timeout UDP sockets to prevent
  167. * holding port numbers when there is no RPC traffic.
  168. */
  169. #define XS_IDLE_DISC_TO (5U * 60 * HZ)
  170. #if IS_ENABLED(CONFIG_SUNRPC_DEBUG)
  171. # undef RPC_DEBUG_DATA
  172. # define RPCDBG_FACILITY RPCDBG_TRANS
  173. #endif
  174. #ifdef RPC_DEBUG_DATA
  175. static void xs_pktdump(char *msg, u32 *packet, unsigned int count)
  176. {
  177. u8 *buf = (u8 *) packet;
  178. int j;
  179. dprintk("RPC: %s\n", msg);
  180. for (j = 0; j < count && j < 128; j += 4) {
  181. if (!(j & 31)) {
  182. if (j)
  183. dprintk("\n");
  184. dprintk("0x%04x ", j);
  185. }
  186. dprintk("%02x%02x%02x%02x ",
  187. buf[j], buf[j+1], buf[j+2], buf[j+3]);
  188. }
  189. dprintk("\n");
  190. }
  191. #else
  192. static inline void xs_pktdump(char *msg, u32 *packet, unsigned int count)
  193. {
  194. /* NOP */
  195. }
  196. #endif
  197. static inline struct rpc_xprt *xprt_from_sock(struct sock *sk)
  198. {
  199. return (struct rpc_xprt *) sk->sk_user_data;
  200. }
  201. static inline struct sockaddr *xs_addr(struct rpc_xprt *xprt)
  202. {
  203. return (struct sockaddr *) &xprt->addr;
  204. }
  205. static inline struct sockaddr_un *xs_addr_un(struct rpc_xprt *xprt)
  206. {
  207. return (struct sockaddr_un *) &xprt->addr;
  208. }
  209. static inline struct sockaddr_in *xs_addr_in(struct rpc_xprt *xprt)
  210. {
  211. return (struct sockaddr_in *) &xprt->addr;
  212. }
  213. static inline struct sockaddr_in6 *xs_addr_in6(struct rpc_xprt *xprt)
  214. {
  215. return (struct sockaddr_in6 *) &xprt->addr;
  216. }
  217. static void xs_format_common_peer_addresses(struct rpc_xprt *xprt)
  218. {
  219. struct sockaddr *sap = xs_addr(xprt);
  220. struct sockaddr_in6 *sin6;
  221. struct sockaddr_in *sin;
  222. struct sockaddr_un *sun;
  223. char buf[128];
  224. switch (sap->sa_family) {
  225. case AF_LOCAL:
  226. sun = xs_addr_un(xprt);
  227. strlcpy(buf, sun->sun_path, sizeof(buf));
  228. xprt->address_strings[RPC_DISPLAY_ADDR] =
  229. kstrdup(buf, GFP_KERNEL);
  230. break;
  231. case AF_INET:
  232. (void)rpc_ntop(sap, buf, sizeof(buf));
  233. xprt->address_strings[RPC_DISPLAY_ADDR] =
  234. kstrdup(buf, GFP_KERNEL);
  235. sin = xs_addr_in(xprt);
  236. snprintf(buf, sizeof(buf), "%08x", ntohl(sin->sin_addr.s_addr));
  237. break;
  238. case AF_INET6:
  239. (void)rpc_ntop(sap, buf, sizeof(buf));
  240. xprt->address_strings[RPC_DISPLAY_ADDR] =
  241. kstrdup(buf, GFP_KERNEL);
  242. sin6 = xs_addr_in6(xprt);
  243. snprintf(buf, sizeof(buf), "%pi6", &sin6->sin6_addr);
  244. break;
  245. default:
  246. BUG();
  247. }
  248. xprt->address_strings[RPC_DISPLAY_HEX_ADDR] = kstrdup(buf, GFP_KERNEL);
  249. }
  250. static void xs_format_common_peer_ports(struct rpc_xprt *xprt)
  251. {
  252. struct sockaddr *sap = xs_addr(xprt);
  253. char buf[128];
  254. snprintf(buf, sizeof(buf), "%u", rpc_get_port(sap));
  255. xprt->address_strings[RPC_DISPLAY_PORT] = kstrdup(buf, GFP_KERNEL);
  256. snprintf(buf, sizeof(buf), "%4hx", rpc_get_port(sap));
  257. xprt->address_strings[RPC_DISPLAY_HEX_PORT] = kstrdup(buf, GFP_KERNEL);
  258. }
  259. static void xs_format_peer_addresses(struct rpc_xprt *xprt,
  260. const char *protocol,
  261. const char *netid)
  262. {
  263. xprt->address_strings[RPC_DISPLAY_PROTO] = protocol;
  264. xprt->address_strings[RPC_DISPLAY_NETID] = netid;
  265. xs_format_common_peer_addresses(xprt);
  266. xs_format_common_peer_ports(xprt);
  267. }
  268. static void xs_update_peer_port(struct rpc_xprt *xprt)
  269. {
  270. kfree(xprt->address_strings[RPC_DISPLAY_HEX_PORT]);
  271. kfree(xprt->address_strings[RPC_DISPLAY_PORT]);
  272. xs_format_common_peer_ports(xprt);
  273. }
  274. static void xs_free_peer_addresses(struct rpc_xprt *xprt)
  275. {
  276. unsigned int i;
  277. for (i = 0; i < RPC_DISPLAY_MAX; i++)
  278. switch (i) {
  279. case RPC_DISPLAY_PROTO:
  280. case RPC_DISPLAY_NETID:
  281. continue;
  282. default:
  283. kfree(xprt->address_strings[i]);
  284. }
  285. }
  286. #define XS_SENDMSG_FLAGS (MSG_DONTWAIT | MSG_NOSIGNAL)
  287. static int xs_send_kvec(struct socket *sock, struct sockaddr *addr, int addrlen, struct kvec *vec, unsigned int base, int more)
  288. {
  289. struct msghdr msg = {
  290. .msg_name = addr,
  291. .msg_namelen = addrlen,
  292. .msg_flags = XS_SENDMSG_FLAGS | (more ? MSG_MORE : 0),
  293. };
  294. struct kvec iov = {
  295. .iov_base = vec->iov_base + base,
  296. .iov_len = vec->iov_len - base,
  297. };
  298. if (iov.iov_len != 0)
  299. return kernel_sendmsg(sock, &msg, &iov, 1, iov.iov_len);
  300. return kernel_sendmsg(sock, &msg, NULL, 0, 0);
  301. }
  302. static int xs_send_pagedata(struct socket *sock, struct xdr_buf *xdr, unsigned int base, int more, bool zerocopy, int *sent_p)
  303. {
  304. ssize_t (*do_sendpage)(struct socket *sock, struct page *page,
  305. int offset, size_t size, int flags);
  306. struct page **ppage;
  307. unsigned int remainder;
  308. int err;
  309. remainder = xdr->page_len - base;
  310. base += xdr->page_base;
  311. ppage = xdr->pages + (base >> PAGE_SHIFT);
  312. base &= ~PAGE_MASK;
  313. do_sendpage = sock->ops->sendpage;
  314. if (!zerocopy)
  315. do_sendpage = sock_no_sendpage;
  316. for(;;) {
  317. unsigned int len = min_t(unsigned int, PAGE_SIZE - base, remainder);
  318. int flags = XS_SENDMSG_FLAGS;
  319. remainder -= len;
  320. if (more)
  321. flags |= MSG_MORE;
  322. if (remainder != 0)
  323. flags |= MSG_SENDPAGE_NOTLAST | MSG_MORE;
  324. err = do_sendpage(sock, *ppage, base, len, flags);
  325. if (remainder == 0 || err != len)
  326. break;
  327. *sent_p += err;
  328. ppage++;
  329. base = 0;
  330. }
  331. if (err > 0) {
  332. *sent_p += err;
  333. err = 0;
  334. }
  335. return err;
  336. }
  337. /**
  338. * xs_sendpages - write pages directly to a socket
  339. * @sock: socket to send on
  340. * @addr: UDP only -- address of destination
  341. * @addrlen: UDP only -- length of destination address
  342. * @xdr: buffer containing this request
  343. * @base: starting position in the buffer
  344. * @zerocopy: true if it is safe to use sendpage()
  345. * @sent_p: return the total number of bytes successfully queued for sending
  346. *
  347. */
  348. static int xs_sendpages(struct socket *sock, struct sockaddr *addr, int addrlen, struct xdr_buf *xdr, unsigned int base, bool zerocopy, int *sent_p)
  349. {
  350. unsigned int remainder = xdr->len - base;
  351. int err = 0;
  352. int sent = 0;
  353. if (unlikely(!sock))
  354. return -ENOTSOCK;
  355. if (base != 0) {
  356. addr = NULL;
  357. addrlen = 0;
  358. }
  359. if (base < xdr->head[0].iov_len || addr != NULL) {
  360. unsigned int len = xdr->head[0].iov_len - base;
  361. remainder -= len;
  362. err = xs_send_kvec(sock, addr, addrlen, &xdr->head[0], base, remainder != 0);
  363. if (remainder == 0 || err != len)
  364. goto out;
  365. *sent_p += err;
  366. base = 0;
  367. } else
  368. base -= xdr->head[0].iov_len;
  369. if (base < xdr->page_len) {
  370. unsigned int len = xdr->page_len - base;
  371. remainder -= len;
  372. err = xs_send_pagedata(sock, xdr, base, remainder != 0, zerocopy, &sent);
  373. *sent_p += sent;
  374. if (remainder == 0 || sent != len)
  375. goto out;
  376. base = 0;
  377. } else
  378. base -= xdr->page_len;
  379. if (base >= xdr->tail[0].iov_len)
  380. return 0;
  381. err = xs_send_kvec(sock, NULL, 0, &xdr->tail[0], base, 0);
  382. out:
  383. if (err > 0) {
  384. *sent_p += err;
  385. err = 0;
  386. }
  387. return err;
  388. }
  389. static void xs_nospace_callback(struct rpc_task *task)
  390. {
  391. struct sock_xprt *transport = container_of(task->tk_rqstp->rq_xprt, struct sock_xprt, xprt);
  392. transport->inet->sk_write_pending--;
  393. }
  394. /**
  395. * xs_nospace - place task on wait queue if transmit was incomplete
  396. * @task: task to put to sleep
  397. *
  398. */
  399. static int xs_nospace(struct rpc_task *task)
  400. {
  401. struct rpc_rqst *req = task->tk_rqstp;
  402. struct rpc_xprt *xprt = req->rq_xprt;
  403. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  404. struct sock *sk = transport->inet;
  405. int ret = -EAGAIN;
  406. dprintk("RPC: %5u xmit incomplete (%u left of %u)\n",
  407. task->tk_pid, req->rq_slen - req->rq_bytes_sent,
  408. req->rq_slen);
  409. /* Protect against races with write_space */
  410. spin_lock_bh(&xprt->transport_lock);
  411. /* Don't race with disconnect */
  412. if (xprt_connected(xprt)) {
  413. /* wait for more buffer space */
  414. sk->sk_write_pending++;
  415. xprt_wait_for_buffer_space(task, xs_nospace_callback);
  416. } else
  417. ret = -ENOTCONN;
  418. spin_unlock_bh(&xprt->transport_lock);
  419. /* Race breaker in case memory is freed before above code is called */
  420. if (ret == -EAGAIN) {
  421. struct socket_wq *wq;
  422. rcu_read_lock();
  423. wq = rcu_dereference(sk->sk_wq);
  424. set_bit(SOCKWQ_ASYNC_NOSPACE, &wq->flags);
  425. rcu_read_unlock();
  426. sk->sk_write_space(sk);
  427. }
  428. return ret;
  429. }
  430. /*
  431. * Construct a stream transport record marker in @buf.
  432. */
  433. static inline void xs_encode_stream_record_marker(struct xdr_buf *buf)
  434. {
  435. u32 reclen = buf->len - sizeof(rpc_fraghdr);
  436. rpc_fraghdr *base = buf->head[0].iov_base;
  437. *base = cpu_to_be32(RPC_LAST_STREAM_FRAGMENT | reclen);
  438. }
  439. /**
  440. * xs_local_send_request - write an RPC request to an AF_LOCAL socket
  441. * @task: RPC task that manages the state of an RPC request
  442. *
  443. * Return values:
  444. * 0: The request has been sent
  445. * EAGAIN: The socket was blocked, please call again later to
  446. * complete the request
  447. * ENOTCONN: Caller needs to invoke connect logic then call again
  448. * other: Some other error occured, the request was not sent
  449. */
  450. static int xs_local_send_request(struct rpc_task *task)
  451. {
  452. struct rpc_rqst *req = task->tk_rqstp;
  453. struct rpc_xprt *xprt = req->rq_xprt;
  454. struct sock_xprt *transport =
  455. container_of(xprt, struct sock_xprt, xprt);
  456. struct xdr_buf *xdr = &req->rq_snd_buf;
  457. int status;
  458. int sent = 0;
  459. xs_encode_stream_record_marker(&req->rq_snd_buf);
  460. xs_pktdump("packet data:",
  461. req->rq_svec->iov_base, req->rq_svec->iov_len);
  462. status = xs_sendpages(transport->sock, NULL, 0, xdr, req->rq_bytes_sent,
  463. true, &sent);
  464. dprintk("RPC: %s(%u) = %d\n",
  465. __func__, xdr->len - req->rq_bytes_sent, status);
  466. if (status == -EAGAIN && sock_writeable(transport->inet))
  467. status = -ENOBUFS;
  468. if (likely(sent > 0) || status == 0) {
  469. req->rq_bytes_sent += sent;
  470. req->rq_xmit_bytes_sent += sent;
  471. if (likely(req->rq_bytes_sent >= req->rq_slen)) {
  472. req->rq_bytes_sent = 0;
  473. return 0;
  474. }
  475. status = -EAGAIN;
  476. }
  477. switch (status) {
  478. case -ENOBUFS:
  479. break;
  480. case -EAGAIN:
  481. status = xs_nospace(task);
  482. break;
  483. default:
  484. dprintk("RPC: sendmsg returned unrecognized error %d\n",
  485. -status);
  486. case -EPIPE:
  487. xs_close(xprt);
  488. status = -ENOTCONN;
  489. }
  490. return status;
  491. }
  492. /**
  493. * xs_udp_send_request - write an RPC request to a UDP socket
  494. * @task: address of RPC task that manages the state of an RPC request
  495. *
  496. * Return values:
  497. * 0: The request has been sent
  498. * EAGAIN: The socket was blocked, please call again later to
  499. * complete the request
  500. * ENOTCONN: Caller needs to invoke connect logic then call again
  501. * other: Some other error occurred, the request was not sent
  502. */
  503. static int xs_udp_send_request(struct rpc_task *task)
  504. {
  505. struct rpc_rqst *req = task->tk_rqstp;
  506. struct rpc_xprt *xprt = req->rq_xprt;
  507. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  508. struct xdr_buf *xdr = &req->rq_snd_buf;
  509. int sent = 0;
  510. int status;
  511. xs_pktdump("packet data:",
  512. req->rq_svec->iov_base,
  513. req->rq_svec->iov_len);
  514. if (!xprt_bound(xprt))
  515. return -ENOTCONN;
  516. status = xs_sendpages(transport->sock, xs_addr(xprt), xprt->addrlen,
  517. xdr, req->rq_bytes_sent, true, &sent);
  518. dprintk("RPC: xs_udp_send_request(%u) = %d\n",
  519. xdr->len - req->rq_bytes_sent, status);
  520. /* firewall is blocking us, don't return -EAGAIN or we end up looping */
  521. if (status == -EPERM)
  522. goto process_status;
  523. if (status == -EAGAIN && sock_writeable(transport->inet))
  524. status = -ENOBUFS;
  525. if (sent > 0 || status == 0) {
  526. req->rq_xmit_bytes_sent += sent;
  527. if (sent >= req->rq_slen)
  528. return 0;
  529. /* Still some bytes left; set up for a retry later. */
  530. status = -EAGAIN;
  531. }
  532. process_status:
  533. switch (status) {
  534. case -ENOTSOCK:
  535. status = -ENOTCONN;
  536. /* Should we call xs_close() here? */
  537. break;
  538. case -EAGAIN:
  539. status = xs_nospace(task);
  540. break;
  541. case -ENETUNREACH:
  542. case -ENOBUFS:
  543. case -EPIPE:
  544. case -ECONNREFUSED:
  545. case -EPERM:
  546. /* When the server has died, an ICMP port unreachable message
  547. * prompts ECONNREFUSED. */
  548. break;
  549. default:
  550. dprintk("RPC: sendmsg returned unrecognized error %d\n",
  551. -status);
  552. }
  553. return status;
  554. }
  555. /**
  556. * xs_tcp_send_request - write an RPC request to a TCP socket
  557. * @task: address of RPC task that manages the state of an RPC request
  558. *
  559. * Return values:
  560. * 0: The request has been sent
  561. * EAGAIN: The socket was blocked, please call again later to
  562. * complete the request
  563. * ENOTCONN: Caller needs to invoke connect logic then call again
  564. * other: Some other error occurred, the request was not sent
  565. *
  566. * XXX: In the case of soft timeouts, should we eventually give up
  567. * if sendmsg is not able to make progress?
  568. */
  569. static int xs_tcp_send_request(struct rpc_task *task)
  570. {
  571. struct rpc_rqst *req = task->tk_rqstp;
  572. struct rpc_xprt *xprt = req->rq_xprt;
  573. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  574. struct xdr_buf *xdr = &req->rq_snd_buf;
  575. bool zerocopy = true;
  576. bool vm_wait = false;
  577. int status;
  578. int sent;
  579. xs_encode_stream_record_marker(&req->rq_snd_buf);
  580. xs_pktdump("packet data:",
  581. req->rq_svec->iov_base,
  582. req->rq_svec->iov_len);
  583. /* Don't use zero copy if this is a resend. If the RPC call
  584. * completes while the socket holds a reference to the pages,
  585. * then we may end up resending corrupted data.
  586. */
  587. if (task->tk_flags & RPC_TASK_SENT)
  588. zerocopy = false;
  589. if (test_bit(XPRT_SOCK_UPD_TIMEOUT, &transport->sock_state))
  590. xs_tcp_set_socket_timeouts(xprt, transport->sock);
  591. /* Continue transmitting the packet/record. We must be careful
  592. * to cope with writespace callbacks arriving _after_ we have
  593. * called sendmsg(). */
  594. while (1) {
  595. sent = 0;
  596. status = xs_sendpages(transport->sock, NULL, 0, xdr,
  597. req->rq_bytes_sent, zerocopy, &sent);
  598. dprintk("RPC: xs_tcp_send_request(%u) = %d\n",
  599. xdr->len - req->rq_bytes_sent, status);
  600. /* If we've sent the entire packet, immediately
  601. * reset the count of bytes sent. */
  602. req->rq_bytes_sent += sent;
  603. req->rq_xmit_bytes_sent += sent;
  604. if (likely(req->rq_bytes_sent >= req->rq_slen)) {
  605. req->rq_bytes_sent = 0;
  606. return 0;
  607. }
  608. WARN_ON_ONCE(sent == 0 && status == 0);
  609. if (status == -EAGAIN ) {
  610. /*
  611. * Return EAGAIN if we're sure we're hitting the
  612. * socket send buffer limits.
  613. */
  614. if (test_bit(SOCK_NOSPACE, &transport->sock->flags))
  615. break;
  616. /*
  617. * Did we hit a memory allocation failure?
  618. */
  619. if (sent == 0) {
  620. status = -ENOBUFS;
  621. if (vm_wait)
  622. break;
  623. /* Retry, knowing now that we're below the
  624. * socket send buffer limit
  625. */
  626. vm_wait = true;
  627. }
  628. continue;
  629. }
  630. if (status < 0)
  631. break;
  632. vm_wait = false;
  633. }
  634. switch (status) {
  635. case -ENOTSOCK:
  636. status = -ENOTCONN;
  637. /* Should we call xs_close() here? */
  638. break;
  639. case -EAGAIN:
  640. status = xs_nospace(task);
  641. break;
  642. case -ECONNRESET:
  643. case -ECONNREFUSED:
  644. case -ENOTCONN:
  645. case -EADDRINUSE:
  646. case -ENOBUFS:
  647. case -EPIPE:
  648. break;
  649. default:
  650. dprintk("RPC: sendmsg returned unrecognized error %d\n",
  651. -status);
  652. }
  653. return status;
  654. }
  655. /**
  656. * xs_tcp_release_xprt - clean up after a tcp transmission
  657. * @xprt: transport
  658. * @task: rpc task
  659. *
  660. * This cleans up if an error causes us to abort the transmission of a request.
  661. * In this case, the socket may need to be reset in order to avoid confusing
  662. * the server.
  663. */
  664. static void xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task)
  665. {
  666. struct rpc_rqst *req;
  667. if (task != xprt->snd_task)
  668. return;
  669. if (task == NULL)
  670. goto out_release;
  671. req = task->tk_rqstp;
  672. if (req == NULL)
  673. goto out_release;
  674. if (req->rq_bytes_sent == 0)
  675. goto out_release;
  676. if (req->rq_bytes_sent == req->rq_snd_buf.len)
  677. goto out_release;
  678. set_bit(XPRT_CLOSE_WAIT, &xprt->state);
  679. out_release:
  680. xprt_release_xprt(xprt, task);
  681. }
  682. static void xs_save_old_callbacks(struct sock_xprt *transport, struct sock *sk)
  683. {
  684. transport->old_data_ready = sk->sk_data_ready;
  685. transport->old_state_change = sk->sk_state_change;
  686. transport->old_write_space = sk->sk_write_space;
  687. transport->old_error_report = sk->sk_error_report;
  688. }
  689. static void xs_restore_old_callbacks(struct sock_xprt *transport, struct sock *sk)
  690. {
  691. sk->sk_data_ready = transport->old_data_ready;
  692. sk->sk_state_change = transport->old_state_change;
  693. sk->sk_write_space = transport->old_write_space;
  694. sk->sk_error_report = transport->old_error_report;
  695. }
  696. static void xs_sock_reset_state_flags(struct rpc_xprt *xprt)
  697. {
  698. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  699. clear_bit(XPRT_SOCK_DATA_READY, &transport->sock_state);
  700. }
  701. static void xs_sock_reset_connection_flags(struct rpc_xprt *xprt)
  702. {
  703. smp_mb__before_atomic();
  704. clear_bit(XPRT_CLOSE_WAIT, &xprt->state);
  705. clear_bit(XPRT_CLOSING, &xprt->state);
  706. xs_sock_reset_state_flags(xprt);
  707. smp_mb__after_atomic();
  708. }
  709. static void xs_sock_mark_closed(struct rpc_xprt *xprt)
  710. {
  711. xs_sock_reset_connection_flags(xprt);
  712. /* Mark transport as closed and wake up all pending tasks */
  713. xprt_disconnect_done(xprt);
  714. }
  715. /**
  716. * xs_error_report - callback to handle TCP socket state errors
  717. * @sk: socket
  718. *
  719. * Note: we don't call sock_error() since there may be a rpc_task
  720. * using the socket, and so we don't want to clear sk->sk_err.
  721. */
  722. static void xs_error_report(struct sock *sk)
  723. {
  724. struct rpc_xprt *xprt;
  725. int err;
  726. read_lock_bh(&sk->sk_callback_lock);
  727. if (!(xprt = xprt_from_sock(sk)))
  728. goto out;
  729. err = -sk->sk_err;
  730. if (err == 0)
  731. goto out;
  732. /* Is this a reset event? */
  733. if (sk->sk_state == TCP_CLOSE)
  734. xs_sock_mark_closed(xprt);
  735. dprintk("RPC: xs_error_report client %p, error=%d...\n",
  736. xprt, -err);
  737. trace_rpc_socket_error(xprt, sk->sk_socket, err);
  738. xprt_wake_pending_tasks(xprt, err);
  739. out:
  740. read_unlock_bh(&sk->sk_callback_lock);
  741. }
  742. static void xs_reset_transport(struct sock_xprt *transport)
  743. {
  744. struct socket *sock = transport->sock;
  745. struct sock *sk = transport->inet;
  746. struct rpc_xprt *xprt = &transport->xprt;
  747. if (sk == NULL)
  748. return;
  749. if (atomic_read(&transport->xprt.swapper))
  750. sk_clear_memalloc(sk);
  751. kernel_sock_shutdown(sock, SHUT_RDWR);
  752. mutex_lock(&transport->recv_mutex);
  753. write_lock_bh(&sk->sk_callback_lock);
  754. transport->inet = NULL;
  755. transport->sock = NULL;
  756. sk->sk_user_data = NULL;
  757. xs_restore_old_callbacks(transport, sk);
  758. xprt_clear_connected(xprt);
  759. write_unlock_bh(&sk->sk_callback_lock);
  760. xs_sock_reset_connection_flags(xprt);
  761. mutex_unlock(&transport->recv_mutex);
  762. trace_rpc_socket_close(xprt, sock);
  763. sock_release(sock);
  764. }
  765. /**
  766. * xs_close - close a socket
  767. * @xprt: transport
  768. *
  769. * This is used when all requests are complete; ie, no DRC state remains
  770. * on the server we want to save.
  771. *
  772. * The caller _must_ be holding XPRT_LOCKED in order to avoid issues with
  773. * xs_reset_transport() zeroing the socket from underneath a writer.
  774. */
  775. static void xs_close(struct rpc_xprt *xprt)
  776. {
  777. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  778. dprintk("RPC: xs_close xprt %p\n", xprt);
  779. xs_reset_transport(transport);
  780. xprt->reestablish_timeout = 0;
  781. xprt_disconnect_done(xprt);
  782. }
  783. static void xs_inject_disconnect(struct rpc_xprt *xprt)
  784. {
  785. dprintk("RPC: injecting transport disconnect on xprt=%p\n",
  786. xprt);
  787. xprt_disconnect_done(xprt);
  788. }
  789. static void xs_xprt_free(struct rpc_xprt *xprt)
  790. {
  791. xs_free_peer_addresses(xprt);
  792. xprt_free(xprt);
  793. }
  794. /**
  795. * xs_destroy - prepare to shutdown a transport
  796. * @xprt: doomed transport
  797. *
  798. */
  799. static void xs_destroy(struct rpc_xprt *xprt)
  800. {
  801. struct sock_xprt *transport = container_of(xprt,
  802. struct sock_xprt, xprt);
  803. dprintk("RPC: xs_destroy xprt %p\n", xprt);
  804. cancel_delayed_work_sync(&transport->connect_worker);
  805. xs_close(xprt);
  806. cancel_work_sync(&transport->recv_worker);
  807. xs_xprt_free(xprt);
  808. module_put(THIS_MODULE);
  809. }
  810. static int xs_local_copy_to_xdr(struct xdr_buf *xdr, struct sk_buff *skb)
  811. {
  812. struct xdr_skb_reader desc = {
  813. .skb = skb,
  814. .offset = sizeof(rpc_fraghdr),
  815. .count = skb->len - sizeof(rpc_fraghdr),
  816. };
  817. if (xdr_partial_copy_from_skb(xdr, 0, &desc, xdr_skb_read_bits) < 0)
  818. return -1;
  819. if (desc.count)
  820. return -1;
  821. return 0;
  822. }
  823. /**
  824. * xs_local_data_read_skb
  825. * @xprt: transport
  826. * @sk: socket
  827. * @skb: skbuff
  828. *
  829. * Currently this assumes we can read the whole reply in a single gulp.
  830. */
  831. static void xs_local_data_read_skb(struct rpc_xprt *xprt,
  832. struct sock *sk,
  833. struct sk_buff *skb)
  834. {
  835. struct rpc_task *task;
  836. struct rpc_rqst *rovr;
  837. int repsize, copied;
  838. u32 _xid;
  839. __be32 *xp;
  840. repsize = skb->len - sizeof(rpc_fraghdr);
  841. if (repsize < 4) {
  842. dprintk("RPC: impossible RPC reply size %d\n", repsize);
  843. return;
  844. }
  845. /* Copy the XID from the skb... */
  846. xp = skb_header_pointer(skb, sizeof(rpc_fraghdr), sizeof(_xid), &_xid);
  847. if (xp == NULL)
  848. return;
  849. /* Look up and lock the request corresponding to the given XID */
  850. spin_lock_bh(&xprt->transport_lock);
  851. rovr = xprt_lookup_rqst(xprt, *xp);
  852. if (!rovr)
  853. goto out_unlock;
  854. task = rovr->rq_task;
  855. copied = rovr->rq_private_buf.buflen;
  856. if (copied > repsize)
  857. copied = repsize;
  858. if (xs_local_copy_to_xdr(&rovr->rq_private_buf, skb)) {
  859. dprintk("RPC: sk_buff copy failed\n");
  860. goto out_unlock;
  861. }
  862. xprt_complete_rqst(task, copied);
  863. out_unlock:
  864. spin_unlock_bh(&xprt->transport_lock);
  865. }
  866. static void xs_local_data_receive(struct sock_xprt *transport)
  867. {
  868. struct sk_buff *skb;
  869. struct sock *sk;
  870. int err;
  871. mutex_lock(&transport->recv_mutex);
  872. sk = transport->inet;
  873. if (sk == NULL)
  874. goto out;
  875. for (;;) {
  876. skb = skb_recv_datagram(sk, 0, 1, &err);
  877. if (skb != NULL) {
  878. xs_local_data_read_skb(&transport->xprt, sk, skb);
  879. skb_free_datagram(sk, skb);
  880. continue;
  881. }
  882. if (!test_and_clear_bit(XPRT_SOCK_DATA_READY, &transport->sock_state))
  883. break;
  884. }
  885. out:
  886. mutex_unlock(&transport->recv_mutex);
  887. }
  888. static void xs_local_data_receive_workfn(struct work_struct *work)
  889. {
  890. struct sock_xprt *transport =
  891. container_of(work, struct sock_xprt, recv_worker);
  892. xs_local_data_receive(transport);
  893. }
  894. /**
  895. * xs_udp_data_read_skb - receive callback for UDP sockets
  896. * @xprt: transport
  897. * @sk: socket
  898. * @skb: skbuff
  899. *
  900. */
  901. static void xs_udp_data_read_skb(struct rpc_xprt *xprt,
  902. struct sock *sk,
  903. struct sk_buff *skb)
  904. {
  905. struct rpc_task *task;
  906. struct rpc_rqst *rovr;
  907. int repsize, copied;
  908. u32 _xid;
  909. __be32 *xp;
  910. repsize = skb->len;
  911. if (repsize < 4) {
  912. dprintk("RPC: impossible RPC reply size %d!\n", repsize);
  913. return;
  914. }
  915. /* Copy the XID from the skb... */
  916. xp = skb_header_pointer(skb, 0, sizeof(_xid), &_xid);
  917. if (xp == NULL)
  918. return;
  919. /* Look up and lock the request corresponding to the given XID */
  920. spin_lock_bh(&xprt->transport_lock);
  921. rovr = xprt_lookup_rqst(xprt, *xp);
  922. if (!rovr)
  923. goto out_unlock;
  924. task = rovr->rq_task;
  925. if ((copied = rovr->rq_private_buf.buflen) > repsize)
  926. copied = repsize;
  927. /* Suck it into the iovec, verify checksum if not done by hw. */
  928. if (csum_partial_copy_to_xdr(&rovr->rq_private_buf, skb)) {
  929. __UDPX_INC_STATS(sk, UDP_MIB_INERRORS);
  930. goto out_unlock;
  931. }
  932. __UDPX_INC_STATS(sk, UDP_MIB_INDATAGRAMS);
  933. xprt_adjust_cwnd(xprt, task, copied);
  934. xprt_complete_rqst(task, copied);
  935. out_unlock:
  936. spin_unlock_bh(&xprt->transport_lock);
  937. }
  938. static void xs_udp_data_receive(struct sock_xprt *transport)
  939. {
  940. struct sk_buff *skb;
  941. struct sock *sk;
  942. int err;
  943. mutex_lock(&transport->recv_mutex);
  944. sk = transport->inet;
  945. if (sk == NULL)
  946. goto out;
  947. for (;;) {
  948. skb = skb_recv_udp(sk, 0, 1, &err);
  949. if (skb != NULL) {
  950. xs_udp_data_read_skb(&transport->xprt, sk, skb);
  951. consume_skb(skb);
  952. continue;
  953. }
  954. if (!test_and_clear_bit(XPRT_SOCK_DATA_READY, &transport->sock_state))
  955. break;
  956. }
  957. out:
  958. mutex_unlock(&transport->recv_mutex);
  959. }
  960. static void xs_udp_data_receive_workfn(struct work_struct *work)
  961. {
  962. struct sock_xprt *transport =
  963. container_of(work, struct sock_xprt, recv_worker);
  964. xs_udp_data_receive(transport);
  965. }
  966. /**
  967. * xs_data_ready - "data ready" callback for UDP sockets
  968. * @sk: socket with data to read
  969. *
  970. */
  971. static void xs_data_ready(struct sock *sk)
  972. {
  973. struct rpc_xprt *xprt;
  974. read_lock_bh(&sk->sk_callback_lock);
  975. dprintk("RPC: xs_data_ready...\n");
  976. xprt = xprt_from_sock(sk);
  977. if (xprt != NULL) {
  978. struct sock_xprt *transport = container_of(xprt,
  979. struct sock_xprt, xprt);
  980. transport->old_data_ready(sk);
  981. /* Any data means we had a useful conversation, so
  982. * then we don't need to delay the next reconnect
  983. */
  984. if (xprt->reestablish_timeout)
  985. xprt->reestablish_timeout = 0;
  986. if (!test_and_set_bit(XPRT_SOCK_DATA_READY, &transport->sock_state))
  987. queue_work(xprtiod_workqueue, &transport->recv_worker);
  988. }
  989. read_unlock_bh(&sk->sk_callback_lock);
  990. }
  991. /*
  992. * Helper function to force a TCP close if the server is sending
  993. * junk and/or it has put us in CLOSE_WAIT
  994. */
  995. static void xs_tcp_force_close(struct rpc_xprt *xprt)
  996. {
  997. xprt_force_disconnect(xprt);
  998. }
  999. static inline void xs_tcp_read_fraghdr(struct rpc_xprt *xprt, struct xdr_skb_reader *desc)
  1000. {
  1001. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1002. size_t len, used;
  1003. char *p;
  1004. p = ((char *) &transport->tcp_fraghdr) + transport->tcp_offset;
  1005. len = sizeof(transport->tcp_fraghdr) - transport->tcp_offset;
  1006. used = xdr_skb_read_bits(desc, p, len);
  1007. transport->tcp_offset += used;
  1008. if (used != len)
  1009. return;
  1010. transport->tcp_reclen = ntohl(transport->tcp_fraghdr);
  1011. if (transport->tcp_reclen & RPC_LAST_STREAM_FRAGMENT)
  1012. transport->tcp_flags |= TCP_RCV_LAST_FRAG;
  1013. else
  1014. transport->tcp_flags &= ~TCP_RCV_LAST_FRAG;
  1015. transport->tcp_reclen &= RPC_FRAGMENT_SIZE_MASK;
  1016. transport->tcp_flags &= ~TCP_RCV_COPY_FRAGHDR;
  1017. transport->tcp_offset = 0;
  1018. /* Sanity check of the record length */
  1019. if (unlikely(transport->tcp_reclen < 8)) {
  1020. dprintk("RPC: invalid TCP record fragment length\n");
  1021. xs_tcp_force_close(xprt);
  1022. return;
  1023. }
  1024. dprintk("RPC: reading TCP record fragment of length %d\n",
  1025. transport->tcp_reclen);
  1026. }
  1027. static void xs_tcp_check_fraghdr(struct sock_xprt *transport)
  1028. {
  1029. if (transport->tcp_offset == transport->tcp_reclen) {
  1030. transport->tcp_flags |= TCP_RCV_COPY_FRAGHDR;
  1031. transport->tcp_offset = 0;
  1032. if (transport->tcp_flags & TCP_RCV_LAST_FRAG) {
  1033. transport->tcp_flags &= ~TCP_RCV_COPY_DATA;
  1034. transport->tcp_flags |= TCP_RCV_COPY_XID;
  1035. transport->tcp_copied = 0;
  1036. }
  1037. }
  1038. }
  1039. static inline void xs_tcp_read_xid(struct sock_xprt *transport, struct xdr_skb_reader *desc)
  1040. {
  1041. size_t len, used;
  1042. char *p;
  1043. len = sizeof(transport->tcp_xid) - transport->tcp_offset;
  1044. dprintk("RPC: reading XID (%zu bytes)\n", len);
  1045. p = ((char *) &transport->tcp_xid) + transport->tcp_offset;
  1046. used = xdr_skb_read_bits(desc, p, len);
  1047. transport->tcp_offset += used;
  1048. if (used != len)
  1049. return;
  1050. transport->tcp_flags &= ~TCP_RCV_COPY_XID;
  1051. transport->tcp_flags |= TCP_RCV_READ_CALLDIR;
  1052. transport->tcp_copied = 4;
  1053. dprintk("RPC: reading %s XID %08x\n",
  1054. (transport->tcp_flags & TCP_RPC_REPLY) ? "reply for"
  1055. : "request with",
  1056. ntohl(transport->tcp_xid));
  1057. xs_tcp_check_fraghdr(transport);
  1058. }
  1059. static inline void xs_tcp_read_calldir(struct sock_xprt *transport,
  1060. struct xdr_skb_reader *desc)
  1061. {
  1062. size_t len, used;
  1063. u32 offset;
  1064. char *p;
  1065. /*
  1066. * We want transport->tcp_offset to be 8 at the end of this routine
  1067. * (4 bytes for the xid and 4 bytes for the call/reply flag).
  1068. * When this function is called for the first time,
  1069. * transport->tcp_offset is 4 (after having already read the xid).
  1070. */
  1071. offset = transport->tcp_offset - sizeof(transport->tcp_xid);
  1072. len = sizeof(transport->tcp_calldir) - offset;
  1073. dprintk("RPC: reading CALL/REPLY flag (%zu bytes)\n", len);
  1074. p = ((char *) &transport->tcp_calldir) + offset;
  1075. used = xdr_skb_read_bits(desc, p, len);
  1076. transport->tcp_offset += used;
  1077. if (used != len)
  1078. return;
  1079. transport->tcp_flags &= ~TCP_RCV_READ_CALLDIR;
  1080. /*
  1081. * We don't yet have the XDR buffer, so we will write the calldir
  1082. * out after we get the buffer from the 'struct rpc_rqst'
  1083. */
  1084. switch (ntohl(transport->tcp_calldir)) {
  1085. case RPC_REPLY:
  1086. transport->tcp_flags |= TCP_RCV_COPY_CALLDIR;
  1087. transport->tcp_flags |= TCP_RCV_COPY_DATA;
  1088. transport->tcp_flags |= TCP_RPC_REPLY;
  1089. break;
  1090. case RPC_CALL:
  1091. transport->tcp_flags |= TCP_RCV_COPY_CALLDIR;
  1092. transport->tcp_flags |= TCP_RCV_COPY_DATA;
  1093. transport->tcp_flags &= ~TCP_RPC_REPLY;
  1094. break;
  1095. default:
  1096. dprintk("RPC: invalid request message type\n");
  1097. xs_tcp_force_close(&transport->xprt);
  1098. }
  1099. xs_tcp_check_fraghdr(transport);
  1100. }
  1101. static inline void xs_tcp_read_common(struct rpc_xprt *xprt,
  1102. struct xdr_skb_reader *desc,
  1103. struct rpc_rqst *req)
  1104. {
  1105. struct sock_xprt *transport =
  1106. container_of(xprt, struct sock_xprt, xprt);
  1107. struct xdr_buf *rcvbuf;
  1108. size_t len;
  1109. ssize_t r;
  1110. rcvbuf = &req->rq_private_buf;
  1111. if (transport->tcp_flags & TCP_RCV_COPY_CALLDIR) {
  1112. /*
  1113. * Save the RPC direction in the XDR buffer
  1114. */
  1115. memcpy(rcvbuf->head[0].iov_base + transport->tcp_copied,
  1116. &transport->tcp_calldir,
  1117. sizeof(transport->tcp_calldir));
  1118. transport->tcp_copied += sizeof(transport->tcp_calldir);
  1119. transport->tcp_flags &= ~TCP_RCV_COPY_CALLDIR;
  1120. }
  1121. len = desc->count;
  1122. if (len > transport->tcp_reclen - transport->tcp_offset) {
  1123. struct xdr_skb_reader my_desc;
  1124. len = transport->tcp_reclen - transport->tcp_offset;
  1125. memcpy(&my_desc, desc, sizeof(my_desc));
  1126. my_desc.count = len;
  1127. r = xdr_partial_copy_from_skb(rcvbuf, transport->tcp_copied,
  1128. &my_desc, xdr_skb_read_bits);
  1129. desc->count -= r;
  1130. desc->offset += r;
  1131. } else
  1132. r = xdr_partial_copy_from_skb(rcvbuf, transport->tcp_copied,
  1133. desc, xdr_skb_read_bits);
  1134. if (r > 0) {
  1135. transport->tcp_copied += r;
  1136. transport->tcp_offset += r;
  1137. }
  1138. if (r != len) {
  1139. /* Error when copying to the receive buffer,
  1140. * usually because we weren't able to allocate
  1141. * additional buffer pages. All we can do now
  1142. * is turn off TCP_RCV_COPY_DATA, so the request
  1143. * will not receive any additional updates,
  1144. * and time out.
  1145. * Any remaining data from this record will
  1146. * be discarded.
  1147. */
  1148. transport->tcp_flags &= ~TCP_RCV_COPY_DATA;
  1149. dprintk("RPC: XID %08x truncated request\n",
  1150. ntohl(transport->tcp_xid));
  1151. dprintk("RPC: xprt = %p, tcp_copied = %lu, "
  1152. "tcp_offset = %u, tcp_reclen = %u\n",
  1153. xprt, transport->tcp_copied,
  1154. transport->tcp_offset, transport->tcp_reclen);
  1155. return;
  1156. }
  1157. dprintk("RPC: XID %08x read %zd bytes\n",
  1158. ntohl(transport->tcp_xid), r);
  1159. dprintk("RPC: xprt = %p, tcp_copied = %lu, tcp_offset = %u, "
  1160. "tcp_reclen = %u\n", xprt, transport->tcp_copied,
  1161. transport->tcp_offset, transport->tcp_reclen);
  1162. if (transport->tcp_copied == req->rq_private_buf.buflen)
  1163. transport->tcp_flags &= ~TCP_RCV_COPY_DATA;
  1164. else if (transport->tcp_offset == transport->tcp_reclen) {
  1165. if (transport->tcp_flags & TCP_RCV_LAST_FRAG)
  1166. transport->tcp_flags &= ~TCP_RCV_COPY_DATA;
  1167. }
  1168. }
  1169. /*
  1170. * Finds the request corresponding to the RPC xid and invokes the common
  1171. * tcp read code to read the data.
  1172. */
  1173. static inline int xs_tcp_read_reply(struct rpc_xprt *xprt,
  1174. struct xdr_skb_reader *desc)
  1175. {
  1176. struct sock_xprt *transport =
  1177. container_of(xprt, struct sock_xprt, xprt);
  1178. struct rpc_rqst *req;
  1179. dprintk("RPC: read reply XID %08x\n", ntohl(transport->tcp_xid));
  1180. /* Find and lock the request corresponding to this xid */
  1181. spin_lock_bh(&xprt->transport_lock);
  1182. req = xprt_lookup_rqst(xprt, transport->tcp_xid);
  1183. if (!req) {
  1184. dprintk("RPC: XID %08x request not found!\n",
  1185. ntohl(transport->tcp_xid));
  1186. spin_unlock_bh(&xprt->transport_lock);
  1187. return -1;
  1188. }
  1189. xs_tcp_read_common(xprt, desc, req);
  1190. if (!(transport->tcp_flags & TCP_RCV_COPY_DATA))
  1191. xprt_complete_rqst(req->rq_task, transport->tcp_copied);
  1192. spin_unlock_bh(&xprt->transport_lock);
  1193. return 0;
  1194. }
  1195. #if defined(CONFIG_SUNRPC_BACKCHANNEL)
  1196. /*
  1197. * Obtains an rpc_rqst previously allocated and invokes the common
  1198. * tcp read code to read the data. The result is placed in the callback
  1199. * queue.
  1200. * If we're unable to obtain the rpc_rqst we schedule the closing of the
  1201. * connection and return -1.
  1202. */
  1203. static int xs_tcp_read_callback(struct rpc_xprt *xprt,
  1204. struct xdr_skb_reader *desc)
  1205. {
  1206. struct sock_xprt *transport =
  1207. container_of(xprt, struct sock_xprt, xprt);
  1208. struct rpc_rqst *req;
  1209. /* Look up and lock the request corresponding to the given XID */
  1210. spin_lock_bh(&xprt->transport_lock);
  1211. req = xprt_lookup_bc_request(xprt, transport->tcp_xid);
  1212. if (req == NULL) {
  1213. spin_unlock_bh(&xprt->transport_lock);
  1214. printk(KERN_WARNING "Callback slot table overflowed\n");
  1215. xprt_force_disconnect(xprt);
  1216. return -1;
  1217. }
  1218. dprintk("RPC: read callback XID %08x\n", ntohl(req->rq_xid));
  1219. xs_tcp_read_common(xprt, desc, req);
  1220. if (!(transport->tcp_flags & TCP_RCV_COPY_DATA))
  1221. xprt_complete_bc_request(req, transport->tcp_copied);
  1222. spin_unlock_bh(&xprt->transport_lock);
  1223. return 0;
  1224. }
  1225. static inline int _xs_tcp_read_data(struct rpc_xprt *xprt,
  1226. struct xdr_skb_reader *desc)
  1227. {
  1228. struct sock_xprt *transport =
  1229. container_of(xprt, struct sock_xprt, xprt);
  1230. return (transport->tcp_flags & TCP_RPC_REPLY) ?
  1231. xs_tcp_read_reply(xprt, desc) :
  1232. xs_tcp_read_callback(xprt, desc);
  1233. }
  1234. static int xs_tcp_bc_up(struct svc_serv *serv, struct net *net)
  1235. {
  1236. int ret;
  1237. ret = svc_create_xprt(serv, "tcp-bc", net, PF_INET, 0,
  1238. SVC_SOCK_ANONYMOUS);
  1239. if (ret < 0)
  1240. return ret;
  1241. return 0;
  1242. }
  1243. static size_t xs_tcp_bc_maxpayload(struct rpc_xprt *xprt)
  1244. {
  1245. return PAGE_SIZE;
  1246. }
  1247. #else
  1248. static inline int _xs_tcp_read_data(struct rpc_xprt *xprt,
  1249. struct xdr_skb_reader *desc)
  1250. {
  1251. return xs_tcp_read_reply(xprt, desc);
  1252. }
  1253. #endif /* CONFIG_SUNRPC_BACKCHANNEL */
  1254. /*
  1255. * Read data off the transport. This can be either an RPC_CALL or an
  1256. * RPC_REPLY. Relay the processing to helper functions.
  1257. */
  1258. static void xs_tcp_read_data(struct rpc_xprt *xprt,
  1259. struct xdr_skb_reader *desc)
  1260. {
  1261. struct sock_xprt *transport =
  1262. container_of(xprt, struct sock_xprt, xprt);
  1263. if (_xs_tcp_read_data(xprt, desc) == 0)
  1264. xs_tcp_check_fraghdr(transport);
  1265. else {
  1266. /*
  1267. * The transport_lock protects the request handling.
  1268. * There's no need to hold it to update the tcp_flags.
  1269. */
  1270. transport->tcp_flags &= ~TCP_RCV_COPY_DATA;
  1271. }
  1272. }
  1273. static inline void xs_tcp_read_discard(struct sock_xprt *transport, struct xdr_skb_reader *desc)
  1274. {
  1275. size_t len;
  1276. len = transport->tcp_reclen - transport->tcp_offset;
  1277. if (len > desc->count)
  1278. len = desc->count;
  1279. desc->count -= len;
  1280. desc->offset += len;
  1281. transport->tcp_offset += len;
  1282. dprintk("RPC: discarded %zu bytes\n", len);
  1283. xs_tcp_check_fraghdr(transport);
  1284. }
  1285. static int xs_tcp_data_recv(read_descriptor_t *rd_desc, struct sk_buff *skb, unsigned int offset, size_t len)
  1286. {
  1287. struct rpc_xprt *xprt = rd_desc->arg.data;
  1288. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1289. struct xdr_skb_reader desc = {
  1290. .skb = skb,
  1291. .offset = offset,
  1292. .count = len,
  1293. };
  1294. dprintk("RPC: xs_tcp_data_recv started\n");
  1295. do {
  1296. trace_xs_tcp_data_recv(transport);
  1297. /* Read in a new fragment marker if necessary */
  1298. /* Can we ever really expect to get completely empty fragments? */
  1299. if (transport->tcp_flags & TCP_RCV_COPY_FRAGHDR) {
  1300. xs_tcp_read_fraghdr(xprt, &desc);
  1301. continue;
  1302. }
  1303. /* Read in the xid if necessary */
  1304. if (transport->tcp_flags & TCP_RCV_COPY_XID) {
  1305. xs_tcp_read_xid(transport, &desc);
  1306. continue;
  1307. }
  1308. /* Read in the call/reply flag */
  1309. if (transport->tcp_flags & TCP_RCV_READ_CALLDIR) {
  1310. xs_tcp_read_calldir(transport, &desc);
  1311. continue;
  1312. }
  1313. /* Read in the request data */
  1314. if (transport->tcp_flags & TCP_RCV_COPY_DATA) {
  1315. xs_tcp_read_data(xprt, &desc);
  1316. continue;
  1317. }
  1318. /* Skip over any trailing bytes on short reads */
  1319. xs_tcp_read_discard(transport, &desc);
  1320. } while (desc.count);
  1321. trace_xs_tcp_data_recv(transport);
  1322. dprintk("RPC: xs_tcp_data_recv done\n");
  1323. return len - desc.count;
  1324. }
  1325. static void xs_tcp_data_receive(struct sock_xprt *transport)
  1326. {
  1327. struct rpc_xprt *xprt = &transport->xprt;
  1328. struct sock *sk;
  1329. read_descriptor_t rd_desc = {
  1330. .count = 2*1024*1024,
  1331. .arg.data = xprt,
  1332. };
  1333. unsigned long total = 0;
  1334. int read = 0;
  1335. mutex_lock(&transport->recv_mutex);
  1336. sk = transport->inet;
  1337. if (sk == NULL)
  1338. goto out;
  1339. /* We use rd_desc to pass struct xprt to xs_tcp_data_recv */
  1340. for (;;) {
  1341. lock_sock(sk);
  1342. read = tcp_read_sock(sk, &rd_desc, xs_tcp_data_recv);
  1343. if (read <= 0) {
  1344. clear_bit(XPRT_SOCK_DATA_READY, &transport->sock_state);
  1345. release_sock(sk);
  1346. if (!test_bit(XPRT_SOCK_DATA_READY, &transport->sock_state))
  1347. break;
  1348. } else {
  1349. release_sock(sk);
  1350. total += read;
  1351. }
  1352. rd_desc.count = 65536;
  1353. }
  1354. out:
  1355. mutex_unlock(&transport->recv_mutex);
  1356. trace_xs_tcp_data_ready(xprt, read, total);
  1357. }
  1358. static void xs_tcp_data_receive_workfn(struct work_struct *work)
  1359. {
  1360. struct sock_xprt *transport =
  1361. container_of(work, struct sock_xprt, recv_worker);
  1362. xs_tcp_data_receive(transport);
  1363. }
  1364. /**
  1365. * xs_tcp_state_change - callback to handle TCP socket state changes
  1366. * @sk: socket whose state has changed
  1367. *
  1368. */
  1369. static void xs_tcp_state_change(struct sock *sk)
  1370. {
  1371. struct rpc_xprt *xprt;
  1372. struct sock_xprt *transport;
  1373. read_lock_bh(&sk->sk_callback_lock);
  1374. if (!(xprt = xprt_from_sock(sk)))
  1375. goto out;
  1376. dprintk("RPC: xs_tcp_state_change client %p...\n", xprt);
  1377. dprintk("RPC: state %x conn %d dead %d zapped %d sk_shutdown %d\n",
  1378. sk->sk_state, xprt_connected(xprt),
  1379. sock_flag(sk, SOCK_DEAD),
  1380. sock_flag(sk, SOCK_ZAPPED),
  1381. sk->sk_shutdown);
  1382. transport = container_of(xprt, struct sock_xprt, xprt);
  1383. trace_rpc_socket_state_change(xprt, sk->sk_socket);
  1384. switch (sk->sk_state) {
  1385. case TCP_ESTABLISHED:
  1386. spin_lock(&xprt->transport_lock);
  1387. if (!xprt_test_and_set_connected(xprt)) {
  1388. /* Reset TCP record info */
  1389. transport->tcp_offset = 0;
  1390. transport->tcp_reclen = 0;
  1391. transport->tcp_copied = 0;
  1392. transport->tcp_flags =
  1393. TCP_RCV_COPY_FRAGHDR | TCP_RCV_COPY_XID;
  1394. xprt->connect_cookie++;
  1395. clear_bit(XPRT_SOCK_CONNECTING, &transport->sock_state);
  1396. xprt_clear_connecting(xprt);
  1397. xprt_wake_pending_tasks(xprt, -EAGAIN);
  1398. }
  1399. spin_unlock(&xprt->transport_lock);
  1400. break;
  1401. case TCP_FIN_WAIT1:
  1402. /* The client initiated a shutdown of the socket */
  1403. xprt->connect_cookie++;
  1404. xprt->reestablish_timeout = 0;
  1405. set_bit(XPRT_CLOSING, &xprt->state);
  1406. smp_mb__before_atomic();
  1407. clear_bit(XPRT_CONNECTED, &xprt->state);
  1408. clear_bit(XPRT_CLOSE_WAIT, &xprt->state);
  1409. smp_mb__after_atomic();
  1410. break;
  1411. case TCP_CLOSE_WAIT:
  1412. /* The server initiated a shutdown of the socket */
  1413. xprt->connect_cookie++;
  1414. clear_bit(XPRT_CONNECTED, &xprt->state);
  1415. xs_tcp_force_close(xprt);
  1416. case TCP_CLOSING:
  1417. /*
  1418. * If the server closed down the connection, make sure that
  1419. * we back off before reconnecting
  1420. */
  1421. if (xprt->reestablish_timeout < XS_TCP_INIT_REEST_TO)
  1422. xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO;
  1423. break;
  1424. case TCP_LAST_ACK:
  1425. set_bit(XPRT_CLOSING, &xprt->state);
  1426. smp_mb__before_atomic();
  1427. clear_bit(XPRT_CONNECTED, &xprt->state);
  1428. smp_mb__after_atomic();
  1429. break;
  1430. case TCP_CLOSE:
  1431. if (test_and_clear_bit(XPRT_SOCK_CONNECTING,
  1432. &transport->sock_state))
  1433. xprt_clear_connecting(xprt);
  1434. xs_sock_mark_closed(xprt);
  1435. }
  1436. out:
  1437. read_unlock_bh(&sk->sk_callback_lock);
  1438. }
  1439. static void xs_write_space(struct sock *sk)
  1440. {
  1441. struct socket_wq *wq;
  1442. struct rpc_xprt *xprt;
  1443. if (!sk->sk_socket)
  1444. return;
  1445. clear_bit(SOCK_NOSPACE, &sk->sk_socket->flags);
  1446. if (unlikely(!(xprt = xprt_from_sock(sk))))
  1447. return;
  1448. rcu_read_lock();
  1449. wq = rcu_dereference(sk->sk_wq);
  1450. if (!wq || test_and_clear_bit(SOCKWQ_ASYNC_NOSPACE, &wq->flags) == 0)
  1451. goto out;
  1452. xprt_write_space(xprt);
  1453. out:
  1454. rcu_read_unlock();
  1455. }
  1456. /**
  1457. * xs_udp_write_space - callback invoked when socket buffer space
  1458. * becomes available
  1459. * @sk: socket whose state has changed
  1460. *
  1461. * Called when more output buffer space is available for this socket.
  1462. * We try not to wake our writers until they can make "significant"
  1463. * progress, otherwise we'll waste resources thrashing kernel_sendmsg
  1464. * with a bunch of small requests.
  1465. */
  1466. static void xs_udp_write_space(struct sock *sk)
  1467. {
  1468. read_lock_bh(&sk->sk_callback_lock);
  1469. /* from net/core/sock.c:sock_def_write_space */
  1470. if (sock_writeable(sk))
  1471. xs_write_space(sk);
  1472. read_unlock_bh(&sk->sk_callback_lock);
  1473. }
  1474. /**
  1475. * xs_tcp_write_space - callback invoked when socket buffer space
  1476. * becomes available
  1477. * @sk: socket whose state has changed
  1478. *
  1479. * Called when more output buffer space is available for this socket.
  1480. * We try not to wake our writers until they can make "significant"
  1481. * progress, otherwise we'll waste resources thrashing kernel_sendmsg
  1482. * with a bunch of small requests.
  1483. */
  1484. static void xs_tcp_write_space(struct sock *sk)
  1485. {
  1486. read_lock_bh(&sk->sk_callback_lock);
  1487. /* from net/core/stream.c:sk_stream_write_space */
  1488. if (sk_stream_is_writeable(sk))
  1489. xs_write_space(sk);
  1490. read_unlock_bh(&sk->sk_callback_lock);
  1491. }
  1492. static void xs_udp_do_set_buffer_size(struct rpc_xprt *xprt)
  1493. {
  1494. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1495. struct sock *sk = transport->inet;
  1496. if (transport->rcvsize) {
  1497. sk->sk_userlocks |= SOCK_RCVBUF_LOCK;
  1498. sk->sk_rcvbuf = transport->rcvsize * xprt->max_reqs * 2;
  1499. }
  1500. if (transport->sndsize) {
  1501. sk->sk_userlocks |= SOCK_SNDBUF_LOCK;
  1502. sk->sk_sndbuf = transport->sndsize * xprt->max_reqs * 2;
  1503. sk->sk_write_space(sk);
  1504. }
  1505. }
  1506. /**
  1507. * xs_udp_set_buffer_size - set send and receive limits
  1508. * @xprt: generic transport
  1509. * @sndsize: requested size of send buffer, in bytes
  1510. * @rcvsize: requested size of receive buffer, in bytes
  1511. *
  1512. * Set socket send and receive buffer size limits.
  1513. */
  1514. static void xs_udp_set_buffer_size(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize)
  1515. {
  1516. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1517. transport->sndsize = 0;
  1518. if (sndsize)
  1519. transport->sndsize = sndsize + 1024;
  1520. transport->rcvsize = 0;
  1521. if (rcvsize)
  1522. transport->rcvsize = rcvsize + 1024;
  1523. xs_udp_do_set_buffer_size(xprt);
  1524. }
  1525. /**
  1526. * xs_udp_timer - called when a retransmit timeout occurs on a UDP transport
  1527. * @task: task that timed out
  1528. *
  1529. * Adjust the congestion window after a retransmit timeout has occurred.
  1530. */
  1531. static void xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task)
  1532. {
  1533. spin_lock_bh(&xprt->transport_lock);
  1534. xprt_adjust_cwnd(xprt, task, -ETIMEDOUT);
  1535. spin_unlock_bh(&xprt->transport_lock);
  1536. }
  1537. static unsigned short xs_get_random_port(void)
  1538. {
  1539. unsigned short range = xprt_max_resvport - xprt_min_resvport + 1;
  1540. unsigned short rand = (unsigned short) prandom_u32() % range;
  1541. return rand + xprt_min_resvport;
  1542. }
  1543. /**
  1544. * xs_set_reuseaddr_port - set the socket's port and address reuse options
  1545. * @sock: socket
  1546. *
  1547. * Note that this function has to be called on all sockets that share the
  1548. * same port, and it must be called before binding.
  1549. */
  1550. static void xs_sock_set_reuseport(struct socket *sock)
  1551. {
  1552. int opt = 1;
  1553. kernel_setsockopt(sock, SOL_SOCKET, SO_REUSEPORT,
  1554. (char *)&opt, sizeof(opt));
  1555. }
  1556. static unsigned short xs_sock_getport(struct socket *sock)
  1557. {
  1558. struct sockaddr_storage buf;
  1559. int buflen;
  1560. unsigned short port = 0;
  1561. if (kernel_getsockname(sock, (struct sockaddr *)&buf, &buflen) < 0)
  1562. goto out;
  1563. switch (buf.ss_family) {
  1564. case AF_INET6:
  1565. port = ntohs(((struct sockaddr_in6 *)&buf)->sin6_port);
  1566. break;
  1567. case AF_INET:
  1568. port = ntohs(((struct sockaddr_in *)&buf)->sin_port);
  1569. }
  1570. out:
  1571. return port;
  1572. }
  1573. /**
  1574. * xs_set_port - reset the port number in the remote endpoint address
  1575. * @xprt: generic transport
  1576. * @port: new port number
  1577. *
  1578. */
  1579. static void xs_set_port(struct rpc_xprt *xprt, unsigned short port)
  1580. {
  1581. dprintk("RPC: setting port for xprt %p to %u\n", xprt, port);
  1582. rpc_set_port(xs_addr(xprt), port);
  1583. xs_update_peer_port(xprt);
  1584. }
  1585. static void xs_set_srcport(struct sock_xprt *transport, struct socket *sock)
  1586. {
  1587. if (transport->srcport == 0)
  1588. transport->srcport = xs_sock_getport(sock);
  1589. }
  1590. static unsigned short xs_get_srcport(struct sock_xprt *transport)
  1591. {
  1592. unsigned short port = transport->srcport;
  1593. if (port == 0 && transport->xprt.resvport)
  1594. port = xs_get_random_port();
  1595. return port;
  1596. }
  1597. static unsigned short xs_next_srcport(struct sock_xprt *transport, unsigned short port)
  1598. {
  1599. if (transport->srcport != 0)
  1600. transport->srcport = 0;
  1601. if (!transport->xprt.resvport)
  1602. return 0;
  1603. if (port <= xprt_min_resvport || port > xprt_max_resvport)
  1604. return xprt_max_resvport;
  1605. return --port;
  1606. }
  1607. static int xs_bind(struct sock_xprt *transport, struct socket *sock)
  1608. {
  1609. struct sockaddr_storage myaddr;
  1610. int err, nloop = 0;
  1611. unsigned short port = xs_get_srcport(transport);
  1612. unsigned short last;
  1613. /*
  1614. * If we are asking for any ephemeral port (i.e. port == 0 &&
  1615. * transport->xprt.resvport == 0), don't bind. Let the local
  1616. * port selection happen implicitly when the socket is used
  1617. * (for example at connect time).
  1618. *
  1619. * This ensures that we can continue to establish TCP
  1620. * connections even when all local ephemeral ports are already
  1621. * a part of some TCP connection. This makes no difference
  1622. * for UDP sockets, but also doens't harm them.
  1623. *
  1624. * If we're asking for any reserved port (i.e. port == 0 &&
  1625. * transport->xprt.resvport == 1) xs_get_srcport above will
  1626. * ensure that port is non-zero and we will bind as needed.
  1627. */
  1628. if (port == 0)
  1629. return 0;
  1630. memcpy(&myaddr, &transport->srcaddr, transport->xprt.addrlen);
  1631. do {
  1632. rpc_set_port((struct sockaddr *)&myaddr, port);
  1633. err = kernel_bind(sock, (struct sockaddr *)&myaddr,
  1634. transport->xprt.addrlen);
  1635. if (err == 0) {
  1636. transport->srcport = port;
  1637. break;
  1638. }
  1639. last = port;
  1640. port = xs_next_srcport(transport, port);
  1641. if (port > last)
  1642. nloop++;
  1643. } while (err == -EADDRINUSE && nloop != 2);
  1644. if (myaddr.ss_family == AF_INET)
  1645. dprintk("RPC: %s %pI4:%u: %s (%d)\n", __func__,
  1646. &((struct sockaddr_in *)&myaddr)->sin_addr,
  1647. port, err ? "failed" : "ok", err);
  1648. else
  1649. dprintk("RPC: %s %pI6:%u: %s (%d)\n", __func__,
  1650. &((struct sockaddr_in6 *)&myaddr)->sin6_addr,
  1651. port, err ? "failed" : "ok", err);
  1652. return err;
  1653. }
  1654. /*
  1655. * We don't support autobind on AF_LOCAL sockets
  1656. */
  1657. static void xs_local_rpcbind(struct rpc_task *task)
  1658. {
  1659. xprt_set_bound(task->tk_xprt);
  1660. }
  1661. static void xs_local_set_port(struct rpc_xprt *xprt, unsigned short port)
  1662. {
  1663. }
  1664. #ifdef CONFIG_DEBUG_LOCK_ALLOC
  1665. static struct lock_class_key xs_key[2];
  1666. static struct lock_class_key xs_slock_key[2];
  1667. static inline void xs_reclassify_socketu(struct socket *sock)
  1668. {
  1669. struct sock *sk = sock->sk;
  1670. sock_lock_init_class_and_name(sk, "slock-AF_LOCAL-RPC",
  1671. &xs_slock_key[1], "sk_lock-AF_LOCAL-RPC", &xs_key[1]);
  1672. }
  1673. static inline void xs_reclassify_socket4(struct socket *sock)
  1674. {
  1675. struct sock *sk = sock->sk;
  1676. sock_lock_init_class_and_name(sk, "slock-AF_INET-RPC",
  1677. &xs_slock_key[0], "sk_lock-AF_INET-RPC", &xs_key[0]);
  1678. }
  1679. static inline void xs_reclassify_socket6(struct socket *sock)
  1680. {
  1681. struct sock *sk = sock->sk;
  1682. sock_lock_init_class_and_name(sk, "slock-AF_INET6-RPC",
  1683. &xs_slock_key[1], "sk_lock-AF_INET6-RPC", &xs_key[1]);
  1684. }
  1685. static inline void xs_reclassify_socket(int family, struct socket *sock)
  1686. {
  1687. if (WARN_ON_ONCE(!sock_allow_reclassification(sock->sk)))
  1688. return;
  1689. switch (family) {
  1690. case AF_LOCAL:
  1691. xs_reclassify_socketu(sock);
  1692. break;
  1693. case AF_INET:
  1694. xs_reclassify_socket4(sock);
  1695. break;
  1696. case AF_INET6:
  1697. xs_reclassify_socket6(sock);
  1698. break;
  1699. }
  1700. }
  1701. #else
  1702. static inline void xs_reclassify_socket(int family, struct socket *sock)
  1703. {
  1704. }
  1705. #endif
  1706. static void xs_dummy_setup_socket(struct work_struct *work)
  1707. {
  1708. }
  1709. static struct socket *xs_create_sock(struct rpc_xprt *xprt,
  1710. struct sock_xprt *transport, int family, int type,
  1711. int protocol, bool reuseport)
  1712. {
  1713. struct socket *sock;
  1714. int err;
  1715. err = __sock_create(xprt->xprt_net, family, type, protocol, &sock, 1);
  1716. if (err < 0) {
  1717. dprintk("RPC: can't create %d transport socket (%d).\n",
  1718. protocol, -err);
  1719. goto out;
  1720. }
  1721. xs_reclassify_socket(family, sock);
  1722. if (reuseport)
  1723. xs_sock_set_reuseport(sock);
  1724. err = xs_bind(transport, sock);
  1725. if (err) {
  1726. sock_release(sock);
  1727. goto out;
  1728. }
  1729. return sock;
  1730. out:
  1731. return ERR_PTR(err);
  1732. }
  1733. static int xs_local_finish_connecting(struct rpc_xprt *xprt,
  1734. struct socket *sock)
  1735. {
  1736. struct sock_xprt *transport = container_of(xprt, struct sock_xprt,
  1737. xprt);
  1738. if (!transport->inet) {
  1739. struct sock *sk = sock->sk;
  1740. write_lock_bh(&sk->sk_callback_lock);
  1741. xs_save_old_callbacks(transport, sk);
  1742. sk->sk_user_data = xprt;
  1743. sk->sk_data_ready = xs_data_ready;
  1744. sk->sk_write_space = xs_udp_write_space;
  1745. sock_set_flag(sk, SOCK_FASYNC);
  1746. sk->sk_error_report = xs_error_report;
  1747. sk->sk_allocation = GFP_NOIO;
  1748. xprt_clear_connected(xprt);
  1749. /* Reset to new socket */
  1750. transport->sock = sock;
  1751. transport->inet = sk;
  1752. write_unlock_bh(&sk->sk_callback_lock);
  1753. }
  1754. /* Tell the socket layer to start connecting... */
  1755. xprt->stat.connect_count++;
  1756. xprt->stat.connect_start = jiffies;
  1757. return kernel_connect(sock, xs_addr(xprt), xprt->addrlen, 0);
  1758. }
  1759. /**
  1760. * xs_local_setup_socket - create AF_LOCAL socket, connect to a local endpoint
  1761. * @transport: socket transport to connect
  1762. */
  1763. static int xs_local_setup_socket(struct sock_xprt *transport)
  1764. {
  1765. struct rpc_xprt *xprt = &transport->xprt;
  1766. struct socket *sock;
  1767. int status = -EIO;
  1768. status = __sock_create(xprt->xprt_net, AF_LOCAL,
  1769. SOCK_STREAM, 0, &sock, 1);
  1770. if (status < 0) {
  1771. dprintk("RPC: can't create AF_LOCAL "
  1772. "transport socket (%d).\n", -status);
  1773. goto out;
  1774. }
  1775. xs_reclassify_socket(AF_LOCAL, sock);
  1776. dprintk("RPC: worker connecting xprt %p via AF_LOCAL to %s\n",
  1777. xprt, xprt->address_strings[RPC_DISPLAY_ADDR]);
  1778. status = xs_local_finish_connecting(xprt, sock);
  1779. trace_rpc_socket_connect(xprt, sock, status);
  1780. switch (status) {
  1781. case 0:
  1782. dprintk("RPC: xprt %p connected to %s\n",
  1783. xprt, xprt->address_strings[RPC_DISPLAY_ADDR]);
  1784. xprt_set_connected(xprt);
  1785. case -ENOBUFS:
  1786. break;
  1787. case -ENOENT:
  1788. dprintk("RPC: xprt %p: socket %s does not exist\n",
  1789. xprt, xprt->address_strings[RPC_DISPLAY_ADDR]);
  1790. break;
  1791. case -ECONNREFUSED:
  1792. dprintk("RPC: xprt %p: connection refused for %s\n",
  1793. xprt, xprt->address_strings[RPC_DISPLAY_ADDR]);
  1794. break;
  1795. default:
  1796. printk(KERN_ERR "%s: unhandled error (%d) connecting to %s\n",
  1797. __func__, -status,
  1798. xprt->address_strings[RPC_DISPLAY_ADDR]);
  1799. }
  1800. out:
  1801. xprt_clear_connecting(xprt);
  1802. xprt_wake_pending_tasks(xprt, status);
  1803. return status;
  1804. }
  1805. static void xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task)
  1806. {
  1807. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1808. int ret;
  1809. if (RPC_IS_ASYNC(task)) {
  1810. /*
  1811. * We want the AF_LOCAL connect to be resolved in the
  1812. * filesystem namespace of the process making the rpc
  1813. * call. Thus we connect synchronously.
  1814. *
  1815. * If we want to support asynchronous AF_LOCAL calls,
  1816. * we'll need to figure out how to pass a namespace to
  1817. * connect.
  1818. */
  1819. rpc_exit(task, -ENOTCONN);
  1820. return;
  1821. }
  1822. ret = xs_local_setup_socket(transport);
  1823. if (ret && !RPC_IS_SOFTCONN(task))
  1824. msleep_interruptible(15000);
  1825. }
  1826. #if IS_ENABLED(CONFIG_SUNRPC_SWAP)
  1827. /*
  1828. * Note that this should be called with XPRT_LOCKED held (or when we otherwise
  1829. * know that we have exclusive access to the socket), to guard against
  1830. * races with xs_reset_transport.
  1831. */
  1832. static void xs_set_memalloc(struct rpc_xprt *xprt)
  1833. {
  1834. struct sock_xprt *transport = container_of(xprt, struct sock_xprt,
  1835. xprt);
  1836. /*
  1837. * If there's no sock, then we have nothing to set. The
  1838. * reconnecting process will get it for us.
  1839. */
  1840. if (!transport->inet)
  1841. return;
  1842. if (atomic_read(&xprt->swapper))
  1843. sk_set_memalloc(transport->inet);
  1844. }
  1845. /**
  1846. * xs_enable_swap - Tag this transport as being used for swap.
  1847. * @xprt: transport to tag
  1848. *
  1849. * Take a reference to this transport on behalf of the rpc_clnt, and
  1850. * optionally mark it for swapping if it wasn't already.
  1851. */
  1852. static int
  1853. xs_enable_swap(struct rpc_xprt *xprt)
  1854. {
  1855. struct sock_xprt *xs = container_of(xprt, struct sock_xprt, xprt);
  1856. if (atomic_inc_return(&xprt->swapper) != 1)
  1857. return 0;
  1858. if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE))
  1859. return -ERESTARTSYS;
  1860. if (xs->inet)
  1861. sk_set_memalloc(xs->inet);
  1862. xprt_release_xprt(xprt, NULL);
  1863. return 0;
  1864. }
  1865. /**
  1866. * xs_disable_swap - Untag this transport as being used for swap.
  1867. * @xprt: transport to tag
  1868. *
  1869. * Drop a "swapper" reference to this xprt on behalf of the rpc_clnt. If the
  1870. * swapper refcount goes to 0, untag the socket as a memalloc socket.
  1871. */
  1872. static void
  1873. xs_disable_swap(struct rpc_xprt *xprt)
  1874. {
  1875. struct sock_xprt *xs = container_of(xprt, struct sock_xprt, xprt);
  1876. if (!atomic_dec_and_test(&xprt->swapper))
  1877. return;
  1878. if (wait_on_bit_lock(&xprt->state, XPRT_LOCKED, TASK_KILLABLE))
  1879. return;
  1880. if (xs->inet)
  1881. sk_clear_memalloc(xs->inet);
  1882. xprt_release_xprt(xprt, NULL);
  1883. }
  1884. #else
  1885. static void xs_set_memalloc(struct rpc_xprt *xprt)
  1886. {
  1887. }
  1888. static int
  1889. xs_enable_swap(struct rpc_xprt *xprt)
  1890. {
  1891. return -EINVAL;
  1892. }
  1893. static void
  1894. xs_disable_swap(struct rpc_xprt *xprt)
  1895. {
  1896. }
  1897. #endif
  1898. static void xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock)
  1899. {
  1900. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1901. if (!transport->inet) {
  1902. struct sock *sk = sock->sk;
  1903. write_lock_bh(&sk->sk_callback_lock);
  1904. xs_save_old_callbacks(transport, sk);
  1905. sk->sk_user_data = xprt;
  1906. sk->sk_data_ready = xs_data_ready;
  1907. sk->sk_write_space = xs_udp_write_space;
  1908. sock_set_flag(sk, SOCK_FASYNC);
  1909. sk->sk_allocation = GFP_NOIO;
  1910. xprt_set_connected(xprt);
  1911. /* Reset to new socket */
  1912. transport->sock = sock;
  1913. transport->inet = sk;
  1914. xs_set_memalloc(xprt);
  1915. write_unlock_bh(&sk->sk_callback_lock);
  1916. }
  1917. xs_udp_do_set_buffer_size(xprt);
  1918. xprt->stat.connect_start = jiffies;
  1919. }
  1920. static void xs_udp_setup_socket(struct work_struct *work)
  1921. {
  1922. struct sock_xprt *transport =
  1923. container_of(work, struct sock_xprt, connect_worker.work);
  1924. struct rpc_xprt *xprt = &transport->xprt;
  1925. struct socket *sock = transport->sock;
  1926. int status = -EIO;
  1927. sock = xs_create_sock(xprt, transport,
  1928. xs_addr(xprt)->sa_family, SOCK_DGRAM,
  1929. IPPROTO_UDP, false);
  1930. if (IS_ERR(sock))
  1931. goto out;
  1932. dprintk("RPC: worker connecting xprt %p via %s to "
  1933. "%s (port %s)\n", xprt,
  1934. xprt->address_strings[RPC_DISPLAY_PROTO],
  1935. xprt->address_strings[RPC_DISPLAY_ADDR],
  1936. xprt->address_strings[RPC_DISPLAY_PORT]);
  1937. xs_udp_finish_connecting(xprt, sock);
  1938. trace_rpc_socket_connect(xprt, sock, 0);
  1939. status = 0;
  1940. out:
  1941. xprt_unlock_connect(xprt, transport);
  1942. xprt_clear_connecting(xprt);
  1943. xprt_wake_pending_tasks(xprt, status);
  1944. }
  1945. /**
  1946. * xs_tcp_shutdown - gracefully shut down a TCP socket
  1947. * @xprt: transport
  1948. *
  1949. * Initiates a graceful shutdown of the TCP socket by calling the
  1950. * equivalent of shutdown(SHUT_RDWR);
  1951. */
  1952. static void xs_tcp_shutdown(struct rpc_xprt *xprt)
  1953. {
  1954. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1955. struct socket *sock = transport->sock;
  1956. if (sock == NULL)
  1957. return;
  1958. if (xprt_connected(xprt)) {
  1959. kernel_sock_shutdown(sock, SHUT_RDWR);
  1960. trace_rpc_socket_shutdown(xprt, sock);
  1961. } else
  1962. xs_reset_transport(transport);
  1963. }
  1964. static void xs_tcp_set_socket_timeouts(struct rpc_xprt *xprt,
  1965. struct socket *sock)
  1966. {
  1967. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1968. unsigned int keepidle;
  1969. unsigned int keepcnt;
  1970. unsigned int opt_on = 1;
  1971. unsigned int timeo;
  1972. spin_lock_bh(&xprt->transport_lock);
  1973. keepidle = DIV_ROUND_UP(xprt->timeout->to_initval, HZ);
  1974. keepcnt = xprt->timeout->to_retries + 1;
  1975. timeo = jiffies_to_msecs(xprt->timeout->to_initval) *
  1976. (xprt->timeout->to_retries + 1);
  1977. clear_bit(XPRT_SOCK_UPD_TIMEOUT, &transport->sock_state);
  1978. spin_unlock_bh(&xprt->transport_lock);
  1979. /* TCP Keepalive options */
  1980. kernel_setsockopt(sock, SOL_SOCKET, SO_KEEPALIVE,
  1981. (char *)&opt_on, sizeof(opt_on));
  1982. kernel_setsockopt(sock, SOL_TCP, TCP_KEEPIDLE,
  1983. (char *)&keepidle, sizeof(keepidle));
  1984. kernel_setsockopt(sock, SOL_TCP, TCP_KEEPINTVL,
  1985. (char *)&keepidle, sizeof(keepidle));
  1986. kernel_setsockopt(sock, SOL_TCP, TCP_KEEPCNT,
  1987. (char *)&keepcnt, sizeof(keepcnt));
  1988. /* TCP user timeout (see RFC5482) */
  1989. kernel_setsockopt(sock, SOL_TCP, TCP_USER_TIMEOUT,
  1990. (char *)&timeo, sizeof(timeo));
  1991. }
  1992. static void xs_tcp_set_connect_timeout(struct rpc_xprt *xprt,
  1993. unsigned long connect_timeout,
  1994. unsigned long reconnect_timeout)
  1995. {
  1996. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  1997. struct rpc_timeout to;
  1998. unsigned long initval;
  1999. spin_lock_bh(&xprt->transport_lock);
  2000. if (reconnect_timeout < xprt->max_reconnect_timeout)
  2001. xprt->max_reconnect_timeout = reconnect_timeout;
  2002. if (connect_timeout < xprt->connect_timeout) {
  2003. memcpy(&to, xprt->timeout, sizeof(to));
  2004. initval = DIV_ROUND_UP(connect_timeout, to.to_retries + 1);
  2005. /* Arbitrary lower limit */
  2006. if (initval < XS_TCP_INIT_REEST_TO << 1)
  2007. initval = XS_TCP_INIT_REEST_TO << 1;
  2008. to.to_initval = initval;
  2009. to.to_maxval = initval;
  2010. memcpy(&transport->tcp_timeout, &to,
  2011. sizeof(transport->tcp_timeout));
  2012. xprt->timeout = &transport->tcp_timeout;
  2013. xprt->connect_timeout = connect_timeout;
  2014. }
  2015. set_bit(XPRT_SOCK_UPD_TIMEOUT, &transport->sock_state);
  2016. spin_unlock_bh(&xprt->transport_lock);
  2017. }
  2018. static int xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock)
  2019. {
  2020. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  2021. int ret = -ENOTCONN;
  2022. if (!transport->inet) {
  2023. struct sock *sk = sock->sk;
  2024. unsigned int addr_pref = IPV6_PREFER_SRC_PUBLIC;
  2025. /* Avoid temporary address, they are bad for long-lived
  2026. * connections such as NFS mounts.
  2027. * RFC4941, section 3.6 suggests that:
  2028. * Individual applications, which have specific
  2029. * knowledge about the normal duration of connections,
  2030. * MAY override this as appropriate.
  2031. */
  2032. kernel_setsockopt(sock, SOL_IPV6, IPV6_ADDR_PREFERENCES,
  2033. (char *)&addr_pref, sizeof(addr_pref));
  2034. xs_tcp_set_socket_timeouts(xprt, sock);
  2035. write_lock_bh(&sk->sk_callback_lock);
  2036. xs_save_old_callbacks(transport, sk);
  2037. sk->sk_user_data = xprt;
  2038. sk->sk_data_ready = xs_data_ready;
  2039. sk->sk_state_change = xs_tcp_state_change;
  2040. sk->sk_write_space = xs_tcp_write_space;
  2041. sock_set_flag(sk, SOCK_FASYNC);
  2042. sk->sk_error_report = xs_error_report;
  2043. sk->sk_allocation = GFP_NOIO;
  2044. /* socket options */
  2045. sock_reset_flag(sk, SOCK_LINGER);
  2046. tcp_sk(sk)->nonagle |= TCP_NAGLE_OFF;
  2047. xprt_clear_connected(xprt);
  2048. /* Reset to new socket */
  2049. transport->sock = sock;
  2050. transport->inet = sk;
  2051. write_unlock_bh(&sk->sk_callback_lock);
  2052. }
  2053. if (!xprt_bound(xprt))
  2054. goto out;
  2055. xs_set_memalloc(xprt);
  2056. /* Tell the socket layer to start connecting... */
  2057. xprt->stat.connect_count++;
  2058. xprt->stat.connect_start = jiffies;
  2059. set_bit(XPRT_SOCK_CONNECTING, &transport->sock_state);
  2060. ret = kernel_connect(sock, xs_addr(xprt), xprt->addrlen, O_NONBLOCK);
  2061. switch (ret) {
  2062. case 0:
  2063. xs_set_srcport(transport, sock);
  2064. case -EINPROGRESS:
  2065. /* SYN_SENT! */
  2066. if (xprt->reestablish_timeout < XS_TCP_INIT_REEST_TO)
  2067. xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO;
  2068. break;
  2069. case -EADDRNOTAVAIL:
  2070. /* Source port number is unavailable. Try a new one! */
  2071. transport->srcport = 0;
  2072. }
  2073. out:
  2074. return ret;
  2075. }
  2076. /**
  2077. * xs_tcp_setup_socket - create a TCP socket and connect to a remote endpoint
  2078. *
  2079. * Invoked by a work queue tasklet.
  2080. */
  2081. static void xs_tcp_setup_socket(struct work_struct *work)
  2082. {
  2083. struct sock_xprt *transport =
  2084. container_of(work, struct sock_xprt, connect_worker.work);
  2085. struct socket *sock = transport->sock;
  2086. struct rpc_xprt *xprt = &transport->xprt;
  2087. int status = -EIO;
  2088. if (!sock) {
  2089. sock = xs_create_sock(xprt, transport,
  2090. xs_addr(xprt)->sa_family, SOCK_STREAM,
  2091. IPPROTO_TCP, true);
  2092. if (IS_ERR(sock)) {
  2093. status = PTR_ERR(sock);
  2094. goto out;
  2095. }
  2096. }
  2097. dprintk("RPC: worker connecting xprt %p via %s to "
  2098. "%s (port %s)\n", xprt,
  2099. xprt->address_strings[RPC_DISPLAY_PROTO],
  2100. xprt->address_strings[RPC_DISPLAY_ADDR],
  2101. xprt->address_strings[RPC_DISPLAY_PORT]);
  2102. status = xs_tcp_finish_connecting(xprt, sock);
  2103. trace_rpc_socket_connect(xprt, sock, status);
  2104. dprintk("RPC: %p connect status %d connected %d sock state %d\n",
  2105. xprt, -status, xprt_connected(xprt),
  2106. sock->sk->sk_state);
  2107. switch (status) {
  2108. default:
  2109. printk("%s: connect returned unhandled error %d\n",
  2110. __func__, status);
  2111. case -EADDRNOTAVAIL:
  2112. /* We're probably in TIME_WAIT. Get rid of existing socket,
  2113. * and retry
  2114. */
  2115. xs_tcp_force_close(xprt);
  2116. break;
  2117. case 0:
  2118. case -EINPROGRESS:
  2119. case -EALREADY:
  2120. xprt_unlock_connect(xprt, transport);
  2121. return;
  2122. case -EINVAL:
  2123. /* Happens, for instance, if the user specified a link
  2124. * local IPv6 address without a scope-id.
  2125. */
  2126. case -ECONNREFUSED:
  2127. case -ECONNRESET:
  2128. case -ENETUNREACH:
  2129. case -EADDRINUSE:
  2130. case -ENOBUFS:
  2131. /* retry with existing socket, after a delay */
  2132. xs_tcp_force_close(xprt);
  2133. goto out;
  2134. }
  2135. status = -EAGAIN;
  2136. out:
  2137. xprt_unlock_connect(xprt, transport);
  2138. xprt_clear_connecting(xprt);
  2139. xprt_wake_pending_tasks(xprt, status);
  2140. }
  2141. static unsigned long xs_reconnect_delay(const struct rpc_xprt *xprt)
  2142. {
  2143. unsigned long start, now = jiffies;
  2144. start = xprt->stat.connect_start + xprt->reestablish_timeout;
  2145. if (time_after(start, now))
  2146. return start - now;
  2147. return 0;
  2148. }
  2149. static void xs_reconnect_backoff(struct rpc_xprt *xprt)
  2150. {
  2151. xprt->reestablish_timeout <<= 1;
  2152. if (xprt->reestablish_timeout > xprt->max_reconnect_timeout)
  2153. xprt->reestablish_timeout = xprt->max_reconnect_timeout;
  2154. if (xprt->reestablish_timeout < XS_TCP_INIT_REEST_TO)
  2155. xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO;
  2156. }
  2157. /**
  2158. * xs_connect - connect a socket to a remote endpoint
  2159. * @xprt: pointer to transport structure
  2160. * @task: address of RPC task that manages state of connect request
  2161. *
  2162. * TCP: If the remote end dropped the connection, delay reconnecting.
  2163. *
  2164. * UDP socket connects are synchronous, but we use a work queue anyway
  2165. * to guarantee that even unprivileged user processes can set up a
  2166. * socket on a privileged port.
  2167. *
  2168. * If a UDP socket connect fails, the delay behavior here prevents
  2169. * retry floods (hard mounts).
  2170. */
  2171. static void xs_connect(struct rpc_xprt *xprt, struct rpc_task *task)
  2172. {
  2173. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  2174. unsigned long delay = 0;
  2175. WARN_ON_ONCE(!xprt_lock_connect(xprt, task, transport));
  2176. if (transport->sock != NULL) {
  2177. dprintk("RPC: xs_connect delayed xprt %p for %lu "
  2178. "seconds\n",
  2179. xprt, xprt->reestablish_timeout / HZ);
  2180. /* Start by resetting any existing state */
  2181. xs_reset_transport(transport);
  2182. delay = xs_reconnect_delay(xprt);
  2183. xs_reconnect_backoff(xprt);
  2184. } else
  2185. dprintk("RPC: xs_connect scheduled xprt %p\n", xprt);
  2186. queue_delayed_work(xprtiod_workqueue,
  2187. &transport->connect_worker,
  2188. delay);
  2189. }
  2190. /**
  2191. * xs_local_print_stats - display AF_LOCAL socket-specifc stats
  2192. * @xprt: rpc_xprt struct containing statistics
  2193. * @seq: output file
  2194. *
  2195. */
  2196. static void xs_local_print_stats(struct rpc_xprt *xprt, struct seq_file *seq)
  2197. {
  2198. long idle_time = 0;
  2199. if (xprt_connected(xprt))
  2200. idle_time = (long)(jiffies - xprt->last_used) / HZ;
  2201. seq_printf(seq, "\txprt:\tlocal %lu %lu %lu %ld %lu %lu %lu "
  2202. "%llu %llu %lu %llu %llu\n",
  2203. xprt->stat.bind_count,
  2204. xprt->stat.connect_count,
  2205. xprt->stat.connect_time,
  2206. idle_time,
  2207. xprt->stat.sends,
  2208. xprt->stat.recvs,
  2209. xprt->stat.bad_xids,
  2210. xprt->stat.req_u,
  2211. xprt->stat.bklog_u,
  2212. xprt->stat.max_slots,
  2213. xprt->stat.sending_u,
  2214. xprt->stat.pending_u);
  2215. }
  2216. /**
  2217. * xs_udp_print_stats - display UDP socket-specifc stats
  2218. * @xprt: rpc_xprt struct containing statistics
  2219. * @seq: output file
  2220. *
  2221. */
  2222. static void xs_udp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq)
  2223. {
  2224. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  2225. seq_printf(seq, "\txprt:\tudp %u %lu %lu %lu %lu %llu %llu "
  2226. "%lu %llu %llu\n",
  2227. transport->srcport,
  2228. xprt->stat.bind_count,
  2229. xprt->stat.sends,
  2230. xprt->stat.recvs,
  2231. xprt->stat.bad_xids,
  2232. xprt->stat.req_u,
  2233. xprt->stat.bklog_u,
  2234. xprt->stat.max_slots,
  2235. xprt->stat.sending_u,
  2236. xprt->stat.pending_u);
  2237. }
  2238. /**
  2239. * xs_tcp_print_stats - display TCP socket-specifc stats
  2240. * @xprt: rpc_xprt struct containing statistics
  2241. * @seq: output file
  2242. *
  2243. */
  2244. static void xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq)
  2245. {
  2246. struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
  2247. long idle_time = 0;
  2248. if (xprt_connected(xprt))
  2249. idle_time = (long)(jiffies - xprt->last_used) / HZ;
  2250. seq_printf(seq, "\txprt:\ttcp %u %lu %lu %lu %ld %lu %lu %lu "
  2251. "%llu %llu %lu %llu %llu\n",
  2252. transport->srcport,
  2253. xprt->stat.bind_count,
  2254. xprt->stat.connect_count,
  2255. xprt->stat.connect_time,
  2256. idle_time,
  2257. xprt->stat.sends,
  2258. xprt->stat.recvs,
  2259. xprt->stat.bad_xids,
  2260. xprt->stat.req_u,
  2261. xprt->stat.bklog_u,
  2262. xprt->stat.max_slots,
  2263. xprt->stat.sending_u,
  2264. xprt->stat.pending_u);
  2265. }
  2266. /*
  2267. * Allocate a bunch of pages for a scratch buffer for the rpc code. The reason
  2268. * we allocate pages instead doing a kmalloc like rpc_malloc is because we want
  2269. * to use the server side send routines.
  2270. */
  2271. static int bc_malloc(struct rpc_task *task)
  2272. {
  2273. struct rpc_rqst *rqst = task->tk_rqstp;
  2274. size_t size = rqst->rq_callsize;
  2275. struct page *page;
  2276. struct rpc_buffer *buf;
  2277. if (size > PAGE_SIZE - sizeof(struct rpc_buffer)) {
  2278. WARN_ONCE(1, "xprtsock: large bc buffer request (size %zu)\n",
  2279. size);
  2280. return -EINVAL;
  2281. }
  2282. page = alloc_page(GFP_KERNEL);
  2283. if (!page)
  2284. return -ENOMEM;
  2285. buf = page_address(page);
  2286. buf->len = PAGE_SIZE;
  2287. rqst->rq_buffer = buf->data;
  2288. rqst->rq_rbuffer = (char *)rqst->rq_buffer + rqst->rq_callsize;
  2289. return 0;
  2290. }
  2291. /*
  2292. * Free the space allocated in the bc_alloc routine
  2293. */
  2294. static void bc_free(struct rpc_task *task)
  2295. {
  2296. void *buffer = task->tk_rqstp->rq_buffer;
  2297. struct rpc_buffer *buf;
  2298. buf = container_of(buffer, struct rpc_buffer, data);
  2299. free_page((unsigned long)buf);
  2300. }
  2301. /*
  2302. * Use the svc_sock to send the callback. Must be called with svsk->sk_mutex
  2303. * held. Borrows heavily from svc_tcp_sendto and xs_tcp_send_request.
  2304. */
  2305. static int bc_sendto(struct rpc_rqst *req)
  2306. {
  2307. int len;
  2308. struct xdr_buf *xbufp = &req->rq_snd_buf;
  2309. struct rpc_xprt *xprt = req->rq_xprt;
  2310. struct sock_xprt *transport =
  2311. container_of(xprt, struct sock_xprt, xprt);
  2312. struct socket *sock = transport->sock;
  2313. unsigned long headoff;
  2314. unsigned long tailoff;
  2315. xs_encode_stream_record_marker(xbufp);
  2316. tailoff = (unsigned long)xbufp->tail[0].iov_base & ~PAGE_MASK;
  2317. headoff = (unsigned long)xbufp->head[0].iov_base & ~PAGE_MASK;
  2318. len = svc_send_common(sock, xbufp,
  2319. virt_to_page(xbufp->head[0].iov_base), headoff,
  2320. xbufp->tail[0].iov_base, tailoff);
  2321. if (len != xbufp->len) {
  2322. printk(KERN_NOTICE "Error sending entire callback!\n");
  2323. len = -EAGAIN;
  2324. }
  2325. return len;
  2326. }
  2327. /*
  2328. * The send routine. Borrows from svc_send
  2329. */
  2330. static int bc_send_request(struct rpc_task *task)
  2331. {
  2332. struct rpc_rqst *req = task->tk_rqstp;
  2333. struct svc_xprt *xprt;
  2334. int len;
  2335. dprintk("sending request with xid: %08x\n", ntohl(req->rq_xid));
  2336. /*
  2337. * Get the server socket associated with this callback xprt
  2338. */
  2339. xprt = req->rq_xprt->bc_xprt;
  2340. /*
  2341. * Grab the mutex to serialize data as the connection is shared
  2342. * with the fore channel
  2343. */
  2344. if (!mutex_trylock(&xprt->xpt_mutex)) {
  2345. rpc_sleep_on(&xprt->xpt_bc_pending, task, NULL);
  2346. if (!mutex_trylock(&xprt->xpt_mutex))
  2347. return -EAGAIN;
  2348. rpc_wake_up_queued_task(&xprt->xpt_bc_pending, task);
  2349. }
  2350. if (test_bit(XPT_DEAD, &xprt->xpt_flags))
  2351. len = -ENOTCONN;
  2352. else
  2353. len = bc_sendto(req);
  2354. mutex_unlock(&xprt->xpt_mutex);
  2355. if (len > 0)
  2356. len = 0;
  2357. return len;
  2358. }
  2359. /*
  2360. * The close routine. Since this is client initiated, we do nothing
  2361. */
  2362. static void bc_close(struct rpc_xprt *xprt)
  2363. {
  2364. }
  2365. /*
  2366. * The xprt destroy routine. Again, because this connection is client
  2367. * initiated, we do nothing
  2368. */
  2369. static void bc_destroy(struct rpc_xprt *xprt)
  2370. {
  2371. dprintk("RPC: bc_destroy xprt %p\n", xprt);
  2372. xs_xprt_free(xprt);
  2373. module_put(THIS_MODULE);
  2374. }
  2375. static struct rpc_xprt_ops xs_local_ops = {
  2376. .reserve_xprt = xprt_reserve_xprt,
  2377. .release_xprt = xs_tcp_release_xprt,
  2378. .alloc_slot = xprt_alloc_slot,
  2379. .rpcbind = xs_local_rpcbind,
  2380. .set_port = xs_local_set_port,
  2381. .connect = xs_local_connect,
  2382. .buf_alloc = rpc_malloc,
  2383. .buf_free = rpc_free,
  2384. .send_request = xs_local_send_request,
  2385. .set_retrans_timeout = xprt_set_retrans_timeout_def,
  2386. .close = xs_close,
  2387. .destroy = xs_destroy,
  2388. .print_stats = xs_local_print_stats,
  2389. .enable_swap = xs_enable_swap,
  2390. .disable_swap = xs_disable_swap,
  2391. };
  2392. static struct rpc_xprt_ops xs_udp_ops = {
  2393. .set_buffer_size = xs_udp_set_buffer_size,
  2394. .reserve_xprt = xprt_reserve_xprt_cong,
  2395. .release_xprt = xprt_release_xprt_cong,
  2396. .alloc_slot = xprt_alloc_slot,
  2397. .rpcbind = rpcb_getport_async,
  2398. .set_port = xs_set_port,
  2399. .connect = xs_connect,
  2400. .buf_alloc = rpc_malloc,
  2401. .buf_free = rpc_free,
  2402. .send_request = xs_udp_send_request,
  2403. .set_retrans_timeout = xprt_set_retrans_timeout_rtt,
  2404. .timer = xs_udp_timer,
  2405. .release_request = xprt_release_rqst_cong,
  2406. .close = xs_close,
  2407. .destroy = xs_destroy,
  2408. .print_stats = xs_udp_print_stats,
  2409. .enable_swap = xs_enable_swap,
  2410. .disable_swap = xs_disable_swap,
  2411. .inject_disconnect = xs_inject_disconnect,
  2412. };
  2413. static struct rpc_xprt_ops xs_tcp_ops = {
  2414. .reserve_xprt = xprt_reserve_xprt,
  2415. .release_xprt = xs_tcp_release_xprt,
  2416. .alloc_slot = xprt_lock_and_alloc_slot,
  2417. .rpcbind = rpcb_getport_async,
  2418. .set_port = xs_set_port,
  2419. .connect = xs_connect,
  2420. .buf_alloc = rpc_malloc,
  2421. .buf_free = rpc_free,
  2422. .send_request = xs_tcp_send_request,
  2423. .set_retrans_timeout = xprt_set_retrans_timeout_def,
  2424. .close = xs_tcp_shutdown,
  2425. .destroy = xs_destroy,
  2426. .set_connect_timeout = xs_tcp_set_connect_timeout,
  2427. .print_stats = xs_tcp_print_stats,
  2428. .enable_swap = xs_enable_swap,
  2429. .disable_swap = xs_disable_swap,
  2430. .inject_disconnect = xs_inject_disconnect,
  2431. #ifdef CONFIG_SUNRPC_BACKCHANNEL
  2432. .bc_setup = xprt_setup_bc,
  2433. .bc_up = xs_tcp_bc_up,
  2434. .bc_maxpayload = xs_tcp_bc_maxpayload,
  2435. .bc_free_rqst = xprt_free_bc_rqst,
  2436. .bc_destroy = xprt_destroy_bc,
  2437. #endif
  2438. };
  2439. /*
  2440. * The rpc_xprt_ops for the server backchannel
  2441. */
  2442. static struct rpc_xprt_ops bc_tcp_ops = {
  2443. .reserve_xprt = xprt_reserve_xprt,
  2444. .release_xprt = xprt_release_xprt,
  2445. .alloc_slot = xprt_alloc_slot,
  2446. .buf_alloc = bc_malloc,
  2447. .buf_free = bc_free,
  2448. .send_request = bc_send_request,
  2449. .set_retrans_timeout = xprt_set_retrans_timeout_def,
  2450. .close = bc_close,
  2451. .destroy = bc_destroy,
  2452. .print_stats = xs_tcp_print_stats,
  2453. .enable_swap = xs_enable_swap,
  2454. .disable_swap = xs_disable_swap,
  2455. .inject_disconnect = xs_inject_disconnect,
  2456. };
  2457. static int xs_init_anyaddr(const int family, struct sockaddr *sap)
  2458. {
  2459. static const struct sockaddr_in sin = {
  2460. .sin_family = AF_INET,
  2461. .sin_addr.s_addr = htonl(INADDR_ANY),
  2462. };
  2463. static const struct sockaddr_in6 sin6 = {
  2464. .sin6_family = AF_INET6,
  2465. .sin6_addr = IN6ADDR_ANY_INIT,
  2466. };
  2467. switch (family) {
  2468. case AF_LOCAL:
  2469. break;
  2470. case AF_INET:
  2471. memcpy(sap, &sin, sizeof(sin));
  2472. break;
  2473. case AF_INET6:
  2474. memcpy(sap, &sin6, sizeof(sin6));
  2475. break;
  2476. default:
  2477. dprintk("RPC: %s: Bad address family\n", __func__);
  2478. return -EAFNOSUPPORT;
  2479. }
  2480. return 0;
  2481. }
  2482. static struct rpc_xprt *xs_setup_xprt(struct xprt_create *args,
  2483. unsigned int slot_table_size,
  2484. unsigned int max_slot_table_size)
  2485. {
  2486. struct rpc_xprt *xprt;
  2487. struct sock_xprt *new;
  2488. if (args->addrlen > sizeof(xprt->addr)) {
  2489. dprintk("RPC: xs_setup_xprt: address too large\n");
  2490. return ERR_PTR(-EBADF);
  2491. }
  2492. xprt = xprt_alloc(args->net, sizeof(*new), slot_table_size,
  2493. max_slot_table_size);
  2494. if (xprt == NULL) {
  2495. dprintk("RPC: xs_setup_xprt: couldn't allocate "
  2496. "rpc_xprt\n");
  2497. return ERR_PTR(-ENOMEM);
  2498. }
  2499. new = container_of(xprt, struct sock_xprt, xprt);
  2500. mutex_init(&new->recv_mutex);
  2501. memcpy(&xprt->addr, args->dstaddr, args->addrlen);
  2502. xprt->addrlen = args->addrlen;
  2503. if (args->srcaddr)
  2504. memcpy(&new->srcaddr, args->srcaddr, args->addrlen);
  2505. else {
  2506. int err;
  2507. err = xs_init_anyaddr(args->dstaddr->sa_family,
  2508. (struct sockaddr *)&new->srcaddr);
  2509. if (err != 0) {
  2510. xprt_free(xprt);
  2511. return ERR_PTR(err);
  2512. }
  2513. }
  2514. return xprt;
  2515. }
  2516. static const struct rpc_timeout xs_local_default_timeout = {
  2517. .to_initval = 10 * HZ,
  2518. .to_maxval = 10 * HZ,
  2519. .to_retries = 2,
  2520. };
  2521. /**
  2522. * xs_setup_local - Set up transport to use an AF_LOCAL socket
  2523. * @args: rpc transport creation arguments
  2524. *
  2525. * AF_LOCAL is a "tpi_cots_ord" transport, just like TCP
  2526. */
  2527. static struct rpc_xprt *xs_setup_local(struct xprt_create *args)
  2528. {
  2529. struct sockaddr_un *sun = (struct sockaddr_un *)args->dstaddr;
  2530. struct sock_xprt *transport;
  2531. struct rpc_xprt *xprt;
  2532. struct rpc_xprt *ret;
  2533. xprt = xs_setup_xprt(args, xprt_tcp_slot_table_entries,
  2534. xprt_max_tcp_slot_table_entries);
  2535. if (IS_ERR(xprt))
  2536. return xprt;
  2537. transport = container_of(xprt, struct sock_xprt, xprt);
  2538. xprt->prot = 0;
  2539. xprt->tsh_size = sizeof(rpc_fraghdr) / sizeof(u32);
  2540. xprt->max_payload = RPC_MAX_FRAGMENT_SIZE;
  2541. xprt->bind_timeout = XS_BIND_TO;
  2542. xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO;
  2543. xprt->idle_timeout = XS_IDLE_DISC_TO;
  2544. xprt->ops = &xs_local_ops;
  2545. xprt->timeout = &xs_local_default_timeout;
  2546. INIT_WORK(&transport->recv_worker, xs_local_data_receive_workfn);
  2547. INIT_DELAYED_WORK(&transport->connect_worker,
  2548. xs_dummy_setup_socket);
  2549. switch (sun->sun_family) {
  2550. case AF_LOCAL:
  2551. if (sun->sun_path[0] != '/') {
  2552. dprintk("RPC: bad AF_LOCAL address: %s\n",
  2553. sun->sun_path);
  2554. ret = ERR_PTR(-EINVAL);
  2555. goto out_err;
  2556. }
  2557. xprt_set_bound(xprt);
  2558. xs_format_peer_addresses(xprt, "local", RPCBIND_NETID_LOCAL);
  2559. ret = ERR_PTR(xs_local_setup_socket(transport));
  2560. if (ret)
  2561. goto out_err;
  2562. break;
  2563. default:
  2564. ret = ERR_PTR(-EAFNOSUPPORT);
  2565. goto out_err;
  2566. }
  2567. dprintk("RPC: set up xprt to %s via AF_LOCAL\n",
  2568. xprt->address_strings[RPC_DISPLAY_ADDR]);
  2569. if (try_module_get(THIS_MODULE))
  2570. return xprt;
  2571. ret = ERR_PTR(-EINVAL);
  2572. out_err:
  2573. xs_xprt_free(xprt);
  2574. return ret;
  2575. }
  2576. static const struct rpc_timeout xs_udp_default_timeout = {
  2577. .to_initval = 5 * HZ,
  2578. .to_maxval = 30 * HZ,
  2579. .to_increment = 5 * HZ,
  2580. .to_retries = 5,
  2581. };
  2582. /**
  2583. * xs_setup_udp - Set up transport to use a UDP socket
  2584. * @args: rpc transport creation arguments
  2585. *
  2586. */
  2587. static struct rpc_xprt *xs_setup_udp(struct xprt_create *args)
  2588. {
  2589. struct sockaddr *addr = args->dstaddr;
  2590. struct rpc_xprt *xprt;
  2591. struct sock_xprt *transport;
  2592. struct rpc_xprt *ret;
  2593. xprt = xs_setup_xprt(args, xprt_udp_slot_table_entries,
  2594. xprt_udp_slot_table_entries);
  2595. if (IS_ERR(xprt))
  2596. return xprt;
  2597. transport = container_of(xprt, struct sock_xprt, xprt);
  2598. xprt->prot = IPPROTO_UDP;
  2599. xprt->tsh_size = 0;
  2600. /* XXX: header size can vary due to auth type, IPv6, etc. */
  2601. xprt->max_payload = (1U << 16) - (MAX_HEADER << 3);
  2602. xprt->bind_timeout = XS_BIND_TO;
  2603. xprt->reestablish_timeout = XS_UDP_REEST_TO;
  2604. xprt->idle_timeout = XS_IDLE_DISC_TO;
  2605. xprt->ops = &xs_udp_ops;
  2606. xprt->timeout = &xs_udp_default_timeout;
  2607. INIT_WORK(&transport->recv_worker, xs_udp_data_receive_workfn);
  2608. INIT_DELAYED_WORK(&transport->connect_worker, xs_udp_setup_socket);
  2609. switch (addr->sa_family) {
  2610. case AF_INET:
  2611. if (((struct sockaddr_in *)addr)->sin_port != htons(0))
  2612. xprt_set_bound(xprt);
  2613. xs_format_peer_addresses(xprt, "udp", RPCBIND_NETID_UDP);
  2614. break;
  2615. case AF_INET6:
  2616. if (((struct sockaddr_in6 *)addr)->sin6_port != htons(0))
  2617. xprt_set_bound(xprt);
  2618. xs_format_peer_addresses(xprt, "udp", RPCBIND_NETID_UDP6);
  2619. break;
  2620. default:
  2621. ret = ERR_PTR(-EAFNOSUPPORT);
  2622. goto out_err;
  2623. }
  2624. if (xprt_bound(xprt))
  2625. dprintk("RPC: set up xprt to %s (port %s) via %s\n",
  2626. xprt->address_strings[RPC_DISPLAY_ADDR],
  2627. xprt->address_strings[RPC_DISPLAY_PORT],
  2628. xprt->address_strings[RPC_DISPLAY_PROTO]);
  2629. else
  2630. dprintk("RPC: set up xprt to %s (autobind) via %s\n",
  2631. xprt->address_strings[RPC_DISPLAY_ADDR],
  2632. xprt->address_strings[RPC_DISPLAY_PROTO]);
  2633. if (try_module_get(THIS_MODULE))
  2634. return xprt;
  2635. ret = ERR_PTR(-EINVAL);
  2636. out_err:
  2637. xs_xprt_free(xprt);
  2638. return ret;
  2639. }
  2640. static const struct rpc_timeout xs_tcp_default_timeout = {
  2641. .to_initval = 60 * HZ,
  2642. .to_maxval = 60 * HZ,
  2643. .to_retries = 2,
  2644. };
  2645. /**
  2646. * xs_setup_tcp - Set up transport to use a TCP socket
  2647. * @args: rpc transport creation arguments
  2648. *
  2649. */
  2650. static struct rpc_xprt *xs_setup_tcp(struct xprt_create *args)
  2651. {
  2652. struct sockaddr *addr = args->dstaddr;
  2653. struct rpc_xprt *xprt;
  2654. struct sock_xprt *transport;
  2655. struct rpc_xprt *ret;
  2656. unsigned int max_slot_table_size = xprt_max_tcp_slot_table_entries;
  2657. if (args->flags & XPRT_CREATE_INFINITE_SLOTS)
  2658. max_slot_table_size = RPC_MAX_SLOT_TABLE_LIMIT;
  2659. xprt = xs_setup_xprt(args, xprt_tcp_slot_table_entries,
  2660. max_slot_table_size);
  2661. if (IS_ERR(xprt))
  2662. return xprt;
  2663. transport = container_of(xprt, struct sock_xprt, xprt);
  2664. xprt->prot = IPPROTO_TCP;
  2665. xprt->tsh_size = sizeof(rpc_fraghdr) / sizeof(u32);
  2666. xprt->max_payload = RPC_MAX_FRAGMENT_SIZE;
  2667. xprt->bind_timeout = XS_BIND_TO;
  2668. xprt->reestablish_timeout = XS_TCP_INIT_REEST_TO;
  2669. xprt->idle_timeout = XS_IDLE_DISC_TO;
  2670. xprt->ops = &xs_tcp_ops;
  2671. xprt->timeout = &xs_tcp_default_timeout;
  2672. xprt->max_reconnect_timeout = xprt->timeout->to_maxval;
  2673. xprt->connect_timeout = xprt->timeout->to_initval *
  2674. (xprt->timeout->to_retries + 1);
  2675. INIT_WORK(&transport->recv_worker, xs_tcp_data_receive_workfn);
  2676. INIT_DELAYED_WORK(&transport->connect_worker, xs_tcp_setup_socket);
  2677. switch (addr->sa_family) {
  2678. case AF_INET:
  2679. if (((struct sockaddr_in *)addr)->sin_port != htons(0))
  2680. xprt_set_bound(xprt);
  2681. xs_format_peer_addresses(xprt, "tcp", RPCBIND_NETID_TCP);
  2682. break;
  2683. case AF_INET6:
  2684. if (((struct sockaddr_in6 *)addr)->sin6_port != htons(0))
  2685. xprt_set_bound(xprt);
  2686. xs_format_peer_addresses(xprt, "tcp", RPCBIND_NETID_TCP6);
  2687. break;
  2688. default:
  2689. ret = ERR_PTR(-EAFNOSUPPORT);
  2690. goto out_err;
  2691. }
  2692. if (xprt_bound(xprt))
  2693. dprintk("RPC: set up xprt to %s (port %s) via %s\n",
  2694. xprt->address_strings[RPC_DISPLAY_ADDR],
  2695. xprt->address_strings[RPC_DISPLAY_PORT],
  2696. xprt->address_strings[RPC_DISPLAY_PROTO]);
  2697. else
  2698. dprintk("RPC: set up xprt to %s (autobind) via %s\n",
  2699. xprt->address_strings[RPC_DISPLAY_ADDR],
  2700. xprt->address_strings[RPC_DISPLAY_PROTO]);
  2701. if (try_module_get(THIS_MODULE))
  2702. return xprt;
  2703. ret = ERR_PTR(-EINVAL);
  2704. out_err:
  2705. xs_xprt_free(xprt);
  2706. return ret;
  2707. }
  2708. /**
  2709. * xs_setup_bc_tcp - Set up transport to use a TCP backchannel socket
  2710. * @args: rpc transport creation arguments
  2711. *
  2712. */
  2713. static struct rpc_xprt *xs_setup_bc_tcp(struct xprt_create *args)
  2714. {
  2715. struct sockaddr *addr = args->dstaddr;
  2716. struct rpc_xprt *xprt;
  2717. struct sock_xprt *transport;
  2718. struct svc_sock *bc_sock;
  2719. struct rpc_xprt *ret;
  2720. xprt = xs_setup_xprt(args, xprt_tcp_slot_table_entries,
  2721. xprt_tcp_slot_table_entries);
  2722. if (IS_ERR(xprt))
  2723. return xprt;
  2724. transport = container_of(xprt, struct sock_xprt, xprt);
  2725. xprt->prot = IPPROTO_TCP;
  2726. xprt->tsh_size = sizeof(rpc_fraghdr) / sizeof(u32);
  2727. xprt->max_payload = RPC_MAX_FRAGMENT_SIZE;
  2728. xprt->timeout = &xs_tcp_default_timeout;
  2729. /* backchannel */
  2730. xprt_set_bound(xprt);
  2731. xprt->bind_timeout = 0;
  2732. xprt->reestablish_timeout = 0;
  2733. xprt->idle_timeout = 0;
  2734. xprt->ops = &bc_tcp_ops;
  2735. switch (addr->sa_family) {
  2736. case AF_INET:
  2737. xs_format_peer_addresses(xprt, "tcp",
  2738. RPCBIND_NETID_TCP);
  2739. break;
  2740. case AF_INET6:
  2741. xs_format_peer_addresses(xprt, "tcp",
  2742. RPCBIND_NETID_TCP6);
  2743. break;
  2744. default:
  2745. ret = ERR_PTR(-EAFNOSUPPORT);
  2746. goto out_err;
  2747. }
  2748. dprintk("RPC: set up xprt to %s (port %s) via %s\n",
  2749. xprt->address_strings[RPC_DISPLAY_ADDR],
  2750. xprt->address_strings[RPC_DISPLAY_PORT],
  2751. xprt->address_strings[RPC_DISPLAY_PROTO]);
  2752. /*
  2753. * Once we've associated a backchannel xprt with a connection,
  2754. * we want to keep it around as long as the connection lasts,
  2755. * in case we need to start using it for a backchannel again;
  2756. * this reference won't be dropped until bc_xprt is destroyed.
  2757. */
  2758. xprt_get(xprt);
  2759. args->bc_xprt->xpt_bc_xprt = xprt;
  2760. xprt->bc_xprt = args->bc_xprt;
  2761. bc_sock = container_of(args->bc_xprt, struct svc_sock, sk_xprt);
  2762. transport->sock = bc_sock->sk_sock;
  2763. transport->inet = bc_sock->sk_sk;
  2764. /*
  2765. * Since we don't want connections for the backchannel, we set
  2766. * the xprt status to connected
  2767. */
  2768. xprt_set_connected(xprt);
  2769. if (try_module_get(THIS_MODULE))
  2770. return xprt;
  2771. args->bc_xprt->xpt_bc_xprt = NULL;
  2772. args->bc_xprt->xpt_bc_xps = NULL;
  2773. xprt_put(xprt);
  2774. ret = ERR_PTR(-EINVAL);
  2775. out_err:
  2776. xs_xprt_free(xprt);
  2777. return ret;
  2778. }
  2779. static struct xprt_class xs_local_transport = {
  2780. .list = LIST_HEAD_INIT(xs_local_transport.list),
  2781. .name = "named UNIX socket",
  2782. .owner = THIS_MODULE,
  2783. .ident = XPRT_TRANSPORT_LOCAL,
  2784. .setup = xs_setup_local,
  2785. };
  2786. static struct xprt_class xs_udp_transport = {
  2787. .list = LIST_HEAD_INIT(xs_udp_transport.list),
  2788. .name = "udp",
  2789. .owner = THIS_MODULE,
  2790. .ident = XPRT_TRANSPORT_UDP,
  2791. .setup = xs_setup_udp,
  2792. };
  2793. static struct xprt_class xs_tcp_transport = {
  2794. .list = LIST_HEAD_INIT(xs_tcp_transport.list),
  2795. .name = "tcp",
  2796. .owner = THIS_MODULE,
  2797. .ident = XPRT_TRANSPORT_TCP,
  2798. .setup = xs_setup_tcp,
  2799. };
  2800. static struct xprt_class xs_bc_tcp_transport = {
  2801. .list = LIST_HEAD_INIT(xs_bc_tcp_transport.list),
  2802. .name = "tcp NFSv4.1 backchannel",
  2803. .owner = THIS_MODULE,
  2804. .ident = XPRT_TRANSPORT_BC_TCP,
  2805. .setup = xs_setup_bc_tcp,
  2806. };
  2807. /**
  2808. * init_socket_xprt - set up xprtsock's sysctls, register with RPC client
  2809. *
  2810. */
  2811. int init_socket_xprt(void)
  2812. {
  2813. #if IS_ENABLED(CONFIG_SUNRPC_DEBUG)
  2814. if (!sunrpc_table_header)
  2815. sunrpc_table_header = register_sysctl_table(sunrpc_table);
  2816. #endif
  2817. xprt_register_transport(&xs_local_transport);
  2818. xprt_register_transport(&xs_udp_transport);
  2819. xprt_register_transport(&xs_tcp_transport);
  2820. xprt_register_transport(&xs_bc_tcp_transport);
  2821. return 0;
  2822. }
  2823. /**
  2824. * cleanup_socket_xprt - remove xprtsock's sysctls, unregister
  2825. *
  2826. */
  2827. void cleanup_socket_xprt(void)
  2828. {
  2829. #if IS_ENABLED(CONFIG_SUNRPC_DEBUG)
  2830. if (sunrpc_table_header) {
  2831. unregister_sysctl_table(sunrpc_table_header);
  2832. sunrpc_table_header = NULL;
  2833. }
  2834. #endif
  2835. xprt_unregister_transport(&xs_local_transport);
  2836. xprt_unregister_transport(&xs_udp_transport);
  2837. xprt_unregister_transport(&xs_tcp_transport);
  2838. xprt_unregister_transport(&xs_bc_tcp_transport);
  2839. }
  2840. static int param_set_uint_minmax(const char *val,
  2841. const struct kernel_param *kp,
  2842. unsigned int min, unsigned int max)
  2843. {
  2844. unsigned int num;
  2845. int ret;
  2846. if (!val)
  2847. return -EINVAL;
  2848. ret = kstrtouint(val, 0, &num);
  2849. if (ret)
  2850. return ret;
  2851. if (num < min || num > max)
  2852. return -EINVAL;
  2853. *((unsigned int *)kp->arg) = num;
  2854. return 0;
  2855. }
  2856. static int param_set_portnr(const char *val, const struct kernel_param *kp)
  2857. {
  2858. if (kp->arg == &xprt_min_resvport)
  2859. return param_set_uint_minmax(val, kp,
  2860. RPC_MIN_RESVPORT,
  2861. xprt_max_resvport);
  2862. return param_set_uint_minmax(val, kp,
  2863. xprt_min_resvport,
  2864. RPC_MAX_RESVPORT);
  2865. }
  2866. static const struct kernel_param_ops param_ops_portnr = {
  2867. .set = param_set_portnr,
  2868. .get = param_get_uint,
  2869. };
  2870. #define param_check_portnr(name, p) \
  2871. __param_check(name, p, unsigned int);
  2872. module_param_named(min_resvport, xprt_min_resvport, portnr, 0644);
  2873. module_param_named(max_resvport, xprt_max_resvport, portnr, 0644);
  2874. static int param_set_slot_table_size(const char *val,
  2875. const struct kernel_param *kp)
  2876. {
  2877. return param_set_uint_minmax(val, kp,
  2878. RPC_MIN_SLOT_TABLE,
  2879. RPC_MAX_SLOT_TABLE);
  2880. }
  2881. static const struct kernel_param_ops param_ops_slot_table_size = {
  2882. .set = param_set_slot_table_size,
  2883. .get = param_get_uint,
  2884. };
  2885. #define param_check_slot_table_size(name, p) \
  2886. __param_check(name, p, unsigned int);
  2887. static int param_set_max_slot_table_size(const char *val,
  2888. const struct kernel_param *kp)
  2889. {
  2890. return param_set_uint_minmax(val, kp,
  2891. RPC_MIN_SLOT_TABLE,
  2892. RPC_MAX_SLOT_TABLE_LIMIT);
  2893. }
  2894. static const struct kernel_param_ops param_ops_max_slot_table_size = {
  2895. .set = param_set_max_slot_table_size,
  2896. .get = param_get_uint,
  2897. };
  2898. #define param_check_max_slot_table_size(name, p) \
  2899. __param_check(name, p, unsigned int);
  2900. module_param_named(tcp_slot_table_entries, xprt_tcp_slot_table_entries,
  2901. slot_table_size, 0644);
  2902. module_param_named(tcp_max_slot_table_entries, xprt_max_tcp_slot_table_entries,
  2903. max_slot_table_size, 0644);
  2904. module_param_named(udp_slot_table_entries, xprt_udp_slot_table_entries,
  2905. slot_table_size, 0644);