1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /* CacheFiles path walking and related routines
3 *
4 * Copyright (C) 2021 Red Hat, Inc. All Rights Reserved.
5 * Written by David Howells (dhowells@redhat.com)
6 */
7
8 #include <linux/fs.h>
9 #include <linux/namei.h>
10 #include "internal.h"
11
12 /*
13 * Mark the backing file as being a cache file if it's not already in use. The
14 * mark tells the culling request command that it's not allowed to cull the
15 * file or directory. The caller must hold the inode lock.
16 */
__cachefiles_mark_inode_in_use(struct cachefiles_object * object,struct inode * inode)17 static bool __cachefiles_mark_inode_in_use(struct cachefiles_object *object,
18 struct inode *inode)
19 {
20 bool can_use = false;
21
22 if (!(inode->i_flags & S_KERNEL_FILE)) {
23 inode->i_flags |= S_KERNEL_FILE;
24 trace_cachefiles_mark_active(object, inode);
25 can_use = true;
26 } else {
27 trace_cachefiles_mark_failed(object, inode);
28 }
29
30 return can_use;
31 }
32
cachefiles_mark_inode_in_use(struct cachefiles_object * object,struct inode * inode)33 static bool cachefiles_mark_inode_in_use(struct cachefiles_object *object,
34 struct inode *inode)
35 {
36 bool can_use;
37
38 inode_lock(inode);
39 can_use = __cachefiles_mark_inode_in_use(object, inode);
40 inode_unlock(inode);
41 return can_use;
42 }
43
44 /*
45 * Unmark a backing inode. The caller must hold the inode lock.
46 */
__cachefiles_unmark_inode_in_use(struct cachefiles_object * object,struct inode * inode)47 static void __cachefiles_unmark_inode_in_use(struct cachefiles_object *object,
48 struct inode *inode)
49 {
50 inode->i_flags &= ~S_KERNEL_FILE;
51 trace_cachefiles_mark_inactive(object, inode);
52 }
53
cachefiles_do_unmark_inode_in_use(struct cachefiles_object * object,struct inode * inode)54 static void cachefiles_do_unmark_inode_in_use(struct cachefiles_object *object,
55 struct inode *inode)
56 {
57 inode_lock(inode);
58 __cachefiles_unmark_inode_in_use(object, inode);
59 inode_unlock(inode);
60 }
61
62 /*
63 * Unmark a backing inode and tell cachefilesd that there's something that can
64 * be culled.
65 */
cachefiles_unmark_inode_in_use(struct cachefiles_object * object,struct file * file)66 void cachefiles_unmark_inode_in_use(struct cachefiles_object *object,
67 struct file *file)
68 {
69 struct cachefiles_cache *cache = object->volume->cache;
70 struct inode *inode = file_inode(file);
71
72 cachefiles_do_unmark_inode_in_use(object, inode);
73
74 if (!test_bit(CACHEFILES_OBJECT_USING_TMPFILE, &object->flags)) {
75 atomic_long_add(inode->i_blocks, &cache->b_released);
76 if (atomic_inc_return(&cache->f_released))
77 cachefiles_state_changed(cache);
78 }
79 }
80
81 /*
82 * get a subdirectory
83 */
cachefiles_get_directory(struct cachefiles_cache * cache,struct dentry * dir,const char * dirname,bool * _is_new)84 struct dentry *cachefiles_get_directory(struct cachefiles_cache *cache,
85 struct dentry *dir,
86 const char *dirname,
87 bool *_is_new)
88 {
89 struct dentry *subdir;
90 struct path path;
91 int ret;
92
93 _enter(",,%s", dirname);
94
95 /* search the current directory for the element name */
96
97 retry:
98 ret = cachefiles_inject_read_error();
99 if (ret == 0)
100 subdir = start_creating(&nop_mnt_idmap, dir, &QSTR(dirname));
101 else
102 subdir = ERR_PTR(ret);
103 trace_cachefiles_lookup(NULL, dir, subdir);
104 if (IS_ERR(subdir)) {
105 trace_cachefiles_vfs_error(NULL, d_backing_inode(dir),
106 PTR_ERR(subdir),
107 cachefiles_trace_lookup_error);
108 if (PTR_ERR(subdir) == -ENOMEM)
109 goto nomem_d_alloc;
110 goto lookup_error;
111 }
112
113 _debug("subdir -> %pd %s",
114 subdir, d_backing_inode(subdir) ? "positive" : "negative");
115
116 /* we need to create the subdir if it doesn't exist yet */
117 if (d_is_negative(subdir)) {
118 ret = cachefiles_has_space(cache, 1, 0,
119 cachefiles_has_space_for_create);
120 if (ret < 0)
121 goto mkdir_error;
122
123 _debug("attempt mkdir");
124
125 path.mnt = cache->mnt;
126 path.dentry = dir;
127 ret = security_path_mkdir(&path, subdir, 0700);
128 if (ret < 0)
129 goto mkdir_error;
130 ret = cachefiles_inject_write_error();
131 if (ret == 0) {
132 subdir = vfs_mkdir(&nop_mnt_idmap, d_inode(dir), subdir, 0700, NULL);
133 if (IS_ERR(subdir))
134 ret = PTR_ERR(subdir);
135 } else {
136 end_creating(subdir);
137 subdir = ERR_PTR(ret);
138 }
139 if (IS_ERR(subdir)) {
140 trace_cachefiles_vfs_error(NULL, d_inode(dir), ret,
141 cachefiles_trace_mkdir_error);
142 goto mkdir_error;
143 }
144 trace_cachefiles_mkdir(dir, subdir);
145
146 if (unlikely(d_unhashed(subdir) || d_is_negative(subdir))) {
147 end_creating(subdir);
148 goto retry;
149 }
150 ASSERT(d_backing_inode(subdir));
151
152 _debug("mkdir -> %pd{ino=%llu}",
153 subdir, d_backing_inode(subdir)->i_ino);
154 if (_is_new)
155 *_is_new = true;
156 }
157
158 /* Tell rmdir() it's not allowed to delete the subdir */
159 inode_lock(d_inode(subdir));
160 end_creating_keep(subdir);
161
162 if (!__cachefiles_mark_inode_in_use(NULL, d_inode(subdir))) {
163 pr_notice("cachefiles: Inode already in use: %pd (B=%llx)\n",
164 subdir, d_inode(subdir)->i_ino);
165 goto mark_error;
166 }
167
168 inode_unlock(d_inode(subdir));
169
170 /* we need to make sure the subdir is a directory */
171 ASSERT(d_backing_inode(subdir));
172
173 if (!d_can_lookup(subdir)) {
174 pr_err("%s is not a directory\n", dirname);
175 ret = -EIO;
176 goto check_error;
177 }
178
179 ret = -EPERM;
180 if (!(d_backing_inode(subdir)->i_opflags & IOP_XATTR) ||
181 !d_backing_inode(subdir)->i_op->lookup ||
182 !d_backing_inode(subdir)->i_op->mkdir ||
183 !d_backing_inode(subdir)->i_op->rename ||
184 !d_backing_inode(subdir)->i_op->rmdir ||
185 !d_backing_inode(subdir)->i_op->unlink)
186 goto check_error;
187
188 _leave(" = [%llu]", d_backing_inode(subdir)->i_ino);
189 return subdir;
190
191 check_error:
192 cachefiles_put_directory(subdir);
193 _leave(" = %d [check]", ret);
194 return ERR_PTR(ret);
195
196 mark_error:
197 inode_unlock(d_inode(subdir));
198 dput(subdir);
199 return ERR_PTR(-EBUSY);
200
201 mkdir_error:
202 end_creating(subdir);
203 pr_err("mkdir %s failed with error %d\n", dirname, ret);
204 return ERR_PTR(ret);
205
206 lookup_error:
207 ret = PTR_ERR(subdir);
208 pr_err("Lookup %s failed with error %d\n", dirname, ret);
209 return ERR_PTR(ret);
210
211 nomem_d_alloc:
212 _leave(" = -ENOMEM");
213 return ERR_PTR(-ENOMEM);
214 }
215
216 /*
217 * Put a subdirectory.
218 */
cachefiles_put_directory(struct dentry * dir)219 void cachefiles_put_directory(struct dentry *dir)
220 {
221 if (dir) {
222 cachefiles_do_unmark_inode_in_use(NULL, d_inode(dir));
223 dput(dir);
224 }
225 }
226
227 /*
228 * Remove a regular file from the cache.
229 */
cachefiles_unlink(struct cachefiles_cache * cache,struct cachefiles_object * object,struct dentry * dir,struct dentry * dentry,enum fscache_why_object_killed why)230 static int cachefiles_unlink(struct cachefiles_cache *cache,
231 struct cachefiles_object *object,
232 struct dentry *dir, struct dentry *dentry,
233 enum fscache_why_object_killed why)
234 {
235 struct path path = {
236 .mnt = cache->mnt,
237 .dentry = dir,
238 };
239 int ret;
240
241 trace_cachefiles_unlink(object, d_inode(dentry)->i_ino, why);
242 ret = security_path_unlink(&path, dentry);
243 if (ret < 0) {
244 cachefiles_io_error(cache, "Unlink security error");
245 return ret;
246 }
247
248 ret = cachefiles_inject_remove_error();
249 if (ret == 0) {
250 ret = vfs_unlink(&nop_mnt_idmap, d_backing_inode(dir), dentry, NULL);
251 if (ret == -EIO)
252 cachefiles_io_error(cache, "Unlink failed");
253 }
254 if (ret != 0)
255 trace_cachefiles_vfs_error(object, d_backing_inode(dir), ret,
256 cachefiles_trace_unlink_error);
257 return ret;
258 }
259
260 /*
261 * Delete an object representation from the cache
262 * - File backed objects are unlinked
263 * - Directory backed objects are stuffed into the graveyard for userspace to
264 * delete
265 * On entry dir must be locked. It will be unlocked on exit.
266 * On entry there must be at least 2 refs on rep, one will be dropped on exit.
267 */
cachefiles_bury_object(struct cachefiles_cache * cache,struct cachefiles_object * object,struct dentry * dir,struct dentry * rep,enum fscache_why_object_killed why)268 int cachefiles_bury_object(struct cachefiles_cache *cache,
269 struct cachefiles_object *object,
270 struct dentry *dir,
271 struct dentry *rep,
272 enum fscache_why_object_killed why)
273 {
274 struct dentry *grave;
275 struct renamedata rd = {};
276 struct path path, path_to_graveyard;
277 char nbuffer[8 + 8 + 1];
278 int ret;
279
280 _enter(",'%pd','%pd'", dir, rep);
281
282 if (rep->d_parent != dir) {
283 end_removing(rep);
284 _leave(" = -ESTALE");
285 return -ESTALE;
286 }
287
288 /* non-directories can just be unlinked */
289 if (!d_is_dir(rep)) {
290 ret = cachefiles_unlink(cache, object, dir, rep, why);
291 end_removing(rep);
292
293 _leave(" = %d", ret);
294 return ret;
295 }
296
297 /* directories have to be moved to the graveyard */
298 _debug("move stale object to graveyard");
299 end_removing(rep);
300
301 try_again:
302 /* first step is to make up a grave dentry in the graveyard */
303 sprintf(nbuffer, "%08x%08x",
304 (uint32_t) ktime_get_real_seconds(),
305 (uint32_t) atomic_inc_return(&cache->gravecounter));
306
307 rd.mnt_idmap = &nop_mnt_idmap;
308 rd.old_parent = dir;
309 rd.new_parent = cache->graveyard;
310 rd.flags = 0;
311 ret = start_renaming_dentry(&rd, 0, rep, &QSTR(nbuffer));
312 if (ret) {
313 /* Some errors aren't fatal */
314 if (ret == -EXDEV)
315 /* double-lock failed */
316 return ret;
317 if (d_unhashed(rep) || rep->d_parent != dir || IS_DEADDIR(d_inode(rep))) {
318 /* the entry was probably culled when we dropped the parent dir
319 * lock */
320 _leave(" = 0 [culled?]");
321 return 0;
322 }
323 if (ret == -EINVAL || ret == -ENOTEMPTY) {
324 cachefiles_io_error(cache, "May not make directory loop");
325 return -EIO;
326 }
327 if (ret == -ENOMEM) {
328 _leave(" = -ENOMEM");
329 return -ENOMEM;
330 }
331
332 cachefiles_io_error(cache, "Lookup error %d", ret);
333 return -EIO;
334 }
335
336 if (d_mountpoint(rep)) {
337 end_renaming(&rd);
338 cachefiles_io_error(cache, "Mountpoint in cache");
339 return -EIO;
340 }
341
342 grave = rd.new_dentry;
343 if (d_is_positive(grave)) {
344 end_renaming(&rd);
345 grave = NULL;
346 cond_resched();
347 goto try_again;
348 }
349
350 if (d_mountpoint(grave)) {
351 end_renaming(&rd);
352 cachefiles_io_error(cache, "Mountpoint in graveyard");
353 return -EIO;
354 }
355
356 /* attempt the rename */
357 path.mnt = cache->mnt;
358 path.dentry = dir;
359 path_to_graveyard.mnt = cache->mnt;
360 path_to_graveyard.dentry = cache->graveyard;
361 ret = security_path_rename(&path, rep, &path_to_graveyard, grave, 0);
362 if (ret < 0) {
363 cachefiles_io_error(cache, "Rename security error %d", ret);
364 } else {
365 trace_cachefiles_rename(object, d_inode(rep)->i_ino, why);
366 ret = cachefiles_inject_read_error();
367 if (ret == 0)
368 ret = vfs_rename(&rd);
369 if (ret != 0)
370 trace_cachefiles_vfs_error(object, d_inode(dir), ret,
371 cachefiles_trace_rename_error);
372 if (ret != 0 && ret != -ENOMEM)
373 cachefiles_io_error(cache,
374 "Rename failed with error %d", ret);
375 }
376
377 cachefiles_do_unmark_inode_in_use(object, d_inode(rep));
378 end_renaming(&rd);
379 _leave(" = 0");
380 return 0;
381 }
382
383 /*
384 * Delete a cache file.
385 */
cachefiles_delete_object(struct cachefiles_object * object,enum fscache_why_object_killed why)386 int cachefiles_delete_object(struct cachefiles_object *object,
387 enum fscache_why_object_killed why)
388 {
389 struct cachefiles_volume *volume = object->volume;
390 struct dentry *dentry = object->file->f_path.dentry;
391 struct dentry *fan = volume->fanout[(u8)object->cookie->key_hash];
392 int ret;
393
394 _enter(",OBJ%x{%pD}", object->debug_id, object->file);
395
396 dentry = start_removing_dentry(fan, dentry);
397 if (IS_ERR(dentry))
398 ret = PTR_ERR(dentry);
399 else
400 ret = cachefiles_unlink(volume->cache, object, fan, dentry, why);
401 end_removing(dentry);
402 return ret;
403 }
404
405 /*
406 * Create a temporary file and leave it unattached and un-xattr'd until the
407 * time comes to discard the object from memory.
408 */
cachefiles_create_tmpfile(struct cachefiles_object * object)409 struct file *cachefiles_create_tmpfile(struct cachefiles_object *object)
410 {
411 struct cachefiles_volume *volume = object->volume;
412 struct cachefiles_cache *cache = volume->cache;
413 const struct cred *saved_cred;
414 struct dentry *fan = volume->fanout[(u8)object->cookie->key_hash];
415 struct file *file;
416 const struct path parentpath = { .mnt = cache->mnt, .dentry = fan };
417 uint64_t ni_size;
418 long ret;
419
420
421 cachefiles_begin_secure(cache, &saved_cred);
422
423 ret = cachefiles_inject_write_error();
424 if (ret == 0) {
425 file = kernel_tmpfile_open(&nop_mnt_idmap, &parentpath,
426 S_IFREG | 0600,
427 O_RDWR | O_LARGEFILE | O_DIRECT,
428 cache->cache_cred);
429 ret = PTR_ERR_OR_ZERO(file);
430 }
431 if (ret) {
432 trace_cachefiles_vfs_error(object, d_inode(fan), ret,
433 cachefiles_trace_tmpfile_error);
434 if (ret == -EIO)
435 cachefiles_io_error_obj(object, "Failed to create tmpfile");
436 goto err;
437 }
438
439 trace_cachefiles_tmpfile(object, file_inode(file));
440
441 /* This is a newly created file with no other possible user */
442 if (!cachefiles_mark_inode_in_use(object, file_inode(file)))
443 WARN_ON(1);
444
445 ni_size = object->cookie->object_size;
446 ni_size = round_up(ni_size, CACHEFILES_DIO_BLOCK_SIZE);
447
448 if (ni_size > 0) {
449 trace_cachefiles_trunc(object, file_inode(file), 0, ni_size,
450 cachefiles_trunc_expand_tmpfile);
451 ret = cachefiles_inject_write_error();
452 if (ret == 0)
453 ret = vfs_truncate(&file->f_path, ni_size);
454 if (ret < 0) {
455 trace_cachefiles_vfs_error(
456 object, file_inode(file), ret,
457 cachefiles_trace_trunc_error);
458 goto err_unuse;
459 }
460 }
461
462 ret = -EINVAL;
463 if (unlikely(!file->f_op->read_iter) ||
464 unlikely(!file->f_op->write_iter)) {
465 pr_notice("Cache does not support read_iter and write_iter\n");
466 goto err_unuse;
467 }
468 out:
469 cachefiles_end_secure(cache, saved_cred);
470 return file;
471
472 err_unuse:
473 cachefiles_do_unmark_inode_in_use(object, file_inode(file));
474 fput(file);
475 err:
476 file = ERR_PTR(ret);
477 goto out;
478 }
479
480 /*
481 * Create a new file.
482 */
cachefiles_create_file(struct cachefiles_object * object)483 static bool cachefiles_create_file(struct cachefiles_object *object)
484 {
485 struct file *file;
486 int ret;
487
488 ret = cachefiles_has_space(object->volume->cache, 1, 0,
489 cachefiles_has_space_for_create);
490 if (ret < 0)
491 return false;
492
493 file = cachefiles_create_tmpfile(object);
494 if (IS_ERR(file))
495 return false;
496
497 set_bit(FSCACHE_COOKIE_NEEDS_UPDATE, &object->cookie->flags);
498 set_bit(CACHEFILES_OBJECT_USING_TMPFILE, &object->flags);
499 _debug("create -> %pD{ino=%llu}", file, file_inode(file)->i_ino);
500 object->file = file;
501 return true;
502 }
503
504 /*
505 * Open an existing file, checking its attributes and replacing it if it is
506 * stale.
507 */
cachefiles_open_file(struct cachefiles_object * object,struct dentry * dentry)508 static bool cachefiles_open_file(struct cachefiles_object *object,
509 struct dentry *dentry)
510 {
511 struct cachefiles_cache *cache = object->volume->cache;
512 struct file *file;
513 struct path path;
514 int ret;
515
516 _enter("%pd", dentry);
517
518 if (!cachefiles_mark_inode_in_use(object, d_inode(dentry))) {
519 pr_notice("cachefiles: Inode already in use: %pd (B=%llx)\n",
520 dentry, d_inode(dentry)->i_ino);
521 return false;
522 }
523
524 /* We need to open a file interface onto a data file now as we can't do
525 * it on demand because writeback called from do_exit() sees
526 * current->fs == NULL - which breaks d_path() called from ext4 open.
527 */
528 path.mnt = cache->mnt;
529 path.dentry = dentry;
530 file = kernel_file_open(&path, O_RDWR | O_LARGEFILE | O_DIRECT, cache->cache_cred);
531 if (IS_ERR(file)) {
532 trace_cachefiles_vfs_error(object, d_backing_inode(dentry),
533 PTR_ERR(file),
534 cachefiles_trace_open_error);
535 goto error;
536 }
537
538 if (unlikely(!file->f_op->read_iter) ||
539 unlikely(!file->f_op->write_iter)) {
540 pr_notice("Cache does not support read_iter and write_iter\n");
541 goto error_fput;
542 }
543 _debug("file -> %pd positive", dentry);
544
545 ret = cachefiles_check_auxdata(object, file);
546 if (ret < 0)
547 goto check_failed;
548
549 clear_bit(FSCACHE_COOKIE_NO_DATA_TO_READ, &object->cookie->flags);
550
551 object->file = file;
552
553 /* Always update the atime on an object we've just looked up (this is
554 * used to keep track of culling, and atimes are only updated by read,
555 * write and readdir but not lookup or open).
556 */
557 touch_atime(&file->f_path);
558 return true;
559
560 check_failed:
561 fscache_cookie_lookup_negative(object->cookie);
562 cachefiles_unmark_inode_in_use(object, file);
563 fput(file);
564 if (ret == -ESTALE)
565 return cachefiles_create_file(object);
566 return false;
567
568 error_fput:
569 fput(file);
570 error:
571 cachefiles_do_unmark_inode_in_use(object, d_inode(dentry));
572 return false;
573 }
574
575 /*
576 * walk from the parent object to the child object through the backing
577 * filesystem, creating directories as we go
578 */
cachefiles_look_up_object(struct cachefiles_object * object)579 bool cachefiles_look_up_object(struct cachefiles_object *object)
580 {
581 struct cachefiles_volume *volume = object->volume;
582 struct dentry *dentry, *fan = volume->fanout[(u8)object->cookie->key_hash];
583 int ret;
584
585 _enter("OBJ%x,%s,", object->debug_id, object->d_name);
586
587 /* Look up path "cache/vol/fanout/file". */
588 ret = cachefiles_inject_read_error();
589 if (ret == 0)
590 dentry = lookup_one_positive_unlocked(&nop_mnt_idmap,
591 &QSTR(object->d_name), fan);
592 else
593 dentry = ERR_PTR(ret);
594 trace_cachefiles_lookup(object, fan, dentry);
595 if (IS_ERR(dentry)) {
596 if (dentry == ERR_PTR(-ENOENT))
597 goto new_file;
598 if (dentry == ERR_PTR(-EIO))
599 cachefiles_io_error_obj(object, "Lookup failed");
600 return false;
601 }
602
603 if (!d_is_reg(dentry)) {
604 pr_err("%pd is not a file\n", dentry);
605 struct dentry *de = start_removing_dentry(fan, dentry);
606 if (IS_ERR(de))
607 ret = PTR_ERR(de);
608 else
609 ret = cachefiles_bury_object(volume->cache, object,
610 fan, de,
611 FSCACHE_OBJECT_IS_WEIRD);
612 dput(dentry);
613 if (ret < 0)
614 return false;
615 goto new_file;
616 }
617
618 ret = cachefiles_open_file(object, dentry);
619 dput(dentry);
620 if (!ret)
621 return false;
622
623 _leave(" = t [%llu]", file_inode(object->file)->i_ino);
624 return true;
625
626 new_file:
627 fscache_cookie_lookup_negative(object->cookie);
628 return cachefiles_create_file(object);
629 }
630
631 /*
632 * Attempt to link a temporary file into its rightful place in the cache.
633 */
cachefiles_commit_tmpfile(struct cachefiles_cache * cache,struct cachefiles_object * object)634 bool cachefiles_commit_tmpfile(struct cachefiles_cache *cache,
635 struct cachefiles_object *object)
636 {
637 struct cachefiles_volume *volume = object->volume;
638 struct dentry *dentry, *fan = volume->fanout[(u8)object->cookie->key_hash];
639 bool success = false;
640 int ret;
641
642 _enter(",%pD", object->file);
643
644 ret = cachefiles_inject_read_error();
645 if (ret == 0)
646 dentry = start_creating(&nop_mnt_idmap, fan, &QSTR(object->d_name));
647 else
648 dentry = ERR_PTR(ret);
649 if (IS_ERR(dentry)) {
650 trace_cachefiles_vfs_error(object, d_inode(fan), PTR_ERR(dentry),
651 cachefiles_trace_lookup_error);
652 _debug("lookup fail %ld", PTR_ERR(dentry));
653 goto out;
654 }
655
656 /*
657 * This loop will only execute more than once if some other thread
658 * races to create the object we are trying to create.
659 */
660 while (!d_is_negative(dentry)) {
661 ret = cachefiles_unlink(volume->cache, object, fan, dentry,
662 FSCACHE_OBJECT_IS_STALE);
663 if (ret < 0)
664 goto out_end;
665
666 end_creating(dentry);
667
668 ret = cachefiles_inject_read_error();
669 if (ret == 0)
670 dentry = start_creating(&nop_mnt_idmap, fan,
671 &QSTR(object->d_name));
672 else
673 dentry = ERR_PTR(ret);
674 if (IS_ERR(dentry)) {
675 trace_cachefiles_vfs_error(object, d_inode(fan), PTR_ERR(dentry),
676 cachefiles_trace_lookup_error);
677 _debug("lookup fail %ld", PTR_ERR(dentry));
678 goto out;
679 }
680 }
681
682 ret = cachefiles_inject_read_error();
683 if (ret == 0)
684 ret = vfs_link(object->file->f_path.dentry, &nop_mnt_idmap,
685 d_inode(fan), dentry, NULL);
686 if (ret < 0) {
687 trace_cachefiles_vfs_error(object, d_inode(fan), ret,
688 cachefiles_trace_link_error);
689 _debug("link fail %d", ret);
690 } else {
691 trace_cachefiles_link(object, file_inode(object->file));
692 spin_lock(&object->lock);
693 /* TODO: Do we want to switch the file pointer to the new dentry? */
694 clear_bit(CACHEFILES_OBJECT_USING_TMPFILE, &object->flags);
695 spin_unlock(&object->lock);
696 success = true;
697 }
698
699 out_end:
700 end_creating(dentry);
701 out:
702 _leave(" = %u", success);
703 return success;
704 }
705
706 /*
707 * Look up an inode to be checked or culled. Return -EBUSY if the inode is
708 * marked in use.
709 */
cachefiles_lookup_for_cull(struct cachefiles_cache * cache,struct dentry * dir,char * filename)710 static struct dentry *cachefiles_lookup_for_cull(struct cachefiles_cache *cache,
711 struct dentry *dir,
712 char *filename)
713 {
714 struct dentry *victim;
715 int ret = -ENOENT;
716
717 victim = start_removing(&nop_mnt_idmap, dir, &QSTR(filename));
718
719 if (IS_ERR(victim))
720 goto lookup_error;
721 if (d_inode(victim)->i_flags & S_KERNEL_FILE)
722 goto lookup_busy;
723 return victim;
724
725 lookup_busy:
726 ret = -EBUSY;
727 end_removing(victim);
728 return ERR_PTR(ret);
729
730 lookup_error:
731 ret = PTR_ERR(victim);
732 if (ret == -ENOENT)
733 return ERR_PTR(-ESTALE); /* Probably got retired by the netfs */
734
735 if (ret == -EIO) {
736 cachefiles_io_error(cache, "Lookup failed");
737 } else if (ret != -ENOMEM) {
738 pr_err("Internal error: %d\n", ret);
739 ret = -EIO;
740 }
741
742 return ERR_PTR(ret);
743 }
744
745 /*
746 * Cull an object if it's not in use
747 * - called only by cache manager daemon
748 */
cachefiles_cull(struct cachefiles_cache * cache,struct dentry * dir,char * filename)749 int cachefiles_cull(struct cachefiles_cache *cache, struct dentry *dir,
750 char *filename)
751 {
752 struct dentry *victim;
753 struct inode *inode;
754 int ret;
755
756 _enter(",%pd/,%s", dir, filename);
757
758 victim = cachefiles_lookup_for_cull(cache, dir, filename);
759 if (IS_ERR(victim))
760 return PTR_ERR(victim);
761
762 /* check to see if someone is using this object */
763 inode = d_inode(victim);
764 inode_lock(inode);
765 if (inode->i_flags & S_KERNEL_FILE) {
766 ret = -EBUSY;
767 } else {
768 /* Stop the cache from picking it back up */
769 inode->i_flags |= S_KERNEL_FILE;
770 ret = 0;
771 }
772 inode_unlock(inode);
773 if (ret < 0)
774 goto error_unlock;
775
776 /*
777 * cachefiles_bury_object() expects 2 references to 'victim',
778 * and drops one.
779 */
780 dget(victim);
781 ret = cachefiles_bury_object(cache, NULL, dir, victim,
782 FSCACHE_OBJECT_WAS_CULLED);
783 dput(victim);
784 if (ret < 0)
785 goto error;
786
787 fscache_count_culled();
788 _leave(" = 0");
789 return 0;
790
791 error_unlock:
792 end_removing(victim);
793 error:
794 if (ret == -ENOENT)
795 return -ESTALE; /* Probably got retired by the netfs */
796
797 if (ret != -ENOMEM) {
798 pr_err("Internal error: %d\n", ret);
799 ret = -EIO;
800 }
801
802 _leave(" = %d", ret);
803 return ret;
804 }
805
806 /*
807 * Find out if an object is in use or not
808 * - called only by cache manager daemon
809 * - returns -EBUSY or 0 to indicate whether an object is in use or not
810 */
cachefiles_check_in_use(struct cachefiles_cache * cache,struct dentry * dir,char * filename)811 int cachefiles_check_in_use(struct cachefiles_cache *cache, struct dentry *dir,
812 char *filename)
813 {
814 struct dentry *victim;
815 int ret = 0;
816
817 victim = cachefiles_lookup_for_cull(cache, dir, filename);
818 if (IS_ERR(victim))
819 return PTR_ERR(victim);
820
821 inode_unlock(d_inode(dir));
822 dput(victim);
823 return ret;
824 }
825