Home
last modified time | relevance | path

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

/fs/ceph/
A Dsnap.c114 struct ceph_mds_client *mdsc, in ceph_create_snap_realm() argument
139 mdsc->num_snap_realms++; in ceph_create_snap_realm()
179 ceph_get_snap_realm(mdsc, r); in ceph_lookup_snap_realm()
198 mdsc->num_snap_realms--; in __destroy_snap_realm()
239 up_write(&mdsc->snap_rwsem); in ceph_put_snap_realm()
275 down_write(&mdsc->snap_rwsem); in ceph_cleanup_global_and_empty_realms()
279 __cleanup_empty_realms(mdsc); in ceph_cleanup_global_and_empty_realms()
280 up_write(&mdsc->snap_rwsem); in ceph_cleanup_global_and_empty_realms()
980 struct ceph_mds_client *mdsc = ceph_inode_to_fs_client(inode)->mdsc; in ceph_change_snap_realm() local
1130 __lookup_snap_realm(mdsc, in ceph_handle_snap()
[all …]
A Dquota.c247 up_read(&mdsc->snap_rwsem); in get_quota_realm()
249 down_read(&mdsc->snap_rwsem); in get_quota_realm()
293 down_read(&mdsc->snap_rwsem); in ceph_quota_is_same_realm()
297 up_read(&mdsc->snap_rwsem); in ceph_quota_is_same_realm()
303 up_read(&mdsc->snap_rwsem); in ceph_quota_is_same_realm()
340 down_read(&mdsc->snap_rwsem); in check_quota_exceeded()
359 up_read(&mdsc->snap_rwsem); in check_quota_exceeded()
412 up_read(&mdsc->snap_rwsem); in check_quota_exceeded()
492 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_quota_update_statfs() local
499 down_read(&mdsc->snap_rwsem); in ceph_quota_update_statfs()
[all …]
A Dmds_client.c937 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __ceph_lookup_mds_session()
944 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __have_session()
3848 if (mdsc->stopping && !__get_oldest_req(mdsc)) in handle_reply()
5478 if (!mdsc) in ceph_mdsc_init()
5541 fsc->mdsc = mdsc; in ceph_mdsc_init()
5997 __wake_requests(mdsc, &mdsc->waiting_for_map); in ceph_mdsc_force_umount()
6035 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_mdsc_destroy() local
6038 if (!mdsc) in ceph_mdsc_destroy()
6120 __wake_requests(mdsc, &mdsc->waiting_for_map); in ceph_mdsc_handle_fsmap()
6148 if (mdsc->mdsmap && epoch <= mdsc->mdsmap->m_epoch) { in ceph_mdsc_handle_mdsmap()
[all …]
A Dcaps.c164 mdsc->caps_use_max < mdsc->caps_min_count) in ceph_adjust_caps_max_min()
165 mdsc->caps_use_max = mdsc->caps_min_count; in ceph_adjust_caps_max_min()
178 mdsc->caps_reserve_count + mdsc->caps_min_count) { in __ceph_unreserve_caps()
192 mdsc->caps_total_count, mdsc->caps_use_count, in __ceph_unreserve_caps()
227 BUG_ON(mdsc->caps_total_count != mdsc->caps_use_count + in ceph_reserve_caps()
304 mdsc->caps_total_count, mdsc->caps_use_count, in ceph_reserve_caps()
323 mdsc->caps_use_count > mdsc->caps_use_max) in ceph_unreserve_caps()
393 mdsc->caps_total_count, mdsc->caps_use_count, in ceph_put_cap()
418 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_reservation_status() local
3066 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_get_caps() local
[all …]
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 …]
A Ddir.c323 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_readdir() local
1342 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_unlink() local
1541 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc; in __ceph_dentry_lease_touch() local
1575 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dn->d_sb)->mdsc; in __ceph_dentry_dir_lease_touch() local
1611 mdsc = ceph_sb_to_fs_client(di->dentry->d_sb)->mdsc; in __dentry_lease_unlist()
1645 list = lwc->dir_lease ? &mdsc->dentry_dir_leases : &mdsc->dentry_leases; in __dentry_leases_walk()
1772 mdsc->caps_use_count > mdsc->caps_use_max) in ceph_trim_dentries()
1773 count = mdsc->caps_use_count - mdsc->caps_use_max; in ceph_trim_dentries()
1843 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dentry->d_sb)->mdsc; in dentry_lease_is_valid() local
1954 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(dentry->d_sb)->mdsc; in ceph_d_revalidate() local
[all …]
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
254 __ceph_touch_fmode(ci, mdsc, fi->fmode); in ceph_ioctl_lazyio()
280 mutex_lock(&mdsc->mutex); in vet_mds_for_fscrypt()
281 for (i = 0; i < mdsc->max_sessions; i++) { in vet_mds_for_fscrypt()
[all …]
A Dmds_client.h568 extern void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc);
569 extern void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc);
572 extern void ceph_mdsc_sync(struct ceph_mds_client *mdsc);
579 extern int ceph_mdsc_submit_request(struct ceph_mds_client *mdsc,
582 int ceph_mdsc_wait_request(struct ceph_mds_client *mdsc,
585 extern int ceph_mdsc_do_request(struct ceph_mds_client *mdsc,
618 extern void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc);
626 extern char *ceph_mdsc_build_path(struct ceph_mds_client *mdsc,
635 extern void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc,
637 extern void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc,
[all …]
A Dsuper.c51 ceph_mdsc_close_sessions(fsc->mdsc); in ceph_put_super()
128 ceph_flush_dirty_caps(fsc->mdsc); in ceph_sync_fs()
129 ceph_flush_cap_releases(fsc->mdsc); in ceph_sync_fs()
136 ceph_mdsc_sync(fsc->mdsc); in ceph_sync_fs()
1063 struct ceph_mds_client *mdsc = fsc->mdsc; in open_root_dentry() local
1492 spin_lock(&mdsc->stopping_lock); in __inc_stopping_blocker()
1524 __dec_stopping_blocker(mdsc); in ceph_dec_mds_stopping_blocker()
1535 __dec_stopping_blocker(mdsc); in ceph_dec_osd_stopping_blocker()
1542 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_kill_sb() local
1547 ceph_mdsc_pre_umount(mdsc); in ceph_kill_sb()
[all …]
A Dexport.c133 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc; in __lookup_inode() local
161 err = ceph_mdsc_do_request(mdsc, NULL, req); in __lookup_inode()
215 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc; in __snapfh_to_dentry() local
216 struct ceph_client *cl = mdsc->fsc->client; in __snapfh_to_dentry()
270 err = ceph_mdsc_do_request(mdsc, NULL, req); in __snapfh_to_dentry()
326 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(sb)->mdsc; in __get_parent() local
353 err = ceph_mdsc_do_request(mdsc, NULL, req); in __get_parent()
504 err = ceph_mdsc_do_request(fsc->mdsc, NULL, req); in __get_snap_name()
551 struct ceph_mds_client *mdsc; in ceph_get_name() local
561 mdsc = ceph_inode_to_fs_client(inode)->mdsc; in ceph_get_name()
[all …]
A Dmetric.c31 struct ceph_client_metric *m = &mdsc->metric; in ceph_mdsc_send_metrics()
34 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_send_metrics()
41 mutex_lock(&mdsc->mutex); in ceph_mdsc_send_metrics()
43 mutex_unlock(&mdsc->mutex); in ceph_mdsc_send_metrics()
46 mutex_unlock(&mdsc->mutex); in ceph_mdsc_send_metrics()
191 mutex_lock(&mdsc->mutex); in metric_get_session()
193 s = __ceph_lookup_mds_session(mdsc, i); in metric_get_session()
204 mdsc->metric.session = s; in metric_get_session()
210 mutex_unlock(&mdsc->mutex); in metric_get_session()
217 struct ceph_mds_client *mdsc = in metric_delayed_work() local
[all …]
A Dsuper.h137 struct ceph_mds_client *mdsc; member
811 extern void ceph_caps_init(struct ceph_mds_client *mdsc);
812 extern void ceph_caps_finalize(struct ceph_mds_client *mdsc);
815 extern int ceph_reserve_caps(struct ceph_mds_client *mdsc,
817 extern void ceph_unreserve_caps(struct ceph_mds_client *mdsc,
987 extern void ceph_get_snap_realm(struct ceph_mds_client *mdsc,
995 extern void ceph_handle_snap(struct ceph_mds_client *mdsc,
1229 extern void ceph_put_cap(struct ceph_mds_client *mdsc,
1284 struct ceph_mds_client *mdsc, int fmode);
1334 extern int ceph_trim_dentries(struct ceph_mds_client *mdsc);
[all …]
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
80 struct ceph_client *cl = mdsc->fsc->client; in ceph_lock_message()
100 req = ceph_mdsc_create_request(mdsc, operation, USE_AUTH_MDS); in ceph_lock_message()
129 err = ceph_mdsc_submit_request(mdsc, inode, req); in ceph_lock_message()
131 err = ceph_mdsc_wait_request(mdsc, req, wait ? in ceph_lock_message()
162 struct ceph_client *cl = mdsc->fsc->client; in ceph_lock_wait_for_completion()
182 mutex_lock(&mdsc->mutex); in ceph_lock_wait_for_completion()
201 mutex_unlock(&mdsc->mutex); in ceph_lock_wait_for_completion()
205 intr_req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETFILELOCK, in ceph_lock_wait_for_completion()
[all …]
A Daddr.c96 atomic64_inc(&mdsc->dirty_folios); in ceph_dirty_folio()
944 wake_up_all(&mdsc->flush_end_wq); in writepages_finish()
2307 down_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data()
2312 up_read(&fsc->mdsc->snap_rwsem); in ceph_uninline_data()
2356 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_pool_perm_get() local
2365 down_read(&mdsc->pool_perm_rwsem); in __ceph_pool_perm_get()
2366 p = &mdsc->pool_perm_tree.rb_node; in __ceph_pool_perm_get()
2387 up_read(&mdsc->pool_perm_rwsem); in __ceph_pool_perm_get()
2398 p = &mdsc->pool_perm_tree.rb_node; in __ceph_pool_perm_get()
2422 up_write(&mdsc->pool_perm_rwsem); in __ceph_pool_perm_get()
[all …]
A Dinode.c53 percpu_counter_inc(&mdsc->metric.total_inodes); in ceph_set_ino_cb()
135 struct ceph_client *cl = mdsc->fsc->client; in ceph_get_inode()
906 struct ceph_client *cl = mdsc->fsc->client; in decode_encrypted_symlink()
963 lockdep_assert_held(&mdsc->snap_rwsem); in ceph_fill_inode()
1303 __ceph_touch_fmode(ci, mdsc, cap_fmode); in ceph_fill_inode()
1332 ceph_put_cap(mdsc, new_cap); in ceph_fill_inode()
2476 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; in __ceph_setattr() local
2538 down_read(&mdsc->snap_rwsem); in __ceph_setattr()
2777 up_read(&mdsc->snap_rwsem); in __ceph_setattr()
2906 struct ceph_mds_client *mdsc = fsc->mdsc; in __ceph_do_getattr() local
[all …]
A Dfile.c25 struct ceph_client *cl = mdsc->fsc->client; in ceph_flags_sys2wire()
303 struct ceph_client *cl = mdsc->fsc->client; in ceph_renew_caps()
309 __ceph_touch_fmode(ci, mdsc, fmode); in ceph_renew_caps()
345 err = ceph_mdsc_do_request(mdsc, NULL, req); in ceph_renew_caps()
364 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_open() local
444 __ceph_touch_fmode(ci, mdsc, fmode); in ceph_open()
456 __ceph_touch_fmode(ci, mdsc, fmode); in ceph_open()
601 struct ceph_client *cl = mdsc->fsc->client; in ceph_async_create_cb()
730 down_read(&mdsc->snap_rwsem); in ceph_finish_async_create()
733 up_read(&mdsc->snap_rwsem); in ceph_finish_async_create()
[all …]
A Dxattr.c1115 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_sync_setxattr() local
1140 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); in ceph_sync_setxattr()
1167 err = ceph_mdsc_do_request(mdsc, NULL, req); in ceph_sync_setxattr()
1183 struct ceph_mds_client *mdsc = ceph_sb_to_fs_client(inode->i_sb)->mdsc; in __ceph_setxattr() local
1238 (required_blob_size > mdsc->mdsmap->m_max_xattr_size)) { in __ceph_setxattr()
1241 mdsc->mdsmap->m_max_xattr_size); in __ceph_setxattr()
1247 if (!down_read_trylock(&mdsc->snap_rwsem)) { in __ceph_setxattr()
1249 down_read(&mdsc->snap_rwsem); in __ceph_setxattr()
1291 up_read(&mdsc->snap_rwsem); in __ceph_setxattr()
1301 up_read(&mdsc->snap_rwsem); in __ceph_setxattr()
A Dmdsmap.h74 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p,
A Dmdsmap.c118 struct ceph_mdsmap *ceph_mdsmap_decode(struct ceph_mds_client *mdsc, void **p, in ceph_mdsmap_decode() argument
121 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsmap_decode()

Completed in 87 milliseconds