Home
last modified time | relevance | path

Searched refs:mdsc (Results 1 – 19 of 19) sorted by relevance

/openbmc/linux/fs/ceph/
H A Dsnap.c114 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 Dquota.c242 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 Dmds_client.c931 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 Dcaps.c163 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 Ddebugfs.c31 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 Dioctl.c51 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 Dmds_client.h526 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 Ddir.c314 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 Dsuper.c51 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 Dmetric.c31 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 Dexport.c126 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 Dsuper.h136 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 Dlocks.c14 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 Daddr.c1934 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 Dinode.c53 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 Dfile.c304 __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 Dxattr.c1100 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 Dmdsmap.c117 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 Dmdsmap.h74 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p,