client.c 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967
  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_trans *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, u32 n_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. n_uname, clnt->dotu);
  147. if (IS_ERR(tc)) {
  148. err = PTR_ERR(tc);
  149. tc = NULL;
  150. goto error;
  151. }
  152. err = p9_conn_rpc(clnt->conn, tc, &rc);
  153. if (err)
  154. goto error;
  155. memmove(&fid->qid, &rc->params.rattach.qid, sizeof(struct p9_qid));
  156. kfree(tc);
  157. kfree(rc);
  158. return fid;
  159. error:
  160. kfree(tc);
  161. kfree(rc);
  162. if (fid)
  163. p9_fid_destroy(fid);
  164. return ERR_PTR(err);
  165. }
  166. EXPORT_SYMBOL(p9_client_attach);
  167. struct p9_fid *p9_client_auth(struct p9_client *clnt, char *uname,
  168. u32 n_uname, char *aname)
  169. {
  170. int err;
  171. struct p9_fcall *tc, *rc;
  172. struct p9_fid *fid;
  173. P9_DPRINTK(P9_DEBUG_9P, "clnt %p uname %s aname %s\n", clnt, uname,
  174. aname);
  175. err = 0;
  176. tc = NULL;
  177. rc = NULL;
  178. fid = p9_fid_create(clnt);
  179. if (IS_ERR(fid)) {
  180. err = PTR_ERR(fid);
  181. fid = NULL;
  182. goto error;
  183. }
  184. tc = p9_create_tauth(fid->fid, uname, aname, n_uname, clnt->dotu);
  185. if (IS_ERR(tc)) {
  186. err = PTR_ERR(tc);
  187. tc = NULL;
  188. goto error;
  189. }
  190. err = p9_conn_rpc(clnt->conn, tc, &rc);
  191. if (err)
  192. goto error;
  193. memmove(&fid->qid, &rc->params.rauth.qid, sizeof(struct p9_qid));
  194. kfree(tc);
  195. kfree(rc);
  196. return fid;
  197. error:
  198. kfree(tc);
  199. kfree(rc);
  200. if (fid)
  201. p9_fid_destroy(fid);
  202. return ERR_PTR(err);
  203. }
  204. EXPORT_SYMBOL(p9_client_auth);
  205. struct p9_fid *p9_client_walk(struct p9_fid *oldfid, int nwname, char **wnames,
  206. int clone)
  207. {
  208. int err;
  209. struct p9_fcall *tc, *rc;
  210. struct p9_client *clnt;
  211. struct p9_fid *fid;
  212. P9_DPRINTK(P9_DEBUG_9P, "fid %d nwname %d wname[0] %s\n",
  213. oldfid->fid, nwname, wnames?wnames[0]:NULL);
  214. err = 0;
  215. tc = NULL;
  216. rc = NULL;
  217. clnt = oldfid->clnt;
  218. if (clone) {
  219. fid = p9_fid_create(clnt);
  220. if (IS_ERR(fid)) {
  221. err = PTR_ERR(fid);
  222. fid = NULL;
  223. goto error;
  224. }
  225. fid->uid = oldfid->uid;
  226. } else
  227. fid = oldfid;
  228. tc = p9_create_twalk(oldfid->fid, fid->fid, nwname, wnames);
  229. if (IS_ERR(tc)) {
  230. err = PTR_ERR(tc);
  231. tc = NULL;
  232. goto error;
  233. }
  234. err = p9_conn_rpc(clnt->conn, tc, &rc);
  235. if (err) {
  236. if (rc && rc->id == P9_RWALK)
  237. goto clunk_fid;
  238. else
  239. goto error;
  240. }
  241. if (rc->params.rwalk.nwqid != nwname) {
  242. err = -ENOENT;
  243. goto clunk_fid;
  244. }
  245. if (nwname)
  246. memmove(&fid->qid,
  247. &rc->params.rwalk.wqids[rc->params.rwalk.nwqid - 1],
  248. sizeof(struct p9_qid));
  249. else
  250. fid->qid = oldfid->qid;
  251. kfree(tc);
  252. kfree(rc);
  253. return fid;
  254. clunk_fid:
  255. kfree(tc);
  256. kfree(rc);
  257. rc = NULL;
  258. tc = p9_create_tclunk(fid->fid);
  259. if (IS_ERR(tc)) {
  260. err = PTR_ERR(tc);
  261. tc = NULL;
  262. goto error;
  263. }
  264. p9_conn_rpc(clnt->conn, tc, &rc);
  265. error:
  266. kfree(tc);
  267. kfree(rc);
  268. if (fid && (fid != oldfid))
  269. p9_fid_destroy(fid);
  270. return ERR_PTR(err);
  271. }
  272. EXPORT_SYMBOL(p9_client_walk);
  273. int p9_client_open(struct p9_fid *fid, int mode)
  274. {
  275. int err;
  276. struct p9_fcall *tc, *rc;
  277. struct p9_client *clnt;
  278. P9_DPRINTK(P9_DEBUG_9P, "fid %d mode %d\n", fid->fid, mode);
  279. err = 0;
  280. tc = NULL;
  281. rc = NULL;
  282. clnt = fid->clnt;
  283. if (fid->mode != -1)
  284. return -EINVAL;
  285. tc = p9_create_topen(fid->fid, mode);
  286. if (IS_ERR(tc)) {
  287. err = PTR_ERR(tc);
  288. tc = NULL;
  289. goto done;
  290. }
  291. err = p9_conn_rpc(clnt->conn, tc, &rc);
  292. if (err)
  293. goto done;
  294. fid->mode = mode;
  295. fid->iounit = rc->params.ropen.iounit;
  296. done:
  297. kfree(tc);
  298. kfree(rc);
  299. return err;
  300. }
  301. EXPORT_SYMBOL(p9_client_open);
  302. int p9_client_fcreate(struct p9_fid *fid, char *name, u32 perm, int mode,
  303. char *extension)
  304. {
  305. int err;
  306. struct p9_fcall *tc, *rc;
  307. struct p9_client *clnt;
  308. P9_DPRINTK(P9_DEBUG_9P, "fid %d name %s perm %d mode %d\n", fid->fid,
  309. name, perm, mode);
  310. err = 0;
  311. tc = NULL;
  312. rc = NULL;
  313. clnt = fid->clnt;
  314. if (fid->mode != -1)
  315. return -EINVAL;
  316. tc = p9_create_tcreate(fid->fid, name, perm, mode, extension,
  317. clnt->dotu);
  318. if (IS_ERR(tc)) {
  319. err = PTR_ERR(tc);
  320. tc = NULL;
  321. goto done;
  322. }
  323. err = p9_conn_rpc(clnt->conn, tc, &rc);
  324. if (err)
  325. goto done;
  326. fid->mode = mode;
  327. fid->iounit = rc->params.ropen.iounit;
  328. done:
  329. kfree(tc);
  330. kfree(rc);
  331. return err;
  332. }
  333. EXPORT_SYMBOL(p9_client_fcreate);
  334. int p9_client_clunk(struct p9_fid *fid)
  335. {
  336. int err;
  337. struct p9_fcall *tc, *rc;
  338. struct p9_client *clnt;
  339. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  340. err = 0;
  341. tc = NULL;
  342. rc = NULL;
  343. clnt = fid->clnt;
  344. tc = p9_create_tclunk(fid->fid);
  345. if (IS_ERR(tc)) {
  346. err = PTR_ERR(tc);
  347. tc = NULL;
  348. goto done;
  349. }
  350. err = p9_conn_rpc(clnt->conn, tc, &rc);
  351. if (err)
  352. goto done;
  353. p9_fid_destroy(fid);
  354. done:
  355. kfree(tc);
  356. kfree(rc);
  357. return err;
  358. }
  359. EXPORT_SYMBOL(p9_client_clunk);
  360. int p9_client_remove(struct p9_fid *fid)
  361. {
  362. int err;
  363. struct p9_fcall *tc, *rc;
  364. struct p9_client *clnt;
  365. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  366. err = 0;
  367. tc = NULL;
  368. rc = NULL;
  369. clnt = fid->clnt;
  370. tc = p9_create_tremove(fid->fid);
  371. if (IS_ERR(tc)) {
  372. err = PTR_ERR(tc);
  373. tc = NULL;
  374. goto done;
  375. }
  376. err = p9_conn_rpc(clnt->conn, tc, &rc);
  377. if (err)
  378. goto done;
  379. p9_fid_destroy(fid);
  380. done:
  381. kfree(tc);
  382. kfree(rc);
  383. return err;
  384. }
  385. EXPORT_SYMBOL(p9_client_remove);
  386. int p9_client_read(struct p9_fid *fid, char *data, u64 offset, u32 count)
  387. {
  388. int err, n, rsize, total;
  389. struct p9_fcall *tc, *rc;
  390. struct p9_client *clnt;
  391. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu %d\n", fid->fid,
  392. (long long unsigned) offset, count);
  393. err = 0;
  394. tc = NULL;
  395. rc = NULL;
  396. clnt = fid->clnt;
  397. total = 0;
  398. rsize = fid->iounit;
  399. if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
  400. rsize = clnt->msize - P9_IOHDRSZ;
  401. do {
  402. if (count < rsize)
  403. rsize = count;
  404. tc = p9_create_tread(fid->fid, offset, rsize);
  405. if (IS_ERR(tc)) {
  406. err = PTR_ERR(tc);
  407. tc = NULL;
  408. goto error;
  409. }
  410. err = p9_conn_rpc(clnt->conn, tc, &rc);
  411. if (err)
  412. goto error;
  413. n = rc->params.rread.count;
  414. if (n > count)
  415. n = count;
  416. memmove(data, rc->params.rread.data, n);
  417. count -= n;
  418. data += n;
  419. offset += n;
  420. total += n;
  421. kfree(tc);
  422. tc = NULL;
  423. kfree(rc);
  424. rc = NULL;
  425. } while (count > 0 && n == rsize);
  426. return total;
  427. error:
  428. kfree(tc);
  429. kfree(rc);
  430. return err;
  431. }
  432. EXPORT_SYMBOL(p9_client_read);
  433. int p9_client_write(struct p9_fid *fid, char *data, u64 offset, u32 count)
  434. {
  435. int err, n, rsize, total;
  436. struct p9_fcall *tc, *rc;
  437. struct p9_client *clnt;
  438. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
  439. (long long unsigned) offset, count);
  440. err = 0;
  441. tc = NULL;
  442. rc = NULL;
  443. clnt = fid->clnt;
  444. total = 0;
  445. rsize = fid->iounit;
  446. if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
  447. rsize = clnt->msize - P9_IOHDRSZ;
  448. do {
  449. if (count < rsize)
  450. rsize = count;
  451. tc = p9_create_twrite(fid->fid, offset, rsize, data);
  452. if (IS_ERR(tc)) {
  453. err = PTR_ERR(tc);
  454. tc = NULL;
  455. goto error;
  456. }
  457. err = p9_conn_rpc(clnt->conn, tc, &rc);
  458. if (err)
  459. goto error;
  460. n = rc->params.rread.count;
  461. count -= n;
  462. data += n;
  463. offset += n;
  464. total += n;
  465. kfree(tc);
  466. tc = NULL;
  467. kfree(rc);
  468. rc = NULL;
  469. } while (count > 0);
  470. return total;
  471. error:
  472. kfree(tc);
  473. kfree(rc);
  474. return err;
  475. }
  476. EXPORT_SYMBOL(p9_client_write);
  477. int
  478. p9_client_uread(struct p9_fid *fid, char __user *data, u64 offset, u32 count)
  479. {
  480. int err, n, rsize, total;
  481. struct p9_fcall *tc, *rc;
  482. struct p9_client *clnt;
  483. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
  484. (long long unsigned) offset, count);
  485. err = 0;
  486. tc = NULL;
  487. rc = NULL;
  488. clnt = fid->clnt;
  489. total = 0;
  490. rsize = fid->iounit;
  491. if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
  492. rsize = clnt->msize - P9_IOHDRSZ;
  493. do {
  494. if (count < rsize)
  495. rsize = count;
  496. tc = p9_create_tread(fid->fid, offset, rsize);
  497. if (IS_ERR(tc)) {
  498. err = PTR_ERR(tc);
  499. tc = NULL;
  500. goto error;
  501. }
  502. err = p9_conn_rpc(clnt->conn, tc, &rc);
  503. if (err)
  504. goto error;
  505. n = rc->params.rread.count;
  506. if (n > count)
  507. n = count;
  508. err = copy_to_user(data, rc->params.rread.data, n);
  509. if (err) {
  510. err = -EFAULT;
  511. goto error;
  512. }
  513. count -= n;
  514. data += n;
  515. offset += n;
  516. total += n;
  517. kfree(tc);
  518. tc = NULL;
  519. kfree(rc);
  520. rc = NULL;
  521. } while (count > 0 && n == rsize);
  522. return total;
  523. error:
  524. kfree(tc);
  525. kfree(rc);
  526. return err;
  527. }
  528. EXPORT_SYMBOL(p9_client_uread);
  529. int
  530. p9_client_uwrite(struct p9_fid *fid, const char __user *data, u64 offset,
  531. u32 count)
  532. {
  533. int err, n, rsize, total;
  534. struct p9_fcall *tc, *rc;
  535. struct p9_client *clnt;
  536. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
  537. (long long unsigned) offset, count);
  538. err = 0;
  539. tc = NULL;
  540. rc = NULL;
  541. clnt = fid->clnt;
  542. total = 0;
  543. rsize = fid->iounit;
  544. if (!rsize || rsize > clnt->msize-P9_IOHDRSZ)
  545. rsize = clnt->msize - P9_IOHDRSZ;
  546. do {
  547. if (count < rsize)
  548. rsize = count;
  549. tc = p9_create_twrite_u(fid->fid, offset, rsize, data);
  550. if (IS_ERR(tc)) {
  551. err = PTR_ERR(tc);
  552. tc = NULL;
  553. goto error;
  554. }
  555. err = p9_conn_rpc(clnt->conn, tc, &rc);
  556. if (err)
  557. goto error;
  558. n = rc->params.rread.count;
  559. count -= n;
  560. data += n;
  561. offset += n;
  562. total += n;
  563. kfree(tc);
  564. tc = NULL;
  565. kfree(rc);
  566. rc = NULL;
  567. } while (count > 0);
  568. return total;
  569. error:
  570. kfree(tc);
  571. kfree(rc);
  572. return err;
  573. }
  574. EXPORT_SYMBOL(p9_client_uwrite);
  575. int p9_client_readn(struct p9_fid *fid, char *data, u64 offset, u32 count)
  576. {
  577. int n, total;
  578. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu count %d\n", fid->fid,
  579. (long long unsigned) offset, count);
  580. n = 0;
  581. total = 0;
  582. while (count) {
  583. n = p9_client_read(fid, data, offset, count);
  584. if (n <= 0)
  585. break;
  586. data += n;
  587. offset += n;
  588. count -= n;
  589. total += n;
  590. }
  591. if (n < 0)
  592. total = n;
  593. return total;
  594. }
  595. EXPORT_SYMBOL(p9_client_readn);
  596. struct p9_stat *p9_client_stat(struct p9_fid *fid)
  597. {
  598. int err;
  599. struct p9_fcall *tc, *rc;
  600. struct p9_client *clnt;
  601. struct p9_stat *ret;
  602. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  603. err = 0;
  604. tc = NULL;
  605. rc = NULL;
  606. ret = NULL;
  607. clnt = fid->clnt;
  608. tc = p9_create_tstat(fid->fid);
  609. if (IS_ERR(tc)) {
  610. err = PTR_ERR(tc);
  611. tc = NULL;
  612. goto error;
  613. }
  614. err = p9_conn_rpc(clnt->conn, tc, &rc);
  615. if (err)
  616. goto error;
  617. ret = p9_clone_stat(&rc->params.rstat.stat, clnt->dotu);
  618. if (IS_ERR(ret)) {
  619. err = PTR_ERR(ret);
  620. ret = NULL;
  621. goto error;
  622. }
  623. kfree(tc);
  624. kfree(rc);
  625. return ret;
  626. error:
  627. kfree(tc);
  628. kfree(rc);
  629. kfree(ret);
  630. return ERR_PTR(err);
  631. }
  632. EXPORT_SYMBOL(p9_client_stat);
  633. int p9_client_wstat(struct p9_fid *fid, struct p9_wstat *wst)
  634. {
  635. int err;
  636. struct p9_fcall *tc, *rc;
  637. struct p9_client *clnt;
  638. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  639. err = 0;
  640. tc = NULL;
  641. rc = NULL;
  642. clnt = fid->clnt;
  643. tc = p9_create_twstat(fid->fid, wst, clnt->dotu);
  644. if (IS_ERR(tc)) {
  645. err = PTR_ERR(tc);
  646. tc = NULL;
  647. goto done;
  648. }
  649. err = p9_conn_rpc(clnt->conn, tc, &rc);
  650. done:
  651. kfree(tc);
  652. kfree(rc);
  653. return err;
  654. }
  655. EXPORT_SYMBOL(p9_client_wstat);
  656. struct p9_stat *p9_client_dirread(struct p9_fid *fid, u64 offset)
  657. {
  658. int err, n, m;
  659. struct p9_fcall *tc, *rc;
  660. struct p9_client *clnt;
  661. struct p9_stat st, *ret;
  662. P9_DPRINTK(P9_DEBUG_9P, "fid %d offset %llu\n", fid->fid,
  663. (long long unsigned) offset);
  664. err = 0;
  665. tc = NULL;
  666. rc = NULL;
  667. ret = NULL;
  668. clnt = fid->clnt;
  669. /* if the offset is below or above the current response, free it */
  670. if (offset < fid->rdir_fpos || (fid->rdir_fcall &&
  671. offset >= fid->rdir_fpos+fid->rdir_fcall->params.rread.count)) {
  672. fid->rdir_pos = 0;
  673. if (fid->rdir_fcall)
  674. fid->rdir_fpos += fid->rdir_fcall->params.rread.count;
  675. kfree(fid->rdir_fcall);
  676. fid->rdir_fcall = NULL;
  677. if (offset < fid->rdir_fpos)
  678. fid->rdir_fpos = 0;
  679. }
  680. if (!fid->rdir_fcall) {
  681. n = fid->iounit;
  682. if (!n || n > clnt->msize-P9_IOHDRSZ)
  683. n = clnt->msize - P9_IOHDRSZ;
  684. while (1) {
  685. if (fid->rdir_fcall) {
  686. fid->rdir_fpos +=
  687. fid->rdir_fcall->params.rread.count;
  688. kfree(fid->rdir_fcall);
  689. fid->rdir_fcall = NULL;
  690. }
  691. tc = p9_create_tread(fid->fid, fid->rdir_fpos, n);
  692. if (IS_ERR(tc)) {
  693. err = PTR_ERR(tc);
  694. tc = NULL;
  695. goto error;
  696. }
  697. err = p9_conn_rpc(clnt->conn, tc, &rc);
  698. if (err)
  699. goto error;
  700. n = rc->params.rread.count;
  701. if (n == 0)
  702. goto done;
  703. fid->rdir_fcall = rc;
  704. rc = NULL;
  705. if (offset >= fid->rdir_fpos &&
  706. offset < fid->rdir_fpos+n)
  707. break;
  708. }
  709. fid->rdir_pos = 0;
  710. }
  711. m = offset - fid->rdir_fpos;
  712. if (m < 0)
  713. goto done;
  714. n = p9_deserialize_stat(fid->rdir_fcall->params.rread.data + m,
  715. fid->rdir_fcall->params.rread.count - m, &st, clnt->dotu);
  716. if (!n) {
  717. err = -EIO;
  718. goto error;
  719. }
  720. fid->rdir_pos += n;
  721. st.size = n;
  722. ret = p9_clone_stat(&st, clnt->dotu);
  723. if (IS_ERR(ret)) {
  724. err = PTR_ERR(ret);
  725. ret = NULL;
  726. goto error;
  727. }
  728. done:
  729. kfree(tc);
  730. kfree(rc);
  731. return ret;
  732. error:
  733. kfree(tc);
  734. kfree(rc);
  735. kfree(ret);
  736. return ERR_PTR(err);
  737. }
  738. EXPORT_SYMBOL(p9_client_dirread);
  739. static struct p9_stat *p9_clone_stat(struct p9_stat *st, int dotu)
  740. {
  741. int n;
  742. char *p;
  743. struct p9_stat *ret;
  744. n = sizeof(struct p9_stat) + st->name.len + st->uid.len + st->gid.len +
  745. st->muid.len;
  746. if (dotu)
  747. n += st->extension.len;
  748. ret = kmalloc(n, GFP_KERNEL);
  749. if (!ret)
  750. return ERR_PTR(-ENOMEM);
  751. memmove(ret, st, sizeof(struct p9_stat));
  752. p = ((char *) ret) + sizeof(struct p9_stat);
  753. memmove(p, st->name.str, st->name.len);
  754. p += st->name.len;
  755. memmove(p, st->uid.str, st->uid.len);
  756. p += st->uid.len;
  757. memmove(p, st->gid.str, st->gid.len);
  758. p += st->gid.len;
  759. memmove(p, st->muid.str, st->muid.len);
  760. p += st->muid.len;
  761. if (dotu) {
  762. memmove(p, st->extension.str, st->extension.len);
  763. p += st->extension.len;
  764. }
  765. return ret;
  766. }
  767. static struct p9_fid *p9_fid_create(struct p9_client *clnt)
  768. {
  769. int err;
  770. struct p9_fid *fid;
  771. P9_DPRINTK(P9_DEBUG_9P, "clnt %p\n", clnt);
  772. fid = kmalloc(sizeof(struct p9_fid), GFP_KERNEL);
  773. if (!fid)
  774. return ERR_PTR(-ENOMEM);
  775. fid->fid = p9_idpool_get(clnt->fidpool);
  776. if (fid->fid < 0) {
  777. err = -ENOSPC;
  778. goto error;
  779. }
  780. memset(&fid->qid, 0, sizeof(struct p9_qid));
  781. fid->mode = -1;
  782. fid->rdir_fpos = 0;
  783. fid->rdir_pos = 0;
  784. fid->rdir_fcall = NULL;
  785. fid->uid = current->fsuid;
  786. fid->clnt = clnt;
  787. fid->aux = NULL;
  788. spin_lock(&clnt->lock);
  789. list_add(&fid->flist, &clnt->fidlist);
  790. spin_unlock(&clnt->lock);
  791. return fid;
  792. error:
  793. kfree(fid);
  794. return ERR_PTR(err);
  795. }
  796. static void p9_fid_destroy(struct p9_fid *fid)
  797. {
  798. struct p9_client *clnt;
  799. P9_DPRINTK(P9_DEBUG_9P, "fid %d\n", fid->fid);
  800. clnt = fid->clnt;
  801. p9_idpool_put(fid->fid, clnt->fidpool);
  802. spin_lock(&clnt->lock);
  803. list_del(&fid->flist);
  804. spin_unlock(&clnt->lock);
  805. kfree(fid->rdir_fcall);
  806. kfree(fid);
  807. }