client.c 41 KB

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