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