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->netfs.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->netfs.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->netfs.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->netfs.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->netfs.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()
538 static int __set_xattr(struct ceph_inode_info *ci, in __set_xattr() argument
550 p = &ci->i_xattrs.index.rb_node; in __set_xattr()
585 __remove_xattr(ci, xattr); in __set_xattr()
599 ci->i_xattrs.count++; in __set_xattr()
600 dout("__set_xattr count=%d\n", ci->i_xattrs.count); in __set_xattr()
611 ci->i_xattrs.names_size -= xattr->name_len; in __set_xattr()
612 ci->i_xattrs.vals_size -= xattr->val_len; in __set_xattr()
614 ci->i_xattrs.names_size += name_len; in __set_xattr()
615 ci->i_xattrs.vals_size += val_len; in __set_xattr()
627 rb_insert_color(&xattr->node, &ci->i_xattrs.index); in __set_xattr()
632 ceph_vinop(&ci->netfs.inode), xattr, name_len, name, val_len, val); in __set_xattr()
637 static struct ceph_inode_xattr *__get_xattr(struct ceph_inode_info *ci, in __get_xattr() argument
646 p = &ci->i_xattrs.index.rb_node; in __get_xattr()
681 static int __remove_xattr(struct ceph_inode_info *ci, in __remove_xattr() argument
687 rb_erase(&xattr->node, &ci->i_xattrs.index); in __remove_xattr()
694 ci->i_xattrs.names_size -= xattr->name_len; in __remove_xattr()
695 ci->i_xattrs.vals_size -= xattr->val_len; in __remove_xattr()
696 ci->i_xattrs.count--; in __remove_xattr()
702 static char *__copy_xattr_names(struct ceph_inode_info *ci, in __copy_xattr_names() argument
708 p = rb_first(&ci->i_xattrs.index); in __copy_xattr_names()
709 dout("__copy_xattr_names count=%d\n", ci->i_xattrs.count); in __copy_xattr_names()
717 xattr->name_len, ci->i_xattrs.names_size); in __copy_xattr_names()
726 void __ceph_destroy_xattrs(struct ceph_inode_info *ci) in __ceph_destroy_xattrs() argument
731 p = rb_first(&ci->i_xattrs.index); in __ceph_destroy_xattrs()
741 rb_erase(tmp, &ci->i_xattrs.index); in __ceph_destroy_xattrs()
746 ci->i_xattrs.names_size = 0; in __ceph_destroy_xattrs()
747 ci->i_xattrs.vals_size = 0; in __ceph_destroy_xattrs()
748 ci->i_xattrs.index_version = 0; in __ceph_destroy_xattrs()
749 ci->i_xattrs.count = 0; in __ceph_destroy_xattrs()
750 ci->i_xattrs.index = RB_ROOT; in __ceph_destroy_xattrs()
754 __releases(ci->i_ceph_lock) in __build_xattrs()
755 __acquires(ci->i_ceph_lock) in __build_xattrs()
762 struct ceph_inode_info *ci = ceph_inode(inode); in __build_xattrs() local
769 ci->i_xattrs.blob ? (int)ci->i_xattrs.blob->vec.iov_len : 0); in __build_xattrs()
771 if (ci->i_xattrs.index_version >= ci->i_xattrs.version) in __build_xattrs()
774 __ceph_destroy_xattrs(ci); in __build_xattrs()
778 if (ci->i_xattrs.blob && ci->i_xattrs.blob->vec.iov_len > 4) { in __build_xattrs()
779 p = ci->i_xattrs.blob->vec.iov_base; in __build_xattrs()
780 end = p + ci->i_xattrs.blob->vec.iov_len; in __build_xattrs()
782 xattr_version = ci->i_xattrs.version; in __build_xattrs()
783 spin_unlock(&ci->i_ceph_lock); in __build_xattrs()
798 spin_lock(&ci->i_ceph_lock); in __build_xattrs()
799 if (ci->i_xattrs.version != xattr_version) { in __build_xattrs()
817 err = __set_xattr(ci, name, namelen, val, len, in __build_xattrs()
825 ci->i_xattrs.index_version = ci->i_xattrs.version; in __build_xattrs()
826 ci->i_xattrs.dirty = false; in __build_xattrs()
830 spin_lock(&ci->i_ceph_lock); in __build_xattrs()
837 ci->i_xattrs.names_size = 0; in __build_xattrs()
841 static int __get_required_blob_size(struct ceph_inode_info *ci, int name_size, in __get_required_blob_size() argument
848 int size = 4 + ci->i_xattrs.count*(4 + 4) + in __get_required_blob_size()
849 ci->i_xattrs.names_size + in __get_required_blob_size()
850 ci->i_xattrs.vals_size; in __get_required_blob_size()
852 ci->i_xattrs.count, ci->i_xattrs.names_size, in __get_required_blob_size()
853 ci->i_xattrs.vals_size); in __get_required_blob_size()
867 struct ceph_buffer *__ceph_build_xattrs_blob(struct ceph_inode_info *ci) in __ceph_build_xattrs_blob() argument
874 dout("__build_xattrs_blob %p\n", &ci->netfs.inode); in __ceph_build_xattrs_blob()
875 if (ci->i_xattrs.dirty) { in __ceph_build_xattrs_blob()
876 int need = __get_required_blob_size(ci, 0, 0); in __ceph_build_xattrs_blob()
878 BUG_ON(need > ci->i_xattrs.prealloc_blob->alloc_len); in __ceph_build_xattrs_blob()
880 p = rb_first(&ci->i_xattrs.index); in __ceph_build_xattrs_blob()
881 dest = ci->i_xattrs.prealloc_blob->vec.iov_base; in __ceph_build_xattrs_blob()
883 ceph_encode_32(&dest, ci->i_xattrs.count); in __ceph_build_xattrs_blob()
898 ci->i_xattrs.prealloc_blob->vec.iov_len = in __ceph_build_xattrs_blob()
899 dest - ci->i_xattrs.prealloc_blob->vec.iov_base; in __ceph_build_xattrs_blob()
901 if (ci->i_xattrs.blob) in __ceph_build_xattrs_blob()
902 old_blob = ci->i_xattrs.blob; in __ceph_build_xattrs_blob()
903 ci->i_xattrs.blob = ci->i_xattrs.prealloc_blob; in __ceph_build_xattrs_blob()
904 ci->i_xattrs.prealloc_blob = NULL; in __ceph_build_xattrs_blob()
905 ci->i_xattrs.dirty = false; in __ceph_build_xattrs_blob()
906 ci->i_xattrs.version++; in __ceph_build_xattrs_blob()
932 struct ceph_inode_info *ci = ceph_inode(inode); in __ceph_getxattr() local
953 if (!(vxattr->exists_cb && !vxattr->exists_cb(ci))) { in __ceph_getxattr()
954 err = vxattr->getxattr_cb(ci, value, size); in __ceph_getxattr()
969 spin_lock(&ci->i_ceph_lock); in __ceph_getxattr()
971 ci->i_xattrs.version, ci->i_xattrs.index_version); in __ceph_getxattr()
973 if (ci->i_xattrs.version == 0 || in __ceph_getxattr()
975 __ceph_caps_issued_mask_metric(ci, CEPH_CAP_XATTR_SHARED, 1))) { in __ceph_getxattr()
976 spin_unlock(&ci->i_ceph_lock); in __ceph_getxattr()
989 spin_lock(&ci->i_ceph_lock); in __ceph_getxattr()
997 xattr = __get_xattr(ci, name); in __ceph_getxattr()
1014 ci->i_ceph_flags |= CEPH_I_SEC_INITED; in __ceph_getxattr()
1016 spin_unlock(&ci->i_ceph_lock); in __ceph_getxattr()
1023 struct ceph_inode_info *ci = ceph_inode(inode); in ceph_listxattr() local
1028 spin_lock(&ci->i_ceph_lock); in ceph_listxattr()
1030 ci->i_xattrs.version, ci->i_xattrs.index_version); in ceph_listxattr()
1032 if (ci->i_xattrs.version == 0 || in ceph_listxattr()
1033 !__ceph_caps_issued_mask_metric(ci, CEPH_CAP_XATTR_SHARED, 1)) { in ceph_listxattr()
1034 spin_unlock(&ci->i_ceph_lock); in ceph_listxattr()
1038 spin_lock(&ci->i_ceph_lock); in ceph_listxattr()
1046 namelen = ci->i_xattrs.names_size + ci->i_xattrs.count; in ceph_listxattr()
1052 names = __copy_xattr_names(ci, names); in ceph_listxattr()
1057 spin_unlock(&ci->i_ceph_lock); in ceph_listxattr()
1065 struct ceph_inode_info *ci = ceph_inode(inode); in ceph_sync_setxattr() local
1118 dout("xattr.ver (before): %lld\n", ci->i_xattrs.version); in ceph_sync_setxattr()
1121 dout("xattr.ver (after): %lld\n", ci->i_xattrs.version); in ceph_sync_setxattr()
1133 struct ceph_inode_info *ci = ceph_inode(inode); in __ceph_setxattr() local
1184 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1186 issued = __ceph_caps_issued(ci, NULL); in __ceph_setxattr()
1187 required_blob_size = __get_required_blob_size(ci, name_len, val_len); in __ceph_setxattr()
1188 if ((ci->i_xattrs.version == 0) || !(issued & CEPH_CAP_XATTR_EXCL) || in __ceph_setxattr()
1191 __func__, ci->i_xattrs.version, required_blob_size, in __ceph_setxattr()
1196 if (!lock_snap_rwsem && !ci->i_head_snapc) { in __ceph_setxattr()
1199 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1201 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1210 if (!ci->i_xattrs.prealloc_blob || in __ceph_setxattr()
1211 required_blob_size > ci->i_xattrs.prealloc_blob->alloc_len) { in __ceph_setxattr()
1214 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1220 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1222 if (ci->i_xattrs.prealloc_blob) in __ceph_setxattr()
1223 old_blob = ci->i_xattrs.prealloc_blob; in __ceph_setxattr()
1224 ci->i_xattrs.prealloc_blob = blob; in __ceph_setxattr()
1228 err = __set_xattr(ci, newname, name_len, newval, val_len, in __ceph_setxattr()
1232 dirty = __ceph_mark_dirty_caps(ci, CEPH_CAP_XATTR_EXCL, in __ceph_setxattr()
1234 ci->i_xattrs.dirty = true; in __ceph_setxattr()
1238 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1248 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1262 spin_lock(&ci->i_ceph_lock); in __ceph_setxattr()
1263 if ((ci->i_max_files || ci->i_max_bytes) && in __ceph_setxattr()
1264 !(ci->i_snap_realm && in __ceph_setxattr()
1265 ci->i_snap_realm->ino == ci->i_vino.ino)) in __ceph_setxattr()
1267 spin_unlock(&ci->i_ceph_lock); in __ceph_setxattr()
1312 struct ceph_inode_info *ci; in ceph_security_xattr_deadlock() local
1316 ci = ceph_inode(in); in ceph_security_xattr_deadlock()
1317 spin_lock(&ci->i_ceph_lock); in ceph_security_xattr_deadlock()
1318 ret = !(ci->i_ceph_flags & CEPH_I_SEC_INITED) && in ceph_security_xattr_deadlock()
1319 !(ci->i_xattrs.version > 0 && in ceph_security_xattr_deadlock()
1320 __ceph_caps_issued_mask(ci, CEPH_CAP_XATTR_SHARED, 0)); in ceph_security_xattr_deadlock()
1321 spin_unlock(&ci->i_ceph_lock); in ceph_security_xattr_deadlock()