client.c 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965
  1. /*
  2. * net/9p/clnt.c
  3. *
  4. * 9P Client
  5. *
  6. * Copyright (C) 2007 by Latchesar Ionkov <lucho@ionkov.net>
  7. *
  8. * This program is free software; you can redistribute it and/or modify
  9. * it under the terms of the GNU General Public License version 2
  10. * as published by the Free Software Foundation.
  11. *
  12. * This program is distributed in the hope that it will be useful,
  13. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  14. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  15. * GNU General Public License for more details.
  16. *
  17. * You should have received a copy of the GNU General Public License
  18. * along with this program; if not, write to:
  19. * Free Software Foundation
  20. * 51 Franklin Street, Fifth Floor
  21. * Boston, MA 02111-1301 USA
  22. *
  23. */
  24. #include <linux/module.h>
  25. #include <linux/errno.h>
  26. #include <linux/fs.h>
  27. #include <linux/idr.h>
  28. #include <linux/mutex.h>
  29. #include <linux/sched.h>
  30. #include <linux/uaccess.h>
  31. #include <net/9p/9p.h>
  32. #include <net/9p/transport.h>
  33. #include <net/9p/conn.h>
  34. #include <net/9p/client.h>
  35. static struct p9_fid *p9_fid_create(struct p9_client *clnt);
  36. static void p9_fid_destroy(struct p9_fid *fid);
  37. static struct p9_stat *p9_clone_stat(struct p9_stat *st, int dotu);
  38. struct p9_client *p9_client_create(struct p9_transport *trans, int msize,
  39. int dotu)
  40. {
  41. int err, n;
  42. struct p9_client *clnt;
  43. struct p9_fcall *tc, *rc;
  44. struct p9_str *version;
  45. err = 0;
  46. tc = NULL;
  47. rc = NULL;
  48. clnt = kmalloc(sizeof(struct p9_client), GFP_KERNEL);
  49. if (!clnt)
  50. return ERR_PTR(-ENOMEM);
  51. P9_DPRINTK(P9_DEBUG_9P, "clnt %p trans %p msize %d dotu %d\n",
  52. clnt, trans, msize, dotu);
  53. spin_lock_init(&clnt->lock);
  54. clnt->trans = trans;
  55. clnt->msize = msize;
  56. clnt->dotu = dotu;
  57. INIT_LIST_HEAD(&clnt->fidlist);
  58. clnt->fidpool = p9_idpool_create();
  59. if (!clnt->fidpool) {
  60. err = PTR_ERR(clnt->fidpool);
  61. clnt->fidpool = NULL;
  62. goto error;
  63. }
  64. clnt->conn = p9_conn_create(clnt->trans, clnt->msize, &clnt->dotu);
  65. if (IS_ERR(clnt->conn)) {
  66. err = PTR_ERR(clnt->conn);
  67. clnt->conn = NULL;
  68. goto error;
  69. }
  70. tc = p9_create_tversion(clnt->msize, clnt->dotu?"9P2000.u":"9P2000");
  71. if (IS_ERR(tc)) {
  72. err = PTR_ERR(tc);
  73. tc = NULL;
  74. goto error;
  75. }
  76. err = p9_conn_rpc(clnt->conn, tc, &rc);
  77. if (err)
  78. goto error;
  79. version = &rc->params.rversion.version;
  80. if (version->len == 8 && !memcmp(version->str, "9P2000.u", 8))
  81. clnt->dotu = 1;
  82. else if (version->len == 6 && !memcmp(version->str, "9P2000", 6))
  83. clnt->dotu = 0;
  84. else {
  85. err = -EREMOTEIO;
  86. goto error;
  87. }
  88. n = rc->params.rversion.msize;
  89. if (n < clnt->msize)
  90. clnt->msize = n;
  91. kfree(tc);
  92. kfree(rc);
  93. return clnt;
  94. error:
  95. kfree(tc);
  96. kfree(rc);
  97. p9_client_destroy(clnt);
  98. return ERR_PTR(err);
  99. }
  100. EXPORT_SYMBOL(p9_client_create);
  101. void p9_client_destroy(struct p9_client *clnt)
  102. {
  103. struct p9_fid *fid, *fidptr;
  104. P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
  105. if (clnt->conn) {
  106. p9_conn_destroy(clnt->conn);
  107. clnt->conn = NULL;
  108. }
  109. if (clnt->trans) {
  110. clnt->trans->close(clnt->trans);
  111. kfree(clnt->trans);
  112. clnt->trans = NULL;
  113. }
  114. list_for_each_entry_safe(fid, fidptr, &clnt->fidlist, flist)
  115. p9_fid_destroy(fid);
  116. if (clnt->fidpool)
  117. p9_idpool_destroy(clnt->fidpool);
  118. kfree(clnt);
  119. }
  120. EXPORT_SYMBOL(p9_client_destroy);
  121. void p9_client_disconnect(struct p9_client *clnt)
  122. {
  123. P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
  124. clnt->trans->status = Disconnected;
  125. p9_conn_cancel(clnt->conn, -EIO);
  126. }
  127. EXPORT_SYMBOL(p9_client_disconnect);
  128. struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid,
  129. char *uname, char *aname)
  130. {
  131. int err;
  132. struct p9_fcall *tc, *rc;
  133. struct p9_fid *fid;
  134. P9_DPRINTK(P9_DEBUG_9P, "clnt %p afid %d uname %s aname %s\n",
  135. clnt, afid?afid->fid:-1, uname, aname);
  136. err = 0;
  137. tc = NULL;
  138. rc = NULL;
  139. fid = p9_fid_create(clnt);
  140. if (IS_ERR(fid)) {
  141. err = PTR_ERR(fid);
  142. fid = NULL;
  143. goto error;
  144. }
  145. tc = p9_create_tattach(fid->fid, afid?afid->fid:P9_NOFID, uname, aname);
  146. if (IS_ERR(tc)) {
  147. err = PTR_ERR(tc);
  148. tc = NULL;
  149. goto error;
  150. }
  151. err = p9_conn_rpc(clnt->conn, tc, &rc);
  152. if (err)
  153. goto error;
  154. memmove(&fid->qid, &rc->params.rattach.qid, sizeof(struct p9_qid));
  155. kfree(tc);
  156. kfree(rc);
  157. return fid;
  158. error:
  159. kfree(tc);
  160. kfree(rc);
  161. if (fid)
  162. p9_fid_destroy(fid);
  163. return ERR_PTR(err);
  164. }
  165. EXPORT_SYMBOL(p9_client_attach);
  166. struct p9_fid *p9_client_auth(struct p9_client *clnt, char *uname, char *aname)
  167. {
  168. int err;
  169. struct p9_fcall *tc, *rc;
  170. struct p9_fid *fid;
  171. P9_DPRINTK(P9_DEBUG_9P, "clnt %p uname %s aname %s\n", clnt, uname,
  172. aname);
  173. err = 0;
  174. tc = NULL;
  175. rc = NULL;
  176. fid = p9_fid_create(clnt);
  177. if (IS_ERR(fid)) {
  178. err = PTR_ERR(fid);
  179. fid = NULL;
  180. goto error;
  181. }
  182. tc = p9_create_tauth(fid->fid, uname, aname);
  183. if (IS_ERR(tc)) {
  184. err = PTR_ERR(tc);
  185. tc = NULL;
  186. goto error;
  187. }
  188. err = p9_conn_rpc(clnt->conn, tc, &rc);
  189. if (err)
  190. goto error;
  191. memmove(&fid->qid, &rc->params.rauth.qid, sizeof(struct p9_qid));
  192. kfree(tc);
  193. kfree(rc);
  194. return fid;
  195. error:
  196. kfree(tc);
  197. kfree(rc);
  198. if (fid)
  199. p9_fid_destroy(fid);
  200. return ERR_PTR(err);
  201. }
  202. EXPORT_SYMBOL(p9_client_auth);
  203. struct p9_fid *p9_client_walk(struct p9_fid *oldfid, int nwname, char **wnames,
  204. int clone)
  205. {
  206. int err;
  207. struct p9_fcall *tc, *rc;
  208. struct p9_client *clnt;
  209. struct p9_fid *fid;
  210. P9_DPRINTK(P9_DEBUG_9P, "fid %d nwname %d wname[0] %s\n",
  211. oldfid->fid, nwname, wnames?wnames[0]:NULL);
  212. err = 0;
  213. tc = NULL;
  214. rc = NULL;
  215. clnt = oldfid->clnt;
  216. if (clone) {
  217. fid = p9_fid_create(clnt);
  218. if (IS_ERR(fid)) {
  219. err = PTR_ERR(fid);
  220. fid = NULL;
  221. goto error;
  222. }
  223. fid->uid = oldfid->uid;
  224. } else
  225. fid = oldfid;
  226. tc = p9_create_twalk(oldfid->fid, fid->fid, nwname, wnames);
  227. if (IS_ERR(tc)) {
  228. err = PTR_ERR(tc);
  229. tc = NULL;
  230. goto error;
  231. }
  232. err = p9_conn_rpc(clnt->conn, tc, &rc);
  233. if (err) {
  234. if (rc && rc->id == P9_RWALK)
  235. goto clunk_fid;
  236. else
  237. goto error;
  238. }
  239. if (rc->params.rwalk.nwqid != nwname) {
  240. err = -ENOENT;
  241. goto clunk_fid;
  242. }
  243. if (nwname)
  244. memmove(&fid->qid,
  245. &rc->params.rwalk.wqids[rc->params.rwalk.nwqid - 1],
  246. sizeof(struct p9_qid));
  247. else
  248. fid->qid = oldfid->qid;
  249. kfree(tc);
  250. kfree(rc);
  251. return fid;
  252. clunk_fid:
  253. kfree(tc);
  254. kfree(rc);
  255. rc = NULL;
  256. tc = p9_create_tclunk(fid->fid);
  257. if (IS_ERR(tc)) {
  258. err = PTR_ERR(tc);
  259. tc = NULL;
  260. goto error;
  261. }
  262. p9_conn_rpc(clnt->conn, tc, &rc);
  263. error:
  264. kfree(tc);
  265. kfree(rc);
  266. if (fid && (fid != oldfid))
  267. p9_fid_destroy(fid);
  268. return ERR_PTR(err);
  269. }
  270. EXPORT_SYMBOL(p9_client_walk);
  271. int p9_client_open(struct p9_fid *fid, int mode)
  272. {
  273. int err;
  274. struct p9_fcall *tc, *rc;
  275. struct p9_client *clnt;
  276. P9_DPRINTK(P9_DEBUG_9P, "fid %d mode %d\n", fid->fid, mode);
  277. err = 0;
  278. tc = NULL;
  279. rc = NULL;
  280. clnt = fid->clnt;
  281. if (fid->mode != -1)
  282. return -EINVAL;
  283. tc = p9_create_topen(fid->fid, mode);
  284. if (IS_ERR(tc)) {
  285. err = PTR_ERR(tc);
  286. tc = NULL;
  287. goto done;
  288. }
  289. err = p9_conn_rpc(clnt->conn, tc, &rc);
  290. if (err)
  291. goto done;
  292. fid->mode = mode;
  293. fid->iounit = rc->params.ropen.iounit;
  294. done:
  295. kfree(tc);
  296. kfree(rc);
  297. return err;
  298. }
  299. EXPORT_SYMBOL(p9_client_open);
  300. int p9_client_fcreate(struct p9_fid *fid, char *name, u32 perm, int mode,
  301. char *extension)
  302. {
  303. int err;
  304. struct p9_fcall *tc, *rc;
  305. struct p9_client *clnt;
  306. P9_DPRINTK(P9_DEBUG_9P, "fid %d name %s perm %d mode %d\n", fid->fid,
  307. name, perm, mode);
  308. err = 0;
  309. tc = NULL;
  310. rc = NULL;
  311. clnt = fid->clnt;
  312. if (fid->mode != -1)
  313. return -EINVAL;
  314. tc = p9_create_tcreate(fid->fid, name, perm, mode, extension,
  315. clnt->dotu);
  316. if (IS_ERR(tc)) {
  317. err = PTR_ERR(tc);
  318. tc = NULL;
  319. goto done;
  320. }
  321. err = p9_conn_rpc(clnt->conn, tc, &rc);
  322. if (err)
  323. goto done;
  324. fid->mode = mode;
  325. fid->iounit = rc->params.ropen.iounit;
  326. done:
  327. kfree(tc);
  328. kfree(rc);
  329. return err;
  330. }
  331. EXPORT_SYMBOL(p9_client_fcreate);
  332. int p9_client_clunk(struct p9_fid *fid)
  333. {
  334. int err;
  335. struct p9_fcall *tc, *rc;
  336. struct p9_client *clnt;
  337. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  338. err = 0;
  339. tc = NULL;
  340. rc = NULL;
  341. clnt = fid->clnt;
  342. tc = p9_create_tclunk(fid->fid);
  343. if (IS_ERR(tc)) {
  344. err = PTR_ERR(tc);
  345. tc = NULL;
  346. goto done;
  347. }
  348. err = p9_conn_rpc(clnt->conn, tc, &rc);
  349. if (err)
  350. goto done;
  351. p9_fid_destroy(fid);
  352. done:
  353. kfree(tc);
  354. kfree(rc);
  355. return err;
  356. }
  357. EXPORT_SYMBOL(p9_client_clunk);
  358. int p9_client_remove(struct p9_fid *fid)
  359. {
  360. int err;
  361. struct p9_fcall *tc, *rc;
  362. struct p9_client *clnt;
  363. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  364. err = 0;
  365. tc = NULL;
  366. rc = NULL;
  367. clnt = fid->clnt;
  368. tc = p9_create_tremove(fid->fid);
  369. if (IS_ERR(tc)) {
  370. err = PTR_ERR(tc);
  371. tc = NULL;
  372. goto done;
  373. }
  374. err = p9_conn_rpc(clnt->conn, tc, &rc);
  375. if (err)
  376. goto done;
  377. p9_fid_destroy(fid);
  378. done:
  379. kfree(tc);
  380. kfree(rc);
  381. return err;
  382. }
  383. EXPORT_SYMBOL(p9_client_remove);
  384. int p9_client_read(struct p9_fid *fid, char *data, u64 offset, u32 count)
  385. {
  386. int err, n, rsize, total;
  387. struct p9_fcall *tc, *rc;
  388. struct p9_client *clnt;
  389. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu %d\n", fid->fid,
  390. (long long unsigned) offset, count);
  391. err = 0;
  392. tc = NULL;
  393. rc = NULL;
  394. clnt = fid->clnt;
  395. total = 0;
  396. rsize = fid->iounit;
  397. if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
  398. rsize = clnt->msize - P9_IOHDRSZ;
  399. do {
  400. if (count < rsize)
  401. rsize = count;
  402. tc = p9_create_tread(fid->fid, offset, rsize);
  403. if (IS_ERR(tc)) {
  404. err = PTR_ERR(tc);
  405. tc = NULL;
  406. goto error;
  407. }
  408. err = p9_conn_rpc(clnt->conn, tc, &rc);
  409. if (err)
  410. goto error;
  411. n = rc->params.rread.count;
  412. if (n > count)
  413. n = count;
  414. memmove(data, rc->params.rread.data, n);
  415. count -= n;
  416. data += n;
  417. offset += n;
  418. total += n;
  419. kfree(tc);
  420. tc = NULL;
  421. kfree(rc);
  422. rc = NULL;
  423. } while (count > 0 && n == rsize);
  424. return total;
  425. error:
  426. kfree(tc);
  427. kfree(rc);
  428. return err;
  429. }
  430. EXPORT_SYMBOL(p9_client_read);
  431. int p9_client_write(struct p9_fid *fid, char *data, u64 offset, u32 count)
  432. {
  433. int err, n, rsize, total;
  434. struct p9_fcall *tc, *rc;
  435. struct p9_client *clnt;
  436. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
  437. (long long unsigned) offset, count);
  438. err = 0;
  439. tc = NULL;
  440. rc = NULL;
  441. clnt = fid->clnt;
  442. total = 0;
  443. rsize = fid->iounit;
  444. if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
  445. rsize = clnt->msize - P9_IOHDRSZ;
  446. do {
  447. if (count < rsize)
  448. rsize = count;
  449. tc = p9_create_twrite(fid->fid, offset, rsize, data);
  450. if (IS_ERR(tc)) {
  451. err = PTR_ERR(tc);
  452. tc = NULL;
  453. goto error;
  454. }
  455. err = p9_conn_rpc(clnt->conn, tc, &rc);
  456. if (err)
  457. goto error;
  458. n = rc->params.rread.count;
  459. count -= n;
  460. data += n;
  461. offset += n;
  462. total += n;
  463. kfree(tc);
  464. tc = NULL;
  465. kfree(rc);
  466. rc = NULL;
  467. } while (count > 0);
  468. return total;
  469. error:
  470. kfree(tc);
  471. kfree(rc);
  472. return err;
  473. }
  474. EXPORT_SYMBOL(p9_client_write);
  475. int
  476. p9_client_uread(struct p9_fid *fid, char __user *data, u64 offset, u32 count)
  477. {
  478. int err, n, rsize, total;
  479. struct p9_fcall *tc, *rc;
  480. struct p9_client *clnt;
  481. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
  482. (long long unsigned) offset, count);
  483. err = 0;
  484. tc = NULL;
  485. rc = NULL;
  486. clnt = fid->clnt;
  487. total = 0;
  488. rsize = fid->iounit;
  489. if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
  490. rsize = clnt->msize - P9_IOHDRSZ;
  491. do {
  492. if (count < rsize)
  493. rsize = count;
  494. tc = p9_create_tread(fid->fid, offset, rsize);
  495. if (IS_ERR(tc)) {
  496. err = PTR_ERR(tc);
  497. tc = NULL;
  498. goto error;
  499. }
  500. err = p9_conn_rpc(clnt->conn, tc, &rc);
  501. if (err)
  502. goto error;
  503. n = rc->params.rread.count;
  504. if (n > count)
  505. n = count;
  506. err = copy_to_user(data, rc->params.rread.data, n);
  507. if (err) {
  508. err = -EFAULT;
  509. goto error;
  510. }
  511. count -= n;
  512. data += n;
  513. offset += n;
  514. total += n;
  515. kfree(tc);
  516. tc = NULL;
  517. kfree(rc);
  518. rc = NULL;
  519. } while (count > 0 && n == rsize);
  520. return total;
  521. error:
  522. kfree(tc);
  523. kfree(rc);
  524. return err;
  525. }
  526. EXPORT_SYMBOL(p9_client_uread);
  527. int
  528. p9_client_uwrite(struct p9_fid *fid, const char __user *data, u64 offset,
  529. u32 count)
  530. {
  531. int err, n, rsize, total;
  532. struct p9_fcall *tc, *rc;
  533. struct p9_client *clnt;
  534. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
  535. (long long unsigned) offset, count);
  536. err = 0;
  537. tc = NULL;
  538. rc = NULL;
  539. clnt = fid->clnt;
  540. total = 0;
  541. rsize = fid->iounit;
  542. if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
  543. rsize = clnt->msize - P9_IOHDRSZ;
  544. do {
  545. if (count < rsize)
  546. rsize = count;
  547. tc = p9_create_twrite_u(fid->fid, offset, rsize, data);
  548. if (IS_ERR(tc)) {
  549. err = PTR_ERR(tc);
  550. tc = NULL;
  551. goto error;
  552. }
  553. err = p9_conn_rpc(clnt->conn, tc, &rc);
  554. if (err)
  555. goto error;
  556. n = rc->params.rread.count;
  557. count -= n;
  558. data += n;
  559. offset += n;
  560. total += n;
  561. kfree(tc);
  562. tc = NULL;
  563. kfree(rc);
  564. rc = NULL;
  565. } while (count > 0);
  566. return total;
  567. error:
  568. kfree(tc);
  569. kfree(rc);
  570. return err;
  571. }
  572. EXPORT_SYMBOL(p9_client_uwrite);
  573. int p9_client_readn(struct p9_fid *fid, char *data, u64 offset, u32 count)
  574. {
  575. int n, total;
  576. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
  577. (long long unsigned) offset, count);
  578. n = 0;
  579. total = 0;
  580. while (count) {
  581. n = p9_client_read(fid, data, offset, count);
  582. if (n <= 0)
  583. break;
  584. data += n;
  585. offset += n;
  586. count -= n;
  587. total += n;
  588. }
  589. if (n < 0)
  590. total = n;
  591. return total;
  592. }
  593. EXPORT_SYMBOL(p9_client_readn);
  594. struct p9_stat *p9_client_stat(struct p9_fid *fid)
  595. {
  596. int err;
  597. struct p9_fcall *tc, *rc;
  598. struct p9_client *clnt;
  599. struct p9_stat *ret;
  600. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  601. err = 0;
  602. tc = NULL;
  603. rc = NULL;
  604. ret = NULL;
  605. clnt = fid->clnt;
  606. tc = p9_create_tstat(fid->fid);
  607. if (IS_ERR(tc)) {
  608. err = PTR_ERR(tc);
  609. tc = NULL;
  610. goto error;
  611. }
  612. err = p9_conn_rpc(clnt->conn, tc, &rc);
  613. if (err)
  614. goto error;
  615. ret = p9_clone_stat(&rc->params.rstat.stat, clnt->dotu);
  616. if (IS_ERR(ret)) {
  617. err = PTR_ERR(ret);
  618. ret = NULL;
  619. goto error;
  620. }
  621. kfree(tc);
  622. kfree(rc);
  623. return ret;
  624. error:
  625. kfree(tc);
  626. kfree(rc);
  627. kfree(ret);
  628. return ERR_PTR(err);
  629. }
  630. EXPORT_SYMBOL(p9_client_stat);
  631. int p9_client_wstat(struct p9_fid *fid, struct p9_wstat *wst)
  632. {
  633. int err;
  634. struct p9_fcall *tc, *rc;
  635. struct p9_client *clnt;
  636. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  637. err = 0;
  638. tc = NULL;
  639. rc = NULL;
  640. clnt = fid->clnt;
  641. tc = p9_create_twstat(fid->fid, wst, clnt->dotu);
  642. if (IS_ERR(tc)) {
  643. err = PTR_ERR(tc);
  644. tc = NULL;
  645. goto done;
  646. }
  647. err = p9_conn_rpc(clnt->conn, tc, &rc);
  648. done:
  649. kfree(tc);
  650. kfree(rc);
  651. return err;
  652. }
  653. EXPORT_SYMBOL(p9_client_wstat);
  654. struct p9_stat *p9_client_dirread(struct p9_fid *fid, u64 offset)
  655. {
  656. int err, n, m;
  657. struct p9_fcall *tc, *rc;
  658. struct p9_client *clnt;
  659. struct p9_stat st, *ret;
  660. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu\n", fid->fid,
  661. (long long unsigned) offset);
  662. err = 0;
  663. tc = NULL;
  664. rc = NULL;
  665. ret = NULL;
  666. clnt = fid->clnt;
  667. /* if the offset is below or above the current response, free it */
  668. if (offset < fid->rdir_fpos || (fid->rdir_fcall &&
  669. offset >= fid->rdir_fpos+fid->rdir_fcall->params.rread.count)) {
  670. fid->rdir_pos = 0;
  671. if (fid->rdir_fcall)
  672. fid->rdir_fpos += fid->rdir_fcall->params.rread.count;
  673. kfree(fid->rdir_fcall);
  674. fid->rdir_fcall = NULL;
  675. if (offset < fid->rdir_fpos)
  676. fid->rdir_fpos = 0;
  677. }
  678. if (!fid->rdir_fcall) {
  679. n = fid->iounit;
  680. if (!n || n > clnt->msize-P9_IOHDRSZ)
  681. n = clnt->msize - P9_IOHDRSZ;
  682. while (1) {
  683. if (fid->rdir_fcall) {
  684. fid->rdir_fpos +=
  685. fid->rdir_fcall->params.rread.count;
  686. kfree(fid->rdir_fcall);
  687. fid->rdir_fcall = NULL;
  688. }
  689. tc = p9_create_tread(fid->fid, fid->rdir_fpos, n);
  690. if (IS_ERR(tc)) {
  691. err = PTR_ERR(tc);
  692. tc = NULL;
  693. goto error;
  694. }
  695. err = p9_conn_rpc(clnt->conn, tc, &rc);
  696. if (err)
  697. goto error;
  698. n = rc->params.rread.count;
  699. if (n == 0)
  700. goto done;
  701. fid->rdir_fcall = rc;
  702. rc = NULL;
  703. if (offset >= fid->rdir_fpos &&
  704. offset < fid->rdir_fpos+n)
  705. break;
  706. }
  707. fid->rdir_pos = 0;
  708. }
  709. m = offset - fid->rdir_fpos;
  710. if (m < 0)
  711. goto done;
  712. n = p9_deserialize_stat(fid->rdir_fcall->params.rread.data + m,
  713. fid->rdir_fcall->params.rread.count - m, &st, clnt->dotu);
  714. if (!n) {
  715. err = -EIO;
  716. goto error;
  717. }
  718. fid->rdir_pos += n;
  719. st.size = n;
  720. ret = p9_clone_stat(&st, clnt->dotu);
  721. if (IS_ERR(ret)) {
  722. err = PTR_ERR(ret);
  723. ret = NULL;
  724. goto error;
  725. }
  726. done:
  727. kfree(tc);
  728. kfree(rc);
  729. return ret;
  730. error:
  731. kfree(tc);
  732. kfree(rc);
  733. kfree(ret);
  734. return ERR_PTR(err);
  735. }
  736. EXPORT_SYMBOL(p9_client_dirread);
  737. static struct p9_stat *p9_clone_stat(struct p9_stat *st, int dotu)
  738. {
  739. int n;
  740. char *p;
  741. struct p9_stat *ret;
  742. n = sizeof(struct p9_stat) + st->name.len + st->uid.len + st->gid.len +
  743. st->muid.len;
  744. if (dotu)
  745. n += st->extension.len;
  746. ret = kmalloc(n, GFP_KERNEL);
  747. if (!ret)
  748. return ERR_PTR(-ENOMEM);
  749. memmove(ret, st, sizeof(struct p9_stat));
  750. p = ((char *) ret) + sizeof(struct p9_stat);
  751. memmove(p, st->name.str, st->name.len);
  752. p += st->name.len;
  753. memmove(p, st->uid.str, st->uid.len);
  754. p += st->uid.len;
  755. memmove(p, st->gid.str, st->gid.len);
  756. p += st->gid.len;
  757. memmove(p, st->muid.str, st->muid.len);
  758. p += st->muid.len;
  759. if (dotu) {
  760. memmove(p, st->extension.str, st->extension.len);
  761. p += st->extension.len;
  762. }
  763. return ret;
  764. }
  765. static struct p9_fid *p9_fid_create(struct p9_client *clnt)
  766. {
  767. int err;
  768. struct p9_fid *fid;
  769. P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
  770. fid = kmalloc(sizeof(struct p9_fid), GFP_KERNEL);
  771. if (!fid)
  772. return ERR_PTR(-ENOMEM);
  773. fid->fid = p9_idpool_get(clnt->fidpool);
  774. if (fid->fid < 0) {
  775. err = -ENOSPC;
  776. goto error;
  777. }
  778. memset(&fid->qid, 0, sizeof(struct p9_qid));
  779. fid->mode = -1;
  780. fid->rdir_fpos = 0;
  781. fid->rdir_pos = 0;
  782. fid->rdir_fcall = NULL;
  783. fid->uid = current->fsuid;
  784. fid->clnt = clnt;
  785. fid->aux = NULL;
  786. spin_lock(&clnt->lock);
  787. list_add(&fid->flist, &clnt->fidlist);
  788. spin_unlock(&clnt->lock);
  789. return fid;
  790. error:
  791. kfree(fid);
  792. return ERR_PTR(err);
  793. }
  794. static void p9_fid_destroy(struct p9_fid *fid)
  795. {
  796. struct p9_client *clnt;
  797. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  798. clnt = fid->clnt;
  799. p9_idpool_put(fid->fid, clnt->fidpool);
  800. spin_lock(&clnt->lock);
  801. list_del(&fid->flist);
  802. spin_unlock(&clnt->lock);
  803. kfree(fid->rdir_fcall);
  804. kfree(fid);
  805. }