client.c 38 KB

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