client.c 35 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390
  1. // SPDX-License-Identifier: GPL-2.0-or-later
  2. /* client.c: NFS client sharing and management code
  3. *
  4. * Copyright (C) 2006 Red Hat, Inc. All Rights Reserved.
  5. * Written by David Howells ([email protected])
  6. */
  7. #include <linux/module.h>
  8. #include <linux/init.h>
  9. #include <linux/sched.h>
  10. #include <linux/time.h>
  11. #include <linux/kernel.h>
  12. #include <linux/mm.h>
  13. #include <linux/string.h>
  14. #include <linux/stat.h>
  15. #include <linux/errno.h>
  16. #include <linux/unistd.h>
  17. #include <linux/sunrpc/addr.h>
  18. #include <linux/sunrpc/clnt.h>
  19. #include <linux/sunrpc/stats.h>
  20. #include <linux/sunrpc/metrics.h>
  21. #include <linux/sunrpc/xprtsock.h>
  22. #include <linux/sunrpc/xprtrdma.h>
  23. #include <linux/nfs_fs.h>
  24. #include <linux/nfs_mount.h>
  25. #include <linux/nfs4_mount.h>
  26. #include <linux/lockd/bind.h>
  27. #include <linux/seq_file.h>
  28. #include <linux/mount.h>
  29. #include <linux/vfs.h>
  30. #include <linux/inet.h>
  31. #include <linux/in6.h>
  32. #include <linux/slab.h>
  33. #include <linux/idr.h>
  34. #include <net/ipv6.h>
  35. #include <linux/nfs_xdr.h>
  36. #include <linux/sunrpc/bc_xprt.h>
  37. #include <linux/nsproxy.h>
  38. #include <linux/pid_namespace.h>
  39. #include "nfs4_fs.h"
  40. #include "callback.h"
  41. #include "delegation.h"
  42. #include "iostat.h"
  43. #include "internal.h"
  44. #include "fscache.h"
  45. #include "pnfs.h"
  46. #include "nfs.h"
  47. #include "netns.h"
  48. #include "sysfs.h"
  49. #include "nfs42.h"
  50. #define NFSDBG_FACILITY NFSDBG_CLIENT
  51. static DECLARE_WAIT_QUEUE_HEAD(nfs_client_active_wq);
  52. static DEFINE_SPINLOCK(nfs_version_lock);
  53. static DEFINE_MUTEX(nfs_version_mutex);
  54. static LIST_HEAD(nfs_versions);
  55. /*
  56. * RPC cruft for NFS
  57. */
  58. static const struct rpc_version *nfs_version[5] = {
  59. [2] = NULL,
  60. [3] = NULL,
  61. [4] = NULL,
  62. };
  63. const struct rpc_program nfs_program = {
  64. .name = "nfs",
  65. .number = NFS_PROGRAM,
  66. .nrvers = ARRAY_SIZE(nfs_version),
  67. .version = nfs_version,
  68. .stats = &nfs_rpcstat,
  69. .pipe_dir_name = NFS_PIPE_DIRNAME,
  70. };
  71. struct rpc_stat nfs_rpcstat = {
  72. .program = &nfs_program
  73. };
  74. static struct nfs_subversion *find_nfs_version(unsigned int version)
  75. {
  76. struct nfs_subversion *nfs;
  77. spin_lock(&nfs_version_lock);
  78. list_for_each_entry(nfs, &nfs_versions, list) {
  79. if (nfs->rpc_ops->version == version) {
  80. spin_unlock(&nfs_version_lock);
  81. return nfs;
  82. }
  83. }
  84. spin_unlock(&nfs_version_lock);
  85. return ERR_PTR(-EPROTONOSUPPORT);
  86. }
  87. struct nfs_subversion *get_nfs_version(unsigned int version)
  88. {
  89. struct nfs_subversion *nfs = find_nfs_version(version);
  90. if (IS_ERR(nfs)) {
  91. mutex_lock(&nfs_version_mutex);
  92. request_module("nfsv%d", version);
  93. nfs = find_nfs_version(version);
  94. mutex_unlock(&nfs_version_mutex);
  95. }
  96. if (!IS_ERR(nfs) && !try_module_get(nfs->owner))
  97. return ERR_PTR(-EAGAIN);
  98. return nfs;
  99. }
  100. void put_nfs_version(struct nfs_subversion *nfs)
  101. {
  102. module_put(nfs->owner);
  103. }
  104. void register_nfs_version(struct nfs_subversion *nfs)
  105. {
  106. spin_lock(&nfs_version_lock);
  107. list_add(&nfs->list, &nfs_versions);
  108. nfs_version[nfs->rpc_ops->version] = nfs->rpc_vers;
  109. spin_unlock(&nfs_version_lock);
  110. }
  111. EXPORT_SYMBOL_GPL(register_nfs_version);
  112. void unregister_nfs_version(struct nfs_subversion *nfs)
  113. {
  114. spin_lock(&nfs_version_lock);
  115. nfs_version[nfs->rpc_ops->version] = NULL;
  116. list_del(&nfs->list);
  117. spin_unlock(&nfs_version_lock);
  118. }
  119. EXPORT_SYMBOL_GPL(unregister_nfs_version);
  120. /*
  121. * Allocate a shared client record
  122. *
  123. * Since these are allocated/deallocated very rarely, we don't
  124. * bother putting them in a slab cache...
  125. */
  126. struct nfs_client *nfs_alloc_client(const struct nfs_client_initdata *cl_init)
  127. {
  128. struct nfs_client *clp;
  129. int err = -ENOMEM;
  130. if ((clp = kzalloc(sizeof(*clp), GFP_KERNEL)) == NULL)
  131. goto error_0;
  132. clp->cl_minorversion = cl_init->minorversion;
  133. clp->cl_nfs_mod = cl_init->nfs_mod;
  134. if (!try_module_get(clp->cl_nfs_mod->owner))
  135. goto error_dealloc;
  136. clp->rpc_ops = clp->cl_nfs_mod->rpc_ops;
  137. refcount_set(&clp->cl_count, 1);
  138. clp->cl_cons_state = NFS_CS_INITING;
  139. memcpy(&clp->cl_addr, cl_init->addr, cl_init->addrlen);
  140. clp->cl_addrlen = cl_init->addrlen;
  141. if (cl_init->hostname) {
  142. err = -ENOMEM;
  143. clp->cl_hostname = kstrdup(cl_init->hostname, GFP_KERNEL);
  144. if (!clp->cl_hostname)
  145. goto error_cleanup;
  146. }
  147. INIT_LIST_HEAD(&clp->cl_superblocks);
  148. clp->cl_rpcclient = ERR_PTR(-EINVAL);
  149. clp->cl_flags = cl_init->init_flags;
  150. clp->cl_proto = cl_init->proto;
  151. clp->cl_nconnect = cl_init->nconnect;
  152. clp->cl_max_connect = cl_init->max_connect ? cl_init->max_connect : 1;
  153. clp->cl_net = get_net(cl_init->net);
  154. clp->cl_principal = "*";
  155. return clp;
  156. error_cleanup:
  157. put_nfs_version(clp->cl_nfs_mod);
  158. error_dealloc:
  159. kfree(clp);
  160. error_0:
  161. return ERR_PTR(err);
  162. }
  163. EXPORT_SYMBOL_GPL(nfs_alloc_client);
  164. #if IS_ENABLED(CONFIG_NFS_V4)
  165. static void nfs_cleanup_cb_ident_idr(struct net *net)
  166. {
  167. struct nfs_net *nn = net_generic(net, nfs_net_id);
  168. idr_destroy(&nn->cb_ident_idr);
  169. }
  170. /* nfs_client_lock held */
  171. static void nfs_cb_idr_remove_locked(struct nfs_client *clp)
  172. {
  173. struct nfs_net *nn = net_generic(clp->cl_net, nfs_net_id);
  174. if (clp->cl_cb_ident)
  175. idr_remove(&nn->cb_ident_idr, clp->cl_cb_ident);
  176. }
  177. static void pnfs_init_server(struct nfs_server *server)
  178. {
  179. rpc_init_wait_queue(&server->roc_rpcwaitq, "pNFS ROC");
  180. }
  181. #else
  182. static void nfs_cleanup_cb_ident_idr(struct net *net)
  183. {
  184. }
  185. static void nfs_cb_idr_remove_locked(struct nfs_client *clp)
  186. {
  187. }
  188. static void pnfs_init_server(struct nfs_server *server)
  189. {
  190. }
  191. #endif /* CONFIG_NFS_V4 */
  192. /*
  193. * Destroy a shared client record
  194. */
  195. void nfs_free_client(struct nfs_client *clp)
  196. {
  197. /* -EIO all pending I/O */
  198. if (!IS_ERR(clp->cl_rpcclient))
  199. rpc_shutdown_client(clp->cl_rpcclient);
  200. put_net(clp->cl_net);
  201. put_nfs_version(clp->cl_nfs_mod);
  202. kfree(clp->cl_hostname);
  203. kfree(clp->cl_acceptor);
  204. kfree(clp);
  205. }
  206. EXPORT_SYMBOL_GPL(nfs_free_client);
  207. /*
  208. * Release a reference to a shared client record
  209. */
  210. void nfs_put_client(struct nfs_client *clp)
  211. {
  212. struct nfs_net *nn;
  213. if (!clp)
  214. return;
  215. nn = net_generic(clp->cl_net, nfs_net_id);
  216. if (refcount_dec_and_lock(&clp->cl_count, &nn->nfs_client_lock)) {
  217. list_del(&clp->cl_share_link);
  218. nfs_cb_idr_remove_locked(clp);
  219. spin_unlock(&nn->nfs_client_lock);
  220. WARN_ON_ONCE(!list_empty(&clp->cl_superblocks));
  221. clp->rpc_ops->free_client(clp);
  222. }
  223. }
  224. EXPORT_SYMBOL_GPL(nfs_put_client);
  225. /*
  226. * Find an nfs_client on the list that matches the initialisation data
  227. * that is supplied.
  228. */
  229. static struct nfs_client *nfs_match_client(const struct nfs_client_initdata *data)
  230. {
  231. struct nfs_client *clp;
  232. const struct sockaddr *sap = (struct sockaddr *)data->addr;
  233. struct nfs_net *nn = net_generic(data->net, nfs_net_id);
  234. int error;
  235. again:
  236. list_for_each_entry(clp, &nn->nfs_client_list, cl_share_link) {
  237. const struct sockaddr *clap = (struct sockaddr *)&clp->cl_addr;
  238. /* Don't match clients that failed to initialise properly */
  239. if (clp->cl_cons_state < 0)
  240. continue;
  241. /* If a client is still initializing then we need to wait */
  242. if (clp->cl_cons_state > NFS_CS_READY) {
  243. refcount_inc(&clp->cl_count);
  244. spin_unlock(&nn->nfs_client_lock);
  245. error = nfs_wait_client_init_complete(clp);
  246. nfs_put_client(clp);
  247. spin_lock(&nn->nfs_client_lock);
  248. if (error < 0)
  249. return ERR_PTR(error);
  250. goto again;
  251. }
  252. /* Different NFS versions cannot share the same nfs_client */
  253. if (clp->rpc_ops != data->nfs_mod->rpc_ops)
  254. continue;
  255. if (clp->cl_proto != data->proto)
  256. continue;
  257. /* Match nfsv4 minorversion */
  258. if (clp->cl_minorversion != data->minorversion)
  259. continue;
  260. /* Match request for a dedicated DS */
  261. if (test_bit(NFS_CS_DS, &data->init_flags) !=
  262. test_bit(NFS_CS_DS, &clp->cl_flags))
  263. continue;
  264. /* Match the full socket address */
  265. if (!rpc_cmp_addr_port(sap, clap))
  266. /* Match all xprt_switch full socket addresses */
  267. if (IS_ERR(clp->cl_rpcclient) ||
  268. !rpc_clnt_xprt_switch_has_addr(clp->cl_rpcclient,
  269. sap))
  270. continue;
  271. refcount_inc(&clp->cl_count);
  272. return clp;
  273. }
  274. return NULL;
  275. }
  276. /*
  277. * Return true if @clp is done initializing, false if still working on it.
  278. *
  279. * Use nfs_client_init_status to check if it was successful.
  280. */
  281. bool nfs_client_init_is_complete(const struct nfs_client *clp)
  282. {
  283. return clp->cl_cons_state <= NFS_CS_READY;
  284. }
  285. EXPORT_SYMBOL_GPL(nfs_client_init_is_complete);
  286. /*
  287. * Return 0 if @clp was successfully initialized, -errno otherwise.
  288. *
  289. * This must be called *after* nfs_client_init_is_complete() returns true,
  290. * otherwise it will pop WARN_ON_ONCE and return -EINVAL
  291. */
  292. int nfs_client_init_status(const struct nfs_client *clp)
  293. {
  294. /* called without checking nfs_client_init_is_complete */
  295. if (clp->cl_cons_state > NFS_CS_READY) {
  296. WARN_ON_ONCE(1);
  297. return -EINVAL;
  298. }
  299. return clp->cl_cons_state;
  300. }
  301. EXPORT_SYMBOL_GPL(nfs_client_init_status);
  302. int nfs_wait_client_init_complete(const struct nfs_client *clp)
  303. {
  304. return wait_event_killable(nfs_client_active_wq,
  305. nfs_client_init_is_complete(clp));
  306. }
  307. EXPORT_SYMBOL_GPL(nfs_wait_client_init_complete);
  308. /*
  309. * Found an existing client. Make sure it's ready before returning.
  310. */
  311. static struct nfs_client *
  312. nfs_found_client(const struct nfs_client_initdata *cl_init,
  313. struct nfs_client *clp)
  314. {
  315. int error;
  316. error = nfs_wait_client_init_complete(clp);
  317. if (error < 0) {
  318. nfs_put_client(clp);
  319. return ERR_PTR(-ERESTARTSYS);
  320. }
  321. if (clp->cl_cons_state < NFS_CS_READY) {
  322. error = clp->cl_cons_state;
  323. nfs_put_client(clp);
  324. return ERR_PTR(error);
  325. }
  326. smp_rmb();
  327. return clp;
  328. }
  329. /*
  330. * Look up a client by IP address and protocol version
  331. * - creates a new record if one doesn't yet exist
  332. */
  333. struct nfs_client *nfs_get_client(const struct nfs_client_initdata *cl_init)
  334. {
  335. struct nfs_client *clp, *new = NULL;
  336. struct nfs_net *nn = net_generic(cl_init->net, nfs_net_id);
  337. const struct nfs_rpc_ops *rpc_ops = cl_init->nfs_mod->rpc_ops;
  338. if (cl_init->hostname == NULL) {
  339. WARN_ON(1);
  340. return ERR_PTR(-EINVAL);
  341. }
  342. /* see if the client already exists */
  343. do {
  344. spin_lock(&nn->nfs_client_lock);
  345. clp = nfs_match_client(cl_init);
  346. if (clp) {
  347. spin_unlock(&nn->nfs_client_lock);
  348. if (new)
  349. new->rpc_ops->free_client(new);
  350. if (IS_ERR(clp))
  351. return clp;
  352. return nfs_found_client(cl_init, clp);
  353. }
  354. if (new) {
  355. list_add_tail(&new->cl_share_link,
  356. &nn->nfs_client_list);
  357. spin_unlock(&nn->nfs_client_lock);
  358. return rpc_ops->init_client(new, cl_init);
  359. }
  360. spin_unlock(&nn->nfs_client_lock);
  361. new = rpc_ops->alloc_client(cl_init);
  362. } while (!IS_ERR(new));
  363. return new;
  364. }
  365. EXPORT_SYMBOL_GPL(nfs_get_client);
  366. /*
  367. * Mark a server as ready or failed
  368. */
  369. void nfs_mark_client_ready(struct nfs_client *clp, int state)
  370. {
  371. smp_wmb();
  372. clp->cl_cons_state = state;
  373. wake_up_all(&nfs_client_active_wq);
  374. }
  375. EXPORT_SYMBOL_GPL(nfs_mark_client_ready);
  376. /*
  377. * Initialise the timeout values for a connection
  378. */
  379. void nfs_init_timeout_values(struct rpc_timeout *to, int proto,
  380. int timeo, int retrans)
  381. {
  382. to->to_initval = timeo * HZ / 10;
  383. to->to_retries = retrans;
  384. switch (proto) {
  385. case XPRT_TRANSPORT_TCP:
  386. case XPRT_TRANSPORT_RDMA:
  387. if (retrans == NFS_UNSPEC_RETRANS)
  388. to->to_retries = NFS_DEF_TCP_RETRANS;
  389. if (timeo == NFS_UNSPEC_TIMEO || to->to_initval == 0)
  390. to->to_initval = NFS_DEF_TCP_TIMEO * HZ / 10;
  391. if (to->to_initval > NFS_MAX_TCP_TIMEOUT)
  392. to->to_initval = NFS_MAX_TCP_TIMEOUT;
  393. to->to_increment = to->to_initval;
  394. to->to_maxval = to->to_initval + (to->to_increment * to->to_retries);
  395. if (to->to_maxval > NFS_MAX_TCP_TIMEOUT)
  396. to->to_maxval = NFS_MAX_TCP_TIMEOUT;
  397. if (to->to_maxval < to->to_initval)
  398. to->to_maxval = to->to_initval;
  399. to->to_exponential = 0;
  400. break;
  401. case XPRT_TRANSPORT_UDP:
  402. if (retrans == NFS_UNSPEC_RETRANS)
  403. to->to_retries = NFS_DEF_UDP_RETRANS;
  404. if (timeo == NFS_UNSPEC_TIMEO || to->to_initval == 0)
  405. to->to_initval = NFS_DEF_UDP_TIMEO * HZ / 10;
  406. if (to->to_initval > NFS_MAX_UDP_TIMEOUT)
  407. to->to_initval = NFS_MAX_UDP_TIMEOUT;
  408. to->to_maxval = NFS_MAX_UDP_TIMEOUT;
  409. to->to_exponential = 1;
  410. break;
  411. default:
  412. BUG();
  413. }
  414. }
  415. EXPORT_SYMBOL_GPL(nfs_init_timeout_values);
  416. /*
  417. * Create an RPC client handle
  418. */
  419. int nfs_create_rpc_client(struct nfs_client *clp,
  420. const struct nfs_client_initdata *cl_init,
  421. rpc_authflavor_t flavor)
  422. {
  423. struct rpc_clnt *clnt = NULL;
  424. struct rpc_create_args args = {
  425. .net = clp->cl_net,
  426. .protocol = clp->cl_proto,
  427. .nconnect = clp->cl_nconnect,
  428. .address = (struct sockaddr *)&clp->cl_addr,
  429. .addrsize = clp->cl_addrlen,
  430. .timeout = cl_init->timeparms,
  431. .servername = clp->cl_hostname,
  432. .nodename = cl_init->nodename,
  433. .program = &nfs_program,
  434. .version = clp->rpc_ops->version,
  435. .authflavor = flavor,
  436. .cred = cl_init->cred,
  437. };
  438. if (test_bit(NFS_CS_DISCRTRY, &clp->cl_flags))
  439. args.flags |= RPC_CLNT_CREATE_DISCRTRY;
  440. if (test_bit(NFS_CS_NO_RETRANS_TIMEOUT, &clp->cl_flags))
  441. args.flags |= RPC_CLNT_CREATE_NO_RETRANS_TIMEOUT;
  442. if (test_bit(NFS_CS_NORESVPORT, &clp->cl_flags))
  443. args.flags |= RPC_CLNT_CREATE_NONPRIVPORT;
  444. if (test_bit(NFS_CS_INFINITE_SLOTS, &clp->cl_flags))
  445. args.flags |= RPC_CLNT_CREATE_INFINITE_SLOTS;
  446. if (test_bit(NFS_CS_NOPING, &clp->cl_flags))
  447. args.flags |= RPC_CLNT_CREATE_NOPING;
  448. if (test_bit(NFS_CS_REUSEPORT, &clp->cl_flags))
  449. args.flags |= RPC_CLNT_CREATE_REUSEPORT;
  450. if (!IS_ERR(clp->cl_rpcclient))
  451. return 0;
  452. clnt = rpc_create(&args);
  453. if (IS_ERR(clnt)) {
  454. dprintk("%s: cannot create RPC client. Error = %ld\n",
  455. __func__, PTR_ERR(clnt));
  456. return PTR_ERR(clnt);
  457. }
  458. clnt->cl_principal = clp->cl_principal;
  459. clp->cl_rpcclient = clnt;
  460. clnt->cl_max_connect = clp->cl_max_connect;
  461. return 0;
  462. }
  463. EXPORT_SYMBOL_GPL(nfs_create_rpc_client);
  464. /*
  465. * Version 2 or 3 client destruction
  466. */
  467. static void nfs_destroy_server(struct nfs_server *server)
  468. {
  469. if (server->nlm_host)
  470. nlmclnt_done(server->nlm_host);
  471. }
  472. /*
  473. * Version 2 or 3 lockd setup
  474. */
  475. static int nfs_start_lockd(struct nfs_server *server)
  476. {
  477. struct nlm_host *host;
  478. struct nfs_client *clp = server->nfs_client;
  479. struct nlmclnt_initdata nlm_init = {
  480. .hostname = clp->cl_hostname,
  481. .address = (struct sockaddr *)&clp->cl_addr,
  482. .addrlen = clp->cl_addrlen,
  483. .nfs_version = clp->rpc_ops->version,
  484. .noresvport = server->flags & NFS_MOUNT_NORESVPORT ?
  485. 1 : 0,
  486. .net = clp->cl_net,
  487. .nlmclnt_ops = clp->cl_nfs_mod->rpc_ops->nlmclnt_ops,
  488. .cred = server->cred,
  489. };
  490. if (nlm_init.nfs_version > 3)
  491. return 0;
  492. if ((server->flags & NFS_MOUNT_LOCAL_FLOCK) &&
  493. (server->flags & NFS_MOUNT_LOCAL_FCNTL))
  494. return 0;
  495. switch (clp->cl_proto) {
  496. default:
  497. nlm_init.protocol = IPPROTO_TCP;
  498. break;
  499. #ifndef CONFIG_NFS_DISABLE_UDP_SUPPORT
  500. case XPRT_TRANSPORT_UDP:
  501. nlm_init.protocol = IPPROTO_UDP;
  502. #endif
  503. }
  504. host = nlmclnt_init(&nlm_init);
  505. if (IS_ERR(host))
  506. return PTR_ERR(host);
  507. server->nlm_host = host;
  508. server->destroy = nfs_destroy_server;
  509. return 0;
  510. }
  511. /*
  512. * Create a general RPC client
  513. */
  514. int nfs_init_server_rpcclient(struct nfs_server *server,
  515. const struct rpc_timeout *timeo,
  516. rpc_authflavor_t pseudoflavour)
  517. {
  518. struct nfs_client *clp = server->nfs_client;
  519. server->client = rpc_clone_client_set_auth(clp->cl_rpcclient,
  520. pseudoflavour);
  521. if (IS_ERR(server->client)) {
  522. dprintk("%s: couldn't create rpc_client!\n", __func__);
  523. return PTR_ERR(server->client);
  524. }
  525. memcpy(&server->client->cl_timeout_default,
  526. timeo,
  527. sizeof(server->client->cl_timeout_default));
  528. server->client->cl_timeout = &server->client->cl_timeout_default;
  529. server->client->cl_softrtry = 0;
  530. if (server->flags & NFS_MOUNT_SOFTERR)
  531. server->client->cl_softerr = 1;
  532. if (server->flags & NFS_MOUNT_SOFT)
  533. server->client->cl_softrtry = 1;
  534. return 0;
  535. }
  536. EXPORT_SYMBOL_GPL(nfs_init_server_rpcclient);
  537. /**
  538. * nfs_init_client - Initialise an NFS2 or NFS3 client
  539. *
  540. * @clp: nfs_client to initialise
  541. * @cl_init: Initialisation parameters
  542. *
  543. * Returns pointer to an NFS client, or an ERR_PTR value.
  544. */
  545. struct nfs_client *nfs_init_client(struct nfs_client *clp,
  546. const struct nfs_client_initdata *cl_init)
  547. {
  548. int error;
  549. /* the client is already initialised */
  550. if (clp->cl_cons_state == NFS_CS_READY)
  551. return clp;
  552. /*
  553. * Create a client RPC handle for doing FSSTAT with UNIX auth only
  554. * - RFC 2623, sec 2.3.2
  555. */
  556. error = nfs_create_rpc_client(clp, cl_init, RPC_AUTH_UNIX);
  557. nfs_mark_client_ready(clp, error == 0 ? NFS_CS_READY : error);
  558. if (error < 0) {
  559. nfs_put_client(clp);
  560. clp = ERR_PTR(error);
  561. }
  562. return clp;
  563. }
  564. EXPORT_SYMBOL_GPL(nfs_init_client);
  565. /*
  566. * Create a version 2 or 3 client
  567. */
  568. static int nfs_init_server(struct nfs_server *server,
  569. const struct fs_context *fc)
  570. {
  571. const struct nfs_fs_context *ctx = nfs_fc2context(fc);
  572. struct rpc_timeout timeparms;
  573. struct nfs_client_initdata cl_init = {
  574. .hostname = ctx->nfs_server.hostname,
  575. .addr = &ctx->nfs_server._address,
  576. .addrlen = ctx->nfs_server.addrlen,
  577. .nfs_mod = ctx->nfs_mod,
  578. .proto = ctx->nfs_server.protocol,
  579. .net = fc->net_ns,
  580. .timeparms = &timeparms,
  581. .cred = server->cred,
  582. .nconnect = ctx->nfs_server.nconnect,
  583. .init_flags = (1UL << NFS_CS_REUSEPORT),
  584. };
  585. struct nfs_client *clp;
  586. int error;
  587. nfs_init_timeout_values(&timeparms, ctx->nfs_server.protocol,
  588. ctx->timeo, ctx->retrans);
  589. if (ctx->flags & NFS_MOUNT_NORESVPORT)
  590. set_bit(NFS_CS_NORESVPORT, &cl_init.init_flags);
  591. /* Allocate or find a client reference we can use */
  592. clp = nfs_get_client(&cl_init);
  593. if (IS_ERR(clp))
  594. return PTR_ERR(clp);
  595. server->nfs_client = clp;
  596. /* Initialise the client representation from the mount data */
  597. server->flags = ctx->flags;
  598. server->options = ctx->options;
  599. server->caps |= NFS_CAP_HARDLINKS | NFS_CAP_SYMLINKS;
  600. switch (clp->rpc_ops->version) {
  601. case 2:
  602. server->fattr_valid = NFS_ATTR_FATTR_V2;
  603. break;
  604. case 3:
  605. server->fattr_valid = NFS_ATTR_FATTR_V3;
  606. break;
  607. default:
  608. server->fattr_valid = NFS_ATTR_FATTR_V4;
  609. }
  610. if (ctx->rsize)
  611. server->rsize = nfs_io_size(ctx->rsize, clp->cl_proto);
  612. if (ctx->wsize)
  613. server->wsize = nfs_io_size(ctx->wsize, clp->cl_proto);
  614. server->acregmin = ctx->acregmin * HZ;
  615. server->acregmax = ctx->acregmax * HZ;
  616. server->acdirmin = ctx->acdirmin * HZ;
  617. server->acdirmax = ctx->acdirmax * HZ;
  618. /* Start lockd here, before we might error out */
  619. error = nfs_start_lockd(server);
  620. if (error < 0)
  621. goto error;
  622. server->port = ctx->nfs_server.port;
  623. server->auth_info = ctx->auth_info;
  624. error = nfs_init_server_rpcclient(server, &timeparms,
  625. ctx->selected_flavor);
  626. if (error < 0)
  627. goto error;
  628. /* Preserve the values of mount_server-related mount options */
  629. if (ctx->mount_server.addrlen) {
  630. memcpy(&server->mountd_address, &ctx->mount_server.address,
  631. ctx->mount_server.addrlen);
  632. server->mountd_addrlen = ctx->mount_server.addrlen;
  633. }
  634. server->mountd_version = ctx->mount_server.version;
  635. server->mountd_port = ctx->mount_server.port;
  636. server->mountd_protocol = ctx->mount_server.protocol;
  637. server->namelen = ctx->namlen;
  638. return 0;
  639. error:
  640. server->nfs_client = NULL;
  641. nfs_put_client(clp);
  642. return error;
  643. }
  644. /*
  645. * Load up the server record from information gained in an fsinfo record
  646. */
  647. static void nfs_server_set_fsinfo(struct nfs_server *server,
  648. struct nfs_fsinfo *fsinfo)
  649. {
  650. struct nfs_client *clp = server->nfs_client;
  651. unsigned long max_rpc_payload, raw_max_rpc_payload;
  652. /* Work out a lot of parameters */
  653. if (server->rsize == 0)
  654. server->rsize = nfs_io_size(fsinfo->rtpref, clp->cl_proto);
  655. if (server->wsize == 0)
  656. server->wsize = nfs_io_size(fsinfo->wtpref, clp->cl_proto);
  657. if (fsinfo->rtmax >= 512 && server->rsize > fsinfo->rtmax)
  658. server->rsize = nfs_io_size(fsinfo->rtmax, clp->cl_proto);
  659. if (fsinfo->wtmax >= 512 && server->wsize > fsinfo->wtmax)
  660. server->wsize = nfs_io_size(fsinfo->wtmax, clp->cl_proto);
  661. raw_max_rpc_payload = rpc_max_payload(server->client);
  662. max_rpc_payload = nfs_block_size(raw_max_rpc_payload, NULL);
  663. if (server->rsize > max_rpc_payload)
  664. server->rsize = max_rpc_payload;
  665. if (server->rsize > NFS_MAX_FILE_IO_SIZE)
  666. server->rsize = NFS_MAX_FILE_IO_SIZE;
  667. server->rpages = (server->rsize + PAGE_SIZE - 1) >> PAGE_SHIFT;
  668. if (server->wsize > max_rpc_payload)
  669. server->wsize = max_rpc_payload;
  670. if (server->wsize > NFS_MAX_FILE_IO_SIZE)
  671. server->wsize = NFS_MAX_FILE_IO_SIZE;
  672. server->wpages = (server->wsize + PAGE_SIZE - 1) >> PAGE_SHIFT;
  673. server->wtmult = nfs_block_bits(fsinfo->wtmult, NULL);
  674. server->dtsize = nfs_block_size(fsinfo->dtpref, NULL);
  675. if (server->dtsize > NFS_MAX_FILE_IO_SIZE)
  676. server->dtsize = NFS_MAX_FILE_IO_SIZE;
  677. if (server->dtsize > server->rsize)
  678. server->dtsize = server->rsize;
  679. if (server->flags & NFS_MOUNT_NOAC) {
  680. server->acregmin = server->acregmax = 0;
  681. server->acdirmin = server->acdirmax = 0;
  682. }
  683. server->maxfilesize = fsinfo->maxfilesize;
  684. server->time_delta = fsinfo->time_delta;
  685. server->change_attr_type = fsinfo->change_attr_type;
  686. server->clone_blksize = fsinfo->clone_blksize;
  687. /* We're airborne Set socket buffersize */
  688. rpc_setbufsize(server->client, server->wsize + 100, server->rsize + 100);
  689. #ifdef CONFIG_NFS_V4_2
  690. /*
  691. * Defaults until limited by the session parameters.
  692. */
  693. server->gxasize = min_t(unsigned int, raw_max_rpc_payload,
  694. XATTR_SIZE_MAX);
  695. server->sxasize = min_t(unsigned int, raw_max_rpc_payload,
  696. XATTR_SIZE_MAX);
  697. server->lxasize = min_t(unsigned int, raw_max_rpc_payload,
  698. nfs42_listxattr_xdrsize(XATTR_LIST_MAX));
  699. if (fsinfo->xattr_support)
  700. server->caps |= NFS_CAP_XATTR;
  701. #endif
  702. }
  703. /*
  704. * Probe filesystem information, including the FSID on v2/v3
  705. */
  706. static int nfs_probe_fsinfo(struct nfs_server *server, struct nfs_fh *mntfh, struct nfs_fattr *fattr)
  707. {
  708. struct nfs_fsinfo fsinfo;
  709. struct nfs_client *clp = server->nfs_client;
  710. int error;
  711. if (clp->rpc_ops->set_capabilities != NULL) {
  712. error = clp->rpc_ops->set_capabilities(server, mntfh);
  713. if (error < 0)
  714. return error;
  715. }
  716. fsinfo.fattr = fattr;
  717. fsinfo.nlayouttypes = 0;
  718. memset(fsinfo.layouttype, 0, sizeof(fsinfo.layouttype));
  719. error = clp->rpc_ops->fsinfo(server, mntfh, &fsinfo);
  720. if (error < 0)
  721. return error;
  722. nfs_server_set_fsinfo(server, &fsinfo);
  723. /* Get some general file system info */
  724. if (server->namelen == 0) {
  725. struct nfs_pathconf pathinfo;
  726. pathinfo.fattr = fattr;
  727. nfs_fattr_init(fattr);
  728. if (clp->rpc_ops->pathconf(server, mntfh, &pathinfo) >= 0)
  729. server->namelen = pathinfo.max_namelen;
  730. }
  731. if (clp->rpc_ops->discover_trunking != NULL &&
  732. (server->caps & NFS_CAP_FS_LOCATIONS &&
  733. (server->flags & NFS_MOUNT_TRUNK_DISCOVERY))) {
  734. error = clp->rpc_ops->discover_trunking(server, mntfh);
  735. if (error < 0)
  736. return error;
  737. }
  738. return 0;
  739. }
  740. /*
  741. * Grab the destination's particulars, including lease expiry time.
  742. *
  743. * Returns zero if probe succeeded and retrieved FSID matches the FSID
  744. * we have cached.
  745. */
  746. int nfs_probe_server(struct nfs_server *server, struct nfs_fh *mntfh)
  747. {
  748. struct nfs_fattr *fattr;
  749. int error;
  750. fattr = nfs_alloc_fattr();
  751. if (fattr == NULL)
  752. return -ENOMEM;
  753. /* Sanity: the probe won't work if the destination server
  754. * does not recognize the migrated FH. */
  755. error = nfs_probe_fsinfo(server, mntfh, fattr);
  756. nfs_free_fattr(fattr);
  757. return error;
  758. }
  759. EXPORT_SYMBOL_GPL(nfs_probe_server);
  760. /*
  761. * Copy useful information when duplicating a server record
  762. */
  763. void nfs_server_copy_userdata(struct nfs_server *target, struct nfs_server *source)
  764. {
  765. target->flags = source->flags;
  766. target->rsize = source->rsize;
  767. target->wsize = source->wsize;
  768. target->acregmin = source->acregmin;
  769. target->acregmax = source->acregmax;
  770. target->acdirmin = source->acdirmin;
  771. target->acdirmax = source->acdirmax;
  772. target->caps = source->caps;
  773. target->options = source->options;
  774. target->auth_info = source->auth_info;
  775. target->port = source->port;
  776. }
  777. EXPORT_SYMBOL_GPL(nfs_server_copy_userdata);
  778. void nfs_server_insert_lists(struct nfs_server *server)
  779. {
  780. struct nfs_client *clp = server->nfs_client;
  781. struct nfs_net *nn = net_generic(clp->cl_net, nfs_net_id);
  782. spin_lock(&nn->nfs_client_lock);
  783. list_add_tail_rcu(&server->client_link, &clp->cl_superblocks);
  784. list_add_tail(&server->master_link, &nn->nfs_volume_list);
  785. clear_bit(NFS_CS_STOP_RENEW, &clp->cl_res_state);
  786. spin_unlock(&nn->nfs_client_lock);
  787. }
  788. EXPORT_SYMBOL_GPL(nfs_server_insert_lists);
  789. void nfs_server_remove_lists(struct nfs_server *server)
  790. {
  791. struct nfs_client *clp = server->nfs_client;
  792. struct nfs_net *nn;
  793. if (clp == NULL)
  794. return;
  795. nn = net_generic(clp->cl_net, nfs_net_id);
  796. spin_lock(&nn->nfs_client_lock);
  797. list_del_rcu(&server->client_link);
  798. if (list_empty(&clp->cl_superblocks))
  799. set_bit(NFS_CS_STOP_RENEW, &clp->cl_res_state);
  800. list_del(&server->master_link);
  801. spin_unlock(&nn->nfs_client_lock);
  802. synchronize_rcu();
  803. }
  804. EXPORT_SYMBOL_GPL(nfs_server_remove_lists);
  805. /*
  806. * Allocate and initialise a server record
  807. */
  808. struct nfs_server *nfs_alloc_server(void)
  809. {
  810. struct nfs_server *server;
  811. server = kzalloc(sizeof(struct nfs_server), GFP_KERNEL);
  812. if (!server)
  813. return NULL;
  814. server->client = server->client_acl = ERR_PTR(-EINVAL);
  815. /* Zero out the NFS state stuff */
  816. INIT_LIST_HEAD(&server->client_link);
  817. INIT_LIST_HEAD(&server->master_link);
  818. INIT_LIST_HEAD(&server->delegations);
  819. INIT_LIST_HEAD(&server->layouts);
  820. INIT_LIST_HEAD(&server->state_owners_lru);
  821. INIT_LIST_HEAD(&server->ss_copies);
  822. atomic_set(&server->active, 0);
  823. server->io_stats = nfs_alloc_iostats();
  824. if (!server->io_stats) {
  825. kfree(server);
  826. return NULL;
  827. }
  828. server->change_attr_type = NFS4_CHANGE_TYPE_IS_UNDEFINED;
  829. ida_init(&server->openowner_id);
  830. ida_init(&server->lockowner_id);
  831. pnfs_init_server(server);
  832. rpc_init_wait_queue(&server->uoc_rpcwaitq, "NFS UOC");
  833. return server;
  834. }
  835. EXPORT_SYMBOL_GPL(nfs_alloc_server);
  836. /*
  837. * Free up a server record
  838. */
  839. void nfs_free_server(struct nfs_server *server)
  840. {
  841. nfs_server_remove_lists(server);
  842. if (server->destroy != NULL)
  843. server->destroy(server);
  844. if (!IS_ERR(server->client_acl))
  845. rpc_shutdown_client(server->client_acl);
  846. if (!IS_ERR(server->client))
  847. rpc_shutdown_client(server->client);
  848. nfs_put_client(server->nfs_client);
  849. ida_destroy(&server->lockowner_id);
  850. ida_destroy(&server->openowner_id);
  851. nfs_free_iostats(server->io_stats);
  852. put_cred(server->cred);
  853. kfree(server);
  854. nfs_release_automount_timer();
  855. }
  856. EXPORT_SYMBOL_GPL(nfs_free_server);
  857. /*
  858. * Create a version 2 or 3 volume record
  859. * - keyed on server and FSID
  860. */
  861. struct nfs_server *nfs_create_server(struct fs_context *fc)
  862. {
  863. struct nfs_fs_context *ctx = nfs_fc2context(fc);
  864. struct nfs_server *server;
  865. struct nfs_fattr *fattr;
  866. int error;
  867. server = nfs_alloc_server();
  868. if (!server)
  869. return ERR_PTR(-ENOMEM);
  870. server->cred = get_cred(fc->cred);
  871. error = -ENOMEM;
  872. fattr = nfs_alloc_fattr();
  873. if (fattr == NULL)
  874. goto error;
  875. /* Get a client representation */
  876. error = nfs_init_server(server, fc);
  877. if (error < 0)
  878. goto error;
  879. /* Probe the root fh to retrieve its FSID */
  880. error = nfs_probe_fsinfo(server, ctx->mntfh, fattr);
  881. if (error < 0)
  882. goto error;
  883. if (server->nfs_client->rpc_ops->version == 3) {
  884. if (server->namelen == 0 || server->namelen > NFS3_MAXNAMLEN)
  885. server->namelen = NFS3_MAXNAMLEN;
  886. if (!(ctx->flags & NFS_MOUNT_NORDIRPLUS))
  887. server->caps |= NFS_CAP_READDIRPLUS;
  888. } else {
  889. if (server->namelen == 0 || server->namelen > NFS2_MAXNAMLEN)
  890. server->namelen = NFS2_MAXNAMLEN;
  891. }
  892. if (!(fattr->valid & NFS_ATTR_FATTR)) {
  893. error = ctx->nfs_mod->rpc_ops->getattr(server, ctx->mntfh,
  894. fattr, NULL);
  895. if (error < 0) {
  896. dprintk("nfs_create_server: getattr error = %d\n", -error);
  897. goto error;
  898. }
  899. }
  900. memcpy(&server->fsid, &fattr->fsid, sizeof(server->fsid));
  901. dprintk("Server FSID: %llx:%llx\n",
  902. (unsigned long long) server->fsid.major,
  903. (unsigned long long) server->fsid.minor);
  904. nfs_server_insert_lists(server);
  905. server->mount_time = jiffies;
  906. nfs_free_fattr(fattr);
  907. return server;
  908. error:
  909. nfs_free_fattr(fattr);
  910. nfs_free_server(server);
  911. return ERR_PTR(error);
  912. }
  913. EXPORT_SYMBOL_GPL(nfs_create_server);
  914. /*
  915. * Clone an NFS2, NFS3 or NFS4 server record
  916. */
  917. struct nfs_server *nfs_clone_server(struct nfs_server *source,
  918. struct nfs_fh *fh,
  919. struct nfs_fattr *fattr,
  920. rpc_authflavor_t flavor)
  921. {
  922. struct nfs_server *server;
  923. int error;
  924. server = nfs_alloc_server();
  925. if (!server)
  926. return ERR_PTR(-ENOMEM);
  927. server->cred = get_cred(source->cred);
  928. /* Copy data from the source */
  929. server->nfs_client = source->nfs_client;
  930. server->destroy = source->destroy;
  931. refcount_inc(&server->nfs_client->cl_count);
  932. nfs_server_copy_userdata(server, source);
  933. server->fsid = fattr->fsid;
  934. error = nfs_init_server_rpcclient(server,
  935. source->client->cl_timeout,
  936. flavor);
  937. if (error < 0)
  938. goto out_free_server;
  939. /* probe the filesystem info for this server filesystem */
  940. error = nfs_probe_server(server, fh);
  941. if (error < 0)
  942. goto out_free_server;
  943. if (server->namelen == 0 || server->namelen > NFS4_MAXNAMLEN)
  944. server->namelen = NFS4_MAXNAMLEN;
  945. error = nfs_start_lockd(server);
  946. if (error < 0)
  947. goto out_free_server;
  948. nfs_server_insert_lists(server);
  949. server->mount_time = jiffies;
  950. return server;
  951. out_free_server:
  952. nfs_free_server(server);
  953. return ERR_PTR(error);
  954. }
  955. EXPORT_SYMBOL_GPL(nfs_clone_server);
  956. void nfs_clients_init(struct net *net)
  957. {
  958. struct nfs_net *nn = net_generic(net, nfs_net_id);
  959. INIT_LIST_HEAD(&nn->nfs_client_list);
  960. INIT_LIST_HEAD(&nn->nfs_volume_list);
  961. #if IS_ENABLED(CONFIG_NFS_V4)
  962. idr_init(&nn->cb_ident_idr);
  963. #endif
  964. spin_lock_init(&nn->nfs_client_lock);
  965. nn->boot_time = ktime_get_real();
  966. nfs_netns_sysfs_setup(nn, net);
  967. }
  968. void nfs_clients_exit(struct net *net)
  969. {
  970. struct nfs_net *nn = net_generic(net, nfs_net_id);
  971. nfs_netns_sysfs_destroy(nn);
  972. nfs_cleanup_cb_ident_idr(net);
  973. WARN_ON_ONCE(!list_empty(&nn->nfs_client_list));
  974. WARN_ON_ONCE(!list_empty(&nn->nfs_volume_list));
  975. }
  976. #ifdef CONFIG_PROC_FS
  977. static void *nfs_server_list_start(struct seq_file *p, loff_t *pos);
  978. static void *nfs_server_list_next(struct seq_file *p, void *v, loff_t *pos);
  979. static void nfs_server_list_stop(struct seq_file *p, void *v);
  980. static int nfs_server_list_show(struct seq_file *m, void *v);
  981. static const struct seq_operations nfs_server_list_ops = {
  982. .start = nfs_server_list_start,
  983. .next = nfs_server_list_next,
  984. .stop = nfs_server_list_stop,
  985. .show = nfs_server_list_show,
  986. };
  987. static void *nfs_volume_list_start(struct seq_file *p, loff_t *pos);
  988. static void *nfs_volume_list_next(struct seq_file *p, void *v, loff_t *pos);
  989. static void nfs_volume_list_stop(struct seq_file *p, void *v);
  990. static int nfs_volume_list_show(struct seq_file *m, void *v);
  991. static const struct seq_operations nfs_volume_list_ops = {
  992. .start = nfs_volume_list_start,
  993. .next = nfs_volume_list_next,
  994. .stop = nfs_volume_list_stop,
  995. .show = nfs_volume_list_show,
  996. };
  997. /*
  998. * set up the iterator to start reading from the server list and return the first item
  999. */
  1000. static void *nfs_server_list_start(struct seq_file *m, loff_t *_pos)
  1001. __acquires(&nn->nfs_client_lock)
  1002. {
  1003. struct nfs_net *nn = net_generic(seq_file_net(m), nfs_net_id);
  1004. /* lock the list against modification */
  1005. spin_lock(&nn->nfs_client_lock);
  1006. return seq_list_start_head(&nn->nfs_client_list, *_pos);
  1007. }
  1008. /*
  1009. * move to next server
  1010. */
  1011. static void *nfs_server_list_next(struct seq_file *p, void *v, loff_t *pos)
  1012. {
  1013. struct nfs_net *nn = net_generic(seq_file_net(p), nfs_net_id);
  1014. return seq_list_next(v, &nn->nfs_client_list, pos);
  1015. }
  1016. /*
  1017. * clean up after reading from the transports list
  1018. */
  1019. static void nfs_server_list_stop(struct seq_file *p, void *v)
  1020. __releases(&nn->nfs_client_lock)
  1021. {
  1022. struct nfs_net *nn = net_generic(seq_file_net(p), nfs_net_id);
  1023. spin_unlock(&nn->nfs_client_lock);
  1024. }
  1025. /*
  1026. * display a header line followed by a load of call lines
  1027. */
  1028. static int nfs_server_list_show(struct seq_file *m, void *v)
  1029. {
  1030. struct nfs_client *clp;
  1031. struct nfs_net *nn = net_generic(seq_file_net(m), nfs_net_id);
  1032. /* display header on line 1 */
  1033. if (v == &nn->nfs_client_list) {
  1034. seq_puts(m, "NV SERVER PORT USE HOSTNAME\n");
  1035. return 0;
  1036. }
  1037. /* display one transport per line on subsequent lines */
  1038. clp = list_entry(v, struct nfs_client, cl_share_link);
  1039. /* Check if the client is initialized */
  1040. if (clp->cl_cons_state != NFS_CS_READY)
  1041. return 0;
  1042. rcu_read_lock();
  1043. seq_printf(m, "v%u %s %s %3d %s\n",
  1044. clp->rpc_ops->version,
  1045. rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_HEX_ADDR),
  1046. rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_HEX_PORT),
  1047. refcount_read(&clp->cl_count),
  1048. clp->cl_hostname);
  1049. rcu_read_unlock();
  1050. return 0;
  1051. }
  1052. /*
  1053. * set up the iterator to start reading from the volume list and return the first item
  1054. */
  1055. static void *nfs_volume_list_start(struct seq_file *m, loff_t *_pos)
  1056. __acquires(&nn->nfs_client_lock)
  1057. {
  1058. struct nfs_net *nn = net_generic(seq_file_net(m), nfs_net_id);
  1059. /* lock the list against modification */
  1060. spin_lock(&nn->nfs_client_lock);
  1061. return seq_list_start_head(&nn->nfs_volume_list, *_pos);
  1062. }
  1063. /*
  1064. * move to next volume
  1065. */
  1066. static void *nfs_volume_list_next(struct seq_file *p, void *v, loff_t *pos)
  1067. {
  1068. struct nfs_net *nn = net_generic(seq_file_net(p), nfs_net_id);
  1069. return seq_list_next(v, &nn->nfs_volume_list, pos);
  1070. }
  1071. /*
  1072. * clean up after reading from the transports list
  1073. */
  1074. static void nfs_volume_list_stop(struct seq_file *p, void *v)
  1075. __releases(&nn->nfs_client_lock)
  1076. {
  1077. struct nfs_net *nn = net_generic(seq_file_net(p), nfs_net_id);
  1078. spin_unlock(&nn->nfs_client_lock);
  1079. }
  1080. /*
  1081. * display a header line followed by a load of call lines
  1082. */
  1083. static int nfs_volume_list_show(struct seq_file *m, void *v)
  1084. {
  1085. struct nfs_server *server;
  1086. struct nfs_client *clp;
  1087. char dev[13]; // 8 for 2^24, 1 for ':', 3 for 2^8, 1 for '\0'
  1088. char fsid[34]; // 2 * 16 for %llx, 1 for ':', 1 for '\0'
  1089. struct nfs_net *nn = net_generic(seq_file_net(m), nfs_net_id);
  1090. /* display header on line 1 */
  1091. if (v == &nn->nfs_volume_list) {
  1092. seq_puts(m, "NV SERVER PORT DEV FSID"
  1093. " FSC\n");
  1094. return 0;
  1095. }
  1096. /* display one transport per line on subsequent lines */
  1097. server = list_entry(v, struct nfs_server, master_link);
  1098. clp = server->nfs_client;
  1099. snprintf(dev, sizeof(dev), "%u:%u",
  1100. MAJOR(server->s_dev), MINOR(server->s_dev));
  1101. snprintf(fsid, sizeof(fsid), "%llx:%llx",
  1102. (unsigned long long) server->fsid.major,
  1103. (unsigned long long) server->fsid.minor);
  1104. rcu_read_lock();
  1105. seq_printf(m, "v%u %s %s %-12s %-33s %s\n",
  1106. clp->rpc_ops->version,
  1107. rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_HEX_ADDR),
  1108. rpc_peeraddr2str(clp->cl_rpcclient, RPC_DISPLAY_HEX_PORT),
  1109. dev,
  1110. fsid,
  1111. nfs_server_fscache_state(server));
  1112. rcu_read_unlock();
  1113. return 0;
  1114. }
  1115. int nfs_fs_proc_net_init(struct net *net)
  1116. {
  1117. struct nfs_net *nn = net_generic(net, nfs_net_id);
  1118. struct proc_dir_entry *p;
  1119. nn->proc_nfsfs = proc_net_mkdir(net, "nfsfs", net->proc_net);
  1120. if (!nn->proc_nfsfs)
  1121. goto error_0;
  1122. /* a file of servers with which we're dealing */
  1123. p = proc_create_net("servers", S_IFREG|S_IRUGO, nn->proc_nfsfs,
  1124. &nfs_server_list_ops, sizeof(struct seq_net_private));
  1125. if (!p)
  1126. goto error_1;
  1127. /* a file of volumes that we have mounted */
  1128. p = proc_create_net("volumes", S_IFREG|S_IRUGO, nn->proc_nfsfs,
  1129. &nfs_volume_list_ops, sizeof(struct seq_net_private));
  1130. if (!p)
  1131. goto error_1;
  1132. return 0;
  1133. error_1:
  1134. remove_proc_subtree("nfsfs", net->proc_net);
  1135. error_0:
  1136. return -ENOMEM;
  1137. }
  1138. void nfs_fs_proc_net_exit(struct net *net)
  1139. {
  1140. remove_proc_subtree("nfsfs", net->proc_net);
  1141. }
  1142. /*
  1143. * initialise the /proc/fs/nfsfs/ directory
  1144. */
  1145. int __init nfs_fs_proc_init(void)
  1146. {
  1147. if (!proc_mkdir("fs/nfsfs", NULL))
  1148. goto error_0;
  1149. /* a file of servers with which we're dealing */
  1150. if (!proc_symlink("fs/nfsfs/servers", NULL, "../../net/nfsfs/servers"))
  1151. goto error_1;
  1152. /* a file of volumes that we have mounted */
  1153. if (!proc_symlink("fs/nfsfs/volumes", NULL, "../../net/nfsfs/volumes"))
  1154. goto error_1;
  1155. return 0;
  1156. error_1:
  1157. remove_proc_subtree("fs/nfsfs", NULL);
  1158. error_0:
  1159. return -ENOMEM;
  1160. }
  1161. /*
  1162. * clean up the /proc/fs/nfsfs/ directory
  1163. */
  1164. void nfs_fs_proc_exit(void)
  1165. {
  1166. remove_proc_subtree("fs/nfsfs", NULL);
  1167. }
  1168. #endif /* CONFIG_PROC_FS */