client.c 41 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628
  1. /* client.c: NFS client sharing and management code
  2. *
  3. * Copyright (C) 2006 Red Hat, Inc. All Rights Reserved.
  4. * Written by David Howells (dhowells@redhat.com)
  5. *
  6. * This program is free software; you can redistribute it and/or
  7. * modify it under the terms of the GNU General Public License
  8. * as published by the Free Software Foundation; either version
  9. * 2 of the License, or (at your option) any later version.
  10. */
  11. #include <linux/module.h>
  12. #include <linux/init.h>
  13. #include <linux/sched.h>
  14. #include <linux/time.h>
  15. #include <linux/kernel.h>
  16. #include <linux/mm.h>
  17. #include <linux/string.h>
  18. #include <linux/stat.h>
  19. #include <linux/errno.h>
  20. #include <linux/unistd.h>
  21. #include <linux/sunrpc/clnt.h>
  22. #include <linux/sunrpc/stats.h>
  23. #include <linux/sunrpc/metrics.h>
  24. #include <linux/sunrpc/xprtsock.h>
  25. #include <linux/sunrpc/xprtrdma.h>
  26. #include <linux/nfs_fs.h>
  27. #include <linux/nfs_mount.h>
  28. #include <linux/nfs4_mount.h>
  29. #include <linux/lockd/bind.h>
  30. #include <linux/seq_file.h>
  31. #include <linux/mount.h>
  32. #include <linux/nfs_idmap.h>
  33. #include <linux/vfs.h>
  34. #include <linux/inet.h>
  35. #include <linux/in6.h>
  36. #include <net/ipv6.h>
  37. #include <linux/nfs_xdr.h>
  38. #include <asm/system.h>
  39. #include "nfs4_fs.h"
  40. #include "callback.h"
  41. #include "delegation.h"
  42. #include "iostat.h"
  43. #include "internal.h"
  44. #define NFSDBG_FACILITY NFSDBG_CLIENT
  45. static DEFINE_SPINLOCK(nfs_client_lock);
  46. static LIST_HEAD(nfs_client_list);
  47. static LIST_HEAD(nfs_volume_list);
  48. static DECLARE_WAIT_QUEUE_HEAD(nfs_client_active_wq);
  49. /*
  50. * RPC cruft for NFS
  51. */
  52. static struct rpc_version *nfs_version[5] = {
  53. [2] = &nfs_version2,
  54. #ifdef CONFIG_NFS_V3
  55. [3] = &nfs_version3,
  56. #endif
  57. #ifdef CONFIG_NFS_V4
  58. [4] = &nfs_version4,
  59. #endif
  60. };
  61. struct rpc_program nfs_program = {
  62. .name = "nfs",
  63. .number = NFS_PROGRAM,
  64. .nrvers = ARRAY_SIZE(nfs_version),
  65. .version = nfs_version,
  66. .stats = &nfs_rpcstat,
  67. .pipe_dir_name = "/nfs",
  68. };
  69. struct rpc_stat nfs_rpcstat = {
  70. .program = &nfs_program
  71. };
  72. #ifdef CONFIG_NFS_V3_ACL
  73. static struct rpc_stat nfsacl_rpcstat = { &nfsacl_program };
  74. static struct rpc_version * nfsacl_version[] = {
  75. [3] = &nfsacl_version3,
  76. };
  77. struct rpc_program nfsacl_program = {
  78. .name = "nfsacl",
  79. .number = NFS_ACL_PROGRAM,
  80. .nrvers = ARRAY_SIZE(nfsacl_version),
  81. .version = nfsacl_version,
  82. .stats = &nfsacl_rpcstat,
  83. };
  84. #endif /* CONFIG_NFS_V3_ACL */
  85. struct nfs_client_initdata {
  86. const char *hostname;
  87. const struct sockaddr *addr;
  88. size_t addrlen;
  89. const struct nfs_rpc_ops *rpc_ops;
  90. int proto;
  91. };
  92. /*
  93. * Allocate a shared client record
  94. *
  95. * Since these are allocated/deallocated very rarely, we don't
  96. * bother putting them in a slab cache...
  97. */
  98. static struct nfs_client *nfs_alloc_client(const struct nfs_client_initdata *cl_init)
  99. {
  100. struct nfs_client *clp;
  101. struct rpc_cred *cred;
  102. if ((clp = kzalloc(sizeof(*clp), GFP_KERNEL)) == NULL)
  103. goto error_0;
  104. clp->rpc_ops = cl_init->rpc_ops;
  105. if (cl_init->rpc_ops->version == 4) {
  106. if (nfs_callback_up() < 0)
  107. goto error_2;
  108. __set_bit(NFS_CS_CALLBACK, &clp->cl_res_state);
  109. }
  110. atomic_set(&clp->cl_count, 1);
  111. clp->cl_cons_state = NFS_CS_INITING;
  112. memcpy(&clp->cl_addr, cl_init->addr, cl_init->addrlen);
  113. clp->cl_addrlen = cl_init->addrlen;
  114. if (cl_init->hostname) {
  115. clp->cl_hostname = kstrdup(cl_init->hostname, GFP_KERNEL);
  116. if (!clp->cl_hostname)
  117. goto error_3;
  118. }
  119. INIT_LIST_HEAD(&clp->cl_superblocks);
  120. clp->cl_rpcclient = ERR_PTR(-EINVAL);
  121. clp->cl_proto = cl_init->proto;
  122. #ifdef CONFIG_NFS_V4
  123. INIT_LIST_HEAD(&clp->cl_delegations);
  124. spin_lock_init(&clp->cl_lock);
  125. INIT_DELAYED_WORK(&clp->cl_renewd, nfs4_renew_state);
  126. rpc_init_wait_queue(&clp->cl_rpcwaitq, "NFS client");
  127. clp->cl_boot_time = CURRENT_TIME;
  128. clp->cl_state = 1 << NFS4CLNT_LEASE_EXPIRED;
  129. #endif
  130. cred = rpc_lookup_machine_cred();
  131. if (!IS_ERR(cred))
  132. clp->cl_machine_cred = cred;
  133. return clp;
  134. error_3:
  135. if (__test_and_clear_bit(NFS_CS_CALLBACK, &clp->cl_res_state))
  136. nfs_callback_down();
  137. error_2:
  138. kfree(clp);
  139. error_0:
  140. return NULL;
  141. }
  142. static void nfs4_shutdown_client(struct nfs_client *clp)
  143. {
  144. #ifdef CONFIG_NFS_V4
  145. if (__test_and_clear_bit(NFS_CS_RENEWD, &clp->cl_res_state))
  146. nfs4_kill_renewd(clp);
  147. BUG_ON(!RB_EMPTY_ROOT(&clp->cl_state_owners));
  148. if (__test_and_clear_bit(NFS_CS_IDMAP, &clp->cl_res_state))
  149. nfs_idmap_delete(clp);
  150. rpc_destroy_wait_queue(&clp->cl_rpcwaitq);
  151. #endif
  152. }
  153. /*
  154. * Destroy a shared client record
  155. */
  156. static void nfs_free_client(struct nfs_client *clp)
  157. {
  158. dprintk("--> nfs_free_client(%u)\n", clp->rpc_ops->version);
  159. nfs4_shutdown_client(clp);
  160. /* -EIO all pending I/O */
  161. if (!IS_ERR(clp->cl_rpcclient))
  162. rpc_shutdown_client(clp->cl_rpcclient);
  163. if (__test_and_clear_bit(NFS_CS_CALLBACK, &clp->cl_res_state))
  164. nfs_callback_down();
  165. if (clp->cl_machine_cred != NULL)
  166. put_rpccred(clp->cl_machine_cred);
  167. kfree(clp->cl_hostname);
  168. kfree(clp);
  169. dprintk("<-- nfs_free_client()\n");
  170. }
  171. /*
  172. * Release a reference to a shared client record
  173. */
  174. void nfs_put_client(struct nfs_client *clp)
  175. {
  176. if (!clp)
  177. return;
  178. dprintk("--> nfs_put_client({%d})\n", atomic_read(&clp->cl_count));
  179. if (atomic_dec_and_lock(&clp->cl_count, &nfs_client_lock)) {
  180. list_del(&clp->cl_share_link);
  181. spin_unlock(&nfs_client_lock);
  182. BUG_ON(!list_empty(&clp->cl_superblocks));
  183. nfs_free_client(clp);
  184. }
  185. }
  186. #if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE)
  187. /*
  188. * Test if two ip6 socket addresses refer to the same socket by
  189. * comparing relevant fields. The padding bytes specifically, are not
  190. * compared. sin6_flowinfo is not compared because it only affects QoS
  191. * and sin6_scope_id is only compared if the address is "link local"
  192. * because "link local" addresses need only be unique to a specific
  193. * link. Conversely, ordinary unicast addresses might have different
  194. * sin6_scope_id.
  195. *
  196. * The caller should ensure both socket addresses are AF_INET6.
  197. */
  198. static int nfs_sockaddr_match_ipaddr6(const struct sockaddr *sa1,
  199. const struct sockaddr *sa2)
  200. {
  201. const struct sockaddr_in6 *sin1 = (const struct sockaddr_in6 *)sa1;
  202. const struct sockaddr_in6 *sin2 = (const struct sockaddr_in6 *)sa2;
  203. if (ipv6_addr_scope(&sin1->sin6_addr) == IPV6_ADDR_SCOPE_LINKLOCAL &&
  204. sin1->sin6_scope_id != sin2->sin6_scope_id)
  205. return 0;
  206. return ipv6_addr_equal(&sin1->sin6_addr, &sin1->sin6_addr);
  207. }
  208. #else /* !defined(CONFIG_IPV6) && !defined(CONFIG_IPV6_MODULE) */
  209. static int nfs_sockaddr_match_ipaddr6(const struct sockaddr *sa1,
  210. const struct sockaddr *sa2)
  211. {
  212. return 0;
  213. }
  214. #endif
  215. /*
  216. * Test if two ip4 socket addresses refer to the same socket, by
  217. * comparing relevant fields. The padding bytes specifically, are
  218. * not compared.
  219. *
  220. * The caller should ensure both socket addresses are AF_INET.
  221. */
  222. static int nfs_sockaddr_match_ipaddr4(const struct sockaddr *sa1,
  223. const struct sockaddr *sa2)
  224. {
  225. const struct sockaddr_in *sin1 = (const struct sockaddr_in *)sa1;
  226. const struct sockaddr_in *sin2 = (const struct sockaddr_in *)sa2;
  227. return sin1->sin_addr.s_addr == sin2->sin_addr.s_addr;
  228. }
  229. static int nfs_sockaddr_cmp_ip6(const struct sockaddr *sa1,
  230. const struct sockaddr *sa2)
  231. {
  232. const struct sockaddr_in6 *sin1 = (const struct sockaddr_in6 *)sa1;
  233. const struct sockaddr_in6 *sin2 = (const struct sockaddr_in6 *)sa2;
  234. return nfs_sockaddr_match_ipaddr6(sa1, sa2) &&
  235. (sin1->sin6_port == sin2->sin6_port);
  236. }
  237. static int nfs_sockaddr_cmp_ip4(const struct sockaddr *sa1,
  238. const struct sockaddr *sa2)
  239. {
  240. const struct sockaddr_in *sin1 = (const struct sockaddr_in *)sa1;
  241. const struct sockaddr_in *sin2 = (const struct sockaddr_in *)sa2;
  242. return nfs_sockaddr_match_ipaddr4(sa1, sa2) &&
  243. (sin1->sin_port == sin2->sin_port);
  244. }
  245. /*
  246. * Test if two socket addresses represent the same actual socket,
  247. * by comparing (only) relevant fields, excluding the port number.
  248. */
  249. static int nfs_sockaddr_match_ipaddr(const struct sockaddr *sa1,
  250. const struct sockaddr *sa2)
  251. {
  252. if (sa1->sa_family != sa2->sa_family)
  253. return 0;
  254. switch (sa1->sa_family) {
  255. case AF_INET:
  256. return nfs_sockaddr_match_ipaddr4(sa1, sa2);
  257. case AF_INET6:
  258. return nfs_sockaddr_match_ipaddr6(sa1, sa2);
  259. }
  260. return 0;
  261. }
  262. /*
  263. * Test if two socket addresses represent the same actual socket,
  264. * by comparing (only) relevant fields, including the port number.
  265. */
  266. static int nfs_sockaddr_cmp(const struct sockaddr *sa1,
  267. const struct sockaddr *sa2)
  268. {
  269. if (sa1->sa_family != sa2->sa_family)
  270. return 0;
  271. switch (sa1->sa_family) {
  272. case AF_INET:
  273. return nfs_sockaddr_cmp_ip4(sa1, sa2);
  274. case AF_INET6:
  275. return nfs_sockaddr_cmp_ip6(sa1, sa2);
  276. }
  277. return 0;
  278. }
  279. /*
  280. * Find a client by IP address and protocol version
  281. * - returns NULL if no such client
  282. */
  283. struct nfs_client *nfs_find_client(const struct sockaddr *addr, u32 nfsversion)
  284. {
  285. struct nfs_client *clp;
  286. spin_lock(&nfs_client_lock);
  287. list_for_each_entry(clp, &nfs_client_list, cl_share_link) {
  288. struct sockaddr *clap = (struct sockaddr *)&clp->cl_addr;
  289. /* Don't match clients that failed to initialise properly */
  290. if (clp->cl_cons_state != NFS_CS_READY)
  291. continue;
  292. /* Different NFS versions cannot share the same nfs_client */
  293. if (clp->rpc_ops->version != nfsversion)
  294. continue;
  295. /* Match only the IP address, not the port number */
  296. if (!nfs_sockaddr_match_ipaddr(addr, clap))
  297. continue;
  298. atomic_inc(&clp->cl_count);
  299. spin_unlock(&nfs_client_lock);
  300. return clp;
  301. }
  302. spin_unlock(&nfs_client_lock);
  303. return NULL;
  304. }
  305. /*
  306. * Find a client by IP address and protocol version
  307. * - returns NULL if no such client
  308. */
  309. struct nfs_client *nfs_find_client_next(struct nfs_client *clp)
  310. {
  311. struct sockaddr *sap = (struct sockaddr *)&clp->cl_addr;
  312. u32 nfsvers = clp->rpc_ops->version;
  313. spin_lock(&nfs_client_lock);
  314. list_for_each_entry_continue(clp, &nfs_client_list, cl_share_link) {
  315. struct sockaddr *clap = (struct sockaddr *)&clp->cl_addr;
  316. /* Don't match clients that failed to initialise properly */
  317. if (clp->cl_cons_state != NFS_CS_READY)
  318. continue;
  319. /* Different NFS versions cannot share the same nfs_client */
  320. if (clp->rpc_ops->version != nfsvers)
  321. continue;
  322. /* Match only the IP address, not the port number */
  323. if (!nfs_sockaddr_match_ipaddr(sap, clap))
  324. continue;
  325. atomic_inc(&clp->cl_count);
  326. spin_unlock(&nfs_client_lock);
  327. return clp;
  328. }
  329. spin_unlock(&nfs_client_lock);
  330. return NULL;
  331. }
  332. /*
  333. * Find an nfs_client on the list that matches the initialisation data
  334. * that is supplied.
  335. */
  336. static struct nfs_client *nfs_match_client(const struct nfs_client_initdata *data)
  337. {
  338. struct nfs_client *clp;
  339. const struct sockaddr *sap = data->addr;
  340. list_for_each_entry(clp, &nfs_client_list, cl_share_link) {
  341. const struct sockaddr *clap = (struct sockaddr *)&clp->cl_addr;
  342. /* Don't match clients that failed to initialise properly */
  343. if (clp->cl_cons_state < 0)
  344. continue;
  345. /* Different NFS versions cannot share the same nfs_client */
  346. if (clp->rpc_ops != data->rpc_ops)
  347. continue;
  348. if (clp->cl_proto != data->proto)
  349. continue;
  350. /* Match the full socket address */
  351. if (!nfs_sockaddr_cmp(sap, clap))
  352. continue;
  353. atomic_inc(&clp->cl_count);
  354. return clp;
  355. }
  356. return NULL;
  357. }
  358. /*
  359. * Look up a client by IP address and protocol version
  360. * - creates a new record if one doesn't yet exist
  361. */
  362. static struct nfs_client *nfs_get_client(const struct nfs_client_initdata *cl_init)
  363. {
  364. struct nfs_client *clp, *new = NULL;
  365. int error;
  366. dprintk("--> nfs_get_client(%s,v%u)\n",
  367. cl_init->hostname ?: "", cl_init->rpc_ops->version);
  368. /* see if the client already exists */
  369. do {
  370. spin_lock(&nfs_client_lock);
  371. clp = nfs_match_client(cl_init);
  372. if (clp)
  373. goto found_client;
  374. if (new)
  375. goto install_client;
  376. spin_unlock(&nfs_client_lock);
  377. new = nfs_alloc_client(cl_init);
  378. } while (new);
  379. return ERR_PTR(-ENOMEM);
  380. /* install a new client and return with it unready */
  381. install_client:
  382. clp = new;
  383. list_add(&clp->cl_share_link, &nfs_client_list);
  384. spin_unlock(&nfs_client_lock);
  385. dprintk("--> nfs_get_client() = %p [new]\n", clp);
  386. return clp;
  387. /* found an existing client
  388. * - make sure it's ready before returning
  389. */
  390. found_client:
  391. spin_unlock(&nfs_client_lock);
  392. if (new)
  393. nfs_free_client(new);
  394. error = wait_event_killable(nfs_client_active_wq,
  395. clp->cl_cons_state != NFS_CS_INITING);
  396. if (error < 0) {
  397. nfs_put_client(clp);
  398. return ERR_PTR(-ERESTARTSYS);
  399. }
  400. if (clp->cl_cons_state < NFS_CS_READY) {
  401. error = clp->cl_cons_state;
  402. nfs_put_client(clp);
  403. return ERR_PTR(error);
  404. }
  405. BUG_ON(clp->cl_cons_state != NFS_CS_READY);
  406. dprintk("--> nfs_get_client() = %p [share]\n", clp);
  407. return clp;
  408. }
  409. /*
  410. * Mark a server as ready or failed
  411. */
  412. static void nfs_mark_client_ready(struct nfs_client *clp, int state)
  413. {
  414. clp->cl_cons_state = state;
  415. wake_up_all(&nfs_client_active_wq);
  416. }
  417. /*
  418. * Initialise the timeout values for a connection
  419. */
  420. static void nfs_init_timeout_values(struct rpc_timeout *to, int proto,
  421. unsigned int timeo, unsigned int retrans)
  422. {
  423. to->to_initval = timeo * HZ / 10;
  424. to->to_retries = retrans;
  425. switch (proto) {
  426. case XPRT_TRANSPORT_TCP:
  427. case XPRT_TRANSPORT_RDMA:
  428. if (to->to_retries == 0)
  429. to->to_retries = NFS_DEF_TCP_RETRANS;
  430. if (to->to_initval == 0)
  431. to->to_initval = NFS_DEF_TCP_TIMEO * HZ / 10;
  432. if (to->to_initval > NFS_MAX_TCP_TIMEOUT)
  433. to->to_initval = NFS_MAX_TCP_TIMEOUT;
  434. to->to_increment = to->to_initval;
  435. to->to_maxval = to->to_initval + (to->to_increment * to->to_retries);
  436. if (to->to_maxval > NFS_MAX_TCP_TIMEOUT)
  437. to->to_maxval = NFS_MAX_TCP_TIMEOUT;
  438. if (to->to_maxval < to->to_initval)
  439. to->to_maxval = to->to_initval;
  440. to->to_exponential = 0;
  441. break;
  442. case XPRT_TRANSPORT_UDP:
  443. if (to->to_retries == 0)
  444. to->to_retries = NFS_DEF_UDP_RETRANS;
  445. if (!to->to_initval)
  446. to->to_initval = NFS_DEF_UDP_TIMEO * HZ / 10;
  447. if (to->to_initval > NFS_MAX_UDP_TIMEOUT)
  448. to->to_initval = NFS_MAX_UDP_TIMEOUT;
  449. to->to_maxval = NFS_MAX_UDP_TIMEOUT;
  450. to->to_exponential = 1;
  451. break;
  452. default:
  453. BUG();
  454. }
  455. }
  456. /*
  457. * Create an RPC client handle
  458. */
  459. static int nfs_create_rpc_client(struct nfs_client *clp,
  460. const struct rpc_timeout *timeparms,
  461. rpc_authflavor_t flavor,
  462. int discrtry, int noresvport)
  463. {
  464. struct rpc_clnt *clnt = NULL;
  465. struct rpc_create_args args = {
  466. .protocol = clp->cl_proto,
  467. .address = (struct sockaddr *)&clp->cl_addr,
  468. .addrsize = clp->cl_addrlen,
  469. .timeout = timeparms,
  470. .servername = clp->cl_hostname,
  471. .program = &nfs_program,
  472. .version = clp->rpc_ops->version,
  473. .authflavor = flavor,
  474. };
  475. if (discrtry)
  476. args.flags |= RPC_CLNT_CREATE_DISCRTRY;
  477. if (noresvport)
  478. args.flags |= RPC_CLNT_CREATE_NONPRIVPORT;
  479. if (!IS_ERR(clp->cl_rpcclient))
  480. return 0;
  481. clnt = rpc_create(&args);
  482. if (IS_ERR(clnt)) {
  483. dprintk("%s: cannot create RPC client. Error = %ld\n",
  484. __func__, PTR_ERR(clnt));
  485. return PTR_ERR(clnt);
  486. }
  487. clp->cl_rpcclient = clnt;
  488. return 0;
  489. }
  490. /*
  491. * Version 2 or 3 client destruction
  492. */
  493. static void nfs_destroy_server(struct nfs_server *server)
  494. {
  495. if (!(server->flags & NFS_MOUNT_NONLM))
  496. nlmclnt_done(server->nlm_host);
  497. }
  498. /*
  499. * Version 2 or 3 lockd setup
  500. */
  501. static int nfs_start_lockd(struct nfs_server *server)
  502. {
  503. struct nlm_host *host;
  504. struct nfs_client *clp = server->nfs_client;
  505. struct nlmclnt_initdata nlm_init = {
  506. .hostname = clp->cl_hostname,
  507. .address = (struct sockaddr *)&clp->cl_addr,
  508. .addrlen = clp->cl_addrlen,
  509. .protocol = server->flags & NFS_MOUNT_TCP ?
  510. IPPROTO_TCP : IPPROTO_UDP,
  511. .nfs_version = clp->rpc_ops->version,
  512. .noresvport = server->flags & NFS_MOUNT_NORESVPORT ?
  513. 1 : 0,
  514. };
  515. if (nlm_init.nfs_version > 3)
  516. return 0;
  517. if (server->flags & NFS_MOUNT_NONLM)
  518. return 0;
  519. host = nlmclnt_init(&nlm_init);
  520. if (IS_ERR(host))
  521. return PTR_ERR(host);
  522. server->nlm_host = host;
  523. server->destroy = nfs_destroy_server;
  524. return 0;
  525. }
  526. /*
  527. * Initialise an NFSv3 ACL client connection
  528. */
  529. #ifdef CONFIG_NFS_V3_ACL
  530. static void nfs_init_server_aclclient(struct nfs_server *server)
  531. {
  532. if (server->nfs_client->rpc_ops->version != 3)
  533. goto out_noacl;
  534. if (server->flags & NFS_MOUNT_NOACL)
  535. goto out_noacl;
  536. server->client_acl = rpc_bind_new_program(server->client, &nfsacl_program, 3);
  537. if (IS_ERR(server->client_acl))
  538. goto out_noacl;
  539. /* No errors! Assume that Sun nfsacls are supported */
  540. server->caps |= NFS_CAP_ACLS;
  541. return;
  542. out_noacl:
  543. server->caps &= ~NFS_CAP_ACLS;
  544. }
  545. #else
  546. static inline void nfs_init_server_aclclient(struct nfs_server *server)
  547. {
  548. server->flags &= ~NFS_MOUNT_NOACL;
  549. server->caps &= ~NFS_CAP_ACLS;
  550. }
  551. #endif
  552. /*
  553. * Create a general RPC client
  554. */
  555. static int nfs_init_server_rpcclient(struct nfs_server *server,
  556. const struct rpc_timeout *timeo,
  557. rpc_authflavor_t pseudoflavour)
  558. {
  559. struct nfs_client *clp = server->nfs_client;
  560. server->client = rpc_clone_client(clp->cl_rpcclient);
  561. if (IS_ERR(server->client)) {
  562. dprintk("%s: couldn't create rpc_client!\n", __func__);
  563. return PTR_ERR(server->client);
  564. }
  565. memcpy(&server->client->cl_timeout_default,
  566. timeo,
  567. sizeof(server->client->cl_timeout_default));
  568. server->client->cl_timeout = &server->client->cl_timeout_default;
  569. if (pseudoflavour != clp->cl_rpcclient->cl_auth->au_flavor) {
  570. struct rpc_auth *auth;
  571. auth = rpcauth_create(pseudoflavour, server->client);
  572. if (IS_ERR(auth)) {
  573. dprintk("%s: couldn't create credcache!\n", __func__);
  574. return PTR_ERR(auth);
  575. }
  576. }
  577. server->client->cl_softrtry = 0;
  578. if (server->flags & NFS_MOUNT_SOFT)
  579. server->client->cl_softrtry = 1;
  580. return 0;
  581. }
  582. /*
  583. * Initialise an NFS2 or NFS3 client
  584. */
  585. static int nfs_init_client(struct nfs_client *clp,
  586. const struct rpc_timeout *timeparms,
  587. const struct nfs_parsed_mount_data *data)
  588. {
  589. int error;
  590. if (clp->cl_cons_state == NFS_CS_READY) {
  591. /* the client is already initialised */
  592. dprintk("<-- nfs_init_client() = 0 [already %p]\n", clp);
  593. return 0;
  594. }
  595. /*
  596. * Create a client RPC handle for doing FSSTAT with UNIX auth only
  597. * - RFC 2623, sec 2.3.2
  598. */
  599. error = nfs_create_rpc_client(clp, timeparms, RPC_AUTH_UNIX,
  600. 0, data->flags & NFS_MOUNT_NORESVPORT);
  601. if (error < 0)
  602. goto error;
  603. nfs_mark_client_ready(clp, NFS_CS_READY);
  604. return 0;
  605. error:
  606. nfs_mark_client_ready(clp, error);
  607. dprintk("<-- nfs_init_client() = xerror %d\n", error);
  608. return error;
  609. }
  610. /*
  611. * Create a version 2 or 3 client
  612. */
  613. static int nfs_init_server(struct nfs_server *server,
  614. const struct nfs_parsed_mount_data *data)
  615. {
  616. struct nfs_client_initdata cl_init = {
  617. .hostname = data->nfs_server.hostname,
  618. .addr = (const struct sockaddr *)&data->nfs_server.address,
  619. .addrlen = data->nfs_server.addrlen,
  620. .rpc_ops = &nfs_v2_clientops,
  621. .proto = data->nfs_server.protocol,
  622. };
  623. struct rpc_timeout timeparms;
  624. struct nfs_client *clp;
  625. int error;
  626. dprintk("--> nfs_init_server()\n");
  627. #ifdef CONFIG_NFS_V3
  628. if (data->flags & NFS_MOUNT_VER3)
  629. cl_init.rpc_ops = &nfs_v3_clientops;
  630. #endif
  631. /* Allocate or find a client reference we can use */
  632. clp = nfs_get_client(&cl_init);
  633. if (IS_ERR(clp)) {
  634. dprintk("<-- nfs_init_server() = error %ld\n", PTR_ERR(clp));
  635. return PTR_ERR(clp);
  636. }
  637. nfs_init_timeout_values(&timeparms, data->nfs_server.protocol,
  638. data->timeo, data->retrans);
  639. error = nfs_init_client(clp, &timeparms, data);
  640. if (error < 0)
  641. goto error;
  642. server->nfs_client = clp;
  643. /* Initialise the client representation from the mount data */
  644. server->flags = data->flags;
  645. if (data->rsize)
  646. server->rsize = nfs_block_size(data->rsize, NULL);
  647. if (data->wsize)
  648. server->wsize = nfs_block_size(data->wsize, NULL);
  649. server->acregmin = data->acregmin * HZ;
  650. server->acregmax = data->acregmax * HZ;
  651. server->acdirmin = data->acdirmin * HZ;
  652. server->acdirmax = data->acdirmax * HZ;
  653. /* Start lockd here, before we might error out */
  654. error = nfs_start_lockd(server);
  655. if (error < 0)
  656. goto error;
  657. server->port = data->nfs_server.port;
  658. error = nfs_init_server_rpcclient(server, &timeparms, data->auth_flavors[0]);
  659. if (error < 0)
  660. goto error;
  661. /* Preserve the values of mount_server-related mount options */
  662. if (data->mount_server.addrlen) {
  663. memcpy(&server->mountd_address, &data->mount_server.address,
  664. data->mount_server.addrlen);
  665. server->mountd_addrlen = data->mount_server.addrlen;
  666. }
  667. server->mountd_version = data->mount_server.version;
  668. server->mountd_port = data->mount_server.port;
  669. server->mountd_protocol = data->mount_server.protocol;
  670. server->namelen = data->namlen;
  671. /* Create a client RPC handle for the NFSv3 ACL management interface */
  672. nfs_init_server_aclclient(server);
  673. dprintk("<-- nfs_init_server() = 0 [new %p]\n", clp);
  674. return 0;
  675. error:
  676. server->nfs_client = NULL;
  677. nfs_put_client(clp);
  678. dprintk("<-- nfs_init_server() = xerror %d\n", error);
  679. return error;
  680. }
  681. /*
  682. * Load up the server record from information gained in an fsinfo record
  683. */
  684. static void nfs_server_set_fsinfo(struct nfs_server *server, struct nfs_fsinfo *fsinfo)
  685. {
  686. unsigned long max_rpc_payload;
  687. /* Work out a lot of parameters */
  688. if (server->rsize == 0)
  689. server->rsize = nfs_block_size(fsinfo->rtpref, NULL);
  690. if (server->wsize == 0)
  691. server->wsize = nfs_block_size(fsinfo->wtpref, NULL);
  692. if (fsinfo->rtmax >= 512 && server->rsize > fsinfo->rtmax)
  693. server->rsize = nfs_block_size(fsinfo->rtmax, NULL);
  694. if (fsinfo->wtmax >= 512 && server->wsize > fsinfo->wtmax)
  695. server->wsize = nfs_block_size(fsinfo->wtmax, NULL);
  696. max_rpc_payload = nfs_block_size(rpc_max_payload(server->client), NULL);
  697. if (server->rsize > max_rpc_payload)
  698. server->rsize = max_rpc_payload;
  699. if (server->rsize > NFS_MAX_FILE_IO_SIZE)
  700. server->rsize = NFS_MAX_FILE_IO_SIZE;
  701. server->rpages = (server->rsize + PAGE_CACHE_SIZE - 1) >> PAGE_CACHE_SHIFT;
  702. server->backing_dev_info.ra_pages = server->rpages * NFS_MAX_READAHEAD;
  703. if (server->wsize > max_rpc_payload)
  704. server->wsize = max_rpc_payload;
  705. if (server->wsize > NFS_MAX_FILE_IO_SIZE)
  706. server->wsize = NFS_MAX_FILE_IO_SIZE;
  707. server->wpages = (server->wsize + PAGE_CACHE_SIZE - 1) >> PAGE_CACHE_SHIFT;
  708. server->wtmult = nfs_block_bits(fsinfo->wtmult, NULL);
  709. server->dtsize = nfs_block_size(fsinfo->dtpref, NULL);
  710. if (server->dtsize > PAGE_CACHE_SIZE)
  711. server->dtsize = PAGE_CACHE_SIZE;
  712. if (server->dtsize > server->rsize)
  713. server->dtsize = server->rsize;
  714. if (server->flags & NFS_MOUNT_NOAC) {
  715. server->acregmin = server->acregmax = 0;
  716. server->acdirmin = server->acdirmax = 0;
  717. }
  718. server->maxfilesize = fsinfo->maxfilesize;
  719. /* We're airborne Set socket buffersize */
  720. rpc_setbufsize(server->client, server->wsize + 100, server->rsize + 100);
  721. }
  722. /*
  723. * Probe filesystem information, including the FSID on v2/v3
  724. */
  725. static int nfs_probe_fsinfo(struct nfs_server *server, struct nfs_fh *mntfh, struct nfs_fattr *fattr)
  726. {
  727. struct nfs_fsinfo fsinfo;
  728. struct nfs_client *clp = server->nfs_client;
  729. int error;
  730. dprintk("--> nfs_probe_fsinfo()\n");
  731. if (clp->rpc_ops->set_capabilities != NULL) {
  732. error = clp->rpc_ops->set_capabilities(server, mntfh);
  733. if (error < 0)
  734. goto out_error;
  735. }
  736. fsinfo.fattr = fattr;
  737. nfs_fattr_init(fattr);
  738. error = clp->rpc_ops->fsinfo(server, mntfh, &fsinfo);
  739. if (error < 0)
  740. goto out_error;
  741. nfs_server_set_fsinfo(server, &fsinfo);
  742. error = bdi_init(&server->backing_dev_info);
  743. if (error)
  744. goto out_error;
  745. /* Get some general file system info */
  746. if (server->namelen == 0) {
  747. struct nfs_pathconf pathinfo;
  748. pathinfo.fattr = fattr;
  749. nfs_fattr_init(fattr);
  750. if (clp->rpc_ops->pathconf(server, mntfh, &pathinfo) >= 0)
  751. server->namelen = pathinfo.max_namelen;
  752. }
  753. dprintk("<-- nfs_probe_fsinfo() = 0\n");
  754. return 0;
  755. out_error:
  756. dprintk("nfs_probe_fsinfo: error = %d\n", -error);
  757. return error;
  758. }
  759. /*
  760. * Copy useful information when duplicating a server record
  761. */
  762. static void nfs_server_copy_userdata(struct nfs_server *target, struct nfs_server *source)
  763. {
  764. target->flags = source->flags;
  765. target->acregmin = source->acregmin;
  766. target->acregmax = source->acregmax;
  767. target->acdirmin = source->acdirmin;
  768. target->acdirmax = source->acdirmax;
  769. target->caps = source->caps;
  770. }
  771. /*
  772. * Allocate and initialise a server record
  773. */
  774. static struct nfs_server *nfs_alloc_server(void)
  775. {
  776. struct nfs_server *server;
  777. server = kzalloc(sizeof(struct nfs_server), GFP_KERNEL);
  778. if (!server)
  779. return NULL;
  780. server->client = server->client_acl = ERR_PTR(-EINVAL);
  781. /* Zero out the NFS state stuff */
  782. INIT_LIST_HEAD(&server->client_link);
  783. INIT_LIST_HEAD(&server->master_link);
  784. atomic_set(&server->active, 0);
  785. server->io_stats = nfs_alloc_iostats();
  786. if (!server->io_stats) {
  787. kfree(server);
  788. return NULL;
  789. }
  790. return server;
  791. }
  792. /*
  793. * Free up a server record
  794. */
  795. void nfs_free_server(struct nfs_server *server)
  796. {
  797. dprintk("--> nfs_free_server()\n");
  798. spin_lock(&nfs_client_lock);
  799. list_del(&server->client_link);
  800. list_del(&server->master_link);
  801. spin_unlock(&nfs_client_lock);
  802. if (server->destroy != NULL)
  803. server->destroy(server);
  804. if (!IS_ERR(server->client_acl))
  805. rpc_shutdown_client(server->client_acl);
  806. if (!IS_ERR(server->client))
  807. rpc_shutdown_client(server->client);
  808. nfs_put_client(server->nfs_client);
  809. nfs_free_iostats(server->io_stats);
  810. bdi_destroy(&server->backing_dev_info);
  811. kfree(server);
  812. nfs_release_automount_timer();
  813. dprintk("<-- nfs_free_server()\n");
  814. }
  815. /*
  816. * Create a version 2 or 3 volume record
  817. * - keyed on server and FSID
  818. */
  819. struct nfs_server *nfs_create_server(const struct nfs_parsed_mount_data *data,
  820. struct nfs_fh *mntfh)
  821. {
  822. struct nfs_server *server;
  823. struct nfs_fattr fattr;
  824. int error;
  825. server = nfs_alloc_server();
  826. if (!server)
  827. return ERR_PTR(-ENOMEM);
  828. /* Get a client representation */
  829. error = nfs_init_server(server, data);
  830. if (error < 0)
  831. goto error;
  832. BUG_ON(!server->nfs_client);
  833. BUG_ON(!server->nfs_client->rpc_ops);
  834. BUG_ON(!server->nfs_client->rpc_ops->file_inode_ops);
  835. /* Probe the root fh to retrieve its FSID */
  836. error = nfs_probe_fsinfo(server, mntfh, &fattr);
  837. if (error < 0)
  838. goto error;
  839. if (server->nfs_client->rpc_ops->version == 3) {
  840. if (server->namelen == 0 || server->namelen > NFS3_MAXNAMLEN)
  841. server->namelen = NFS3_MAXNAMLEN;
  842. if (!(data->flags & NFS_MOUNT_NORDIRPLUS))
  843. server->caps |= NFS_CAP_READDIRPLUS;
  844. } else {
  845. if (server->namelen == 0 || server->namelen > NFS2_MAXNAMLEN)
  846. server->namelen = NFS2_MAXNAMLEN;
  847. }
  848. if (!(fattr.valid & NFS_ATTR_FATTR)) {
  849. error = server->nfs_client->rpc_ops->getattr(server, mntfh, &fattr);
  850. if (error < 0) {
  851. dprintk("nfs_create_server: getattr error = %d\n", -error);
  852. goto error;
  853. }
  854. }
  855. memcpy(&server->fsid, &fattr.fsid, sizeof(server->fsid));
  856. dprintk("Server FSID: %llx:%llx\n",
  857. (unsigned long long) server->fsid.major,
  858. (unsigned long long) server->fsid.minor);
  859. BUG_ON(!server->nfs_client);
  860. BUG_ON(!server->nfs_client->rpc_ops);
  861. BUG_ON(!server->nfs_client->rpc_ops->file_inode_ops);
  862. spin_lock(&nfs_client_lock);
  863. list_add_tail(&server->client_link, &server->nfs_client->cl_superblocks);
  864. list_add_tail(&server->master_link, &nfs_volume_list);
  865. spin_unlock(&nfs_client_lock);
  866. server->mount_time = jiffies;
  867. return server;
  868. error:
  869. nfs_free_server(server);
  870. return ERR_PTR(error);
  871. }
  872. #ifdef CONFIG_NFS_V4
  873. /*
  874. * Initialise an NFS4 client record
  875. */
  876. static int nfs4_init_client(struct nfs_client *clp,
  877. const struct rpc_timeout *timeparms,
  878. const char *ip_addr,
  879. rpc_authflavor_t authflavour,
  880. int flags)
  881. {
  882. int error;
  883. if (clp->cl_cons_state == NFS_CS_READY) {
  884. /* the client is initialised already */
  885. dprintk("<-- nfs4_init_client() = 0 [already %p]\n", clp);
  886. return 0;
  887. }
  888. /* Check NFS protocol revision and initialize RPC op vector */
  889. clp->rpc_ops = &nfs_v4_clientops;
  890. error = nfs_create_rpc_client(clp, timeparms, authflavour,
  891. 1, flags & NFS_MOUNT_NORESVPORT);
  892. if (error < 0)
  893. goto error;
  894. memcpy(clp->cl_ipaddr, ip_addr, sizeof(clp->cl_ipaddr));
  895. error = nfs_idmap_new(clp);
  896. if (error < 0) {
  897. dprintk("%s: failed to create idmapper. Error = %d\n",
  898. __func__, error);
  899. goto error;
  900. }
  901. __set_bit(NFS_CS_IDMAP, &clp->cl_res_state);
  902. nfs_mark_client_ready(clp, NFS_CS_READY);
  903. return 0;
  904. error:
  905. nfs_mark_client_ready(clp, error);
  906. dprintk("<-- nfs4_init_client() = xerror %d\n", error);
  907. return error;
  908. }
  909. /*
  910. * Set up an NFS4 client
  911. */
  912. static int nfs4_set_client(struct nfs_server *server,
  913. const char *hostname,
  914. const struct sockaddr *addr,
  915. const size_t addrlen,
  916. const char *ip_addr,
  917. rpc_authflavor_t authflavour,
  918. int proto, const struct rpc_timeout *timeparms)
  919. {
  920. struct nfs_client_initdata cl_init = {
  921. .hostname = hostname,
  922. .addr = addr,
  923. .addrlen = addrlen,
  924. .rpc_ops = &nfs_v4_clientops,
  925. .proto = proto,
  926. };
  927. struct nfs_client *clp;
  928. int error;
  929. dprintk("--> nfs4_set_client()\n");
  930. /* Allocate or find a client reference we can use */
  931. clp = nfs_get_client(&cl_init);
  932. if (IS_ERR(clp)) {
  933. error = PTR_ERR(clp);
  934. goto error;
  935. }
  936. error = nfs4_init_client(clp, timeparms, ip_addr, authflavour,
  937. server->flags);
  938. if (error < 0)
  939. goto error_put;
  940. server->nfs_client = clp;
  941. dprintk("<-- nfs4_set_client() = 0 [new %p]\n", clp);
  942. return 0;
  943. error_put:
  944. nfs_put_client(clp);
  945. error:
  946. dprintk("<-- nfs4_set_client() = xerror %d\n", error);
  947. return error;
  948. }
  949. /*
  950. * Create a version 4 volume record
  951. */
  952. static int nfs4_init_server(struct nfs_server *server,
  953. const struct nfs_parsed_mount_data *data)
  954. {
  955. struct rpc_timeout timeparms;
  956. int error;
  957. dprintk("--> nfs4_init_server()\n");
  958. nfs_init_timeout_values(&timeparms, data->nfs_server.protocol,
  959. data->timeo, data->retrans);
  960. /* Initialise the client representation from the mount data */
  961. server->flags = data->flags;
  962. server->caps |= NFS_CAP_ATOMIC_OPEN;
  963. /* Get a client record */
  964. error = nfs4_set_client(server,
  965. data->nfs_server.hostname,
  966. (const struct sockaddr *)&data->nfs_server.address,
  967. data->nfs_server.addrlen,
  968. data->client_address,
  969. data->auth_flavors[0],
  970. data->nfs_server.protocol,
  971. &timeparms);
  972. if (error < 0)
  973. goto error;
  974. if (data->rsize)
  975. server->rsize = nfs_block_size(data->rsize, NULL);
  976. if (data->wsize)
  977. server->wsize = nfs_block_size(data->wsize, NULL);
  978. server->acregmin = data->acregmin * HZ;
  979. server->acregmax = data->acregmax * HZ;
  980. server->acdirmin = data->acdirmin * HZ;
  981. server->acdirmax = data->acdirmax * HZ;
  982. server->port = data->nfs_server.port;
  983. error = nfs_init_server_rpcclient(server, &timeparms, data->auth_flavors[0]);
  984. error:
  985. /* Done */
  986. dprintk("<-- nfs4_init_server() = %d\n", error);
  987. return error;
  988. }
  989. /*
  990. * Create a version 4 volume record
  991. * - keyed on server and FSID
  992. */
  993. struct nfs_server *nfs4_create_server(const struct nfs_parsed_mount_data *data,
  994. struct nfs_fh *mntfh)
  995. {
  996. struct nfs_fattr fattr;
  997. struct nfs_server *server;
  998. int error;
  999. dprintk("--> nfs4_create_server()\n");
  1000. server = nfs_alloc_server();
  1001. if (!server)
  1002. return ERR_PTR(-ENOMEM);
  1003. /* set up the general RPC client */
  1004. error = nfs4_init_server(server, data);
  1005. if (error < 0)
  1006. goto error;
  1007. BUG_ON(!server->nfs_client);
  1008. BUG_ON(!server->nfs_client->rpc_ops);
  1009. BUG_ON(!server->nfs_client->rpc_ops->file_inode_ops);
  1010. /* Probe the root fh to retrieve its FSID */
  1011. error = nfs4_path_walk(server, mntfh, data->nfs_server.export_path);
  1012. if (error < 0)
  1013. goto error;
  1014. dprintk("Server FSID: %llx:%llx\n",
  1015. (unsigned long long) server->fsid.major,
  1016. (unsigned long long) server->fsid.minor);
  1017. dprintk("Mount FH: %d\n", mntfh->size);
  1018. error = nfs_probe_fsinfo(server, mntfh, &fattr);
  1019. if (error < 0)
  1020. goto error;
  1021. if (server->namelen == 0 || server->namelen > NFS4_MAXNAMLEN)
  1022. server->namelen = NFS4_MAXNAMLEN;
  1023. BUG_ON(!server->nfs_client);
  1024. BUG_ON(!server->nfs_client->rpc_ops);
  1025. BUG_ON(!server->nfs_client->rpc_ops->file_inode_ops);
  1026. spin_lock(&nfs_client_lock);
  1027. list_add_tail(&server->client_link, &server->nfs_client->cl_superblocks);
  1028. list_add_tail(&server->master_link, &nfs_volume_list);
  1029. spin_unlock(&nfs_client_lock);
  1030. server->mount_time = jiffies;
  1031. dprintk("<-- nfs4_create_server() = %p\n", server);
  1032. return server;
  1033. error:
  1034. nfs_free_server(server);
  1035. dprintk("<-- nfs4_create_server() = error %d\n", error);
  1036. return ERR_PTR(error);
  1037. }
  1038. /*
  1039. * Create an NFS4 referral server record
  1040. */
  1041. struct nfs_server *nfs4_create_referral_server(struct nfs_clone_mount *data,
  1042. struct nfs_fh *mntfh)
  1043. {
  1044. struct nfs_client *parent_client;
  1045. struct nfs_server *server, *parent_server;
  1046. struct nfs_fattr fattr;
  1047. int error;
  1048. dprintk("--> nfs4_create_referral_server()\n");
  1049. server = nfs_alloc_server();
  1050. if (!server)
  1051. return ERR_PTR(-ENOMEM);
  1052. parent_server = NFS_SB(data->sb);
  1053. parent_client = parent_server->nfs_client;
  1054. /* Initialise the client representation from the parent server */
  1055. nfs_server_copy_userdata(server, parent_server);
  1056. server->caps |= NFS_CAP_ATOMIC_OPEN;
  1057. /* Get a client representation.
  1058. * Note: NFSv4 always uses TCP, */
  1059. error = nfs4_set_client(server, data->hostname,
  1060. data->addr,
  1061. data->addrlen,
  1062. parent_client->cl_ipaddr,
  1063. data->authflavor,
  1064. parent_server->client->cl_xprt->prot,
  1065. parent_server->client->cl_timeout);
  1066. if (error < 0)
  1067. goto error;
  1068. error = nfs_init_server_rpcclient(server, parent_server->client->cl_timeout, data->authflavor);
  1069. if (error < 0)
  1070. goto error;
  1071. BUG_ON(!server->nfs_client);
  1072. BUG_ON(!server->nfs_client->rpc_ops);
  1073. BUG_ON(!server->nfs_client->rpc_ops->file_inode_ops);
  1074. /* Probe the root fh to retrieve its FSID and filehandle */
  1075. error = nfs4_path_walk(server, mntfh, data->mnt_path);
  1076. if (error < 0)
  1077. goto error;
  1078. /* probe the filesystem info for this server filesystem */
  1079. error = nfs_probe_fsinfo(server, mntfh, &fattr);
  1080. if (error < 0)
  1081. goto error;
  1082. if (server->namelen == 0 || server->namelen > NFS4_MAXNAMLEN)
  1083. server->namelen = NFS4_MAXNAMLEN;
  1084. dprintk("Referral FSID: %llx:%llx\n",
  1085. (unsigned long long) server->fsid.major,
  1086. (unsigned long long) server->fsid.minor);
  1087. spin_lock(&nfs_client_lock);
  1088. list_add_tail(&server->client_link, &server->nfs_client->cl_superblocks);
  1089. list_add_tail(&server->master_link, &nfs_volume_list);
  1090. spin_unlock(&nfs_client_lock);
  1091. server->mount_time = jiffies;
  1092. dprintk("<-- nfs_create_referral_server() = %p\n", server);
  1093. return server;
  1094. error:
  1095. nfs_free_server(server);
  1096. dprintk("<-- nfs4_create_referral_server() = error %d\n", error);
  1097. return ERR_PTR(error);
  1098. }
  1099. #endif /* CONFIG_NFS_V4 */
  1100. /*
  1101. * Clone an NFS2, NFS3 or NFS4 server record
  1102. */
  1103. struct nfs_server *nfs_clone_server(struct nfs_server *source,
  1104. struct nfs_fh *fh,
  1105. struct nfs_fattr *fattr)
  1106. {
  1107. struct nfs_server *server;
  1108. struct nfs_fattr fattr_fsinfo;
  1109. int error;
  1110. dprintk("--> nfs_clone_server(,%llx:%llx,)\n",
  1111. (unsigned long long) fattr->fsid.major,
  1112. (unsigned long long) fattr->fsid.minor);
  1113. server = nfs_alloc_server();
  1114. if (!server)
  1115. return ERR_PTR(-ENOMEM);
  1116. /* Copy data from the source */
  1117. server->nfs_client = source->nfs_client;
  1118. atomic_inc(&server->nfs_client->cl_count);
  1119. nfs_server_copy_userdata(server, source);
  1120. server->fsid = fattr->fsid;
  1121. error = nfs_init_server_rpcclient(server,
  1122. source->client->cl_timeout,
  1123. source->client->cl_auth->au_flavor);
  1124. if (error < 0)
  1125. goto out_free_server;
  1126. if (!IS_ERR(source->client_acl))
  1127. nfs_init_server_aclclient(server);
  1128. /* probe the filesystem info for this server filesystem */
  1129. error = nfs_probe_fsinfo(server, fh, &fattr_fsinfo);
  1130. if (error < 0)
  1131. goto out_free_server;
  1132. if (server->namelen == 0 || server->namelen > NFS4_MAXNAMLEN)
  1133. server->namelen = NFS4_MAXNAMLEN;
  1134. dprintk("Cloned FSID: %llx:%llx\n",
  1135. (unsigned long long) server->fsid.major,
  1136. (unsigned long long) server->fsid.minor);
  1137. error = nfs_start_lockd(server);
  1138. if (error < 0)
  1139. goto out_free_server;
  1140. spin_lock(&nfs_client_lock);
  1141. list_add_tail(&server->client_link, &server->nfs_client->cl_superblocks);
  1142. list_add_tail(&server->master_link, &nfs_volume_list);
  1143. spin_unlock(&nfs_client_lock);
  1144. server->mount_time = jiffies;
  1145. dprintk("<-- nfs_clone_server() = %p\n", server);
  1146. return server;
  1147. out_free_server:
  1148. nfs_free_server(server);
  1149. dprintk("<-- nfs_clone_server() = error %d\n", error);
  1150. return ERR_PTR(error);
  1151. }
  1152. #ifdef CONFIG_PROC_FS
  1153. static struct proc_dir_entry *proc_fs_nfs;
  1154. static int nfs_server_list_open(struct inode *inode, struct file *file);
  1155. static void *nfs_server_list_start(struct seq_file *p, loff_t *pos);
  1156. static void *nfs_server_list_next(struct seq_file *p, void *v, loff_t *pos);
  1157. static void nfs_server_list_stop(struct seq_file *p, void *v);
  1158. static int nfs_server_list_show(struct seq_file *m, void *v);
  1159. static struct seq_operations nfs_server_list_ops = {
  1160. .start = nfs_server_list_start,
  1161. .next = nfs_server_list_next,
  1162. .stop = nfs_server_list_stop,
  1163. .show = nfs_server_list_show,
  1164. };
  1165. static const struct file_operations nfs_server_list_fops = {
  1166. .open = nfs_server_list_open,
  1167. .read = seq_read,
  1168. .llseek = seq_lseek,
  1169. .release = seq_release,
  1170. .owner = THIS_MODULE,
  1171. };
  1172. static int nfs_volume_list_open(struct inode *inode, struct file *file);
  1173. static void *nfs_volume_list_start(struct seq_file *p, loff_t *pos);
  1174. static void *nfs_volume_list_next(struct seq_file *p, void *v, loff_t *pos);
  1175. static void nfs_volume_list_stop(struct seq_file *p, void *v);
  1176. static int nfs_volume_list_show(struct seq_file *m, void *v);
  1177. static struct seq_operations nfs_volume_list_ops = {
  1178. .start = nfs_volume_list_start,
  1179. .next = nfs_volume_list_next,
  1180. .stop = nfs_volume_list_stop,
  1181. .show = nfs_volume_list_show,
  1182. };
  1183. static const struct file_operations nfs_volume_list_fops = {
  1184. .open = nfs_volume_list_open,
  1185. .read = seq_read,
  1186. .llseek = seq_lseek,
  1187. .release = seq_release,
  1188. .owner = THIS_MODULE,
  1189. };
  1190. /*
  1191. * open "/proc/fs/nfsfs/servers" which provides a summary of servers with which
  1192. * we're dealing
  1193. */
  1194. static int nfs_server_list_open(struct inode *inode, struct file *file)
  1195. {
  1196. struct seq_file *m;
  1197. int ret;
  1198. ret = seq_open(file, &nfs_server_list_ops);
  1199. if (ret < 0)
  1200. return ret;
  1201. m = file->private_data;
  1202. m->private = PDE(inode)->data;
  1203. return 0;
  1204. }
  1205. /*
  1206. * set up the iterator to start reading from the server list and return the first item
  1207. */
  1208. static void *nfs_server_list_start(struct seq_file *m, loff_t *_pos)
  1209. {
  1210. /* lock the list against modification */
  1211. spin_lock(&nfs_client_lock);
  1212. return seq_list_start_head(&nfs_client_list, *_pos);
  1213. }
  1214. /*
  1215. * move to next server
  1216. */
  1217. static void *nfs_server_list_next(struct seq_file *p, void *v, loff_t *pos)
  1218. {
  1219. return seq_list_next(v, &nfs_client_list, pos);
  1220. }
  1221. /*
  1222. * clean up after reading from the transports list
  1223. */
  1224. static void nfs_server_list_stop(struct seq_file *p, void *v)
  1225. {
  1226. spin_unlock(&nfs_client_lock);
  1227. }
  1228. /*
  1229. * display a header line followed by a load of call lines
  1230. */
  1231. static int nfs_server_list_show(struct seq_file *m, void *v)
  1232. {
  1233. struct nfs_client *clp;
  1234. /* display header on line 1 */
  1235. if (v == &nfs_client_list) {
  1236. seq_puts(m, "NV SERVER PORT USE HOSTNAME\n");
  1237. return 0;
  1238. }
  1239. /* display one transport per line on subsequent lines */
  1240. clp = list_entry(v, struct nfs_client, cl_share_link);
  1241. seq_printf(m, "v%u %s %s %3d %s\n",
  1242. clp->rpc_ops->version,
  1243. rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_HEX_ADDR),
  1244. rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_HEX_PORT),
  1245. atomic_read(&clp->cl_count),
  1246. clp->cl_hostname);
  1247. return 0;
  1248. }
  1249. /*
  1250. * open "/proc/fs/nfsfs/volumes" which provides a summary of extant volumes
  1251. */
  1252. static int nfs_volume_list_open(struct inode *inode, struct file *file)
  1253. {
  1254. struct seq_file *m;
  1255. int ret;
  1256. ret = seq_open(file, &nfs_volume_list_ops);
  1257. if (ret < 0)
  1258. return ret;
  1259. m = file->private_data;
  1260. m->private = PDE(inode)->data;
  1261. return 0;
  1262. }
  1263. /*
  1264. * set up the iterator to start reading from the volume list and return the first item
  1265. */
  1266. static void *nfs_volume_list_start(struct seq_file *m, loff_t *_pos)
  1267. {
  1268. /* lock the list against modification */
  1269. spin_lock(&nfs_client_lock);
  1270. return seq_list_start_head(&nfs_volume_list, *_pos);
  1271. }
  1272. /*
  1273. * move to next volume
  1274. */
  1275. static void *nfs_volume_list_next(struct seq_file *p, void *v, loff_t *pos)
  1276. {
  1277. return seq_list_next(v, &nfs_volume_list, pos);
  1278. }
  1279. /*
  1280. * clean up after reading from the transports list
  1281. */
  1282. static void nfs_volume_list_stop(struct seq_file *p, void *v)
  1283. {
  1284. spin_unlock(&nfs_client_lock);
  1285. }
  1286. /*
  1287. * display a header line followed by a load of call lines
  1288. */
  1289. static int nfs_volume_list_show(struct seq_file *m, void *v)
  1290. {
  1291. struct nfs_server *server;
  1292. struct nfs_client *clp;
  1293. char dev[8], fsid[17];
  1294. /* display header on line 1 */
  1295. if (v == &nfs_volume_list) {
  1296. seq_puts(m, "NV SERVER PORT DEV FSID\n");
  1297. return 0;
  1298. }
  1299. /* display one transport per line on subsequent lines */
  1300. server = list_entry(v, struct nfs_server, master_link);
  1301. clp = server->nfs_client;
  1302. snprintf(dev, 8, "%u:%u",
  1303. MAJOR(server->s_dev), MINOR(server->s_dev));
  1304. snprintf(fsid, 17, "%llx:%llx",
  1305. (unsigned long long) server->fsid.major,
  1306. (unsigned long long) server->fsid.minor);
  1307. seq_printf(m, "v%u %s %s %-7s %-17s\n",
  1308. clp->rpc_ops->version,
  1309. rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_HEX_ADDR),
  1310. rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_HEX_PORT),
  1311. dev,
  1312. fsid);
  1313. return 0;
  1314. }
  1315. /*
  1316. * initialise the /proc/fs/nfsfs/ directory
  1317. */
  1318. int __init nfs_fs_proc_init(void)
  1319. {
  1320. struct proc_dir_entry *p;
  1321. proc_fs_nfs = proc_mkdir("fs/nfsfs", NULL);
  1322. if (!proc_fs_nfs)
  1323. goto error_0;
  1324. /* a file of servers with which we're dealing */
  1325. p = proc_create("servers", S_IFREG|S_IRUGO,
  1326. proc_fs_nfs, &nfs_server_list_fops);
  1327. if (!p)
  1328. goto error_1;
  1329. /* a file of volumes that we have mounted */
  1330. p = proc_create("volumes", S_IFREG|S_IRUGO,
  1331. proc_fs_nfs, &nfs_volume_list_fops);
  1332. if (!p)
  1333. goto error_2;
  1334. return 0;
  1335. error_2:
  1336. remove_proc_entry("servers", proc_fs_nfs);
  1337. error_1:
  1338. remove_proc_entry("fs/nfsfs", NULL);
  1339. error_0:
  1340. return -ENOMEM;
  1341. }
  1342. /*
  1343. * clean up the /proc/fs/nfsfs/ directory
  1344. */
  1345. void nfs_fs_proc_exit(void)
  1346. {
  1347. remove_proc_entry("volumes", proc_fs_nfs);
  1348. remove_proc_entry("servers", proc_fs_nfs);
  1349. remove_proc_entry("fs/nfsfs", NULL);
  1350. }
  1351. #endif /* CONFIG_PROC_FS */