/openbmc/linux/fs/ceph/ |
H A D | snap.c | 114 struct ceph_mds_client *mdsc, in ceph_create_snap_realm() argument 139 mdsc->num_snap_realms++; in ceph_create_snap_realm() 178 ceph_get_snap_realm(mdsc, r); in ceph_lookup_snap_realm() 196 mdsc->num_snap_realms--; in __destroy_snap_realm() 237 up_write(&mdsc->snap_rwsem); in ceph_put_snap_realm() 273 down_write(&mdsc->snap_rwsem); in ceph_cleanup_global_and_empty_realms() 277 __cleanup_empty_realms(mdsc); in ceph_cleanup_global_and_empty_realms() 278 up_write(&mdsc->snap_rwsem); in ceph_cleanup_global_and_empty_realms() 967 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; in ceph_change_snap_realm() local 1116 __lookup_snap_realm(mdsc, in ceph_handle_snap() [all …]
|
H A D | quota.c | 242 up_read(&mdsc->snap_rwsem); in get_quota_realm() 244 down_read(&mdsc->snap_rwsem); in get_quota_realm() 288 down_read(&mdsc->snap_rwsem); in ceph_quota_is_same_realm() 292 up_read(&mdsc->snap_rwsem); in ceph_quota_is_same_realm() 298 up_read(&mdsc->snap_rwsem); in ceph_quota_is_same_realm() 334 down_read(&mdsc->snap_rwsem); in check_quota_exceeded() 352 up_read(&mdsc->snap_rwsem); in check_quota_exceeded() 405 up_read(&mdsc->snap_rwsem); in check_quota_exceeded() 485 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_quota_update_statfs() local 492 down_read(&mdsc->snap_rwsem); in ceph_quota_update_statfs() [all …]
|
H A D | mds_client.c | 931 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __ceph_lookup_mds_session() 938 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __have_session() 3688 if (mdsc->stopping && !__get_oldest_req(mdsc)) in handle_reply() 5187 if (!mdsc) in ceph_mdsc_init() 5244 fsc->mdsc = mdsc; in ceph_mdsc_init() 5527 __wake_requests(mdsc, &mdsc->waiting_for_map); in ceph_mdsc_force_umount() 5553 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_mdsc_destroy() local 5556 if (!mdsc) in ceph_mdsc_destroy() 5636 __wake_requests(mdsc, &mdsc->waiting_for_map); in ceph_mdsc_handle_fsmap() 5663 if (mdsc->mdsmap && epoch <= mdsc->mdsmap->m_epoch) { in ceph_mdsc_handle_mdsmap() [all …]
|
H A D | caps.c | 163 mdsc->caps_use_max < mdsc->caps_min_count) in ceph_adjust_caps_max_min() 164 mdsc->caps_use_max = mdsc->caps_min_count; in ceph_adjust_caps_max_min() 177 mdsc->caps_reserve_count + mdsc->caps_min_count) { in __ceph_unreserve_caps() 191 mdsc->caps_total_count, mdsc->caps_use_count, in __ceph_unreserve_caps() 192 mdsc->caps_reserve_count, mdsc->caps_avail_count); in __ceph_unreserve_caps() 193 BUG_ON(mdsc->caps_total_count != mdsc->caps_use_count + in __ceph_unreserve_caps() 225 BUG_ON(mdsc->caps_total_count != mdsc->caps_use_count + in ceph_reserve_caps() 320 mdsc->caps_use_count > mdsc->caps_use_max) in ceph_unreserve_caps() 412 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_reservation_status() local 2993 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_get_caps() local [all …]
|
H A D | debugfs.c | 31 if (!fsc->mdsc || !fsc->mdsc->mdsmap) in mdsmap_show() 33 mdsmap = fsc->mdsc->mdsmap; in mdsmap_show() 55 struct ceph_mds_client *mdsc = fsc->mdsc; in mdsc_show() local 62 mutex_lock(&mdsc->mutex); in mdsc_show() 125 mutex_unlock(&mdsc->mutex); in mdsc_show() 271 struct ceph_mds_client *mdsc = fsc->mdsc; in caps_show() local 285 mutex_lock(&mdsc->mutex); in caps_show() 297 mutex_lock(&mdsc->mutex); in caps_show() 319 struct ceph_mds_client *mdsc = fsc->mdsc; in mds_sessions_show() local 324 mutex_lock(&mdsc->mutex); in mds_sessions_show() [all …]
|
H A D | ioctl.c | 51 mutex_lock(&mdsc->mutex); in __validate_layout() 58 mutex_unlock(&mdsc->mutex); in __validate_layout() 68 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; in ceph_ioctl_set_layout() local 104 err = __validate_layout(mdsc, &nl); in ceph_ioctl_set_layout() 143 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; in ceph_ioctl_set_layout_policy() local 149 err = __validate_layout(mdsc, &l); in ceph_ioctl_set_layout_policy() 247 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; in ceph_ioctl_lazyio() local 253 __ceph_touch_fmode(ci, mdsc, fi->fmode); in ceph_ioctl_lazyio() 277 mutex_lock(&mdsc->mutex); in vet_mds_for_fscrypt() 278 for (i = 0; i < mdsc->max_sessions; i++) { in vet_mds_for_fscrypt() [all …]
|
H A D | mds_client.h | 526 extern int ceph_send_msg_mds(struct ceph_mds_client *mdsc, 531 extern void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc); 534 extern void ceph_mdsc_sync(struct ceph_mds_client *mdsc); 541 extern int ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, 544 int ceph_mdsc_wait_request(struct ceph_mds_client *mdsc, 547 extern int ceph_mdsc_do_request(struct ceph_mds_client *mdsc, 569 extern void ceph_flush_cap_releases(struct ceph_mds_client *mdsc, 576 extern void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc); 584 extern char *ceph_mdsc_build_path(struct ceph_mds_client *mdsc, 595 extern void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, [all …]
|
H A D | dir.c | 314 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_readdir() local 1294 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_unlink() local 1462 struct ceph_mds_client *mdsc; in __ceph_dentry_lease_touch() local 1472 mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc; in __ceph_dentry_lease_touch() 1496 struct ceph_mds_client *mdsc; in __ceph_dentry_dir_lease_touch() local 1519 mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc; in __ceph_dentry_dir_lease_touch() 1533 mdsc = ceph_sb_to_fs_client(di->dentry->d_sb)->mdsc; in __dentry_lease_unlist() 1565 list = lwc->dir_lease ? &mdsc->dentry_dir_leases : &mdsc->dentry_leases; in __dentry_leases_walk() 1689 mdsc->caps_use_count > mdsc->caps_use_max) in ceph_trim_dentries() 1690 count = mdsc->caps_use_count - mdsc->caps_use_max; in ceph_trim_dentries() [all …]
|
H A D | super.c | 51 ceph_mdsc_close_sessions(fsc->mdsc); in ceph_put_super() 125 ceph_flush_dirty_caps(fsc->mdsc); in ceph_sync_fs() 132 ceph_mdsc_sync(fsc->mdsc); in ceph_sync_fs() 1048 struct ceph_mds_client *mdsc = fsc->mdsc; in open_root_dentry() local 1471 spin_lock(&mdsc->stopping_lock); in __inc_stopping_blocker() 1483 spin_lock(&mdsc->stopping_lock); in __dec_stopping_blocker() 1503 __dec_stopping_blocker(mdsc); in ceph_dec_mds_stopping_blocker() 1514 __dec_stopping_blocker(mdsc); in ceph_dec_osd_stopping_blocker() 1520 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_kill_sb() local 1525 ceph_mdsc_pre_umount(mdsc); in ceph_kill_sb() [all …]
|
H A D | metric.c | 31 struct ceph_client_metric *m = &mdsc->metric; in ceph_mdsc_send_metrics() 40 mutex_lock(&mdsc->mutex); in ceph_mdsc_send_metrics() 42 mutex_unlock(&mdsc->mutex); in ceph_mdsc_send_metrics() 45 mutex_unlock(&mdsc->mutex); in ceph_mdsc_send_metrics() 190 mutex_lock(&mdsc->mutex); in metric_get_session() 191 for (i = 0; i < mdsc->max_sessions; i++) { in metric_get_session() 192 s = __ceph_lookup_mds_session(mdsc, i); in metric_get_session() 203 mdsc->metric.session = s; in metric_get_session() 209 mutex_unlock(&mdsc->mutex); in metric_get_session() 216 struct ceph_mds_client *mdsc = in metric_delayed_work() local [all …]
|
H A D | export.c | 126 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc; in __lookup_inode() local 142 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO, in __lookup_inode() 154 err = ceph_mdsc_do_request(mdsc, NULL, req); in __lookup_inode() 208 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc; in __snapfh_to_dentry() local 262 err = ceph_mdsc_do_request(mdsc, NULL, req); in __snapfh_to_dentry() 320 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc; in __get_parent() local 347 err = ceph_mdsc_do_request(mdsc, NULL, req); in __get_parent() 490 err = ceph_mdsc_do_request(fsc->mdsc, NULL, req); in __get_snap_name() 537 struct ceph_mds_client *mdsc; in ceph_get_name() local 547 mdsc = ceph_inode_to_fs_client(inode)->mdsc; in ceph_get_name() [all …]
|
H A D | super.h | 136 struct ceph_mds_client *mdsc; member 804 extern void ceph_caps_init(struct ceph_mds_client *mdsc); 805 extern void ceph_caps_finalize(struct ceph_mds_client *mdsc); 808 extern int ceph_reserve_caps(struct ceph_mds_client *mdsc, 810 extern void ceph_unreserve_caps(struct ceph_mds_client *mdsc, 980 extern void ceph_get_snap_realm(struct ceph_mds_client *mdsc, 988 extern void ceph_handle_snap(struct ceph_mds_client *mdsc, 1229 extern void ceph_put_cap(struct ceph_mds_client *mdsc, 1285 struct ceph_mds_client *mdsc, int fmode); 1335 extern int ceph_trim_dentries(struct ceph_mds_client *mdsc); [all …]
|
H A D | locks.c | 14 static int ceph_lock_wait_for_completion(struct ceph_mds_client *mdsc, 79 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in ceph_lock_message() local 99 req = ceph_mdsc_create_request(mdsc, operation, USE_AUTH_MDS); in ceph_lock_message() 127 err = ceph_mdsc_submit_request(mdsc, inode, req); in ceph_lock_message() 129 err = ceph_mdsc_wait_request(mdsc, req, wait ? in ceph_lock_message() 157 static int ceph_lock_wait_for_completion(struct ceph_mds_client *mdsc, in ceph_lock_wait_for_completion() argument 180 mutex_lock(&mdsc->mutex); in ceph_lock_wait_for_completion() 199 mutex_unlock(&mdsc->mutex); in ceph_lock_wait_for_completion() 203 intr_req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETFILELOCK, in ceph_lock_wait_for_completion() 216 err = ceph_mdsc_do_request(mdsc, inode, intr_req); in ceph_lock_wait_for_completion()
|
H A D | addr.c | 1934 down_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data() 1939 up_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data() 1983 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_pool_perm_get() local 1991 down_read(&mdsc->pool_perm_rwsem); in __ceph_pool_perm_get() 1992 p = &mdsc->pool_perm_tree.rb_node; in __ceph_pool_perm_get() 2013 up_read(&mdsc->pool_perm_rwsem); in __ceph_pool_perm_get() 2023 down_write(&mdsc->pool_perm_rwsem); in __ceph_pool_perm_get() 2024 p = &mdsc->pool_perm_tree.rb_node; in __ceph_pool_perm_get() 2048 up_write(&mdsc->pool_perm_rwsem); in __ceph_pool_perm_get() 2138 up_write(&mdsc->pool_perm_rwsem); in __ceph_pool_perm_get() [all …]
|
H A D | inode.c | 53 percpu_counter_inc(&mdsc->metric.total_inodes); in ceph_set_ino_cb() 708 ceph_put_snapid_map(mdsc, ci->i_snapid_map); in ceph_evict_inode() 937 lockdep_assert_held(&mdsc->snap_rwsem); in ceph_fill_inode() 1270 __ceph_touch_fmode(ci, mdsc, cap_fmode); in ceph_fill_inode() 1299 ceph_put_cap(mdsc, new_cap); in ceph_fill_inode() 2430 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; in __ceph_setattr() local 2463 down_read(&mdsc->snap_rwsem); in __ceph_setattr() 2687 up_read(&mdsc->snap_rwsem); in __ceph_setattr() 2814 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_do_getattr() local 2838 err = ceph_mdsc_do_request(mdsc, NULL, req); in __ceph_do_getattr() [all …]
|
H A D | file.c | 304 __ceph_touch_fmode(ci, mdsc, fmode); in ceph_renew_caps() 339 err = ceph_mdsc_do_request(mdsc, NULL, req); in ceph_renew_caps() 356 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_open() local 405 __ceph_touch_fmode(ci, mdsc, fmode); in ceph_open() 417 __ceph_touch_fmode(ci, mdsc, fmode); in ceph_open() 434 err = ceph_mdsc_do_request(mdsc, NULL, req); in ceph_open() 681 down_read(&mdsc->snap_rwsem); in ceph_finish_async_create() 684 up_read(&mdsc->snap_rwsem); in ceph_finish_async_create() 734 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_atomic_open() local 1053 ceph_update_read_metrics(&fsc->mdsc->metric, in __ceph_sync_read() [all …]
|
H A D | xattr.c | 1100 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_sync_setxattr() local 1125 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); in ceph_sync_setxattr() 1152 err = ceph_mdsc_do_request(mdsc, NULL, req); in ceph_sync_setxattr() 1167 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; in __ceph_setxattr() local 1222 (required_blob_size > mdsc->mdsmap->m_max_xattr_size)) { in __ceph_setxattr() 1225 mdsc->mdsmap->m_max_xattr_size); in __ceph_setxattr() 1231 if (!down_read_trylock(&mdsc->snap_rwsem)) { in __ceph_setxattr() 1233 down_read(&mdsc->snap_rwsem); in __ceph_setxattr() 1274 up_read(&mdsc->snap_rwsem); in __ceph_setxattr() 1284 up_read(&mdsc->snap_rwsem); in __ceph_setxattr()
|
H A D | mdsmap.c | 117 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p, in ceph_mdsmap_decode() argument
|
/openbmc/linux/include/linux/ceph/ |
H A D | mdsmap.h | 74 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p,
|