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);
49 static bool ceph_vxattrcb_layout_exists(struct ceph_inode_info *ci) in ceph_vxattrcb_layout_exists() argument
51 struct ceph_file_layout *fl = &ci->i_layout; in ceph_vxattrcb_layout_exists()
57 static ssize_t ceph_vxattrcb_layout(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_layout() argument
60 struct ceph_fs_client *fsc = ceph_sb_to_client(ci->vfs_inode.i_sb); in ceph_vxattrcb_layout()
63 s64 pool = ci->i_layout.pool_id; in ceph_vxattrcb_layout()
70 pool_ns = ceph_try_get_string(ci->i_layout.pool_ns); in ceph_vxattrcb_layout()
72 dout("ceph_vxattrcb_layout %p\n", &ci->vfs_inode); in ceph_vxattrcb_layout()
78 ci->i_layout.stripe_unit, ci->i_layout.stripe_count, in ceph_vxattrcb_layout()
79 ci->i_layout.object_size); in ceph_vxattrcb_layout()
84 ci->i_layout.stripe_unit, ci->i_layout.stripe_count, in ceph_vxattrcb_layout()
85 ci->i_layout.object_size, pool); in ceph_vxattrcb_layout()
142 static ssize_t ceph_vxattrcb_layout_stripe_unit(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_stripe_unit() argument
145 return ceph_fmt_xattr(val, size, "%u", ci->i_layout.stripe_unit); in ceph_vxattrcb_layout_stripe_unit()
148 static ssize_t ceph_vxattrcb_layout_stripe_count(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_stripe_count() argument
151 return ceph_fmt_xattr(val, size, "%u", ci->i_layout.stripe_count); in ceph_vxattrcb_layout_stripe_count()
154 static ssize_t ceph_vxattrcb_layout_object_size(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_object_size() argument
157 return ceph_fmt_xattr(val, size, "%u", ci->i_layout.object_size); in ceph_vxattrcb_layout_object_size()
160 static ssize_t ceph_vxattrcb_layout_pool(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_pool() argument
164 struct ceph_fs_client *fsc = ceph_sb_to_client(ci->vfs_inode.i_sb); in ceph_vxattrcb_layout_pool()
166 s64 pool = ci->i_layout.pool_id; in ceph_vxattrcb_layout_pool()
182 static ssize_t ceph_vxattrcb_layout_pool_namespace(struct ceph_inode_info *ci, in ceph_vxattrcb_layout_pool_namespace() argument
186 struct ceph_string *ns = ceph_try_get_string(ci->i_layout.pool_ns); in ceph_vxattrcb_layout_pool_namespace()
199 static ssize_t ceph_vxattrcb_dir_entries(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_entries() argument
202 return ceph_fmt_xattr(val, size, "%lld", ci->i_files + ci->i_subdirs); in ceph_vxattrcb_dir_entries()
205 static ssize_t ceph_vxattrcb_dir_files(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_files() argument
208 return ceph_fmt_xattr(val, size, "%lld", ci->i_files); in ceph_vxattrcb_dir_files()
211 static ssize_t ceph_vxattrcb_dir_subdirs(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_subdirs() argument
214 return ceph_fmt_xattr(val, size, "%lld", ci->i_subdirs); in ceph_vxattrcb_dir_subdirs()
217 static ssize_t ceph_vxattrcb_dir_rentries(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rentries() argument
221 ci->i_rfiles + ci->i_rsubdirs); in ceph_vxattrcb_dir_rentries()
224 static ssize_t ceph_vxattrcb_dir_rfiles(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rfiles() argument
227 return ceph_fmt_xattr(val, size, "%lld", ci->i_rfiles); in ceph_vxattrcb_dir_rfiles()
230 static ssize_t ceph_vxattrcb_dir_rsubdirs(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rsubdirs() argument
233 return ceph_fmt_xattr(val, size, "%lld", ci->i_rsubdirs); in ceph_vxattrcb_dir_rsubdirs()
236 static ssize_t ceph_vxattrcb_dir_rsnaps(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rsnaps() argument
239 return ceph_fmt_xattr(val, size, "%lld", ci->i_rsnaps); in ceph_vxattrcb_dir_rsnaps()
242 static ssize_t ceph_vxattrcb_dir_rbytes(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rbytes() argument
245 return ceph_fmt_xattr(val, size, "%lld", ci->i_rbytes); in ceph_vxattrcb_dir_rbytes()
248 static ssize_t ceph_vxattrcb_dir_rctime(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_rctime() argument
251 return ceph_fmt_xattr(val, size, "%lld.%09ld", ci->i_rctime.tv_sec, in ceph_vxattrcb_dir_rctime()
252 ci->i_rctime.tv_nsec); in ceph_vxattrcb_dir_rctime()
256 static bool ceph_vxattrcb_dir_pin_exists(struct ceph_inode_info *ci) in ceph_vxattrcb_dir_pin_exists() argument
258 return ci->i_dir_pin != -ENODATA; in ceph_vxattrcb_dir_pin_exists()
261 static ssize_t ceph_vxattrcb_dir_pin(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_dir_pin() argument
264 return ceph_fmt_xattr(val, size, "%d", (int)ci->i_dir_pin); in ceph_vxattrcb_dir_pin()
268 static bool ceph_vxattrcb_quota_exists(struct ceph_inode_info *ci) in ceph_vxattrcb_quota_exists() argument
271 spin_lock(&ci->i_ceph_lock); in ceph_vxattrcb_quota_exists()
272 if ((ci->i_max_files || ci->i_max_bytes) && in ceph_vxattrcb_quota_exists()
273 ci->i_vino.snap == CEPH_NOSNAP && in ceph_vxattrcb_quota_exists()
274 ci->i_snap_realm && in ceph_vxattrcb_quota_exists()
275 ci->i_snap_realm->ino == ci->i_vino.ino) in ceph_vxattrcb_quota_exists()
277 spin_unlock(&ci->i_ceph_lock); in ceph_vxattrcb_quota_exists()
281 static ssize_t ceph_vxattrcb_quota(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_quota() argument
285 ci->i_max_bytes, ci->i_max_files); in ceph_vxattrcb_quota()
288 static ssize_t ceph_vxattrcb_quota_max_bytes(struct ceph_inode_info *ci, in ceph_vxattrcb_quota_max_bytes() argument
291 return ceph_fmt_xattr(val, size, "%llu", ci->i_max_bytes); in ceph_vxattrcb_quota_max_bytes()
294 static ssize_t ceph_vxattrcb_quota_max_files(struct ceph_inode_info *ci, in ceph_vxattrcb_quota_max_files() argument
297 return ceph_fmt_xattr(val, size, "%llu", ci->i_max_files); in ceph_vxattrcb_quota_max_files()
301 static bool ceph_vxattrcb_snap_btime_exists(struct ceph_inode_info *ci) in ceph_vxattrcb_snap_btime_exists() argument
303 return (ci->i_snap_btime.tv_sec != 0 || ci->i_snap_btime.tv_nsec != 0); in ceph_vxattrcb_snap_btime_exists()
306 static ssize_t ceph_vxattrcb_snap_btime(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_snap_btime() argument
309 return ceph_fmt_xattr(val, size, "%lld.%09ld", ci->i_snap_btime.tv_sec, in ceph_vxattrcb_snap_btime()
310 ci->i_snap_btime.tv_nsec); in ceph_vxattrcb_snap_btime()
313 static ssize_t ceph_vxattrcb_cluster_fsid(struct ceph_inode_info *ci, in ceph_vxattrcb_cluster_fsid() argument
316 struct ceph_fs_client *fsc = ceph_sb_to_client(ci->vfs_inode.i_sb); in ceph_vxattrcb_cluster_fsid()
321 static ssize_t ceph_vxattrcb_client_id(struct ceph_inode_info *ci, in ceph_vxattrcb_client_id() argument
324 struct ceph_fs_client *fsc = ceph_sb_to_client(ci->vfs_inode.i_sb); in ceph_vxattrcb_client_id()
330 static ssize_t ceph_vxattrcb_caps(struct ceph_inode_info *ci, char *val, in ceph_vxattrcb_caps() argument
335 spin_lock(&ci->i_ceph_lock); in ceph_vxattrcb_caps()
336 issued = __ceph_caps_issued(ci, NULL); in ceph_vxattrcb_caps()
337 spin_unlock(&ci->i_ceph_lock); in ceph_vxattrcb_caps()
343 static ssize_t ceph_vxattrcb_auth_mds(struct ceph_inode_info *ci, in ceph_vxattrcb_auth_mds() argument
348 spin_lock(&ci->i_ceph_lock); in ceph_vxattrcb_auth_mds()
350 ci->i_auth_cap ? ci->i_auth_cap->session->s_mds : -1); in ceph_vxattrcb_auth_mds()
351 spin_unlock(&ci->i_ceph_lock); in ceph_vxattrcb_auth_mds()
530 static int __set_xattr(struct ceph_inode_info *ci, in __set_xattr() argument
542 p = &ci->i_xattrs.index.rb_node; in __set_xattr()
577 __remove_xattr(ci, xattr); in __set_xattr()
591 ci->i_xattrs.count++; in __set_xattr()
592 dout("__set_xattr count=%d\n", ci->i_xattrs.count); in __set_xattr()
603 ci->i_xattrs.names_size -= xattr->name_len; in __set_xattr()
604 ci->i_xattrs.vals_size -= xattr->val_len; in __set_xattr()
606 ci->i_xattrs.names_size += name_len; in __set_xattr()
607 ci->i_xattrs.vals_size += val_len; in __set_xattr()
619 rb_insert_color(&xattr->node, &ci->i_xattrs.index); in __set_xattr()
624 ceph_vinop(&ci->vfs_inode), xattr, name_len, name, val_len, val); in __set_xattr()
629 static struct ceph_inode_xattr *__get_xattr(struct ceph_inode_info *ci, in __get_xattr() argument
638 p = &ci->i_xattrs.index.rb_node; in __get_xattr()
673 static int __remove_xattr(struct ceph_inode_info *ci, in __remove_xattr() argument
679 rb_erase(&xattr->node, &ci->i_xattrs.index); in __remove_xattr()
686 ci->i_xattrs.names_size -= xattr->name_len; in __remove_xattr()
687 ci->i_xattrs.vals_size -= xattr->val_len; in __remove_xattr()
688 ci->i_xattrs.count--; in __remove_xattr()
694 static char *__copy_xattr_names(struct ceph_inode_info *ci, in __copy_xattr_names() argument
700 p = rb_first(&ci->i_xattrs.index); in __copy_xattr_names()
701 dout("__copy_xattr_names count=%d\n", ci->i_xattrs.count); in __copy_xattr_names()
709 xattr->name_len, ci->i_xattrs.names_size); in __copy_xattr_names()
718 void __ceph_destroy_xattrs(struct ceph_inode_info *ci) in __ceph_destroy_xattrs() argument
723 p = rb_first(&ci->i_xattrs.index); in __ceph_destroy_xattrs()
733 rb_erase(tmp, &ci->i_xattrs.index); in __ceph_destroy_xattrs()
738 ci->i_xattrs.names_size = 0; in __ceph_destroy_xattrs()
739 ci->i_xattrs.vals_size = 0; in __ceph_destroy_xattrs()
740 ci->i_xattrs.index_version = 0; in __ceph_destroy_xattrs()
741 ci->i_xattrs.count = 0; in __ceph_destroy_xattrs()
742 ci->i_xattrs.index = RB_ROOT; in __ceph_destroy_xattrs()
746 __releases(ci->i_ceph_lock) in __build_xattrs()
747 __acquires(ci->i_ceph_lock) in __build_xattrs()
754 struct ceph_inode_info *ci = ceph_inode(inode); in __build_xattrs() local
761 ci->i_xattrs.blob ? (int)ci->i_xattrs.blob->vec.iov_len : 0); in __build_xattrs()
763 if (ci->i_xattrs.index_version >= ci->i_xattrs.version) in __build_xattrs()
766 __ceph_destroy_xattrs(ci); in __build_xattrs()
770 if (ci->i_xattrs.blob && ci->i_xattrs.blob->vec.iov_len > 4) { in __build_xattrs()
771 p = ci->i_xattrs.blob->vec.iov_base; in __build_xattrs()
772 end = p + ci->i_xattrs.blob->vec.iov_len; in __build_xattrs()
774 xattr_version = ci->i_xattrs.version; in __build_xattrs()
775 spin_unlock(&ci->i_ceph_lock); in __build_xattrs()
790 spin_lock(&ci->i_ceph_lock); in __build_xattrs()
791 if (ci->i_xattrs.version != xattr_version) { in __build_xattrs()
809 err = __set_xattr(ci, name, namelen, val, len, in __build_xattrs()
817 ci->i_xattrs.index_version = ci->i_xattrs.version; in __build_xattrs()
818 ci->i_xattrs.dirty = false; in __build_xattrs()
822 spin_lock(&ci->i_ceph_lock); in __build_xattrs()
829 ci->i_xattrs.names_size = 0; in __build_xattrs()
833 static int __get_required_blob_size(struct ceph_inode_info *ci, int name_size, in __get_required_blob_size() argument
840 int size = 4 + ci->i_xattrs.count*(4 + 4) + in __get_required_blob_size()
841 ci->i_xattrs.names_size + in __get_required_blob_size()
842 ci->i_xattrs.vals_size; in __get_required_blob_size()
844 ci->i_xattrs.count, ci->i_xattrs.names_size, in __get_required_blob_size()
845 ci->i_xattrs.vals_size); in __get_required_blob_size()
859 struct ceph_buffer *__ceph_build_xattrs_blob(struct ceph_inode_info *ci) in __ceph_build_xattrs_blob() argument
866 dout("__build_xattrs_blob %p\n", &ci->vfs_inode); in __ceph_build_xattrs_blob()
867 if (ci->i_xattrs.dirty) { in __ceph_build_xattrs_blob()
868 int need = __get_required_blob_size(ci, 0, 0); in __ceph_build_xattrs_blob()
870 BUG_ON(need > ci->i_xattrs.prealloc_blob->alloc_len); in __ceph_build_xattrs_blob()
872 p = rb_first(&ci->i_xattrs.index); in __ceph_build_xattrs_blob()
873 dest = ci->i_xattrs.prealloc_blob->vec.iov_base; in __ceph_build_xattrs_blob()
875 ceph_encode_32(&dest, ci->i_xattrs.count); in __ceph_build_xattrs_blob()
890 ci->i_xattrs.prealloc_blob->vec.iov_len = in __ceph_build_xattrs_blob()
891 dest - ci->i_xattrs.prealloc_blob->vec.iov_base; in __ceph_build_xattrs_blob()
893 if (ci->i_xattrs.blob) in __ceph_build_xattrs_blob()
894 old_blob = ci->i_xattrs.blob; in __ceph_build_xattrs_blob()
895 ci->i_xattrs.blob = ci->i_xattrs.prealloc_blob; in __ceph_build_xattrs_blob()
896 ci->i_xattrs.prealloc_blob = NULL; in __ceph_build_xattrs_blob()
897 ci->i_xattrs.dirty = false; in __ceph_build_xattrs_blob()
898 ci->i_xattrs.version++; in __ceph_build_xattrs_blob()
924 struct ceph_inode_info *ci = ceph_inode(inode); in __ceph_getxattr() local
942 if (!(vxattr->exists_cb && !vxattr->exists_cb(ci))) { in __ceph_getxattr()
943 err = vxattr->getxattr_cb(ci, value, size); in __ceph_getxattr()
952 spin_lock(&ci->i_ceph_lock); in __ceph_getxattr()
954 ci->i_xattrs.version, ci->i_xattrs.index_version); in __ceph_getxattr()
956 if (ci->i_xattrs.version == 0 || in __ceph_getxattr()
958 __ceph_caps_issued_mask_metric(ci, CEPH_CAP_XATTR_SHARED, 1))) { in __ceph_getxattr()
959 spin_unlock(&ci->i_ceph_lock); in __ceph_getxattr()
972 spin_lock(&ci->i_ceph_lock); in __ceph_getxattr()
980 xattr = __get_xattr(ci, name); in __ceph_getxattr()
997 ci->i_ceph_flags |= CEPH_I_SEC_INITED; in __ceph_getxattr()
999 spin_unlock(&ci->i_ceph_lock); in __ceph_getxattr()
1006 struct ceph_inode_info *ci = ceph_inode(inode); in ceph_listxattr() local
1011 spin_lock(&ci->i_ceph_lock); in ceph_listxattr()
1013 ci->i_xattrs.version, ci->i_xattrs.index_version); in ceph_listxattr()
1015 if (ci->i_xattrs.version == 0 || in ceph_listxattr()
1016 !__ceph_caps_issued_mask_metric(ci, CEPH_CAP_XATTR_SHARED, 1)) { in ceph_listxattr()
1017 spin_unlock(&ci->i_ceph_lock); in ceph_listxattr()
1021 spin_lock(&ci->i_ceph_lock); in ceph_listxattr()
1029 namelen = ci->i_xattrs.names_size + ci->i_xattrs.count; in ceph_listxattr()
1035 names = __copy_xattr_names(ci, names); in ceph_listxattr()
1040 spin_unlock(&ci->i_ceph_lock); in ceph_listxattr()
1048 struct ceph_inode_info *ci = ceph_inode(inode); in ceph_sync_setxattr() local
1101 dout("xattr.ver (before): %lld\n", ci->i_xattrs.version); in ceph_sync_setxattr()
1104 dout("xattr.ver (after): %lld\n", ci->i_xattrs.version); in ceph_sync_setxattr()
1116 struct ceph_inode_info *ci = ceph_inode(inode); in __ceph_setxattr() local
1167 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1169 issued = __ceph_caps_issued(ci, NULL); in __ceph_setxattr()
1170 if (ci->i_xattrs.version == 0 || !(issued & CEPH_CAP_XATTR_EXCL)) in __ceph_setxattr()
1173 if (!lock_snap_rwsem && !ci->i_head_snapc) { in __ceph_setxattr()
1176 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1178 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1187 required_blob_size = __get_required_blob_size(ci, name_len, val_len); in __ceph_setxattr()
1189 if (!ci->i_xattrs.prealloc_blob || in __ceph_setxattr()
1190 required_blob_size > ci->i_xattrs.prealloc_blob->alloc_len) { in __ceph_setxattr()
1193 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1199 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1201 if (ci->i_xattrs.prealloc_blob) in __ceph_setxattr()
1202 old_blob = ci->i_xattrs.prealloc_blob; in __ceph_setxattr()
1203 ci->i_xattrs.prealloc_blob = blob; in __ceph_setxattr()
1207 err = __set_xattr(ci, newname, name_len, newval, val_len, in __ceph_setxattr()
1211 dirty = __ceph_mark_dirty_caps(ci, CEPH_CAP_XATTR_EXCL, in __ceph_setxattr()
1213 ci->i_xattrs.dirty = true; in __ceph_setxattr()
1217 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1227 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1241 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1242 if ((ci->i_max_files || ci->i_max_bytes) && in __ceph_setxattr()
1243 !(ci->i_snap_realm && in __ceph_setxattr()
1244 ci->i_snap_realm->ino == ci->i_vino.ino)) in __ceph_setxattr()
1246 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1291 struct ceph_inode_info *ci; in ceph_security_xattr_deadlock() local
1295 ci = ceph_inode(in); in ceph_security_xattr_deadlock()
1296 spin_lock(&ci->i_ceph_lock); in ceph_security_xattr_deadlock()
1297 ret = !(ci->i_ceph_flags & CEPH_I_SEC_INITED) && in ceph_security_xattr_deadlock()
1298 !(ci->i_xattrs.version > 0 && in ceph_security_xattr_deadlock()
1299 __ceph_caps_issued_mask(ci, CEPH_CAP_XATTR_SHARED, 0)); in ceph_security_xattr_deadlock()
1300 spin_unlock(&ci->i_ceph_lock); in ceph_security_xattr_deadlock()