Lines Matching refs:ci
18 static int __remove_xattr(struct ceph_inode_info *ci,
36 ssize_t (*getxattr_cb)(struct ceph_inode_info *ci, char *val,
38 bool (*exists_cb)(struct ceph_inode_info *ci);
48 static bool ceph_vxattrcb_layout_exists(struct ceph_inode_info *ci) in ceph_vxattrcb_layout_exists() argument
50 struct ceph_file_layout *fl = &ci->i_layout; in ceph_vxattrcb_layout_exists()
56 static ssize_t ceph_vxattrcb_layout(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_layout() argument
59 struct ceph_fs_client *fsc = ceph_sb_to_client(ci->vfs_inode.i_sb); in ceph_vxattrcb_layout()
62 s64 pool = ci->i_layout.pool_id; in ceph_vxattrcb_layout()
69 pool_ns = ceph_try_get_string(ci->i_layout.pool_ns); in ceph_vxattrcb_layout()
71 dout("ceph_vxattrcb_layout %p\n", &ci->vfs_inode); in ceph_vxattrcb_layout()
77 ci->i_layout.stripe_unit, ci->i_layout.stripe_count, in ceph_vxattrcb_layout()
78 ci->i_layout.object_size); in ceph_vxattrcb_layout()
83 ci->i_layout.stripe_unit, ci->i_layout.stripe_count, in ceph_vxattrcb_layout()
84 ci->i_layout.object_size, pool); in ceph_vxattrcb_layout()
141 static ssize_t ceph_vxattrcb_layout_stripe_unit(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_stripe_unit() argument
144 return ceph_fmt_xattr(val, size, "%u", ci->i_layout.stripe_unit); in ceph_vxattrcb_layout_stripe_unit()
147 static ssize_t ceph_vxattrcb_layout_stripe_count(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_stripe_count() argument
150 return ceph_fmt_xattr(val, size, "%u", ci->i_layout.stripe_count); in ceph_vxattrcb_layout_stripe_count()
153 static ssize_t ceph_vxattrcb_layout_object_size(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_object_size() argument
156 return ceph_fmt_xattr(val, size, "%u", ci->i_layout.object_size); in ceph_vxattrcb_layout_object_size()
159 static ssize_t ceph_vxattrcb_layout_pool(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_pool() argument
163 struct ceph_fs_client *fsc = ceph_sb_to_client(ci->vfs_inode.i_sb); in ceph_vxattrcb_layout_pool()
165 s64 pool = ci->i_layout.pool_id; in ceph_vxattrcb_layout_pool()
181 static ssize_t ceph_vxattrcb_layout_pool_namespace(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_pool_namespace() argument
185 struct ceph_string *ns = ceph_try_get_string(ci->i_layout.pool_ns); in ceph_vxattrcb_layout_pool_namespace()
198 static ssize_t ceph_vxattrcb_dir_entries(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_entries() argument
201 return ceph_fmt_xattr(val, size, "%lld", ci->i_files + ci->i_subdirs); in ceph_vxattrcb_dir_entries()
204 static ssize_t ceph_vxattrcb_dir_files(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_files() argument
207 return ceph_fmt_xattr(val, size, "%lld", ci->i_files); in ceph_vxattrcb_dir_files()
210 static ssize_t ceph_vxattrcb_dir_subdirs(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_subdirs() argument
213 return ceph_fmt_xattr(val, size, "%lld", ci->i_subdirs); in ceph_vxattrcb_dir_subdirs()
216 static ssize_t ceph_vxattrcb_dir_rentries(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rentries() argument
220 ci->i_rfiles + ci->i_rsubdirs); in ceph_vxattrcb_dir_rentries()
223 static ssize_t ceph_vxattrcb_dir_rfiles(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rfiles() argument
226 return ceph_fmt_xattr(val, size, "%lld", ci->i_rfiles); in ceph_vxattrcb_dir_rfiles()
229 static ssize_t ceph_vxattrcb_dir_rsubdirs(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rsubdirs() argument
232 return ceph_fmt_xattr(val, size, "%lld", ci->i_rsubdirs); in ceph_vxattrcb_dir_rsubdirs()
235 static ssize_t ceph_vxattrcb_dir_rbytes(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rbytes() argument
238 return ceph_fmt_xattr(val, size, "%lld", ci->i_rbytes); in ceph_vxattrcb_dir_rbytes()
241 static ssize_t ceph_vxattrcb_dir_rctime(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rctime() argument
244 return ceph_fmt_xattr(val, size, "%lld.%09ld", ci->i_rctime.tv_sec, in ceph_vxattrcb_dir_rctime()
245 ci->i_rctime.tv_nsec); in ceph_vxattrcb_dir_rctime()
249 static bool ceph_vxattrcb_dir_pin_exists(struct ceph_inode_info *ci) in ceph_vxattrcb_dir_pin_exists() argument
251 return ci->i_dir_pin != -ENODATA; in ceph_vxattrcb_dir_pin_exists()
254 static ssize_t ceph_vxattrcb_dir_pin(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_pin() argument
257 return ceph_fmt_xattr(val, size, "%d", (int)ci->i_dir_pin); in ceph_vxattrcb_dir_pin()
261 static bool ceph_vxattrcb_quota_exists(struct ceph_inode_info *ci) in ceph_vxattrcb_quota_exists() argument
264 spin_lock(&ci->i_ceph_lock); in ceph_vxattrcb_quota_exists()
265 if ((ci->i_max_files || ci->i_max_bytes) && in ceph_vxattrcb_quota_exists()
266 ci->i_vino.snap == CEPH_NOSNAP && in ceph_vxattrcb_quota_exists()
267 ci->i_snap_realm && in ceph_vxattrcb_quota_exists()
268 ci->i_snap_realm->ino == ci->i_vino.ino) in ceph_vxattrcb_quota_exists()
270 spin_unlock(&ci->i_ceph_lock); in ceph_vxattrcb_quota_exists()
274 static ssize_t ceph_vxattrcb_quota(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_quota() argument
278 ci->i_max_bytes, ci->i_max_files); in ceph_vxattrcb_quota()
281 static ssize_t ceph_vxattrcb_quota_max_bytes(struct ceph_inode_info *ci, in ceph_vxattrcb_quota_max_bytes() argument
284 return ceph_fmt_xattr(val, size, "%llu", ci->i_max_bytes); in ceph_vxattrcb_quota_max_bytes()
287 static ssize_t ceph_vxattrcb_quota_max_files(struct ceph_inode_info *ci, in ceph_vxattrcb_quota_max_files() argument
290 return ceph_fmt_xattr(val, size, "%llu", ci->i_max_files); in ceph_vxattrcb_quota_max_files()
294 static bool ceph_vxattrcb_snap_btime_exists(struct ceph_inode_info *ci) in ceph_vxattrcb_snap_btime_exists() argument
296 return (ci->i_snap_btime.tv_sec != 0 || ci->i_snap_btime.tv_nsec != 0); in ceph_vxattrcb_snap_btime_exists()
299 static ssize_t ceph_vxattrcb_snap_btime(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_snap_btime() argument
302 return ceph_fmt_xattr(val, size, "%lld.%09ld", ci->i_snap_btime.tv_sec, in ceph_vxattrcb_snap_btime()
303 ci->i_snap_btime.tv_nsec); in ceph_vxattrcb_snap_btime()
434 static int __set_xattr(struct ceph_inode_info *ci, in __set_xattr() argument
446 p = &ci->i_xattrs.index.rb_node; in __set_xattr()
481 __remove_xattr(ci, xattr); in __set_xattr()
495 ci->i_xattrs.count++; in __set_xattr()
496 dout("__set_xattr count=%d\n", ci->i_xattrs.count); in __set_xattr()
507 ci->i_xattrs.names_size -= xattr->name_len; in __set_xattr()
508 ci->i_xattrs.vals_size -= xattr->val_len; in __set_xattr()
510 ci->i_xattrs.names_size += name_len; in __set_xattr()
511 ci->i_xattrs.vals_size += val_len; in __set_xattr()
523 rb_insert_color(&xattr->node, &ci->i_xattrs.index); in __set_xattr()
528 ceph_vinop(&ci->vfs_inode), xattr, name_len, name, val_len, val); in __set_xattr()
533 static struct ceph_inode_xattr *__get_xattr(struct ceph_inode_info *ci, in __get_xattr() argument
542 p = &ci->i_xattrs.index.rb_node; in __get_xattr()
577 static int __remove_xattr(struct ceph_inode_info *ci, in __remove_xattr() argument
583 rb_erase(&xattr->node, &ci->i_xattrs.index); in __remove_xattr()
590 ci->i_xattrs.names_size -= xattr->name_len; in __remove_xattr()
591 ci->i_xattrs.vals_size -= xattr->val_len; in __remove_xattr()
592 ci->i_xattrs.count--; in __remove_xattr()
598 static char *__copy_xattr_names(struct ceph_inode_info *ci, in __copy_xattr_names() argument
604 p = rb_first(&ci->i_xattrs.index); in __copy_xattr_names()
605 dout("__copy_xattr_names count=%d\n", ci->i_xattrs.count); in __copy_xattr_names()
613 xattr->name_len, ci->i_xattrs.names_size); in __copy_xattr_names()
622 void __ceph_destroy_xattrs(struct ceph_inode_info *ci) in __ceph_destroy_xattrs() argument
627 p = rb_first(&ci->i_xattrs.index); in __ceph_destroy_xattrs()
637 rb_erase(tmp, &ci->i_xattrs.index); in __ceph_destroy_xattrs()
642 ci->i_xattrs.names_size = 0; in __ceph_destroy_xattrs()
643 ci->i_xattrs.vals_size = 0; in __ceph_destroy_xattrs()
644 ci->i_xattrs.index_version = 0; in __ceph_destroy_xattrs()
645 ci->i_xattrs.count = 0; in __ceph_destroy_xattrs()
646 ci->i_xattrs.index = RB_ROOT; in __ceph_destroy_xattrs()
650 __releases(ci->i_ceph_lock) in __build_xattrs()
651 __acquires(ci->i_ceph_lock) in __build_xattrs()
658 struct ceph_inode_info *ci = ceph_inode(inode); in __build_xattrs() local
665 ci->i_xattrs.blob ? (int)ci->i_xattrs.blob->vec.iov_len : 0); in __build_xattrs()
667 if (ci->i_xattrs.index_version >= ci->i_xattrs.version) in __build_xattrs()
670 __ceph_destroy_xattrs(ci); in __build_xattrs()
674 if (ci->i_xattrs.blob && ci->i_xattrs.blob->vec.iov_len > 4) { in __build_xattrs()
675 p = ci->i_xattrs.blob->vec.iov_base; in __build_xattrs()
676 end = p + ci->i_xattrs.blob->vec.iov_len; in __build_xattrs()
678 xattr_version = ci->i_xattrs.version; in __build_xattrs()
679 spin_unlock(&ci->i_ceph_lock); in __build_xattrs()
694 spin_lock(&ci->i_ceph_lock); in __build_xattrs()
695 if (ci->i_xattrs.version != xattr_version) { in __build_xattrs()
713 err = __set_xattr(ci, name, namelen, val, len, in __build_xattrs()
721 ci->i_xattrs.index_version = ci->i_xattrs.version; in __build_xattrs()
722 ci->i_xattrs.dirty = false; in __build_xattrs()
726 spin_lock(&ci->i_ceph_lock); in __build_xattrs()
733 ci->i_xattrs.names_size = 0; in __build_xattrs()
737 static int __get_required_blob_size(struct ceph_inode_info *ci, int name_size, in __get_required_blob_size() argument
744 int size = 4 + ci->i_xattrs.count*(4 + 4) + in __get_required_blob_size()
745 ci->i_xattrs.names_size + in __get_required_blob_size()
746 ci->i_xattrs.vals_size; in __get_required_blob_size()
748 ci->i_xattrs.count, ci->i_xattrs.names_size, in __get_required_blob_size()
749 ci->i_xattrs.vals_size); in __get_required_blob_size()
763 struct ceph_buffer *__ceph_build_xattrs_blob(struct ceph_inode_info *ci) in __ceph_build_xattrs_blob() argument
770 dout("__build_xattrs_blob %p\n", &ci->vfs_inode); in __ceph_build_xattrs_blob()
771 if (ci->i_xattrs.dirty) { in __ceph_build_xattrs_blob()
772 int need = __get_required_blob_size(ci, 0, 0); in __ceph_build_xattrs_blob()
774 BUG_ON(need > ci->i_xattrs.prealloc_blob->alloc_len); in __ceph_build_xattrs_blob()
776 p = rb_first(&ci->i_xattrs.index); in __ceph_build_xattrs_blob()
777 dest = ci->i_xattrs.prealloc_blob->vec.iov_base; in __ceph_build_xattrs_blob()
779 ceph_encode_32(&dest, ci->i_xattrs.count); in __ceph_build_xattrs_blob()
794 ci->i_xattrs.prealloc_blob->vec.iov_len = in __ceph_build_xattrs_blob()
795 dest - ci->i_xattrs.prealloc_blob->vec.iov_base; in __ceph_build_xattrs_blob()
797 if (ci->i_xattrs.blob) in __ceph_build_xattrs_blob()
798 old_blob = ci->i_xattrs.blob; in __ceph_build_xattrs_blob()
799 ci->i_xattrs.blob = ci->i_xattrs.prealloc_blob; in __ceph_build_xattrs_blob()
800 ci->i_xattrs.prealloc_blob = NULL; in __ceph_build_xattrs_blob()
801 ci->i_xattrs.dirty = false; in __ceph_build_xattrs_blob()
802 ci->i_xattrs.version++; in __ceph_build_xattrs_blob()
828 struct ceph_inode_info *ci = ceph_inode(inode); in __ceph_getxattr() local
844 if (!(vxattr->exists_cb && !vxattr->exists_cb(ci))) { in __ceph_getxattr()
845 err = vxattr->getxattr_cb(ci, value, size); in __ceph_getxattr()
854 spin_lock(&ci->i_ceph_lock); in __ceph_getxattr()
856 ci->i_xattrs.version, ci->i_xattrs.index_version); in __ceph_getxattr()
858 if (ci->i_xattrs.version == 0 || in __ceph_getxattr()
860 __ceph_caps_issued_mask_metric(ci, CEPH_CAP_XATTR_SHARED, 1))) { in __ceph_getxattr()
861 spin_unlock(&ci->i_ceph_lock); in __ceph_getxattr()
874 spin_lock(&ci->i_ceph_lock); in __ceph_getxattr()
882 xattr = __get_xattr(ci, name); in __ceph_getxattr()
899 ci->i_ceph_flags |= CEPH_I_SEC_INITED; in __ceph_getxattr()
901 spin_unlock(&ci->i_ceph_lock); in __ceph_getxattr()
908 struct ceph_inode_info *ci = ceph_inode(inode); in ceph_listxattr() local
913 spin_lock(&ci->i_ceph_lock); in ceph_listxattr()
915 ci->i_xattrs.version, ci->i_xattrs.index_version); in ceph_listxattr()
917 if (ci->i_xattrs.version == 0 || in ceph_listxattr()
918 !__ceph_caps_issued_mask_metric(ci, CEPH_CAP_XATTR_SHARED, 1)) { in ceph_listxattr()
919 spin_unlock(&ci->i_ceph_lock); in ceph_listxattr()
923 spin_lock(&ci->i_ceph_lock); in ceph_listxattr()
931 namelen = ci->i_xattrs.names_size + ci->i_xattrs.count; in ceph_listxattr()
937 names = __copy_xattr_names(ci, names); in ceph_listxattr()
942 spin_unlock(&ci->i_ceph_lock); in ceph_listxattr()
950 struct ceph_inode_info *ci = ceph_inode(inode); in ceph_sync_setxattr() local
1000 dout("xattr.ver (before): %lld\n", ci->i_xattrs.version); in ceph_sync_setxattr()
1003 dout("xattr.ver (after): %lld\n", ci->i_xattrs.version); in ceph_sync_setxattr()
1015 struct ceph_inode_info *ci = ceph_inode(inode); in __ceph_setxattr() local
1066 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1068 issued = __ceph_caps_issued(ci, NULL); in __ceph_setxattr()
1069 if (ci->i_xattrs.version == 0 || !(issued & CEPH_CAP_XATTR_EXCL)) in __ceph_setxattr()
1072 if (!lock_snap_rwsem && !ci->i_head_snapc) { in __ceph_setxattr()
1075 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1077 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1086 required_blob_size = __get_required_blob_size(ci, name_len, val_len); in __ceph_setxattr()
1088 if (!ci->i_xattrs.prealloc_blob || in __ceph_setxattr()
1089 required_blob_size > ci->i_xattrs.prealloc_blob->alloc_len) { in __ceph_setxattr()
1092 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1098 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1100 if (ci->i_xattrs.prealloc_blob) in __ceph_setxattr()
1101 old_blob = ci->i_xattrs.prealloc_blob; in __ceph_setxattr()
1102 ci->i_xattrs.prealloc_blob = blob; in __ceph_setxattr()
1106 err = __set_xattr(ci, newname, name_len, newval, val_len, in __ceph_setxattr()
1110 dirty = __ceph_mark_dirty_caps(ci, CEPH_CAP_XATTR_EXCL, in __ceph_setxattr()
1112 ci->i_xattrs.dirty = true; in __ceph_setxattr()
1116 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1126 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1140 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1141 if ((ci->i_max_files || ci->i_max_bytes) && in __ceph_setxattr()
1142 !(ci->i_snap_realm && in __ceph_setxattr()
1143 ci->i_snap_realm->ino == ci->i_vino.ino)) in __ceph_setxattr()
1145 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1189 struct ceph_inode_info *ci; in ceph_security_xattr_deadlock() local
1193 ci = ceph_inode(in); in ceph_security_xattr_deadlock()
1194 spin_lock(&ci->i_ceph_lock); in ceph_security_xattr_deadlock()
1195 ret = !(ci->i_ceph_flags & CEPH_I_SEC_INITED) && in ceph_security_xattr_deadlock()
1196 !(ci->i_xattrs.version > 0 && in ceph_security_xattr_deadlock()
1197 __ceph_caps_issued_mask(ci, CEPH_CAP_XATTR_SHARED, 0)); in ceph_security_xattr_deadlock()
1198 spin_unlock(&ci->i_ceph_lock); in ceph_security_xattr_deadlock()