vfs_file.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920
  1. /*
  2. * linux/fs/9p/vfs_file.c
  3. *
  4. * This file contians vfs file ops for 9P2000.
  5. *
  6. * Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com>
  7. * Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov>
  8. *
  9. * This program is free software; you can redistribute it and/or modify
  10. * it under the terms of the GNU General Public License version 2
  11. * as published by the Free Software Foundation.
  12. *
  13. * This program is distributed in the hope that it will be useful,
  14. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  16. * GNU General Public License for more details.
  17. *
  18. * You should have received a copy of the GNU General Public License
  19. * along with this program; if not, write to:
  20. * Free Software Foundation
  21. * 51 Franklin Street, Fifth Floor
  22. * Boston, MA 02111-1301 USA
  23. *
  24. */
  25. #include <linux/module.h>
  26. #include <linux/errno.h>
  27. #include <linux/fs.h>
  28. #include <linux/sched.h>
  29. #include <linux/file.h>
  30. #include <linux/stat.h>
  31. #include <linux/string.h>
  32. #include <linux/inet.h>
  33. #include <linux/list.h>
  34. #include <linux/pagemap.h>
  35. #include <linux/utsname.h>
  36. #include <asm/uaccess.h>
  37. #include <linux/idr.h>
  38. #include <net/9p/9p.h>
  39. #include <net/9p/client.h>
  40. #include "v9fs.h"
  41. #include "v9fs_vfs.h"
  42. #include "fid.h"
  43. #include "cache.h"
  44. static const struct vm_operations_struct v9fs_file_vm_ops;
  45. static const struct vm_operations_struct v9fs_mmap_file_vm_ops;
  46. /**
  47. * v9fs_file_open - open a file (or directory)
  48. * @inode: inode to be opened
  49. * @file: file being opened
  50. *
  51. */
  52. int v9fs_file_open(struct inode *inode, struct file *file)
  53. {
  54. int err;
  55. struct v9fs_inode *v9inode;
  56. struct v9fs_session_info *v9ses;
  57. struct p9_fid *fid;
  58. int omode;
  59. p9_debug(P9_DEBUG_VFS, "inode: %p file: %p\n", inode, file);
  60. v9inode = V9FS_I(inode);
  61. v9ses = v9fs_inode2v9ses(inode);
  62. if (v9fs_proto_dotl(v9ses))
  63. omode = v9fs_open_to_dotl_flags(file->f_flags);
  64. else
  65. omode = v9fs_uflags2omode(file->f_flags,
  66. v9fs_proto_dotu(v9ses));
  67. fid = file->private_data;
  68. if (!fid) {
  69. fid = v9fs_fid_clone(file->f_path.dentry);
  70. if (IS_ERR(fid))
  71. return PTR_ERR(fid);
  72. err = p9_client_open(fid, omode);
  73. if (err < 0) {
  74. p9_client_clunk(fid);
  75. return err;
  76. }
  77. if ((file->f_flags & O_APPEND) &&
  78. (!v9fs_proto_dotu(v9ses) && !v9fs_proto_dotl(v9ses)))
  79. generic_file_llseek(file, 0, SEEK_END);
  80. }
  81. file->private_data = fid;
  82. mutex_lock(&v9inode->v_mutex);
  83. if ((v9ses->cache == CACHE_LOOSE || v9ses->cache == CACHE_FSCACHE) &&
  84. !v9inode->writeback_fid &&
  85. ((file->f_flags & O_ACCMODE) != O_RDONLY)) {
  86. /*
  87. * clone a fid and add it to writeback_fid
  88. * we do it during open time instead of
  89. * page dirty time via write_begin/page_mkwrite
  90. * because we want write after unlink usecase
  91. * to work.
  92. */
  93. fid = v9fs_writeback_fid(file->f_path.dentry);
  94. if (IS_ERR(fid)) {
  95. err = PTR_ERR(fid);
  96. mutex_unlock(&v9inode->v_mutex);
  97. goto out_error;
  98. }
  99. v9inode->writeback_fid = (void *) fid;
  100. }
  101. mutex_unlock(&v9inode->v_mutex);
  102. if (v9ses->cache == CACHE_LOOSE || v9ses->cache == CACHE_FSCACHE)
  103. v9fs_cache_inode_set_cookie(inode, file);
  104. return 0;
  105. out_error:
  106. p9_client_clunk(file->private_data);
  107. file->private_data = NULL;
  108. return err;
  109. }
  110. /**
  111. * v9fs_file_lock - lock a file (or directory)
  112. * @filp: file to be locked
  113. * @cmd: lock command
  114. * @fl: file lock structure
  115. *
  116. * Bugs: this looks like a local only lock, we should extend into 9P
  117. * by using open exclusive
  118. */
  119. static int v9fs_file_lock(struct file *filp, int cmd, struct file_lock *fl)
  120. {
  121. int res = 0;
  122. struct inode *inode = file_inode(filp);
  123. p9_debug(P9_DEBUG_VFS, "filp: %p lock: %p\n", filp, fl);
  124. /* No mandatory locks */
  125. if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
  126. return -ENOLCK;
  127. if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
  128. filemap_write_and_wait(inode->i_mapping);
  129. invalidate_mapping_pages(&inode->i_data, 0, -1);
  130. }
  131. return res;
  132. }
  133. static int v9fs_file_do_lock(struct file *filp, int cmd, struct file_lock *fl)
  134. {
  135. struct p9_flock flock;
  136. struct p9_fid *fid;
  137. uint8_t status;
  138. int res = 0;
  139. unsigned char fl_type;
  140. fid = filp->private_data;
  141. BUG_ON(fid == NULL);
  142. if ((fl->fl_flags & FL_POSIX) != FL_POSIX)
  143. BUG();
  144. res = posix_lock_file_wait(filp, fl);
  145. if (res < 0)
  146. goto out;
  147. /* convert posix lock to p9 tlock args */
  148. memset(&flock, 0, sizeof(flock));
  149. /* map the lock type */
  150. switch (fl->fl_type) {
  151. case F_RDLCK:
  152. flock.type = P9_LOCK_TYPE_RDLCK;
  153. break;
  154. case F_WRLCK:
  155. flock.type = P9_LOCK_TYPE_WRLCK;
  156. break;
  157. case F_UNLCK:
  158. flock.type = P9_LOCK_TYPE_UNLCK;
  159. break;
  160. }
  161. flock.start = fl->fl_start;
  162. if (fl->fl_end == OFFSET_MAX)
  163. flock.length = 0;
  164. else
  165. flock.length = fl->fl_end - fl->fl_start + 1;
  166. flock.proc_id = fl->fl_pid;
  167. flock.client_id = fid->clnt->name;
  168. if (IS_SETLKW(cmd))
  169. flock.flags = P9_LOCK_FLAGS_BLOCK;
  170. /*
  171. * if its a blocked request and we get P9_LOCK_BLOCKED as the status
  172. * for lock request, keep on trying
  173. */
  174. for (;;) {
  175. res = p9_client_lock_dotl(fid, &flock, &status);
  176. if (res < 0)
  177. break;
  178. if (status != P9_LOCK_BLOCKED)
  179. break;
  180. if (status == P9_LOCK_BLOCKED && !IS_SETLKW(cmd))
  181. break;
  182. if (schedule_timeout_interruptible(P9_LOCK_TIMEOUT) != 0)
  183. break;
  184. }
  185. /* map 9p status to VFS status */
  186. switch (status) {
  187. case P9_LOCK_SUCCESS:
  188. res = 0;
  189. break;
  190. case P9_LOCK_BLOCKED:
  191. res = -EAGAIN;
  192. break;
  193. case P9_LOCK_ERROR:
  194. case P9_LOCK_GRACE:
  195. res = -ENOLCK;
  196. break;
  197. default:
  198. BUG();
  199. }
  200. /*
  201. * incase server returned error for lock request, revert
  202. * it locally
  203. */
  204. if (res < 0 && fl->fl_type != F_UNLCK) {
  205. fl_type = fl->fl_type;
  206. fl->fl_type = F_UNLCK;
  207. res = posix_lock_file_wait(filp, fl);
  208. fl->fl_type = fl_type;
  209. }
  210. out:
  211. return res;
  212. }
  213. static int v9fs_file_getlock(struct file *filp, struct file_lock *fl)
  214. {
  215. struct p9_getlock glock;
  216. struct p9_fid *fid;
  217. int res = 0;
  218. fid = filp->private_data;
  219. BUG_ON(fid == NULL);
  220. posix_test_lock(filp, fl);
  221. /*
  222. * if we have a conflicting lock locally, no need to validate
  223. * with server
  224. */
  225. if (fl->fl_type != F_UNLCK)
  226. return res;
  227. /* convert posix lock to p9 tgetlock args */
  228. memset(&glock, 0, sizeof(glock));
  229. glock.type = P9_LOCK_TYPE_UNLCK;
  230. glock.start = fl->fl_start;
  231. if (fl->fl_end == OFFSET_MAX)
  232. glock.length = 0;
  233. else
  234. glock.length = fl->fl_end - fl->fl_start + 1;
  235. glock.proc_id = fl->fl_pid;
  236. glock.client_id = fid->clnt->name;
  237. res = p9_client_getlock_dotl(fid, &glock);
  238. if (res < 0)
  239. return res;
  240. /* map 9p lock type to os lock type */
  241. switch (glock.type) {
  242. case P9_LOCK_TYPE_RDLCK:
  243. fl->fl_type = F_RDLCK;
  244. break;
  245. case P9_LOCK_TYPE_WRLCK:
  246. fl->fl_type = F_WRLCK;
  247. break;
  248. case P9_LOCK_TYPE_UNLCK:
  249. fl->fl_type = F_UNLCK;
  250. break;
  251. }
  252. if (glock.type != P9_LOCK_TYPE_UNLCK) {
  253. fl->fl_start = glock.start;
  254. if (glock.length == 0)
  255. fl->fl_end = OFFSET_MAX;
  256. else
  257. fl->fl_end = glock.start + glock.length - 1;
  258. fl->fl_pid = glock.proc_id;
  259. }
  260. return res;
  261. }
  262. /**
  263. * v9fs_file_lock_dotl - lock a file (or directory)
  264. * @filp: file to be locked
  265. * @cmd: lock command
  266. * @fl: file lock structure
  267. *
  268. */
  269. static int v9fs_file_lock_dotl(struct file *filp, int cmd, struct file_lock *fl)
  270. {
  271. struct inode *inode = file_inode(filp);
  272. int ret = -ENOLCK;
  273. p9_debug(P9_DEBUG_VFS, "filp: %p cmd:%d lock: %p name: %s\n",
  274. filp, cmd, fl, filp->f_path.dentry->d_name.name);
  275. /* No mandatory locks */
  276. if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
  277. goto out_err;
  278. if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
  279. filemap_write_and_wait(inode->i_mapping);
  280. invalidate_mapping_pages(&inode->i_data, 0, -1);
  281. }
  282. if (IS_SETLK(cmd) || IS_SETLKW(cmd))
  283. ret = v9fs_file_do_lock(filp, cmd, fl);
  284. else if (IS_GETLK(cmd))
  285. ret = v9fs_file_getlock(filp, fl);
  286. else
  287. ret = -EINVAL;
  288. out_err:
  289. return ret;
  290. }
  291. /**
  292. * v9fs_file_flock_dotl - lock a file
  293. * @filp: file to be locked
  294. * @cmd: lock command
  295. * @fl: file lock structure
  296. *
  297. */
  298. static int v9fs_file_flock_dotl(struct file *filp, int cmd,
  299. struct file_lock *fl)
  300. {
  301. struct inode *inode = file_inode(filp);
  302. int ret = -ENOLCK;
  303. p9_debug(P9_DEBUG_VFS, "filp: %p cmd:%d lock: %p name: %s\n",
  304. filp, cmd, fl, filp->f_path.dentry->d_name.name);
  305. /* No mandatory locks */
  306. if (__mandatory_lock(inode) && fl->fl_type != F_UNLCK)
  307. goto out_err;
  308. if (!(fl->fl_flags & FL_FLOCK))
  309. goto out_err;
  310. if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) {
  311. filemap_write_and_wait(inode->i_mapping);
  312. invalidate_mapping_pages(&inode->i_data, 0, -1);
  313. }
  314. /* Convert flock to posix lock */
  315. fl->fl_owner = (fl_owner_t)filp;
  316. fl->fl_start = 0;
  317. fl->fl_end = OFFSET_MAX;
  318. fl->fl_flags |= FL_POSIX;
  319. fl->fl_flags ^= FL_FLOCK;
  320. if (IS_SETLK(cmd) | IS_SETLKW(cmd))
  321. ret = v9fs_file_do_lock(filp, cmd, fl);
  322. else
  323. ret = -EINVAL;
  324. out_err:
  325. return ret;
  326. }
  327. /**
  328. * v9fs_fid_readn - read from a fid
  329. * @fid: fid to read
  330. * @data: data buffer to read data into
  331. * @udata: user data buffer to read data into
  332. * @count: size of buffer
  333. * @offset: offset at which to read data
  334. *
  335. */
  336. ssize_t
  337. v9fs_fid_readn(struct p9_fid *fid, char *data, char __user *udata, u32 count,
  338. u64 offset)
  339. {
  340. int n, total, size;
  341. p9_debug(P9_DEBUG_VFS, "fid %d offset %llu count %d\n",
  342. fid->fid, (long long unsigned)offset, count);
  343. n = 0;
  344. total = 0;
  345. size = fid->iounit ? fid->iounit : fid->clnt->msize - P9_IOHDRSZ;
  346. do {
  347. n = p9_client_read(fid, data, udata, offset, count);
  348. if (n <= 0)
  349. break;
  350. if (data)
  351. data += n;
  352. if (udata)
  353. udata += n;
  354. offset += n;
  355. count -= n;
  356. total += n;
  357. } while (count > 0 && n == size);
  358. if (n < 0)
  359. total = n;
  360. return total;
  361. }
  362. /**
  363. * v9fs_file_readn - read from a file
  364. * @filp: file pointer to read
  365. * @data: data buffer to read data into
  366. * @udata: user data buffer to read data into
  367. * @count: size of buffer
  368. * @offset: offset at which to read data
  369. *
  370. */
  371. ssize_t
  372. v9fs_file_readn(struct file *filp, char *data, char __user *udata, u32 count,
  373. u64 offset)
  374. {
  375. return v9fs_fid_readn(filp->private_data, data, udata, count, offset);
  376. }
  377. /**
  378. * v9fs_file_read - read from a file
  379. * @filp: file pointer to read
  380. * @udata: user data buffer to read data into
  381. * @count: size of buffer
  382. * @offset: offset at which to read data
  383. *
  384. */
  385. static ssize_t
  386. v9fs_file_read(struct file *filp, char __user *udata, size_t count,
  387. loff_t * offset)
  388. {
  389. int ret;
  390. struct p9_fid *fid;
  391. size_t size;
  392. p9_debug(P9_DEBUG_VFS, "count %zu offset %lld\n", count, *offset);
  393. fid = filp->private_data;
  394. size = fid->iounit ? fid->iounit : fid->clnt->msize - P9_IOHDRSZ;
  395. if (count > size)
  396. ret = v9fs_file_readn(filp, NULL, udata, count, *offset);
  397. else
  398. ret = p9_client_read(fid, NULL, udata, *offset, count);
  399. if (ret > 0)
  400. *offset += ret;
  401. return ret;
  402. }
  403. ssize_t
  404. v9fs_file_write_internal(struct inode *inode, struct p9_fid *fid,
  405. const char __user *data, size_t count,
  406. loff_t *offset, int invalidate)
  407. {
  408. int n;
  409. loff_t i_size;
  410. size_t total = 0;
  411. loff_t origin = *offset;
  412. unsigned long pg_start, pg_end;
  413. p9_debug(P9_DEBUG_VFS, "data %p count %d offset %x\n",
  414. data, (int)count, (int)*offset);
  415. do {
  416. n = p9_client_write(fid, NULL, data+total, origin+total, count);
  417. if (n <= 0)
  418. break;
  419. count -= n;
  420. total += n;
  421. } while (count > 0);
  422. if (invalidate && (total > 0)) {
  423. pg_start = origin >> PAGE_CACHE_SHIFT;
  424. pg_end = (origin + total - 1) >> PAGE_CACHE_SHIFT;
  425. if (inode->i_mapping && inode->i_mapping->nrpages)
  426. invalidate_inode_pages2_range(inode->i_mapping,
  427. pg_start, pg_end);
  428. *offset += total;
  429. i_size = i_size_read(inode);
  430. if (*offset > i_size) {
  431. inode_add_bytes(inode, *offset - i_size);
  432. i_size_write(inode, *offset);
  433. }
  434. }
  435. if (n < 0)
  436. return n;
  437. return total;
  438. }
  439. /**
  440. * v9fs_file_write - write to a file
  441. * @filp: file pointer to write
  442. * @data: data buffer to write data from
  443. * @count: size of buffer
  444. * @offset: offset at which to write data
  445. *
  446. */
  447. static ssize_t
  448. v9fs_file_write(struct file *filp, const char __user * data,
  449. size_t count, loff_t *offset)
  450. {
  451. ssize_t retval = 0;
  452. loff_t origin = *offset;
  453. retval = generic_write_checks(filp, &origin, &count, 0);
  454. if (retval)
  455. goto out;
  456. retval = -EINVAL;
  457. if ((ssize_t) count < 0)
  458. goto out;
  459. retval = 0;
  460. if (!count)
  461. goto out;
  462. retval = v9fs_file_write_internal(file_inode(filp),
  463. filp->private_data,
  464. data, count, &origin, 1);
  465. /* update offset on successful write */
  466. if (retval > 0)
  467. *offset = origin;
  468. out:
  469. return retval;
  470. }
  471. static int v9fs_file_fsync(struct file *filp, loff_t start, loff_t end,
  472. int datasync)
  473. {
  474. struct p9_fid *fid;
  475. struct inode *inode = filp->f_mapping->host;
  476. struct p9_wstat wstat;
  477. int retval;
  478. retval = filemap_write_and_wait_range(inode->i_mapping, start, end);
  479. if (retval)
  480. return retval;
  481. mutex_lock(&inode->i_mutex);
  482. p9_debug(P9_DEBUG_VFS, "filp %p datasync %x\n", filp, datasync);
  483. fid = filp->private_data;
  484. v9fs_blank_wstat(&wstat);
  485. retval = p9_client_wstat(fid, &wstat);
  486. mutex_unlock(&inode->i_mutex);
  487. return retval;
  488. }
  489. int v9fs_file_fsync_dotl(struct file *filp, loff_t start, loff_t end,
  490. int datasync)
  491. {
  492. struct p9_fid *fid;
  493. struct inode *inode = filp->f_mapping->host;
  494. int retval;
  495. retval = filemap_write_and_wait_range(inode->i_mapping, start, end);
  496. if (retval)
  497. return retval;
  498. mutex_lock(&inode->i_mutex);
  499. p9_debug(P9_DEBUG_VFS, "filp %p datasync %x\n", filp, datasync);
  500. fid = filp->private_data;
  501. retval = p9_client_fsync(fid, datasync);
  502. mutex_unlock(&inode->i_mutex);
  503. return retval;
  504. }
  505. static int
  506. v9fs_file_mmap(struct file *filp, struct vm_area_struct *vma)
  507. {
  508. int retval;
  509. retval = generic_file_mmap(filp, vma);
  510. if (!retval)
  511. vma->vm_ops = &v9fs_file_vm_ops;
  512. return retval;
  513. }
  514. static int
  515. v9fs_mmap_file_mmap(struct file *filp, struct vm_area_struct *vma)
  516. {
  517. int retval;
  518. struct inode *inode;
  519. struct v9fs_inode *v9inode;
  520. struct p9_fid *fid;
  521. inode = file_inode(filp);
  522. v9inode = V9FS_I(inode);
  523. mutex_lock(&v9inode->v_mutex);
  524. if (!v9inode->writeback_fid &&
  525. (vma->vm_flags & VM_WRITE)) {
  526. /*
  527. * clone a fid and add it to writeback_fid
  528. * we do it during mmap instead of
  529. * page dirty time via write_begin/page_mkwrite
  530. * because we want write after unlink usecase
  531. * to work.
  532. */
  533. fid = v9fs_writeback_fid(filp->f_path.dentry);
  534. if (IS_ERR(fid)) {
  535. retval = PTR_ERR(fid);
  536. mutex_unlock(&v9inode->v_mutex);
  537. return retval;
  538. }
  539. v9inode->writeback_fid = (void *) fid;
  540. }
  541. mutex_unlock(&v9inode->v_mutex);
  542. retval = generic_file_mmap(filp, vma);
  543. if (!retval)
  544. vma->vm_ops = &v9fs_mmap_file_vm_ops;
  545. return retval;
  546. }
  547. static int
  548. v9fs_vm_page_mkwrite(struct vm_area_struct *vma, struct vm_fault *vmf)
  549. {
  550. struct v9fs_inode *v9inode;
  551. struct page *page = vmf->page;
  552. struct file *filp = vma->vm_file;
  553. struct inode *inode = file_inode(filp);
  554. p9_debug(P9_DEBUG_VFS, "page %p fid %lx\n",
  555. page, (unsigned long)filp->private_data);
  556. /* Update file times before taking page lock */
  557. file_update_time(filp);
  558. v9inode = V9FS_I(inode);
  559. /* make sure the cache has finished storing the page */
  560. v9fs_fscache_wait_on_page_write(inode, page);
  561. BUG_ON(!v9inode->writeback_fid);
  562. lock_page(page);
  563. if (page->mapping != inode->i_mapping)
  564. goto out_unlock;
  565. wait_for_stable_page(page);
  566. return VM_FAULT_LOCKED;
  567. out_unlock:
  568. unlock_page(page);
  569. return VM_FAULT_NOPAGE;
  570. }
  571. static ssize_t
  572. v9fs_direct_read(struct file *filp, char __user *udata, size_t count,
  573. loff_t *offsetp)
  574. {
  575. loff_t size, offset;
  576. struct inode *inode;
  577. struct address_space *mapping;
  578. offset = *offsetp;
  579. mapping = filp->f_mapping;
  580. inode = mapping->host;
  581. if (!count)
  582. return 0;
  583. size = i_size_read(inode);
  584. if (offset < size)
  585. filemap_write_and_wait_range(mapping, offset,
  586. offset + count - 1);
  587. return v9fs_file_read(filp, udata, count, offsetp);
  588. }
  589. /**
  590. * v9fs_cached_file_read - read from a file
  591. * @filp: file pointer to read
  592. * @udata: user data buffer to read data into
  593. * @count: size of buffer
  594. * @offset: offset at which to read data
  595. *
  596. */
  597. static ssize_t
  598. v9fs_cached_file_read(struct file *filp, char __user *data, size_t count,
  599. loff_t *offset)
  600. {
  601. if (filp->f_flags & O_DIRECT)
  602. return v9fs_direct_read(filp, data, count, offset);
  603. return do_sync_read(filp, data, count, offset);
  604. }
  605. /**
  606. * v9fs_mmap_file_read - read from a file
  607. * @filp: file pointer to read
  608. * @udata: user data buffer to read data into
  609. * @count: size of buffer
  610. * @offset: offset at which to read data
  611. *
  612. */
  613. static ssize_t
  614. v9fs_mmap_file_read(struct file *filp, char __user *data, size_t count,
  615. loff_t *offset)
  616. {
  617. /* TODO: Check if there are dirty pages */
  618. return v9fs_file_read(filp, data, count, offset);
  619. }
  620. static ssize_t
  621. v9fs_direct_write(struct file *filp, const char __user * data,
  622. size_t count, loff_t *offsetp)
  623. {
  624. loff_t offset;
  625. ssize_t retval;
  626. struct inode *inode;
  627. struct address_space *mapping;
  628. offset = *offsetp;
  629. mapping = filp->f_mapping;
  630. inode = mapping->host;
  631. if (!count)
  632. return 0;
  633. mutex_lock(&inode->i_mutex);
  634. retval = filemap_write_and_wait_range(mapping, offset,
  635. offset + count - 1);
  636. if (retval)
  637. goto err_out;
  638. /*
  639. * After a write we want buffered reads to be sure to go to disk to get
  640. * the new data. We invalidate clean cached page from the region we're
  641. * about to write. We do this *before* the write so that if we fail
  642. * here we fall back to buffered write
  643. */
  644. if (mapping->nrpages) {
  645. pgoff_t pg_start = offset >> PAGE_CACHE_SHIFT;
  646. pgoff_t pg_end = (offset + count - 1) >> PAGE_CACHE_SHIFT;
  647. retval = invalidate_inode_pages2_range(mapping,
  648. pg_start, pg_end);
  649. /*
  650. * If a page can not be invalidated, fall back
  651. * to buffered write.
  652. */
  653. if (retval) {
  654. if (retval == -EBUSY)
  655. goto buff_write;
  656. goto err_out;
  657. }
  658. }
  659. retval = v9fs_file_write(filp, data, count, offsetp);
  660. err_out:
  661. mutex_unlock(&inode->i_mutex);
  662. return retval;
  663. buff_write:
  664. mutex_unlock(&inode->i_mutex);
  665. return do_sync_write(filp, data, count, offsetp);
  666. }
  667. /**
  668. * v9fs_cached_file_write - write to a file
  669. * @filp: file pointer to write
  670. * @data: data buffer to write data from
  671. * @count: size of buffer
  672. * @offset: offset at which to write data
  673. *
  674. */
  675. static ssize_t
  676. v9fs_cached_file_write(struct file *filp, const char __user * data,
  677. size_t count, loff_t *offset)
  678. {
  679. if (filp->f_flags & O_DIRECT)
  680. return v9fs_direct_write(filp, data, count, offset);
  681. return do_sync_write(filp, data, count, offset);
  682. }
  683. /**
  684. * v9fs_mmap_file_write - write to a file
  685. * @filp: file pointer to write
  686. * @data: data buffer to write data from
  687. * @count: size of buffer
  688. * @offset: offset at which to write data
  689. *
  690. */
  691. static ssize_t
  692. v9fs_mmap_file_write(struct file *filp, const char __user *data,
  693. size_t count, loff_t *offset)
  694. {
  695. /*
  696. * TODO: invalidate mmaps on filp's inode between
  697. * offset and offset+count
  698. */
  699. return v9fs_file_write(filp, data, count, offset);
  700. }
  701. static void v9fs_mmap_vm_close(struct vm_area_struct *vma)
  702. {
  703. struct inode *inode;
  704. struct writeback_control wbc = {
  705. .nr_to_write = LONG_MAX,
  706. .sync_mode = WB_SYNC_ALL,
  707. .range_start = vma->vm_pgoff * PAGE_SIZE,
  708. /* absolute end, byte at end included */
  709. .range_end = vma->vm_pgoff * PAGE_SIZE +
  710. (vma->vm_end - vma->vm_start - 1),
  711. };
  712. p9_debug(P9_DEBUG_VFS, "9p VMA close, %p, flushing", vma);
  713. inode = file_inode(vma->vm_file);
  714. if (!mapping_cap_writeback_dirty(inode->i_mapping))
  715. wbc.nr_to_write = 0;
  716. might_sleep();
  717. sync_inode(inode, &wbc);
  718. }
  719. static const struct vm_operations_struct v9fs_file_vm_ops = {
  720. .fault = filemap_fault,
  721. .map_pages = filemap_map_pages,
  722. .page_mkwrite = v9fs_vm_page_mkwrite,
  723. .remap_pages = generic_file_remap_pages,
  724. };
  725. static const struct vm_operations_struct v9fs_mmap_file_vm_ops = {
  726. .close = v9fs_mmap_vm_close,
  727. .fault = filemap_fault,
  728. .map_pages = filemap_map_pages,
  729. .page_mkwrite = v9fs_vm_page_mkwrite,
  730. .remap_pages = generic_file_remap_pages,
  731. };
  732. const struct file_operations v9fs_cached_file_operations = {
  733. .llseek = generic_file_llseek,
  734. .read = v9fs_cached_file_read,
  735. .write = v9fs_cached_file_write,
  736. .aio_read = generic_file_aio_read,
  737. .aio_write = generic_file_aio_write,
  738. .open = v9fs_file_open,
  739. .release = v9fs_dir_release,
  740. .lock = v9fs_file_lock,
  741. .mmap = v9fs_file_mmap,
  742. .fsync = v9fs_file_fsync,
  743. };
  744. const struct file_operations v9fs_cached_file_operations_dotl = {
  745. .llseek = generic_file_llseek,
  746. .read = v9fs_cached_file_read,
  747. .write = v9fs_cached_file_write,
  748. .aio_read = generic_file_aio_read,
  749. .aio_write = generic_file_aio_write,
  750. .open = v9fs_file_open,
  751. .release = v9fs_dir_release,
  752. .lock = v9fs_file_lock_dotl,
  753. .flock = v9fs_file_flock_dotl,
  754. .mmap = v9fs_file_mmap,
  755. .fsync = v9fs_file_fsync_dotl,
  756. };
  757. const struct file_operations v9fs_file_operations = {
  758. .llseek = generic_file_llseek,
  759. .read = v9fs_file_read,
  760. .write = v9fs_file_write,
  761. .open = v9fs_file_open,
  762. .release = v9fs_dir_release,
  763. .lock = v9fs_file_lock,
  764. .mmap = generic_file_readonly_mmap,
  765. .fsync = v9fs_file_fsync,
  766. };
  767. const struct file_operations v9fs_file_operations_dotl = {
  768. .llseek = generic_file_llseek,
  769. .read = v9fs_file_read,
  770. .write = v9fs_file_write,
  771. .open = v9fs_file_open,
  772. .release = v9fs_dir_release,
  773. .lock = v9fs_file_lock_dotl,
  774. .flock = v9fs_file_flock_dotl,
  775. .mmap = generic_file_readonly_mmap,
  776. .fsync = v9fs_file_fsync_dotl,
  777. };
  778. const struct file_operations v9fs_mmap_file_operations = {
  779. .llseek = generic_file_llseek,
  780. .read = v9fs_mmap_file_read,
  781. .write = v9fs_mmap_file_write,
  782. .open = v9fs_file_open,
  783. .release = v9fs_dir_release,
  784. .lock = v9fs_file_lock,
  785. .mmap = v9fs_mmap_file_mmap,
  786. .fsync = v9fs_file_fsync,
  787. };
  788. const struct file_operations v9fs_mmap_file_operations_dotl = {
  789. .llseek = generic_file_llseek,
  790. .read = v9fs_mmap_file_read,
  791. .write = v9fs_mmap_file_write,
  792. .open = v9fs_file_open,
  793. .release = v9fs_dir_release,
  794. .lock = v9fs_file_lock_dotl,
  795. .flock = v9fs_file_flock_dotl,
  796. .mmap = v9fs_mmap_file_mmap,
  797. .fsync = v9fs_file_fsync_dotl,
  798. };