Lines Matching full: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()
442 static int __set_xattr(struct ceph_inode_info *ci, in __set_xattr() argument
454 p = &ci->i_xattrs.index.rb_node; in __set_xattr()
489 __remove_xattr(ci, xattr); in __set_xattr()
503 ci->i_xattrs.count++; in __set_xattr()
504 dout("__set_xattr count=%d\n", ci->i_xattrs.count); in __set_xattr()
515 ci->i_xattrs.names_size -= xattr->name_len; in __set_xattr()
516 ci->i_xattrs.vals_size -= xattr->val_len; in __set_xattr()
518 ci->i_xattrs.names_size += name_len; in __set_xattr()
519 ci->i_xattrs.vals_size += val_len; in __set_xattr()
531 rb_insert_color(&xattr->node, &ci->i_xattrs.index); in __set_xattr()
536 ceph_vinop(&ci->vfs_inode), xattr, name_len, name, val_len, val); in __set_xattr()
541 static struct ceph_inode_xattr *__get_xattr(struct ceph_inode_info *ci, in __get_xattr() argument
550 p = &ci->i_xattrs.index.rb_node; in __get_xattr()
585 static int __remove_xattr(struct ceph_inode_info *ci, in __remove_xattr() argument
591 rb_erase(&xattr->node, &ci->i_xattrs.index); in __remove_xattr()
598 ci->i_xattrs.names_size -= xattr->name_len; in __remove_xattr()
599 ci->i_xattrs.vals_size -= xattr->val_len; in __remove_xattr()
600 ci->i_xattrs.count--; in __remove_xattr()
606 static char *__copy_xattr_names(struct ceph_inode_info *ci, in __copy_xattr_names() argument
612 p = rb_first(&ci->i_xattrs.index); in __copy_xattr_names()
613 dout("__copy_xattr_names count=%d\n", ci->i_xattrs.count); in __copy_xattr_names()
621 xattr->name_len, ci->i_xattrs.names_size); in __copy_xattr_names()
630 void __ceph_destroy_xattrs(struct ceph_inode_info *ci) in __ceph_destroy_xattrs() argument
635 p = rb_first(&ci->i_xattrs.index); in __ceph_destroy_xattrs()
645 rb_erase(tmp, &ci->i_xattrs.index); in __ceph_destroy_xattrs()
650 ci->i_xattrs.names_size = 0; in __ceph_destroy_xattrs()
651 ci->i_xattrs.vals_size = 0; in __ceph_destroy_xattrs()
652 ci->i_xattrs.index_version = 0; in __ceph_destroy_xattrs()
653 ci->i_xattrs.count = 0; in __ceph_destroy_xattrs()
654 ci->i_xattrs.index = RB_ROOT; in __ceph_destroy_xattrs()
658 __releases(ci->i_ceph_lock) in __build_xattrs()
659 __acquires(ci->i_ceph_lock) in __build_xattrs()
666 struct ceph_inode_info *ci = ceph_inode(inode); in __build_xattrs() local
673 ci->i_xattrs.blob ? (int)ci->i_xattrs.blob->vec.iov_len : 0); in __build_xattrs()
675 if (ci->i_xattrs.index_version >= ci->i_xattrs.version) in __build_xattrs()
678 __ceph_destroy_xattrs(ci); in __build_xattrs()
682 if (ci->i_xattrs.blob && ci->i_xattrs.blob->vec.iov_len > 4) { in __build_xattrs()
683 p = ci->i_xattrs.blob->vec.iov_base; in __build_xattrs()
684 end = p + ci->i_xattrs.blob->vec.iov_len; in __build_xattrs()
686 xattr_version = ci->i_xattrs.version; in __build_xattrs()
687 spin_unlock(&ci->i_ceph_lock); in __build_xattrs()
702 spin_lock(&ci->i_ceph_lock); in __build_xattrs()
703 if (ci->i_xattrs.version != xattr_version) { in __build_xattrs()
721 err = __set_xattr(ci, name, namelen, val, len, in __build_xattrs()
729 ci->i_xattrs.index_version = ci->i_xattrs.version; in __build_xattrs()
730 ci->i_xattrs.dirty = false; in __build_xattrs()
734 spin_lock(&ci->i_ceph_lock); in __build_xattrs()
741 ci->i_xattrs.names_size = 0; in __build_xattrs()
745 static int __get_required_blob_size(struct ceph_inode_info *ci, int name_size, in __get_required_blob_size() argument
752 int size = 4 + ci->i_xattrs.count*(4 + 4) + in __get_required_blob_size()
753 ci->i_xattrs.names_size + in __get_required_blob_size()
754 ci->i_xattrs.vals_size; in __get_required_blob_size()
756 ci->i_xattrs.count, ci->i_xattrs.names_size, in __get_required_blob_size()
757 ci->i_xattrs.vals_size); in __get_required_blob_size()
771 struct ceph_buffer *__ceph_build_xattrs_blob(struct ceph_inode_info *ci) in __ceph_build_xattrs_blob() argument
778 dout("__build_xattrs_blob %p\n", &ci->vfs_inode); in __ceph_build_xattrs_blob()
779 if (ci->i_xattrs.dirty) { in __ceph_build_xattrs_blob()
780 int need = __get_required_blob_size(ci, 0, 0); in __ceph_build_xattrs_blob()
782 BUG_ON(need > ci->i_xattrs.prealloc_blob->alloc_len); in __ceph_build_xattrs_blob()
784 p = rb_first(&ci->i_xattrs.index); in __ceph_build_xattrs_blob()
785 dest = ci->i_xattrs.prealloc_blob->vec.iov_base; in __ceph_build_xattrs_blob()
787 ceph_encode_32(&dest, ci->i_xattrs.count); in __ceph_build_xattrs_blob()
802 ci->i_xattrs.prealloc_blob->vec.iov_len = in __ceph_build_xattrs_blob()
803 dest - ci->i_xattrs.prealloc_blob->vec.iov_base; in __ceph_build_xattrs_blob()
805 if (ci->i_xattrs.blob) in __ceph_build_xattrs_blob()
806 old_blob = ci->i_xattrs.blob; in __ceph_build_xattrs_blob()
807 ci->i_xattrs.blob = ci->i_xattrs.prealloc_blob; in __ceph_build_xattrs_blob()
808 ci->i_xattrs.prealloc_blob = NULL; in __ceph_build_xattrs_blob()
809 ci->i_xattrs.dirty = false; in __ceph_build_xattrs_blob()
810 ci->i_xattrs.version++; in __ceph_build_xattrs_blob()
836 struct ceph_inode_info *ci = ceph_inode(inode); in __ceph_getxattr() local
852 if (!(vxattr->exists_cb && !vxattr->exists_cb(ci))) { in __ceph_getxattr()
853 err = vxattr->getxattr_cb(ci, value, size); in __ceph_getxattr()
862 spin_lock(&ci->i_ceph_lock); in __ceph_getxattr()
864 ci->i_xattrs.version, ci->i_xattrs.index_version); in __ceph_getxattr()
866 if (ci->i_xattrs.version == 0 || in __ceph_getxattr()
868 __ceph_caps_issued_mask_metric(ci, CEPH_CAP_XATTR_SHARED, 1))) { in __ceph_getxattr()
869 spin_unlock(&ci->i_ceph_lock); in __ceph_getxattr()
882 spin_lock(&ci->i_ceph_lock); in __ceph_getxattr()
890 xattr = __get_xattr(ci, name); in __ceph_getxattr()
907 ci->i_ceph_flags |= CEPH_I_SEC_INITED; in __ceph_getxattr()
909 spin_unlock(&ci->i_ceph_lock); in __ceph_getxattr()
916 struct ceph_inode_info *ci = ceph_inode(inode); in ceph_listxattr() local
921 spin_lock(&ci->i_ceph_lock); in ceph_listxattr()
923 ci->i_xattrs.version, ci->i_xattrs.index_version); in ceph_listxattr()
925 if (ci->i_xattrs.version == 0 || in ceph_listxattr()
926 !__ceph_caps_issued_mask_metric(ci, CEPH_CAP_XATTR_SHARED, 1)) { in ceph_listxattr()
927 spin_unlock(&ci->i_ceph_lock); in ceph_listxattr()
931 spin_lock(&ci->i_ceph_lock); in ceph_listxattr()
939 namelen = ci->i_xattrs.names_size + ci->i_xattrs.count; in ceph_listxattr()
945 names = __copy_xattr_names(ci, names); in ceph_listxattr()
950 spin_unlock(&ci->i_ceph_lock); in ceph_listxattr()
958 struct ceph_inode_info *ci = ceph_inode(inode); in ceph_sync_setxattr() local
1008 dout("xattr.ver (before): %lld\n", ci->i_xattrs.version); in ceph_sync_setxattr()
1011 dout("xattr.ver (after): %lld\n", ci->i_xattrs.version); in ceph_sync_setxattr()
1023 struct ceph_inode_info *ci = ceph_inode(inode); in __ceph_setxattr() local
1074 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1076 issued = __ceph_caps_issued(ci, NULL); in __ceph_setxattr()
1077 if (ci->i_xattrs.version == 0 || !(issued & CEPH_CAP_XATTR_EXCL)) in __ceph_setxattr()
1080 if (!lock_snap_rwsem && !ci->i_head_snapc) { in __ceph_setxattr()
1083 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1085 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1094 required_blob_size = __get_required_blob_size(ci, name_len, val_len); in __ceph_setxattr()
1096 if (!ci->i_xattrs.prealloc_blob || in __ceph_setxattr()
1097 required_blob_size > ci->i_xattrs.prealloc_blob->alloc_len) { in __ceph_setxattr()
1100 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1106 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1108 if (ci->i_xattrs.prealloc_blob) in __ceph_setxattr()
1109 old_blob = ci->i_xattrs.prealloc_blob; in __ceph_setxattr()
1110 ci->i_xattrs.prealloc_blob = blob; in __ceph_setxattr()
1114 err = __set_xattr(ci, newname, name_len, newval, val_len, in __ceph_setxattr()
1118 dirty = __ceph_mark_dirty_caps(ci, CEPH_CAP_XATTR_EXCL, in __ceph_setxattr()
1120 ci->i_xattrs.dirty = true; in __ceph_setxattr()
1124 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1134 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1148 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1149 if ((ci->i_max_files || ci->i_max_bytes) && in __ceph_setxattr()
1150 !(ci->i_snap_realm && in __ceph_setxattr()
1151 ci->i_snap_realm->ino == ci->i_vino.ino)) in __ceph_setxattr()
1153 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1198 struct ceph_inode_info *ci; in ceph_security_xattr_deadlock() local
1202 ci = ceph_inode(in); in ceph_security_xattr_deadlock()
1203 spin_lock(&ci->i_ceph_lock); in ceph_security_xattr_deadlock()
1204 ret = !(ci->i_ceph_flags & CEPH_I_SEC_INITED) && in ceph_security_xattr_deadlock()
1205 !(ci->i_xattrs.version > 0 && in ceph_security_xattr_deadlock()
1206 __ceph_caps_issued_mask(ci, CEPH_CAP_XATTR_SHARED, 0)); in ceph_security_xattr_deadlock()
1207 spin_unlock(&ci->i_ceph_lock); in ceph_security_xattr_deadlock()