Lines Matching +full:realm +full:-
1 // SPDX-License-Identifier: GPL-2.0
48 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in ceph_set_ino_cb()
50 ci->i_vino = *(struct ceph_vino *)data; in ceph_set_ino_cb()
51 inode->i_ino = ceph_vino_to_ino_t(ci->i_vino); in ceph_set_ino_cb()
53 percpu_counter_inc(&mdsc->metric.total_inodes); in ceph_set_ino_cb()
59 * ceph_new_inode - allocate a new inode in advance of an expected create
77 inode = new_inode(dir->i_sb); in ceph_new_inode()
79 return ERR_PTR(-ENOMEM); in ceph_new_inode()
81 inode->i_blkbits = CEPH_FSCRYPT_BLOCK_SHIFT; in ceph_new_inode()
89 inode->i_state = 0; in ceph_new_inode()
90 inode->i_mode = *mode; in ceph_new_inode()
115 if (as_ctx->pagelist) { in ceph_as_ctx_to_req()
116 req->r_pagelist = as_ctx->pagelist; in ceph_as_ctx_to_req()
117 as_ctx->pagelist = NULL; in ceph_as_ctx_to_req()
123 * ceph_get_inode - find or create/hash a new inode
129 * return a reference to it. If new is non-NULL, its reference is consumed.
135 struct ceph_client *cl = mdsc->fsc->client; in ceph_get_inode()
139 return ERR_PTR(-EREMOTEIO); in ceph_get_inode()
153 return ERR_PTR(-ENOMEM); in ceph_get_inode()
158 !!(inode->i_state & I_NEW)); in ceph_get_inode()
172 struct inode *inode = ceph_get_inode(parent->i_sb, vino, NULL); in ceph_get_snapdir()
174 int ret = -ENOTDIR; in ceph_get_snapdir()
179 if (!S_ISDIR(parent->i_mode)) { in ceph_get_snapdir()
181 parent->i_mode); in ceph_get_snapdir()
185 if (!(inode->i_state & I_NEW) && !S_ISDIR(inode->i_mode)) { in ceph_get_snapdir()
187 inode->i_mode); in ceph_get_snapdir()
191 inode->i_mode = parent->i_mode; in ceph_get_snapdir()
192 inode->i_uid = parent->i_uid; in ceph_get_snapdir()
193 inode->i_gid = parent->i_gid; in ceph_get_snapdir()
197 ci->i_rbytes = 0; in ceph_get_snapdir()
198 ci->i_btime = ceph_inode(parent)->i_btime; in ceph_get_snapdir()
205 ci->fscrypt_auth = kmemdup(pci->fscrypt_auth, in ceph_get_snapdir()
206 pci->fscrypt_auth_len, in ceph_get_snapdir()
208 if (ci->fscrypt_auth) { in ceph_get_snapdir()
209 inode->i_flags |= S_ENCRYPTED; in ceph_get_snapdir()
210 ci->fscrypt_auth_len = pci->fscrypt_auth_len; in ceph_get_snapdir()
213 ret = -ENOMEM; in ceph_get_snapdir()
218 if (inode->i_state & I_NEW) { in ceph_get_snapdir()
219 inode->i_op = &ceph_snapdir_iops; in ceph_get_snapdir()
220 inode->i_fop = &ceph_snapdir_fops; in ceph_get_snapdir()
221 ci->i_snap_caps = CEPH_CAP_PIN; /* so we can open */ in ceph_get_snapdir()
227 if ((inode->i_state & I_NEW)) in ceph_get_snapdir()
258 struct inode *inode = &ci->netfs.inode; in __get_or_create_frag()
265 p = &ci->i_fragtree.rb_node; in __get_or_create_frag()
269 c = ceph_frag_compare(f, frag->frag); in __get_or_create_frag()
271 p = &(*p)->rb_left; in __get_or_create_frag()
273 p = &(*p)->rb_right; in __get_or_create_frag()
280 return ERR_PTR(-ENOMEM); in __get_or_create_frag()
282 frag->frag = f; in __get_or_create_frag()
283 frag->split_by = 0; in __get_or_create_frag()
284 frag->mds = -1; in __get_or_create_frag()
285 frag->ndist = 0; in __get_or_create_frag()
287 rb_link_node(&frag->node, parent, p); in __get_or_create_frag()
288 rb_insert_color(&frag->node, &ci->i_fragtree); in __get_or_create_frag()
299 struct rb_node *n = ci->i_fragtree.rb_node; in __ceph_find_frag()
304 int c = ceph_frag_compare(f, frag->frag); in __ceph_find_frag()
306 n = n->rb_left; in __ceph_find_frag()
308 n = n->rb_right; in __ceph_find_frag()
323 struct ceph_client *cl = ceph_inode_to_client(&ci->netfs.inode); in __ceph_choose_frag()
337 if (frag->split_by == 0) { in __ceph_choose_frag()
346 nway = 1 << frag->split_by; in __ceph_choose_frag()
348 frag->split_by, nway); in __ceph_choose_frag()
350 n = ceph_frag_make_child(t, frag->split_by, i); in __ceph_choose_frag()
367 mutex_lock(&ci->i_fragtree_mutex); in ceph_choose_frag()
369 mutex_unlock(&ci->i_fragtree_mutex); in ceph_choose_frag()
384 u32 id = le32_to_cpu(dirinfo->frag); in ceph_fill_dirfrag()
385 int mds = le32_to_cpu(dirinfo->auth); in ceph_fill_dirfrag()
386 int ndist = le32_to_cpu(dirinfo->ndist); in ceph_fill_dirfrag()
387 int diri_auth = -1; in ceph_fill_dirfrag()
391 spin_lock(&ci->i_ceph_lock); in ceph_fill_dirfrag()
392 if (ci->i_auth_cap) in ceph_fill_dirfrag()
393 diri_auth = ci->i_auth_cap->mds; in ceph_fill_dirfrag()
394 spin_unlock(&ci->i_ceph_lock); in ceph_fill_dirfrag()
396 if (mds == -1) /* CDIR_AUTH_PARENT */ in ceph_fill_dirfrag()
399 mutex_lock(&ci->i_fragtree_mutex); in ceph_fill_dirfrag()
405 if (frag->split_by == 0) { in ceph_fill_dirfrag()
409 rb_erase(&frag->node, &ci->i_fragtree); in ceph_fill_dirfrag()
415 frag->mds = -1; in ceph_fill_dirfrag()
416 frag->ndist = 0; in ceph_fill_dirfrag()
429 le32_to_cpu(dirinfo->frag)); in ceph_fill_dirfrag()
430 err = -ENOMEM; in ceph_fill_dirfrag()
434 frag->mds = mds; in ceph_fill_dirfrag()
435 frag->ndist = min_t(u32, ndist, CEPH_MAX_DIRFRAG_REP); in ceph_fill_dirfrag()
436 for (i = 0; i < frag->ndist; i++) in ceph_fill_dirfrag()
437 frag->dist[i] = le32_to_cpu(dirinfo->dist[i]); in ceph_fill_dirfrag()
439 ceph_vinop(inode), frag->frag, frag->ndist); in ceph_fill_dirfrag()
442 mutex_unlock(&ci->i_fragtree_mutex); in ceph_fill_dirfrag()
450 return ceph_frag_compare(le32_to_cpu(ls->frag), in frag_tree_split_cmp()
451 le32_to_cpu(rs->frag)); in frag_tree_split_cmp()
458 if (ceph_frag_bits(f) != ceph_frag_bits(frag->frag) + frag->split_by) in is_frag_child()
460 return ceph_frag_contains_value(frag->frag, ceph_frag_value(f)); in is_frag_child()
475 mutex_lock(&ci->i_fragtree_mutex); in ceph_fill_fragtree()
476 nsplits = le32_to_cpu(fragtree->nsplits); in ceph_fill_fragtree()
477 if (nsplits != ci->i_fragtree_nsplits) { in ceph_fill_fragtree()
481 id = le32_to_cpu(fragtree->splits[i].frag); in ceph_fill_fragtree()
484 } else if (!RB_EMPTY_ROOT(&ci->i_fragtree)) { in ceph_fill_fragtree()
485 rb_node = rb_first(&ci->i_fragtree); in ceph_fill_fragtree()
487 if (frag->frag != ceph_frag_make(0, 0) || rb_next(rb_node)) in ceph_fill_fragtree()
491 id = le32_to_cpu(dirinfo->frag); in ceph_fill_fragtree()
499 sort(fragtree->splits, nsplits, sizeof(fragtree->splits[0]), in ceph_fill_fragtree()
504 rb_node = rb_first(&ci->i_fragtree); in ceph_fill_fragtree()
506 id = le32_to_cpu(fragtree->splits[i].frag); in ceph_fill_fragtree()
507 split_by = le32_to_cpu(fragtree->splits[i].by); in ceph_fill_fragtree()
517 if (ceph_frag_compare(frag->frag, id) >= 0) { in ceph_fill_fragtree()
518 if (frag->frag != id) in ceph_fill_fragtree()
526 if (frag->split_by > 0 || in ceph_fill_fragtree()
527 !is_frag_child(frag->frag, prev_frag)) { in ceph_fill_fragtree()
528 rb_erase(&frag->node, &ci->i_fragtree); in ceph_fill_fragtree()
529 if (frag->split_by > 0) in ceph_fill_fragtree()
530 ci->i_fragtree_nsplits--; in ceph_fill_fragtree()
540 if (frag->split_by == 0) in ceph_fill_fragtree()
541 ci->i_fragtree_nsplits++; in ceph_fill_fragtree()
542 frag->split_by = split_by; in ceph_fill_fragtree()
543 doutc(cl, " frag %x split by %d\n", frag->frag, frag->split_by); in ceph_fill_fragtree()
550 if (frag->split_by > 0 || in ceph_fill_fragtree()
551 !is_frag_child(frag->frag, prev_frag)) { in ceph_fill_fragtree()
552 rb_erase(&frag->node, &ci->i_fragtree); in ceph_fill_fragtree()
553 if (frag->split_by > 0) in ceph_fill_fragtree()
554 ci->i_fragtree_nsplits--; in ceph_fill_fragtree()
559 mutex_unlock(&ci->i_fragtree_mutex); in ceph_fill_fragtree()
576 doutc(fsc->client, "%p\n", &ci->netfs.inode); in ceph_alloc_inode()
579 netfs_inode_init(&ci->netfs, &ceph_netfs_ops, false); in ceph_alloc_inode()
581 spin_lock_init(&ci->i_ceph_lock); in ceph_alloc_inode()
583 ci->i_version = 0; in ceph_alloc_inode()
584 ci->i_inline_version = 0; in ceph_alloc_inode()
585 ci->i_time_warp_seq = 0; in ceph_alloc_inode()
586 ci->i_ceph_flags = 0; in ceph_alloc_inode()
587 atomic64_set(&ci->i_ordered_count, 1); in ceph_alloc_inode()
588 atomic64_set(&ci->i_release_count, 1); in ceph_alloc_inode()
589 atomic64_set(&ci->i_complete_seq[0], 0); in ceph_alloc_inode()
590 atomic64_set(&ci->i_complete_seq[1], 0); in ceph_alloc_inode()
591 ci->i_symlink = NULL; in ceph_alloc_inode()
593 ci->i_max_bytes = 0; in ceph_alloc_inode()
594 ci->i_max_files = 0; in ceph_alloc_inode()
596 memset(&ci->i_dir_layout, 0, sizeof(ci->i_dir_layout)); in ceph_alloc_inode()
597 memset(&ci->i_cached_layout, 0, sizeof(ci->i_cached_layout)); in ceph_alloc_inode()
598 RCU_INIT_POINTER(ci->i_layout.pool_ns, NULL); in ceph_alloc_inode()
600 ci->i_fragtree = RB_ROOT; in ceph_alloc_inode()
601 mutex_init(&ci->i_fragtree_mutex); in ceph_alloc_inode()
603 ci->i_xattrs.blob = NULL; in ceph_alloc_inode()
604 ci->i_xattrs.prealloc_blob = NULL; in ceph_alloc_inode()
605 ci->i_xattrs.dirty = false; in ceph_alloc_inode()
606 ci->i_xattrs.index = RB_ROOT; in ceph_alloc_inode()
607 ci->i_xattrs.count = 0; in ceph_alloc_inode()
608 ci->i_xattrs.names_size = 0; in ceph_alloc_inode()
609 ci->i_xattrs.vals_size = 0; in ceph_alloc_inode()
610 ci->i_xattrs.version = 0; in ceph_alloc_inode()
611 ci->i_xattrs.index_version = 0; in ceph_alloc_inode()
613 ci->i_caps = RB_ROOT; in ceph_alloc_inode()
614 ci->i_auth_cap = NULL; in ceph_alloc_inode()
615 ci->i_dirty_caps = 0; in ceph_alloc_inode()
616 ci->i_flushing_caps = 0; in ceph_alloc_inode()
617 INIT_LIST_HEAD(&ci->i_dirty_item); in ceph_alloc_inode()
618 INIT_LIST_HEAD(&ci->i_flushing_item); in ceph_alloc_inode()
619 ci->i_prealloc_cap_flush = NULL; in ceph_alloc_inode()
620 INIT_LIST_HEAD(&ci->i_cap_flush_list); in ceph_alloc_inode()
621 init_waitqueue_head(&ci->i_cap_wq); in ceph_alloc_inode()
622 ci->i_hold_caps_max = 0; in ceph_alloc_inode()
623 INIT_LIST_HEAD(&ci->i_cap_delay_list); in ceph_alloc_inode()
624 INIT_LIST_HEAD(&ci->i_cap_snaps); in ceph_alloc_inode()
625 ci->i_head_snapc = NULL; in ceph_alloc_inode()
626 ci->i_snap_caps = 0; in ceph_alloc_inode()
628 ci->i_last_rd = ci->i_last_wr = jiffies - 3600 * HZ; in ceph_alloc_inode()
630 ci->i_nr_by_mode[i] = 0; in ceph_alloc_inode()
632 mutex_init(&ci->i_truncate_mutex); in ceph_alloc_inode()
633 ci->i_truncate_seq = 0; in ceph_alloc_inode()
634 ci->i_truncate_size = 0; in ceph_alloc_inode()
635 ci->i_truncate_pending = 0; in ceph_alloc_inode()
636 ci->i_truncate_pagecache_size = 0; in ceph_alloc_inode()
638 ci->i_max_size = 0; in ceph_alloc_inode()
639 ci->i_reported_size = 0; in ceph_alloc_inode()
640 ci->i_wanted_max_size = 0; in ceph_alloc_inode()
641 ci->i_requested_max_size = 0; in ceph_alloc_inode()
643 ci->i_pin_ref = 0; in ceph_alloc_inode()
644 ci->i_rd_ref = 0; in ceph_alloc_inode()
645 ci->i_rdcache_ref = 0; in ceph_alloc_inode()
646 ci->i_wr_ref = 0; in ceph_alloc_inode()
647 ci->i_wb_ref = 0; in ceph_alloc_inode()
648 ci->i_fx_ref = 0; in ceph_alloc_inode()
649 ci->i_wrbuffer_ref = 0; in ceph_alloc_inode()
650 ci->i_wrbuffer_ref_head = 0; in ceph_alloc_inode()
651 atomic_set(&ci->i_filelock_ref, 0); in ceph_alloc_inode()
652 atomic_set(&ci->i_shared_gen, 1); in ceph_alloc_inode()
653 ci->i_rdcache_gen = 0; in ceph_alloc_inode()
654 ci->i_rdcache_revoking = 0; in ceph_alloc_inode()
656 INIT_LIST_HEAD(&ci->i_unsafe_dirops); in ceph_alloc_inode()
657 INIT_LIST_HEAD(&ci->i_unsafe_iops); in ceph_alloc_inode()
658 spin_lock_init(&ci->i_unsafe_lock); in ceph_alloc_inode()
660 ci->i_snap_realm = NULL; in ceph_alloc_inode()
661 INIT_LIST_HEAD(&ci->i_snap_realm_item); in ceph_alloc_inode()
662 INIT_LIST_HEAD(&ci->i_snap_flush_item); in ceph_alloc_inode()
664 INIT_WORK(&ci->i_work, ceph_inode_work); in ceph_alloc_inode()
665 ci->i_work_mask = 0; in ceph_alloc_inode()
666 memset(&ci->i_btime, '\0', sizeof(ci->i_btime)); in ceph_alloc_inode()
668 ci->fscrypt_auth = NULL; in ceph_alloc_inode()
669 ci->fscrypt_auth_len = 0; in ceph_alloc_inode()
671 return &ci->netfs.inode; in ceph_alloc_inode()
678 kfree(ci->i_symlink); in ceph_free_inode()
680 kfree(ci->fscrypt_auth); in ceph_free_inode()
689 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in ceph_evict_inode()
696 percpu_counter_dec(&mdsc->metric.total_inodes); in ceph_evict_inode()
699 truncate_inode_pages_final(&inode->i_data); in ceph_evict_inode()
700 if (inode->i_state & I_PINNING_NETFS_WB) in ceph_evict_inode()
716 if (ci->i_snap_realm) { in ceph_evict_inode()
718 doutc(cl, " dropping residual ref to snap realm %p\n", in ceph_evict_inode()
719 ci->i_snap_realm); in ceph_evict_inode()
722 ceph_put_snapid_map(mdsc, ci->i_snapid_map); in ceph_evict_inode()
723 ci->i_snap_realm = NULL; in ceph_evict_inode()
727 while ((n = rb_first(&ci->i_fragtree)) != NULL) { in ceph_evict_inode()
729 rb_erase(n, &ci->i_fragtree); in ceph_evict_inode()
732 ci->i_fragtree_nsplits = 0; in ceph_evict_inode()
735 if (ci->i_xattrs.blob) in ceph_evict_inode()
736 ceph_buffer_put(ci->i_xattrs.blob); in ceph_evict_inode()
737 if (ci->i_xattrs.prealloc_blob) in ceph_evict_inode()
738 ceph_buffer_put(ci->i_xattrs.prealloc_blob); in ceph_evict_inode()
740 ceph_put_string(rcu_dereference_raw(ci->i_layout.pool_ns)); in ceph_evict_inode()
741 ceph_put_string(rcu_dereference_raw(ci->i_cached_layout.pool_ns)); in ceph_evict_inode()
746 return (size + (1<<9) - 1) >> 9; in calc_inode_blocks()
765 if (ceph_seq_cmp(truncate_seq, ci->i_truncate_seq) > 0 || in ceph_fill_file_size()
766 (truncate_seq == ci->i_truncate_seq && size > isize)) { in ceph_fill_file_size()
767 doutc(cl, "size %lld -> %llu\n", isize, size); in ceph_fill_file_size()
768 if (size > 0 && S_ISDIR(inode->i_mode)) { in ceph_fill_file_size()
769 pr_err_client(cl, "non-zero size for directory\n"); in ceph_fill_file_size()
773 inode->i_blocks = calc_inode_blocks(size); in ceph_fill_file_size()
780 ci->i_reported_size = size; in ceph_fill_file_size()
781 if (truncate_seq != ci->i_truncate_seq) { in ceph_fill_file_size()
782 doutc(cl, "truncate_seq %u -> %u\n", in ceph_fill_file_size()
783 ci->i_truncate_seq, truncate_seq); in ceph_fill_file_size()
784 ci->i_truncate_seq = truncate_seq; in ceph_fill_file_size()
797 mapping_mapped(inode->i_mapping) || in ceph_fill_file_size()
799 ci->i_truncate_pending++; in ceph_fill_file_size()
811 if (ceph_seq_cmp(truncate_seq, ci->i_truncate_seq) >= 0) { in ceph_fill_file_size()
812 doutc(cl, "truncate_size %lld -> %llu, encrypted %d\n", in ceph_fill_file_size()
813 ci->i_truncate_size, truncate_size, in ceph_fill_file_size()
816 ci->i_truncate_size = truncate_size; in ceph_fill_file_size()
819 doutc(cl, "truncate_pagecache_size %lld -> %llu\n", in ceph_fill_file_size()
820 ci->i_truncate_pagecache_size, size); in ceph_fill_file_size()
821 ci->i_truncate_pagecache_size = size; in ceph_fill_file_size()
823 ci->i_truncate_pagecache_size = truncate_size; in ceph_fill_file_size()
843 if (ci->i_version == 0 || in ceph_fill_file_time()
845 doutc(cl, "ctime %lld.%09ld -> %lld.%09ld inc w/ cap\n", in ceph_fill_file_time()
847 ctime->tv_sec, ctime->tv_nsec); in ceph_fill_file_time()
850 if (ci->i_version == 0 || in ceph_fill_file_time()
851 ceph_seq_cmp(time_warp_seq, ci->i_time_warp_seq) > 0) { in ceph_fill_file_time()
853 doutc(cl, "mtime %lld.%09ld -> %lld.%09ld tw %d -> %d\n", in ceph_fill_file_time()
856 mtime->tv_sec, mtime->tv_nsec, in ceph_fill_file_time()
857 ci->i_time_warp_seq, (int)time_warp_seq); in ceph_fill_file_time()
861 ci->i_time_warp_seq = time_warp_seq; in ceph_fill_file_time()
862 } else if (time_warp_seq == ci->i_time_warp_seq) { in ceph_fill_file_time()
868 doutc(cl, "mtime %lld.%09ld -> %lld.%09ld inc\n", in ceph_fill_file_time()
870 mtime->tv_sec, mtime->tv_nsec); in ceph_fill_file_time()
875 doutc(cl, "atime %lld.%09ld -> %lld.%09ld inc\n", in ceph_fill_file_time()
877 atime->tv_sec, atime->tv_nsec); in ceph_fill_file_time()
887 if (ceph_seq_cmp(time_warp_seq, ci->i_time_warp_seq) >= 0) { in ceph_fill_file_time()
891 ci->i_time_warp_seq = time_warp_seq; in ceph_fill_file_time()
898 time_warp_seq, ci->i_time_warp_seq); in ceph_fill_file_time()
906 struct ceph_client *cl = mdsc->fsc->client; in decode_encrypted_symlink()
912 return -ENOMEM; in decode_encrypted_symlink()
920 return -EIO; in decode_encrypted_symlink()
931 return -EOPNOTSUPP; in decode_encrypted_symlink()
945 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in ceph_fill_inode()
946 struct ceph_client *cl = mdsc->fsc->client; in ceph_fill_inode()
947 struct ceph_mds_reply_inode *info = iinfo->in; in ceph_fill_inode()
960 umode_t mode = le32_to_cpu(info->mode); in ceph_fill_inode()
961 dev_t rdev = le32_to_cpu(info->rdev); in ceph_fill_inode()
963 lockdep_assert_held(&mdsc->snap_rwsem); in ceph_fill_inode()
966 le64_to_cpu(info->version), ci->i_version); in ceph_fill_inode()
969 if (inode->i_state & I_NEW) { in ceph_fill_inode()
970 inode->i_mode = mode; in ceph_fill_inode()
975 ceph_vinop(inode), inode->i_mode, mode); in ceph_fill_inode()
976 return -ESTALE; in ceph_fill_inode()
979 if ((S_ISCHR(mode) || S_ISBLK(mode)) && inode->i_rdev != rdev) { in ceph_fill_inode()
982 ceph_vinop(inode), MAJOR(inode->i_rdev), in ceph_fill_inode()
983 MINOR(inode->i_rdev), MAJOR(rdev), in ceph_fill_inode()
985 return -ESTALE; in ceph_fill_inode()
989 info_caps = le32_to_cpu(info->cap.caps); in ceph_fill_inode()
995 return -ENOMEM; in ceph_fill_inode()
1003 if (iinfo->xattr_len > 4) { in ceph_fill_inode()
1004 xattr_blob = ceph_buffer_new(iinfo->xattr_len, GFP_NOFS); in ceph_fill_inode()
1007 iinfo->xattr_len); in ceph_fill_inode()
1010 if (iinfo->pool_ns_len > 0) in ceph_fill_inode()
1011 pool_ns = ceph_find_or_create_string(iinfo->pool_ns_data, in ceph_fill_inode()
1012 iinfo->pool_ns_len); in ceph_fill_inode()
1014 if (ceph_snap(inode) != CEPH_NOSNAP && !ci->i_snapid_map) in ceph_fill_inode()
1015 ci->i_snapid_map = ceph_get_snapid_map(mdsc, ceph_snap(inode)); in ceph_fill_inode()
1017 spin_lock(&ci->i_ceph_lock); in ceph_fill_inode()
1030 if (ci->i_version == 0 || in ceph_fill_inode()
1031 ((info->cap.flags & CEPH_CAP_FLAG_AUTH) && in ceph_fill_inode()
1032 le64_to_cpu(info->version) > (ci->i_version & ~1))) in ceph_fill_inode()
1036 inode_set_max_iversion_raw(inode, iinfo->change_attr); in ceph_fill_inode()
1042 __ceph_update_quota(ci, iinfo->max_bytes, iinfo->max_files); in ceph_fill_inode()
1045 if (iinfo->fscrypt_auth_len && in ceph_fill_inode()
1046 ((inode->i_state & I_NEW) || (ci->fscrypt_auth_len == 0))) { in ceph_fill_inode()
1047 kfree(ci->fscrypt_auth); in ceph_fill_inode()
1048 ci->fscrypt_auth_len = iinfo->fscrypt_auth_len; in ceph_fill_inode()
1049 ci->fscrypt_auth = iinfo->fscrypt_auth; in ceph_fill_inode()
1050 iinfo->fscrypt_auth = NULL; in ceph_fill_inode()
1051 iinfo->fscrypt_auth_len = 0; in ceph_fill_inode()
1058 inode->i_mode = mode; in ceph_fill_inode()
1059 inode->i_uid = make_kuid(&init_user_ns, le32_to_cpu(info->uid)); in ceph_fill_inode()
1060 inode->i_gid = make_kgid(&init_user_ns, le32_to_cpu(info->gid)); in ceph_fill_inode()
1062 ceph_vinop(inode), inode->i_mode, in ceph_fill_inode()
1063 from_kuid(&init_user_ns, inode->i_uid), in ceph_fill_inode()
1064 from_kgid(&init_user_ns, inode->i_gid)); in ceph_fill_inode()
1065 ceph_decode_timespec64(&ci->i_btime, &iinfo->btime); in ceph_fill_inode()
1066 ceph_decode_timespec64(&ci->i_snap_btime, &iinfo->snap_btime); in ceph_fill_inode()
1071 inode->i_blkbits = CEPH_FSCRYPT_BLOCK_SHIFT; in ceph_fill_inode()
1072 else if (le32_to_cpu(info->layout.fl_stripe_unit)) in ceph_fill_inode()
1073 inode->i_blkbits = in ceph_fill_inode()
1074 fls(le32_to_cpu(info->layout.fl_stripe_unit)) - 1; in ceph_fill_inode()
1076 inode->i_blkbits = CEPH_BLOCK_SHIFT; in ceph_fill_inode()
1080 set_nlink(inode, le32_to_cpu(info->nlink)); in ceph_fill_inode()
1084 ceph_decode_timespec64(&atime, &info->atime); in ceph_fill_inode()
1085 ceph_decode_timespec64(&mtime, &info->mtime); in ceph_fill_inode()
1086 ceph_decode_timespec64(&ctime, &info->ctime); in ceph_fill_inode()
1088 le32_to_cpu(info->time_warp_seq), in ceph_fill_inode()
1093 ci->i_files = le64_to_cpu(info->files); in ceph_fill_inode()
1094 ci->i_subdirs = le64_to_cpu(info->subdirs); in ceph_fill_inode()
1099 u64 size = le64_to_cpu(info->size); in ceph_fill_inode()
1100 s64 old_pool = ci->i_layout.pool_id; in ceph_fill_inode()
1103 ceph_file_layout_from_legacy(&ci->i_layout, &info->layout); in ceph_fill_inode()
1104 old_ns = rcu_dereference_protected(ci->i_layout.pool_ns, in ceph_fill_inode()
1105 lockdep_is_held(&ci->i_ceph_lock)); in ceph_fill_inode()
1106 rcu_assign_pointer(ci->i_layout.pool_ns, pool_ns); in ceph_fill_inode()
1108 if (ci->i_layout.pool_id != old_pool || pool_ns != old_ns) in ceph_fill_inode()
1109 ci->i_ceph_flags &= ~CEPH_I_POOL_PERM; in ceph_fill_inode()
1114 iinfo->fscrypt_file_len == sizeof(__le64)) { in ceph_fill_inode()
1115 u64 fsize = __le64_to_cpu(*(__le64 *)iinfo->fscrypt_file); in ceph_fill_inode()
1122 info->size, size); in ceph_fill_inode()
1127 le32_to_cpu(info->truncate_seq), in ceph_fill_inode()
1128 le64_to_cpu(info->truncate_size), in ceph_fill_inode()
1131 if ((info->cap.flags & CEPH_CAP_FLAG_AUTH) && in ceph_fill_inode()
1132 ci->i_max_size != le64_to_cpu(info->max_size)) { in ceph_fill_inode()
1133 doutc(cl, "max_size %lld -> %llu\n", in ceph_fill_inode()
1134 ci->i_max_size, le64_to_cpu(info->max_size)); in ceph_fill_inode()
1135 ci->i_max_size = le64_to_cpu(info->max_size); in ceph_fill_inode()
1141 if (new_version || (info->cap.flags & CEPH_CAP_FLAG_AUTH)) { in ceph_fill_inode()
1142 if (S_ISDIR(inode->i_mode)) { in ceph_fill_inode()
1143 ci->i_dir_layout = iinfo->dir_layout; in ceph_fill_inode()
1144 ci->i_rbytes = le64_to_cpu(info->rbytes); in ceph_fill_inode()
1145 ci->i_rfiles = le64_to_cpu(info->rfiles); in ceph_fill_inode()
1146 ci->i_rsubdirs = le64_to_cpu(info->rsubdirs); in ceph_fill_inode()
1147 ci->i_dir_pin = iinfo->dir_pin; in ceph_fill_inode()
1148 ci->i_rsnaps = iinfo->rsnaps; in ceph_fill_inode()
1149 ceph_decode_timespec64(&ci->i_rctime, &info->rctime); in ceph_fill_inode()
1155 if ((ci->i_xattrs.version == 0 || !(issued & CEPH_CAP_XATTR_EXCL)) && in ceph_fill_inode()
1156 le64_to_cpu(info->xattr_version) > ci->i_xattrs.version) { in ceph_fill_inode()
1157 if (ci->i_xattrs.blob) in ceph_fill_inode()
1158 old_blob = ci->i_xattrs.blob; in ceph_fill_inode()
1159 ci->i_xattrs.blob = xattr_blob; in ceph_fill_inode()
1161 memcpy(ci->i_xattrs.blob->vec.iov_base, in ceph_fill_inode()
1162 iinfo->xattr_data, iinfo->xattr_len); in ceph_fill_inode()
1163 ci->i_xattrs.version = le64_to_cpu(info->xattr_version); in ceph_fill_inode()
1170 if (le64_to_cpu(info->version) > ci->i_version) in ceph_fill_inode()
1171 ci->i_version = le64_to_cpu(info->version); in ceph_fill_inode()
1173 inode->i_mapping->a_ops = &ceph_aops; in ceph_fill_inode()
1175 switch (inode->i_mode & S_IFMT) { in ceph_fill_inode()
1180 inode->i_blkbits = PAGE_SHIFT; in ceph_fill_inode()
1181 init_special_inode(inode, inode->i_mode, rdev); in ceph_fill_inode()
1182 inode->i_op = &ceph_file_iops; in ceph_fill_inode()
1185 inode->i_op = &ceph_file_iops; in ceph_fill_inode()
1186 inode->i_fop = &ceph_file_fops; in ceph_fill_inode()
1189 if (!ci->i_symlink) { in ceph_fill_inode()
1190 u32 symlen = iinfo->symlink_len; in ceph_fill_inode()
1193 spin_unlock(&ci->i_ceph_lock); in ceph_fill_inode()
1202 err = decode_encrypted_symlink(mdsc, iinfo->symlink, in ceph_fill_inode()
1212 inode->i_blocks = calc_inode_blocks(symlen); in ceph_fill_inode()
1220 inode->i_blocks = calc_inode_blocks(symlen); in ceph_fill_inode()
1223 err = -ENOMEM; in ceph_fill_inode()
1224 sym = kstrndup(iinfo->symlink, symlen, GFP_NOFS); in ceph_fill_inode()
1229 spin_lock(&ci->i_ceph_lock); in ceph_fill_inode()
1230 if (!ci->i_symlink) in ceph_fill_inode()
1231 ci->i_symlink = sym; in ceph_fill_inode()
1241 inode->i_op = &ceph_encrypted_symlink_iops; in ceph_fill_inode()
1243 inode->i_link = ci->i_symlink; in ceph_fill_inode()
1244 inode->i_op = &ceph_symlink_iops; in ceph_fill_inode()
1248 inode->i_op = &ceph_dir_iops; in ceph_fill_inode()
1249 inode->i_fop = &ceph_dir_fops; in ceph_fill_inode()
1253 ceph_vinop(inode), inode->i_mode); in ceph_fill_inode()
1260 le64_to_cpu(info->cap.cap_id), in ceph_fill_inode()
1262 le32_to_cpu(info->cap.wanted), in ceph_fill_inode()
1263 le32_to_cpu(info->cap.seq), in ceph_fill_inode()
1264 le32_to_cpu(info->cap.mseq), in ceph_fill_inode()
1265 le64_to_cpu(info->cap.realm), in ceph_fill_inode()
1266 info->cap.flags, &new_cap); in ceph_fill_inode()
1269 if (S_ISDIR(inode->i_mode) && in ceph_fill_inode()
1270 ci->i_files == 0 && ci->i_subdirs == 0 && in ceph_fill_inode()
1278 atomic64_read(&ci->i_release_count), in ceph_fill_inode()
1279 atomic64_read(&ci->i_ordered_count)); in ceph_fill_inode()
1286 ci->i_snap_caps |= info_caps; in ceph_fill_inode()
1290 if (iinfo->inline_version > 0 && in ceph_fill_inode()
1291 iinfo->inline_version >= ci->i_inline_version) { in ceph_fill_inode()
1293 ci->i_inline_version = iinfo->inline_version; in ceph_fill_inode()
1306 spin_unlock(&ci->i_ceph_lock); in ceph_fill_inode()
1312 iinfo->inline_data, iinfo->inline_len); in ceph_fill_inode()
1315 wake_up_all(&ci->i_cap_wq); in ceph_fill_inode()
1322 if (S_ISDIR(inode->i_mode)) in ceph_fill_inode()
1323 ceph_fill_fragtree(inode, &info->fragtree, dirinfo); in ceph_fill_inode()
1340 * caller should hold session s_mutex and dentry->d_lock.
1350 unsigned mask = le16_to_cpu(lease->mask); in __update_dentry_lease()
1351 long unsigned duration = le32_to_cpu(lease->duration_ms); in __update_dentry_lease()
1362 di->flags |= CEPH_DENTRY_PRIMARY_LINK; in __update_dentry_lease()
1364 di->flags &= ~CEPH_DENTRY_PRIMARY_LINK; in __update_dentry_lease()
1366 di->lease_shared_gen = atomic_read(&ceph_inode(dir)->i_shared_gen); in __update_dentry_lease()
1372 if (di->lease_gen == atomic_read(&session->s_cap_gen) && in __update_dentry_lease()
1373 time_before(ttl, di->time)) in __update_dentry_lease()
1376 if (di->lease_session && di->lease_session != session) { in __update_dentry_lease()
1377 *old_lease_session = di->lease_session; in __update_dentry_lease()
1378 di->lease_session = NULL; in __update_dentry_lease()
1381 if (!di->lease_session) in __update_dentry_lease()
1382 di->lease_session = ceph_get_mds_session(session); in __update_dentry_lease()
1383 di->lease_gen = atomic_read(&session->s_cap_gen); in __update_dentry_lease()
1384 di->lease_seq = le32_to_cpu(lease->seq); in __update_dentry_lease()
1385 di->lease_renew_after = half_ttl; in __update_dentry_lease()
1386 di->lease_renew_from = 0; in __update_dentry_lease()
1387 di->time = ttl; in __update_dentry_lease()
1398 spin_lock(&dentry->d_lock); in update_dentry_lease()
1401 spin_unlock(&dentry->d_lock); in update_dentry_lease()
1420 spin_lock(&dentry->d_lock); in update_dentry_lease_careful()
1422 if (dentry->d_name.len != dname_len || in update_dentry_lease_careful()
1423 memcmp(dentry->d_name.name, dname, dname_len)) in update_dentry_lease_careful()
1426 dir = d_inode(dentry->d_parent); in update_dentry_lease_careful()
1446 spin_unlock(&dentry->d_lock); in update_dentry_lease_careful()
1462 if (S_ISDIR(in->i_mode)) { in splice_dentry()
1470 spin_lock(&realdn->d_lock); in splice_dentry()
1472 realdn->d_op->d_prune(realdn); in splice_dentry()
1474 di->time = jiffies; in splice_dentry()
1475 di->lease_shared_gen = 0; in splice_dentry()
1476 di->offset = 0; in splice_dentry()
1478 spin_unlock(&realdn->d_lock); in splice_dentry()
1509 * one inode, or a directory, dentry, and possibly linked-to inode (e.g.,
1520 struct ceph_mds_session *session = req->r_session; in ceph_fill_trace()
1521 struct ceph_mds_reply_info_parsed *rinfo = &req->r_reply_info; in ceph_fill_trace()
1525 struct ceph_client *cl = fsc->client; in ceph_fill_trace()
1529 rinfo->head->is_dentry, rinfo->head->is_target); in ceph_fill_trace()
1531 if (!rinfo->head->is_target && !rinfo->head->is_dentry) { in ceph_fill_trace()
1533 if (rinfo->head->result == 0 && req->r_parent) in ceph_fill_trace()
1538 if (rinfo->head->is_dentry) { in ceph_fill_trace()
1539 struct inode *dir = req->r_parent; in ceph_fill_trace()
1542 err = ceph_fill_inode(dir, NULL, &rinfo->diri, in ceph_fill_trace()
1543 rinfo->dirfrag, session, -1, in ceph_fill_trace()
1544 &req->r_caps_reservation); in ceph_fill_trace()
1551 if (dir && req->r_op == CEPH_MDS_OP_LOOKUPNAME && in ceph_fill_trace()
1552 test_bit(CEPH_MDS_R_PARENT_LOCKED, &req->r_req_flags) && in ceph_fill_trace()
1553 !test_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags)) { in ceph_fill_trace()
1559 .name = rinfo->dname, in ceph_fill_trace()
1560 .ctext = rinfo->altname, in ceph_fill_trace()
1561 .name_len = rinfo->dname_len, in ceph_fill_trace()
1562 .ctext_len = rinfo->altname_len }; in ceph_fill_trace()
1564 BUG_ON(!rinfo->head->is_target); in ceph_fill_trace()
1565 BUG_ON(req->r_dentry); in ceph_fill_trace()
1585 tvino.ino = le64_to_cpu(rinfo->targeti.in->ino); in ceph_fill_trace()
1586 tvino.snap = le64_to_cpu(rinfo->targeti.in->snapid); in ceph_fill_trace()
1599 err = -ENOMEM; in ceph_fill_trace()
1603 spin_lock(&dn->d_lock); in ceph_fill_trace()
1604 dn->d_flags |= DCACHE_NOKEY_NAME; in ceph_fill_trace()
1605 spin_unlock(&dn->d_lock); in ceph_fill_trace()
1620 req->r_dentry = dn; in ceph_fill_trace()
1625 if (rinfo->head->is_target) { in ceph_fill_trace()
1627 BUG_ON(!req->r_target_inode); in ceph_fill_trace()
1629 in = req->r_target_inode; in ceph_fill_trace()
1630 err = ceph_fill_inode(in, req->r_locked_page, &rinfo->targeti, in ceph_fill_trace()
1632 (!test_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags) && in ceph_fill_trace()
1633 !test_bit(CEPH_MDS_R_ASYNC, &req->r_req_flags) && in ceph_fill_trace()
1634 rinfo->head->result == 0) ? req->r_fmode : -1, in ceph_fill_trace()
1635 &req->r_caps_reservation); in ceph_fill_trace()
1639 req->r_target_inode = NULL; in ceph_fill_trace()
1640 if (in->i_state & I_NEW) in ceph_fill_trace()
1646 if (in->i_state & I_NEW) in ceph_fill_trace()
1654 if (rinfo->head->is_dentry && in ceph_fill_trace()
1655 !test_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags) && in ceph_fill_trace()
1656 test_bit(CEPH_MDS_R_PARENT_LOCKED, &req->r_req_flags) && in ceph_fill_trace()
1657 (rinfo->head->is_target || strncmp(req->r_dentry->d_name.name, in ceph_fill_trace()
1658 fsc->mount_options->snapdir_name, in ceph_fill_trace()
1659 req->r_dentry->d_name.len))) { in ceph_fill_trace()
1661 * lookup link rename : null -> possibly existing inode in ceph_fill_trace()
1662 * mknod symlink mkdir : null -> new inode in ceph_fill_trace()
1663 * unlink : linked -> null in ceph_fill_trace()
1665 struct inode *dir = req->r_parent; in ceph_fill_trace()
1666 struct dentry *dn = req->r_dentry; in ceph_fill_trace()
1671 BUG_ON(d_inode(dn->d_parent) != dir); in ceph_fill_trace()
1673 dvino.ino = le64_to_cpu(rinfo->diri.in->ino); in ceph_fill_trace()
1674 dvino.snap = le64_to_cpu(rinfo->diri.in->snapid); in ceph_fill_trace()
1681 (le32_to_cpu(rinfo->diri.in->cap.caps) & in ceph_fill_trace()
1686 le32_to_cpu(rinfo->dlease->duration_ms); in ceph_fill_trace()
1691 if (req->r_old_dentry && req->r_op == CEPH_MDS_OP_RENAME) { in ceph_fill_trace()
1692 struct inode *olddir = req->r_old_dentry_dir; in ceph_fill_trace()
1696 req->r_old_dentry, req->r_old_dentry, dn, dn); in ceph_fill_trace()
1697 doutc(cl, "doing d_move %p -> %p\n", req->r_old_dentry, dn); in ceph_fill_trace()
1703 d_move(req->r_old_dentry, dn); in ceph_fill_trace()
1705 req->r_old_dentry, req->r_old_dentry, dn, dn); in ceph_fill_trace()
1712 req->r_old_dentry, in ceph_fill_trace()
1713 ceph_dentry(req->r_old_dentry)->offset); in ceph_fill_trace()
1718 req->r_dentry = req->r_old_dentry; in ceph_fill_trace()
1719 req->r_old_dentry = dn; in ceph_fill_trace()
1720 dn = req->r_dentry; in ceph_fill_trace()
1724 if (!rinfo->head->is_target) { in ceph_fill_trace()
1737 rinfo->dlease, session, in ceph_fill_trace()
1738 req->r_request_started); in ceph_fill_trace()
1746 err = splice_dentry(&req->r_dentry, in); in ceph_fill_trace()
1749 dn = req->r_dentry; /* may have spliced */ in ceph_fill_trace()
1760 rinfo->dlease, session, in ceph_fill_trace()
1761 req->r_request_started); in ceph_fill_trace()
1764 } else if ((req->r_op == CEPH_MDS_OP_LOOKUPSNAP || in ceph_fill_trace()
1765 req->r_op == CEPH_MDS_OP_MKSNAP) && in ceph_fill_trace()
1766 test_bit(CEPH_MDS_R_PARENT_LOCKED, &req->r_req_flags) && in ceph_fill_trace()
1767 !test_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags)) { in ceph_fill_trace()
1768 struct inode *dir = req->r_parent; in ceph_fill_trace()
1773 BUG_ON(!req->r_dentry); in ceph_fill_trace()
1775 req->r_dentry); in ceph_fill_trace()
1778 err = splice_dentry(&req->r_dentry, in); in ceph_fill_trace()
1781 } else if (rinfo->head->is_dentry && req->r_dentry) { in ceph_fill_trace()
1784 dvino.ino = le64_to_cpu(rinfo->diri.in->ino); in ceph_fill_trace()
1785 dvino.snap = le64_to_cpu(rinfo->diri.in->snapid); in ceph_fill_trace()
1786 if (rinfo->head->is_target) { in ceph_fill_trace()
1787 tvino.ino = le64_to_cpu(rinfo->targeti.in->ino); in ceph_fill_trace()
1788 tvino.snap = le64_to_cpu(rinfo->targeti.in->snapid); in ceph_fill_trace()
1791 update_dentry_lease_careful(req->r_dentry, rinfo->dlease, in ceph_fill_trace()
1792 session, req->r_request_started, in ceph_fill_trace()
1793 rinfo->dname, rinfo->dname_len, in ceph_fill_trace()
1807 struct ceph_mds_reply_info_parsed *rinfo = &req->r_reply_info; in readdir_prepopulate_inodes_only()
1808 struct ceph_client *cl = session->s_mdsc->fsc->client; in readdir_prepopulate_inodes_only()
1811 for (i = 0; i < rinfo->dir_nr; i++) { in readdir_prepopulate_inodes_only()
1812 struct ceph_mds_reply_dir_entry *rde = rinfo->dir_entries + i; in readdir_prepopulate_inodes_only()
1817 vino.ino = le64_to_cpu(rde->inode.in->ino); in readdir_prepopulate_inodes_only()
1818 vino.snap = le64_to_cpu(rde->inode.in->snapid); in readdir_prepopulate_inodes_only()
1820 in = ceph_get_inode(req->r_dentry->d_sb, vino, NULL); in readdir_prepopulate_inodes_only()
1826 rc = ceph_fill_inode(in, NULL, &rde->inode, NULL, session, in readdir_prepopulate_inodes_only()
1827 -1, &req->r_caps_reservation); in readdir_prepopulate_inodes_only()
1832 if (in->i_state & I_NEW) { in readdir_prepopulate_inodes_only()
1836 } else if (in->i_state & I_NEW) { in readdir_prepopulate_inodes_only()
1848 if (ctl->folio) { in ceph_readdir_cache_release()
1849 folio_release_kmap(ctl->folio, ctl->dentries); in ceph_readdir_cache_release()
1850 ctl->folio = NULL; in ceph_readdir_cache_release()
1861 unsigned idx = ctl->index % nsize; in fill_readdir_cache()
1862 pgoff_t pgoff = ctl->index / nsize; in fill_readdir_cache()
1864 if (!ctl->folio || pgoff != ctl->folio->index) { in fill_readdir_cache()
1871 ctl->folio = __filemap_get_folio(&dir->i_data, pgoff, in fill_readdir_cache()
1872 fgf, mapping_gfp_mask(&dir->i_data)); in fill_readdir_cache()
1873 if (IS_ERR(ctl->folio)) { in fill_readdir_cache()
1874 int err = PTR_ERR(ctl->folio); in fill_readdir_cache()
1876 ctl->folio = NULL; in fill_readdir_cache()
1877 ctl->index = -1; in fill_readdir_cache()
1882 folio_unlock(ctl->folio); in fill_readdir_cache()
1883 ctl->dentries = kmap_local_folio(ctl->folio, 0); in fill_readdir_cache()
1885 memset(ctl->dentries, 0, PAGE_SIZE); in fill_readdir_cache()
1888 if (req->r_dir_release_cnt == atomic64_read(&ci->i_release_count) && in fill_readdir_cache()
1889 req->r_dir_ordered_cnt == atomic64_read(&ci->i_ordered_count)) { in fill_readdir_cache()
1890 doutc(cl, "dn %p idx %d\n", dn, ctl->index); in fill_readdir_cache()
1891 ctl->dentries[idx] = dn; in fill_readdir_cache()
1892 ctl->index++; in fill_readdir_cache()
1895 ctl->index = -1; in fill_readdir_cache()
1903 struct dentry *parent = req->r_dentry; in ceph_readdir_prepopulate()
1906 struct ceph_mds_reply_info_parsed *rinfo = &req->r_reply_info; in ceph_readdir_prepopulate()
1907 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_readdir_prepopulate()
1912 u32 frag = le32_to_cpu(req->r_args.readdir.frag); in ceph_readdir_prepopulate()
1917 if (test_bit(CEPH_MDS_R_ABORTED, &req->r_req_flags)) in ceph_readdir_prepopulate()
1920 if (rinfo->hash_order) { in ceph_readdir_prepopulate()
1921 if (req->r_path2) { in ceph_readdir_prepopulate()
1922 last_hash = ceph_str_hash(ci->i_dir_layout.dl_dir_hash, in ceph_readdir_prepopulate()
1923 req->r_path2, in ceph_readdir_prepopulate()
1924 strlen(req->r_path2)); in ceph_readdir_prepopulate()
1926 } else if (rinfo->offset_hash) { in ceph_readdir_prepopulate()
1928 WARN_ON_ONCE(req->r_readdir_offset != 2); in ceph_readdir_prepopulate()
1929 last_hash = le32_to_cpu(req->r_args.readdir.offset_hash); in ceph_readdir_prepopulate()
1933 if (rinfo->dir_dir && in ceph_readdir_prepopulate()
1934 le32_to_cpu(rinfo->dir_dir->frag) != frag) { in ceph_readdir_prepopulate()
1935 doutc(cl, "got new frag %x -> %x\n", frag, in ceph_readdir_prepopulate()
1936 le32_to_cpu(rinfo->dir_dir->frag)); in ceph_readdir_prepopulate()
1937 frag = le32_to_cpu(rinfo->dir_dir->frag); in ceph_readdir_prepopulate()
1938 if (!rinfo->hash_order) in ceph_readdir_prepopulate()
1939 req->r_readdir_offset = 2; in ceph_readdir_prepopulate()
1942 if (le32_to_cpu(rinfo->head->op) == CEPH_MDS_OP_LSSNAP) { in ceph_readdir_prepopulate()
1944 rinfo->dir_nr, parent); in ceph_readdir_prepopulate()
1946 doutc(cl, "%d items under dn %p\n", rinfo->dir_nr, parent); in ceph_readdir_prepopulate()
1947 if (rinfo->dir_dir) in ceph_readdir_prepopulate()
1948 ceph_fill_dirfrag(d_inode(parent), rinfo->dir_dir); in ceph_readdir_prepopulate()
1951 req->r_readdir_offset == 2 && in ceph_readdir_prepopulate()
1952 !(rinfo->hash_order && last_hash)) { in ceph_readdir_prepopulate()
1955 req->r_dir_release_cnt = in ceph_readdir_prepopulate()
1956 atomic64_read(&ci->i_release_count); in ceph_readdir_prepopulate()
1957 req->r_dir_ordered_cnt = in ceph_readdir_prepopulate()
1958 atomic64_read(&ci->i_ordered_count); in ceph_readdir_prepopulate()
1959 req->r_readdir_cache_idx = 0; in ceph_readdir_prepopulate()
1963 cache_ctl.index = req->r_readdir_cache_idx; in ceph_readdir_prepopulate()
1964 fpos_offset = req->r_readdir_offset; in ceph_readdir_prepopulate()
1967 for (i = 0; i < rinfo->dir_nr; i++) { in ceph_readdir_prepopulate()
1968 struct ceph_mds_reply_dir_entry *rde = rinfo->dir_entries + i; in ceph_readdir_prepopulate()
1971 dname.name = rde->name; in ceph_readdir_prepopulate()
1972 dname.len = rde->name_len; in ceph_readdir_prepopulate()
1975 tvino.ino = le64_to_cpu(rde->inode.in->ino); in ceph_readdir_prepopulate()
1976 tvino.snap = le64_to_cpu(rde->inode.in->snapid); in ceph_readdir_prepopulate()
1978 if (rinfo->hash_order) { in ceph_readdir_prepopulate()
1979 u32 hash = ceph_frag_value(rde->raw_hash); in ceph_readdir_prepopulate()
1983 rde->offset = ceph_make_fpos(hash, fpos_offset++, true); in ceph_readdir_prepopulate()
1985 rde->offset = ceph_make_fpos(frag, fpos_offset++, false); in ceph_readdir_prepopulate()
1999 err = -ENOMEM; in ceph_readdir_prepopulate()
2002 if (rde->is_nokey) { in ceph_readdir_prepopulate()
2003 spin_lock(&dn->d_lock); in ceph_readdir_prepopulate()
2004 dn->d_flags |= DCACHE_NOKEY_NAME; in ceph_readdir_prepopulate()
2005 spin_unlock(&dn->d_lock); in ceph_readdir_prepopulate()
2014 spin_lock(&dn->d_lock); in ceph_readdir_prepopulate()
2015 if (di->offset > 0 && in ceph_readdir_prepopulate()
2016 di->lease_shared_gen == in ceph_readdir_prepopulate()
2017 atomic_read(&ci->i_shared_gen)) { in ceph_readdir_prepopulate()
2019 di->offset = 0; in ceph_readdir_prepopulate()
2021 spin_unlock(&dn->d_lock); in ceph_readdir_prepopulate()
2032 in = ceph_get_inode(parent->d_sb, tvino, NULL); in ceph_readdir_prepopulate()
2042 ret = ceph_fill_inode(in, NULL, &rde->inode, NULL, session, in ceph_readdir_prepopulate()
2043 -1, &req->r_caps_reservation); in ceph_readdir_prepopulate()
2048 if (in->i_state & I_NEW) { in ceph_readdir_prepopulate()
2058 if (in->i_state & I_NEW) in ceph_readdir_prepopulate()
2075 ceph_dentry(dn)->offset = rde->offset; in ceph_readdir_prepopulate()
2078 rde->lease, req->r_session, in ceph_readdir_prepopulate()
2079 req->r_request_started); in ceph_readdir_prepopulate()
2092 set_bit(CEPH_MDS_R_DID_PREPOPULATE, &req->r_req_flags); in ceph_readdir_prepopulate()
2093 req->r_readdir_cache_idx = cache_ctl.index; in ceph_readdir_prepopulate()
2106 spin_lock(&ci->i_ceph_lock); in ceph_inode_set_size()
2107 doutc(cl, "set_size %p %llu -> %llu\n", inode, i_size_read(inode), size); in ceph_inode_set_size()
2110 inode->i_blocks = calc_inode_blocks(size); in ceph_inode_set_size()
2114 spin_unlock(&ci->i_ceph_lock); in ceph_inode_set_size()
2122 struct ceph_client *cl = fsc->client; in ceph_queue_inode_work()
2124 set_bit(work_bit, &ci->i_work_mask); in ceph_queue_inode_work()
2127 if (queue_work(fsc->inode_wq, &ci->i_work)) { in ceph_queue_inode_work()
2129 ceph_vinop(inode), ci->i_work_mask); in ceph_queue_inode_work()
2132 inode, ceph_vinop(inode), ci->i_work_mask); in ceph_queue_inode_work()
2146 mutex_lock(&ci->i_truncate_mutex); in ceph_do_invalidate_pages()
2152 mapping_set_error(inode->i_mapping, -EIO); in ceph_do_invalidate_pages()
2154 mutex_unlock(&ci->i_truncate_mutex); in ceph_do_invalidate_pages()
2158 spin_lock(&ci->i_ceph_lock); in ceph_do_invalidate_pages()
2160 ceph_vinop(inode), ci->i_rdcache_gen, ci->i_rdcache_revoking); in ceph_do_invalidate_pages()
2161 if (ci->i_rdcache_revoking != ci->i_rdcache_gen) { in ceph_do_invalidate_pages()
2164 spin_unlock(&ci->i_ceph_lock); in ceph_do_invalidate_pages()
2165 mutex_unlock(&ci->i_truncate_mutex); in ceph_do_invalidate_pages()
2168 orig_gen = ci->i_rdcache_gen; in ceph_do_invalidate_pages()
2169 spin_unlock(&ci->i_ceph_lock); in ceph_do_invalidate_pages()
2171 if (invalidate_inode_pages2(inode->i_mapping) < 0) { in ceph_do_invalidate_pages()
2176 spin_lock(&ci->i_ceph_lock); in ceph_do_invalidate_pages()
2177 if (orig_gen == ci->i_rdcache_gen && in ceph_do_invalidate_pages()
2178 orig_gen == ci->i_rdcache_revoking) { in ceph_do_invalidate_pages()
2180 ceph_vinop(inode), ci->i_rdcache_gen); in ceph_do_invalidate_pages()
2181 ci->i_rdcache_revoking--; in ceph_do_invalidate_pages()
2185 inode, ceph_vinop(inode), orig_gen, ci->i_rdcache_gen, in ceph_do_invalidate_pages()
2186 ci->i_rdcache_revoking); in ceph_do_invalidate_pages()
2190 spin_unlock(&ci->i_ceph_lock); in ceph_do_invalidate_pages()
2191 mutex_unlock(&ci->i_truncate_mutex); in ceph_do_invalidate_pages()
2208 mutex_lock(&ci->i_truncate_mutex); in __ceph_do_pending_vmtruncate()
2210 spin_lock(&ci->i_ceph_lock); in __ceph_do_pending_vmtruncate()
2211 if (ci->i_truncate_pending == 0) { in __ceph_do_pending_vmtruncate()
2214 spin_unlock(&ci->i_ceph_lock); in __ceph_do_pending_vmtruncate()
2215 mutex_unlock(&ci->i_truncate_mutex); in __ceph_do_pending_vmtruncate()
2223 if (ci->i_wrbuffer_ref_head < ci->i_wrbuffer_ref) { in __ceph_do_pending_vmtruncate()
2224 spin_unlock(&ci->i_ceph_lock); in __ceph_do_pending_vmtruncate()
2227 filemap_write_and_wait_range(&inode->i_data, 0, in __ceph_do_pending_vmtruncate()
2228 inode->i_sb->s_maxbytes); in __ceph_do_pending_vmtruncate()
2233 WARN_ON_ONCE(ci->i_rd_ref || ci->i_wr_ref); in __ceph_do_pending_vmtruncate()
2235 to = ci->i_truncate_pagecache_size; in __ceph_do_pending_vmtruncate()
2236 wrbuffer_refs = ci->i_wrbuffer_ref; in __ceph_do_pending_vmtruncate()
2238 ci->i_truncate_pending, to); in __ceph_do_pending_vmtruncate()
2239 spin_unlock(&ci->i_ceph_lock); in __ceph_do_pending_vmtruncate()
2244 spin_lock(&ci->i_ceph_lock); in __ceph_do_pending_vmtruncate()
2245 if (to == ci->i_truncate_pagecache_size) { in __ceph_do_pending_vmtruncate()
2246 ci->i_truncate_pending = 0; in __ceph_do_pending_vmtruncate()
2249 spin_unlock(&ci->i_ceph_lock); in __ceph_do_pending_vmtruncate()
2253 mutex_unlock(&ci->i_truncate_mutex); in __ceph_do_pending_vmtruncate()
2258 wake_up_all(&ci->i_cap_wq); in __ceph_do_pending_vmtruncate()
2265 struct inode *inode = &ci->netfs.inode; in ceph_inode_work()
2268 if (test_and_clear_bit(CEPH_I_WORK_WRITEBACK, &ci->i_work_mask)) { in ceph_inode_work()
2270 filemap_fdatawrite(&inode->i_data); in ceph_inode_work()
2272 if (test_and_clear_bit(CEPH_I_WORK_INVALIDATE_PAGES, &ci->i_work_mask)) in ceph_inode_work()
2275 if (test_and_clear_bit(CEPH_I_WORK_VMTRUNCATE, &ci->i_work_mask)) in ceph_inode_work()
2278 if (test_and_clear_bit(CEPH_I_WORK_CHECK_CAPS, &ci->i_work_mask)) in ceph_inode_work()
2281 if (test_and_clear_bit(CEPH_I_WORK_FLUSH_SNAPS, &ci->i_work_mask)) in ceph_inode_work()
2294 return ERR_PTR(-ECHILD); in ceph_encrypted_get_link()
2296 return fscrypt_get_symlink(inode, ci->i_symlink, i_size_read(inode), in ceph_encrypted_get_link()
2343 int boff = attr->ia_size % CEPH_FSCRYPT_BLOCK_SIZE; in fill_fscrypt_truncate()
2344 loff_t pos, orig_pos = round_down(attr->ia_size, in fill_fscrypt_truncate()
2358 ret = __ceph_get_caps(inode, NULL, CEPH_CAP_FILE_RD, 0, -1, &got); in fill_fscrypt_truncate()
2364 doutc(cl, "size %lld -> %lld got cap refs on %s, issued %s\n", in fill_fscrypt_truncate()
2365 i_size, attr->ia_size, ceph_cap_string(got), in fill_fscrypt_truncate()
2370 loff_t lend = orig_pos + CEPH_FSCRYPT_BLOCK_SIZE - 1; in fill_fscrypt_truncate()
2372 ret = filemap_write_and_wait_range(inode->i_mapping, in fill_fscrypt_truncate()
2380 ret = -ENOMEM; in fill_fscrypt_truncate()
2386 ret = -ENOMEM; in fill_fscrypt_truncate()
2434 memset(iov.iov_base + boff, 0, PAGE_SIZE - boff); in fill_fscrypt_truncate()
2456 req->r_pagelist = pagelist; in fill_fscrypt_truncate()
2474 unsigned int ia_valid = attr->ia_valid; in __ceph_setattr()
2476 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; in __ceph_setattr()
2509 if (err == -EACCES) { in __ceph_setattr()
2520 return -ENOMEM; in __ceph_setattr()
2530 spin_lock(&ci->i_ceph_lock); in __ceph_setattr()
2533 if (!ci->i_head_snapc && in __ceph_setattr()
2536 if (!down_read_trylock(&mdsc->snap_rwsem)) { in __ceph_setattr()
2537 spin_unlock(&ci->i_ceph_lock); in __ceph_setattr()
2538 down_read(&mdsc->snap_rwsem); in __ceph_setattr()
2539 spin_lock(&ci->i_ceph_lock); in __ceph_setattr()
2547 if (cia && cia->fscrypt_auth) { in __ceph_setattr()
2548 u32 len = ceph_fscrypt_auth_len(cia->fscrypt_auth); in __ceph_setattr()
2550 if (len > sizeof(*cia->fscrypt_auth)) { in __ceph_setattr()
2551 err = -EINVAL; in __ceph_setattr()
2552 spin_unlock(&ci->i_ceph_lock); in __ceph_setattr()
2557 ceph_vinop(inode), ci->fscrypt_auth_len, len); in __ceph_setattr()
2559 /* It should never be re-set once set */ in __ceph_setattr()
2560 WARN_ON_ONCE(ci->fscrypt_auth); in __ceph_setattr()
2564 kfree(ci->fscrypt_auth); in __ceph_setattr()
2565 ci->fscrypt_auth = (u8 *)cia->fscrypt_auth; in __ceph_setattr()
2566 ci->fscrypt_auth_len = len; in __ceph_setattr()
2568 ci->fscrypt_auth_len != len || in __ceph_setattr()
2569 memcmp(ci->fscrypt_auth, cia->fscrypt_auth, len)) { in __ceph_setattr()
2570 req->r_fscrypt_auth = cia->fscrypt_auth; in __ceph_setattr()
2574 cia->fscrypt_auth = NULL; in __ceph_setattr()
2577 if (cia && cia->fscrypt_auth) { in __ceph_setattr()
2578 err = -EINVAL; in __ceph_setattr()
2579 spin_unlock(&ci->i_ceph_lock); in __ceph_setattr()
2585 kuid_t fsuid = from_vfsuid(idmap, i_user_ns(inode), attr->ia_vfsuid); in __ceph_setattr()
2587 doutc(cl, "%p %llx.%llx uid %d -> %d\n", inode, in __ceph_setattr()
2589 from_kuid(&init_user_ns, inode->i_uid), in __ceph_setattr()
2590 from_kuid(&init_user_ns, attr->ia_uid)); in __ceph_setattr()
2592 inode->i_uid = fsuid; in __ceph_setattr()
2595 !uid_eq(fsuid, inode->i_uid)) { in __ceph_setattr()
2596 req->r_args.setattr.uid = cpu_to_le32( in __ceph_setattr()
2603 kgid_t fsgid = from_vfsgid(idmap, i_user_ns(inode), attr->ia_vfsgid); in __ceph_setattr()
2605 doutc(cl, "%p %llx.%llx gid %d -> %d\n", inode, in __ceph_setattr()
2607 from_kgid(&init_user_ns, inode->i_gid), in __ceph_setattr()
2608 from_kgid(&init_user_ns, attr->ia_gid)); in __ceph_setattr()
2610 inode->i_gid = fsgid; in __ceph_setattr()
2613 !gid_eq(fsgid, inode->i_gid)) { in __ceph_setattr()
2614 req->r_args.setattr.gid = cpu_to_le32( in __ceph_setattr()
2621 doutc(cl, "%p %llx.%llx mode 0%o -> 0%o\n", inode, in __ceph_setattr()
2622 ceph_vinop(inode), inode->i_mode, attr->ia_mode); in __ceph_setattr()
2624 inode->i_mode = attr->ia_mode; in __ceph_setattr()
2627 attr->ia_mode != inode->i_mode) { in __ceph_setattr()
2628 inode->i_mode = attr->ia_mode; in __ceph_setattr()
2629 req->r_args.setattr.mode = cpu_to_le32(attr->ia_mode); in __ceph_setattr()
2638 doutc(cl, "%p %llx.%llx atime %lld.%09ld -> %lld.%09ld\n", in __ceph_setattr()
2641 attr->ia_atime.tv_sec, attr->ia_atime.tv_nsec); in __ceph_setattr()
2643 ci->i_time_warp_seq++; in __ceph_setattr()
2644 inode_set_atime_to_ts(inode, attr->ia_atime); in __ceph_setattr()
2648 &attr->ia_atime) < 0) { in __ceph_setattr()
2649 inode_set_atime_to_ts(inode, attr->ia_atime); in __ceph_setattr()
2652 !timespec64_equal(&atime, &attr->ia_atime)) { in __ceph_setattr()
2653 ceph_encode_timespec64(&req->r_args.setattr.atime, in __ceph_setattr()
2654 &attr->ia_atime); in __ceph_setattr()
2661 doutc(cl, "%p %llx.%llx size %lld -> %lld\n", inode, in __ceph_setattr()
2662 ceph_vinop(inode), isize, attr->ia_size); in __ceph_setattr()
2667 if (IS_ENCRYPTED(inode) && attr->ia_size < isize && in __ceph_setattr()
2668 (attr->ia_size % CEPH_FSCRYPT_BLOCK_SIZE)) { in __ceph_setattr()
2672 set_bit(CEPH_MDS_R_FSCRYPT_FILE, &req->r_req_flags); in __ceph_setattr()
2674 req->r_args.setattr.size = in __ceph_setattr()
2675 cpu_to_le64(round_up(attr->ia_size, in __ceph_setattr()
2677 req->r_args.setattr.old_size = in __ceph_setattr()
2680 req->r_fscrypt_file = attr->ia_size; in __ceph_setattr()
2682 } else if (!do_sync && (issued & CEPH_CAP_FILE_EXCL) && attr->ia_size >= isize) { in __ceph_setattr()
2683 if (attr->ia_size > isize) { in __ceph_setattr()
2684 i_size_write(inode, attr->ia_size); in __ceph_setattr()
2685 inode->i_blocks = calc_inode_blocks(attr->ia_size); in __ceph_setattr()
2686 ci->i_reported_size = attr->ia_size; in __ceph_setattr()
2691 attr->ia_size != isize) { in __ceph_setattr()
2695 if (IS_ENCRYPTED(inode) && attr->ia_size) { in __ceph_setattr()
2696 set_bit(CEPH_MDS_R_FSCRYPT_FILE, &req->r_req_flags); in __ceph_setattr()
2698 req->r_args.setattr.size = in __ceph_setattr()
2699 cpu_to_le64(round_up(attr->ia_size, in __ceph_setattr()
2701 req->r_args.setattr.old_size = in __ceph_setattr()
2704 req->r_fscrypt_file = attr->ia_size; in __ceph_setattr()
2706 req->r_args.setattr.size = cpu_to_le64(attr->ia_size); in __ceph_setattr()
2707 req->r_args.setattr.old_size = cpu_to_le64(isize); in __ceph_setattr()
2708 req->r_fscrypt_file = 0; in __ceph_setattr()
2715 doutc(cl, "%p %llx.%llx mtime %lld.%09ld -> %lld.%09ld\n", in __ceph_setattr()
2718 attr->ia_mtime.tv_sec, attr->ia_mtime.tv_nsec); in __ceph_setattr()
2720 ci->i_time_warp_seq++; in __ceph_setattr()
2721 inode_set_mtime_to_ts(inode, attr->ia_mtime); in __ceph_setattr()
2724 timespec64_compare(&mtime, &attr->ia_mtime) < 0) { in __ceph_setattr()
2725 inode_set_mtime_to_ts(inode, attr->ia_mtime); in __ceph_setattr()
2728 !timespec64_equal(&mtime, &attr->ia_mtime)) { in __ceph_setattr()
2729 ceph_encode_timespec64(&req->r_args.setattr.mtime, in __ceph_setattr()
2730 &attr->ia_mtime); in __ceph_setattr()
2741 doutc(cl, "%p %llx.%llx ctime %lld.%09ld -> %lld.%09ld (%s)\n", in __ceph_setattr()
2745 attr->ia_ctime.tv_sec, attr->ia_ctime.tv_nsec, in __ceph_setattr()
2751 * a almost-no-op setattr in __ceph_setattr()
2770 inode_set_ctime_to_ts(inode, attr->ia_ctime); in __ceph_setattr()
2775 spin_unlock(&ci->i_ceph_lock); in __ceph_setattr()
2777 up_read(&mdsc->snap_rwsem); in __ceph_setattr()
2785 req->r_inode = inode; in __ceph_setattr()
2787 req->r_inode_drop = release; in __ceph_setattr()
2788 req->r_args.setattr.mask = cpu_to_le32(mask); in __ceph_setattr()
2789 req->r_num_caps = 1; in __ceph_setattr()
2790 req->r_stamp = attr->ia_ctime; in __ceph_setattr()
2798 * The truncate request will return -EAGAIN when the in __ceph_setattr()
2805 if (err == -EAGAIN && truncate_retry--) { in __ceph_setattr()
2838 return -EROFS; in ceph_setattr()
2841 return -ESTALE; in ceph_setattr()
2851 if ((attr->ia_valid & ATTR_SIZE) && in ceph_setattr()
2852 attr->ia_size > max(i_size_read(inode), fsc->max_file_size)) in ceph_setattr()
2853 return -EFBIG; in ceph_setattr()
2855 if ((attr->ia_valid & ATTR_SIZE) && in ceph_setattr()
2856 ceph_quota_is_max_bytes_exceeded(inode, attr->ia_size)) in ceph_setattr()
2857 return -EDQUOT; in ceph_setattr()
2861 if (err >= 0 && (attr->ia_valid & ATTR_MODE)) in ceph_setattr()
2862 err = posix_acl_chmod(idmap, dentry, attr->ia_mode); in ceph_setattr()
2904 struct ceph_fs_client *fsc = ceph_sb_to_fs_client(inode->i_sb); in __ceph_do_getattr()
2905 struct ceph_client *cl = fsc->client; in __ceph_do_getattr()
2906 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_do_getattr()
2918 ceph_vinop(inode), ceph_cap_string(mask), inode->i_mode); in __ceph_do_getattr()
2926 req->r_inode = inode; in __ceph_do_getattr()
2928 req->r_num_caps = 1; in __ceph_do_getattr()
2929 req->r_args.getattr.mask = cpu_to_le32(mask); in __ceph_do_getattr()
2930 req->r_locked_page = locked_page; in __ceph_do_getattr()
2933 u64 inline_version = req->r_reply_info.targeti.inline_version; in __ceph_do_getattr()
2936 err = -EINVAL; in __ceph_do_getattr()
2939 err = -ENODATA; in __ceph_do_getattr()
2941 err = req->r_reply_info.targeti.inline_len; in __ceph_do_getattr()
2952 struct ceph_fs_client *fsc = ceph_sb_to_fs_client(inode->i_sb); in ceph_do_getvxattr()
2953 struct ceph_client *cl = fsc->client; in ceph_do_getvxattr()
2954 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_do_getvxattr()
2963 err = -ENOMEM; in ceph_do_getvxattr()
2967 req->r_feature_needed = CEPHFS_FEATURE_OP_GETVXATTR; in ceph_do_getvxattr()
2968 req->r_path2 = kstrdup(name, GFP_NOFS); in ceph_do_getvxattr()
2969 if (!req->r_path2) { in ceph_do_getvxattr()
2970 err = -ENOMEM; in ceph_do_getvxattr()
2975 req->r_inode = inode; in ceph_do_getvxattr()
2980 xattr_value = req->r_reply_info.xattr_info.xattr_value; in ceph_do_getvxattr()
2981 xattr_value_len = req->r_reply_info.xattr_info.xattr_value_len; in ceph_do_getvxattr()
2990 err = -ERANGE; in ceph_do_getvxattr()
3013 return -ECHILD; in ceph_permission()
3032 * The link count for directories depends on inode->i_subdirs, in statx_to_caps()
3057 struct inode *inode = d_inode(path->dentry); in ceph_getattr()
3058 struct super_block *sb = inode->i_sb; in ceph_getattr()
3064 return -ESTALE; in ceph_getattr()
3069 statx_to_caps(request_mask, inode->i_mode), in ceph_getattr()
3076 stat->ino = ceph_present_inode(inode); in ceph_getattr()
3079 * btime on newly-allocated inodes is 0, so if this is still set to in ceph_getattr()
3082 if (ci->i_btime.tv_sec || ci->i_btime.tv_nsec) { in ceph_getattr()
3083 stat->btime = ci->i_btime; in ceph_getattr()
3088 stat->change_cookie = inode_peek_iversion_raw(inode); in ceph_getattr()
3093 stat->dev = sb->s_dev; in ceph_getattr()
3095 stat->dev = ci->i_snapid_map ? ci->i_snapid_map->dev : 0; in ceph_getattr()
3097 if (S_ISDIR(inode->i_mode)) { in ceph_getattr()
3099 stat->size = ci->i_rbytes; in ceph_getattr()
3102 struct ceph_snap_realm *realm; in ceph_getattr() local
3110 spin_lock(&pci->i_ceph_lock); in ceph_getattr()
3111 realm = pci->i_snap_realm; in ceph_getattr()
3112 if (realm) in ceph_getattr()
3113 stat->size = realm->num_snaps; in ceph_getattr()
3115 stat->size = 0; in ceph_getattr()
3116 spin_unlock(&pci->i_ceph_lock); in ceph_getattr()
3119 stat->size = ci->i_files + ci->i_subdirs; in ceph_getattr()
3121 stat->blocks = 0; in ceph_getattr()
3122 stat->blksize = 65536; in ceph_getattr()
3128 if (stat->nlink == 1) in ceph_getattr()
3130 stat->nlink = 1 + 1 + ci->i_subdirs; in ceph_getattr()
3133 stat->attributes |= STATX_ATTR_CHANGE_MONOTONIC; in ceph_getattr()
3135 stat->attributes |= STATX_ATTR_ENCRYPTED; in ceph_getattr()
3136 stat->attributes_mask |= (STATX_ATTR_CHANGE_MONOTONIC | in ceph_getattr()
3139 stat->result_mask = request_mask & valid_mask; in ceph_getattr()
3150 spin_lock(&ci->i_ceph_lock); in ceph_inode_shutdown()
3151 ci->i_ceph_flags |= CEPH_I_SHUTDOWN; in ceph_inode_shutdown()
3152 p = rb_first(&ci->i_caps); in ceph_inode_shutdown()
3159 spin_unlock(&ci->i_ceph_lock); in ceph_inode_shutdown()
3163 while (iputs--) in ceph_inode_shutdown()