xref: /linux/fs/cachefiles/namei.c (revision 26ba30221c03364d6ed9910be8da4c1fd871b07b)
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  */
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 
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  */
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 
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  */
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  */
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  */
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  */
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  */
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  */
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  */
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 	ret = cachefiles_ondemand_init_object(object);
446 	if (ret < 0)
447 		goto err_unuse;
448 
449 	ni_size = object->cookie->object_size;
450 	ni_size = round_up(ni_size, CACHEFILES_DIO_BLOCK_SIZE);
451 
452 	if (ni_size > 0) {
453 		trace_cachefiles_trunc(object, file_inode(file), 0, ni_size,
454 				       cachefiles_trunc_expand_tmpfile);
455 		ret = cachefiles_inject_write_error();
456 		if (ret == 0)
457 			ret = vfs_truncate(&file->f_path, ni_size);
458 		if (ret < 0) {
459 			trace_cachefiles_vfs_error(
460 				object, file_inode(file), ret,
461 				cachefiles_trace_trunc_error);
462 			goto err_unuse;
463 		}
464 	}
465 
466 	ret = -EINVAL;
467 	if (unlikely(!file->f_op->read_iter) ||
468 	    unlikely(!file->f_op->write_iter)) {
469 		pr_notice("Cache does not support read_iter and write_iter\n");
470 		goto err_unuse;
471 	}
472 out:
473 	cachefiles_end_secure(cache, saved_cred);
474 	return file;
475 
476 err_unuse:
477 	cachefiles_do_unmark_inode_in_use(object, file_inode(file));
478 	fput(file);
479 err:
480 	file = ERR_PTR(ret);
481 	goto out;
482 }
483 
484 /*
485  * Create a new file.
486  */
487 static bool cachefiles_create_file(struct cachefiles_object *object)
488 {
489 	struct file *file;
490 	int ret;
491 
492 	ret = cachefiles_has_space(object->volume->cache, 1, 0,
493 				   cachefiles_has_space_for_create);
494 	if (ret < 0)
495 		return false;
496 
497 	file = cachefiles_create_tmpfile(object);
498 	if (IS_ERR(file))
499 		return false;
500 
501 	set_bit(FSCACHE_COOKIE_NEEDS_UPDATE, &object->cookie->flags);
502 	set_bit(CACHEFILES_OBJECT_USING_TMPFILE, &object->flags);
503 	_debug("create -> %pD{ino=%llu}", file, file_inode(file)->i_ino);
504 	object->file = file;
505 	return true;
506 }
507 
508 /*
509  * Open an existing file, checking its attributes and replacing it if it is
510  * stale.
511  */
512 static bool cachefiles_open_file(struct cachefiles_object *object,
513 				 struct dentry *dentry)
514 {
515 	struct cachefiles_cache *cache = object->volume->cache;
516 	struct file *file;
517 	struct path path;
518 	int ret;
519 
520 	_enter("%pd", dentry);
521 
522 	if (!cachefiles_mark_inode_in_use(object, d_inode(dentry))) {
523 		pr_notice("cachefiles: Inode already in use: %pd (B=%llx)\n",
524 			  dentry, d_inode(dentry)->i_ino);
525 		return false;
526 	}
527 
528 	/* We need to open a file interface onto a data file now as we can't do
529 	 * it on demand because writeback called from do_exit() sees
530 	 * current->fs == NULL - which breaks d_path() called from ext4 open.
531 	 */
532 	path.mnt = cache->mnt;
533 	path.dentry = dentry;
534 	file = kernel_file_open(&path, O_RDWR | O_LARGEFILE | O_DIRECT, cache->cache_cred);
535 	if (IS_ERR(file)) {
536 		trace_cachefiles_vfs_error(object, d_backing_inode(dentry),
537 					   PTR_ERR(file),
538 					   cachefiles_trace_open_error);
539 		goto error;
540 	}
541 
542 	if (unlikely(!file->f_op->read_iter) ||
543 	    unlikely(!file->f_op->write_iter)) {
544 		pr_notice("Cache does not support read_iter and write_iter\n");
545 		goto error_fput;
546 	}
547 	_debug("file -> %pd positive", dentry);
548 
549 	ret = cachefiles_ondemand_init_object(object);
550 	if (ret < 0)
551 		goto error_fput;
552 
553 	ret = cachefiles_check_auxdata(object, file);
554 	if (ret < 0)
555 		goto check_failed;
556 
557 	clear_bit(FSCACHE_COOKIE_NO_DATA_TO_READ, &object->cookie->flags);
558 
559 	object->file = file;
560 
561 	/* Always update the atime on an object we've just looked up (this is
562 	 * used to keep track of culling, and atimes are only updated by read,
563 	 * write and readdir but not lookup or open).
564 	 */
565 	touch_atime(&file->f_path);
566 	return true;
567 
568 check_failed:
569 	fscache_cookie_lookup_negative(object->cookie);
570 	cachefiles_unmark_inode_in_use(object, file);
571 	fput(file);
572 	if (ret == -ESTALE)
573 		return cachefiles_create_file(object);
574 	return false;
575 
576 error_fput:
577 	fput(file);
578 error:
579 	cachefiles_do_unmark_inode_in_use(object, d_inode(dentry));
580 	return false;
581 }
582 
583 /*
584  * walk from the parent object to the child object through the backing
585  * filesystem, creating directories as we go
586  */
587 bool cachefiles_look_up_object(struct cachefiles_object *object)
588 {
589 	struct cachefiles_volume *volume = object->volume;
590 	struct dentry *dentry, *fan = volume->fanout[(u8)object->cookie->key_hash];
591 	int ret;
592 
593 	_enter("OBJ%x,%s,", object->debug_id, object->d_name);
594 
595 	/* Look up path "cache/vol/fanout/file". */
596 	ret = cachefiles_inject_read_error();
597 	if (ret == 0)
598 		dentry = lookup_one_positive_unlocked(&nop_mnt_idmap,
599 						      &QSTR(object->d_name), fan);
600 	else
601 		dentry = ERR_PTR(ret);
602 	trace_cachefiles_lookup(object, fan, dentry);
603 	if (IS_ERR(dentry)) {
604 		if (dentry == ERR_PTR(-ENOENT))
605 			goto new_file;
606 		if (dentry == ERR_PTR(-EIO))
607 			cachefiles_io_error_obj(object, "Lookup failed");
608 		return false;
609 	}
610 
611 	if (!d_is_reg(dentry)) {
612 		pr_err("%pd is not a file\n", dentry);
613 		struct dentry *de = start_removing_dentry(fan, dentry);
614 		if (IS_ERR(de))
615 			ret = PTR_ERR(de);
616 		else
617 			ret = cachefiles_bury_object(volume->cache, object,
618 						     fan, de,
619 						     FSCACHE_OBJECT_IS_WEIRD);
620 		dput(dentry);
621 		if (ret < 0)
622 			return false;
623 		goto new_file;
624 	}
625 
626 	ret = cachefiles_open_file(object, dentry);
627 	dput(dentry);
628 	if (!ret)
629 		return false;
630 
631 	_leave(" = t [%llu]", file_inode(object->file)->i_ino);
632 	return true;
633 
634 new_file:
635 	fscache_cookie_lookup_negative(object->cookie);
636 	return cachefiles_create_file(object);
637 }
638 
639 /*
640  * Attempt to link a temporary file into its rightful place in the cache.
641  */
642 bool cachefiles_commit_tmpfile(struct cachefiles_cache *cache,
643 			       struct cachefiles_object *object)
644 {
645 	struct cachefiles_volume *volume = object->volume;
646 	struct dentry *dentry, *fan = volume->fanout[(u8)object->cookie->key_hash];
647 	bool success = false;
648 	int ret;
649 
650 	_enter(",%pD", object->file);
651 
652 	ret = cachefiles_inject_read_error();
653 	if (ret == 0)
654 		dentry = start_creating(&nop_mnt_idmap, fan, &QSTR(object->d_name));
655 	else
656 		dentry = ERR_PTR(ret);
657 	if (IS_ERR(dentry)) {
658 		trace_cachefiles_vfs_error(object, d_inode(fan), PTR_ERR(dentry),
659 					   cachefiles_trace_lookup_error);
660 		_debug("lookup fail %ld", PTR_ERR(dentry));
661 		goto out;
662 	}
663 
664 	/*
665 	 * This loop will only execute more than once if some other thread
666 	 * races to create the object we are trying to create.
667 	 */
668 	while (!d_is_negative(dentry)) {
669 		ret = cachefiles_unlink(volume->cache, object, fan, dentry,
670 					FSCACHE_OBJECT_IS_STALE);
671 		if (ret < 0)
672 			goto out_end;
673 
674 		end_creating(dentry);
675 
676 		ret = cachefiles_inject_read_error();
677 		if (ret == 0)
678 			dentry = start_creating(&nop_mnt_idmap, fan,
679 						&QSTR(object->d_name));
680 		else
681 			dentry = ERR_PTR(ret);
682 		if (IS_ERR(dentry)) {
683 			trace_cachefiles_vfs_error(object, d_inode(fan), PTR_ERR(dentry),
684 						   cachefiles_trace_lookup_error);
685 			_debug("lookup fail %ld", PTR_ERR(dentry));
686 			goto out;
687 		}
688 	}
689 
690 	ret = cachefiles_inject_read_error();
691 	if (ret == 0)
692 		ret = vfs_link(object->file->f_path.dentry, &nop_mnt_idmap,
693 			       d_inode(fan), dentry, NULL);
694 	if (ret < 0) {
695 		trace_cachefiles_vfs_error(object, d_inode(fan), ret,
696 					   cachefiles_trace_link_error);
697 		_debug("link fail %d", ret);
698 	} else {
699 		trace_cachefiles_link(object, file_inode(object->file));
700 		spin_lock(&object->lock);
701 		/* TODO: Do we want to switch the file pointer to the new dentry? */
702 		clear_bit(CACHEFILES_OBJECT_USING_TMPFILE, &object->flags);
703 		spin_unlock(&object->lock);
704 		success = true;
705 	}
706 
707 out_end:
708 	end_creating(dentry);
709 out:
710 	_leave(" = %u", success);
711 	return success;
712 }
713 
714 /*
715  * Look up an inode to be checked or culled.  Return -EBUSY if the inode is
716  * marked in use.
717  */
718 static struct dentry *cachefiles_lookup_for_cull(struct cachefiles_cache *cache,
719 						 struct dentry *dir,
720 						 char *filename)
721 {
722 	struct dentry *victim;
723 	int ret = -ENOENT;
724 
725 	victim = start_removing(&nop_mnt_idmap, dir, &QSTR(filename));
726 
727 	if (IS_ERR(victim))
728 		goto lookup_error;
729 	if (d_inode(victim)->i_flags & S_KERNEL_FILE)
730 		goto lookup_busy;
731 	return victim;
732 
733 lookup_busy:
734 	ret = -EBUSY;
735 	end_removing(victim);
736 	return ERR_PTR(ret);
737 
738 lookup_error:
739 	ret = PTR_ERR(victim);
740 	if (ret == -ENOENT)
741 		return ERR_PTR(-ESTALE); /* Probably got retired by the netfs */
742 
743 	if (ret == -EIO) {
744 		cachefiles_io_error(cache, "Lookup failed");
745 	} else if (ret != -ENOMEM) {
746 		pr_err("Internal error: %d\n", ret);
747 		ret = -EIO;
748 	}
749 
750 	return ERR_PTR(ret);
751 }
752 
753 /*
754  * Cull an object if it's not in use
755  * - called only by cache manager daemon
756  */
757 int cachefiles_cull(struct cachefiles_cache *cache, struct dentry *dir,
758 		    char *filename)
759 {
760 	struct dentry *victim;
761 	struct inode *inode;
762 	int ret;
763 
764 	_enter(",%pd/,%s", dir, filename);
765 
766 	victim = cachefiles_lookup_for_cull(cache, dir, filename);
767 	if (IS_ERR(victim))
768 		return PTR_ERR(victim);
769 
770 	/* check to see if someone is using this object */
771 	inode = d_inode(victim);
772 	inode_lock(inode);
773 	if (inode->i_flags & S_KERNEL_FILE) {
774 		ret = -EBUSY;
775 	} else {
776 		/* Stop the cache from picking it back up */
777 		inode->i_flags |= S_KERNEL_FILE;
778 		ret = 0;
779 	}
780 	inode_unlock(inode);
781 	if (ret < 0)
782 		goto error_unlock;
783 
784 	/*
785 	 * cachefiles_bury_object() expects 2 references to 'victim',
786 	 * and drops one.
787 	 */
788 	dget(victim);
789 	ret = cachefiles_bury_object(cache, NULL, dir, victim,
790 				     FSCACHE_OBJECT_WAS_CULLED);
791 	dput(victim);
792 	if (ret < 0)
793 		goto error;
794 
795 	fscache_count_culled();
796 	_leave(" = 0");
797 	return 0;
798 
799 error_unlock:
800 	end_removing(victim);
801 error:
802 	if (ret == -ENOENT)
803 		return -ESTALE; /* Probably got retired by the netfs */
804 
805 	if (ret != -ENOMEM) {
806 		pr_err("Internal error: %d\n", ret);
807 		ret = -EIO;
808 	}
809 
810 	_leave(" = %d", ret);
811 	return ret;
812 }
813 
814 /*
815  * Find out if an object is in use or not
816  * - called only by cache manager daemon
817  * - returns -EBUSY or 0 to indicate whether an object is in use or not
818  */
819 int cachefiles_check_in_use(struct cachefiles_cache *cache, struct dentry *dir,
820 			    char *filename)
821 {
822 	struct dentry *victim;
823 	int ret = 0;
824 
825 	victim = cachefiles_lookup_for_cull(cache, dir, filename);
826 	if (IS_ERR(victim))
827 		return PTR_ERR(victim);
828 
829 	inode_unlock(d_inode(dir));
830 	dput(victim);
831 	return ret;
832 }
833