xref: /linux/fs/cachefiles/namei.c (revision fab183d632628381b466a41479489541ac0e29a0)
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