| /kernel/linux/linux-5.10/fs/ceph/ |
| H A D | mds_client.c | 60 static void __wake_requests(struct ceph_mds_client *mdsc,
653 dout("mdsc get_session %p %d -> %d\n", s, in ceph_get_mds_session()
657 dout("mdsc get_session %p 0 -- FAIL\n", s); in ceph_get_mds_session()
667 dout("mdsc put_session %p %d -> %d\n", s, in ceph_put_mds_session()
679 * called under mdsc->mutex
681 struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc, in __ceph_lookup_mds_session() argument
684 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __ceph_lookup_mds_session()
686 return ceph_get_mds_session(mdsc->sessions[mds]); in __ceph_lookup_mds_session()
689 static bool __have_session(struct ceph_mds_client *mdsc, in argument
697 __verify_registered_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *s) __verify_registered_session() argument
710 register_session(struct ceph_mds_client *mdsc, int mds) register_session() argument
788 __unregister_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *s) __unregister_session() argument
812 ceph_mdsc_iterate_sessions(struct ceph_mds_client *mdsc, void (*cb)(struct ceph_mds_session *), bool check_state) ceph_mdsc_iterate_sessions() argument
893 lookup_get_request(struct ceph_mds_client *mdsc, u64 tid) lookup_get_request() argument
910 __register_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, struct inode *dir) __register_request() argument
949 __unregister_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) __unregister_request() argument
1028 __choose_mds(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, bool *random) __choose_mds() argument
1283 create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) create_session_open_msg() argument
1393 __open_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) __open_session() argument
1421 __open_export_target_session(struct ceph_mds_client *mdsc, int target) __open_export_target_session() argument
1443 ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target) ceph_mdsc_open_export_target_session() argument
1456 __open_export_target_sessions(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) __open_export_target_sessions() argument
1476 ceph_mdsc_open_export_target_sessions(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_mdsc_open_export_target_sessions() argument
1498 dispose_cap_releases(struct ceph_mds_client *mdsc, struct list_head *dispose) dispose_cap_releases() argument
1510 cleanup_session_requests(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) cleanup_session_requests() argument
1614 remove_capsnaps(struct ceph_mds_client *mdsc, struct inode *inode) remove_capsnaps() argument
1641 struct ceph_mds_client *mdsc = fsc->mdsc; remove_session_caps_cb() local
1842 send_renew_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) send_renew_caps() argument
1872 send_flushmsg_ack(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, u64 seq) send_flushmsg_ack() argument
1892 renewed_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, int is_renew) renewed_caps() argument
1942 __close_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) __close_session() argument
2057 ceph_trim_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, int max_caps) ceph_trim_caps() argument
2078 check_caps_flush(struct ceph_mds_client *mdsc, u64 want_flush_tid) check_caps_flush() argument
2103 wait_caps_flush(struct ceph_mds_client *mdsc, u64 want_flush_tid) wait_caps_flush() argument
2117 ceph_send_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_send_cap_releases() argument
2224 ceph_flush_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_flush_cap_releases() argument
2255 struct ceph_mds_client *mdsc = ceph_cap_reclaim_work() local
2262 ceph_queue_cap_reclaim_work(struct ceph_mds_client *mdsc) ceph_queue_cap_reclaim_work() argument
2274 ceph_reclaim_caps_nr(struct ceph_mds_client *mdsc, int nr) ceph_reclaim_caps_nr() argument
2332 ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode) ceph_mdsc_create_request() argument
2367 __get_oldest_req(struct ceph_mds_client *mdsc) __get_oldest_req() argument
2375 __get_oldest_tid(struct ceph_mds_client *mdsc) __get_oldest_tid() argument
2549 create_request_message(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, int mds, bool drop_cap_releases) create_request_message() argument
2692 complete_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) complete_request() argument
2705 __prepare_send_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, int mds, bool drop_cap_releases) __prepare_send_request() argument
2792 __send_request(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_mds_request *req, bool drop_cap_releases) __send_request() argument
2812 __do_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) __do_request() argument
2934 __wake_requests(struct ceph_mds_client *mdsc, struct list_head *head) __wake_requests() argument
2955 kick_requests(struct ceph_mds_client *mdsc, int mds) kick_requests() argument
2977 ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, struct inode *dir, struct ceph_mds_request *req) ceph_mdsc_submit_request() argument
3026 ceph_mdsc_wait_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) ceph_mdsc_wait_request() argument
3080 ceph_mdsc_do_request(struct ceph_mds_client *mdsc, struct inode *dir, struct ceph_mds_request *req) ceph_mdsc_do_request() argument
3125 struct ceph_mds_client *mdsc = session->s_mdsc; handle_reply() local
3320 handle_forward(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) handle_forward() argument
3403 struct ceph_mds_client *mdsc = session->s_mdsc; handle_session() local
3577 replay_unsafe_requests(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) replay_unsafe_requests() argument
3904 encode_snap_realms(struct ceph_mds_client *mdsc, struct ceph_reconnect_state *recon_state) encode_snap_realms() argument
3974 send_mds_reconnect(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) send_mds_reconnect() argument
4149 check_new_map(struct ceph_mds_client *mdsc, struct ceph_mdsmap *newmap, struct ceph_mdsmap *oldmap) check_new_map() argument
4268 handle_lease(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) handle_lease() argument
4421 maybe_recover_session(struct ceph_mds_client *mdsc) maybe_recover_session() argument
4492 schedule_delayed(struct ceph_mds_client *mdsc, unsigned long delay) schedule_delayed() argument
4505 struct ceph_mds_client *mdsc = delayed_work() local
4564 struct ceph_mds_client *mdsc; ceph_mdsc_init() local
4647 wait_requests(struct ceph_mds_client *mdsc) wait_requests() argument
4701 ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc) ceph_mdsc_pre_umount() argument
4723 wait_unsafe_requests(struct ceph_mds_client *mdsc, u64 want_tid) wait_unsafe_requests() argument
4766 ceph_mdsc_sync(struct ceph_mds_client *mdsc) ceph_mdsc_sync() argument
4799 done_closing_sessions(struct ceph_mds_client *mdsc, int skipped) done_closing_sessions() argument
4809 ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc) ceph_mdsc_close_sessions() argument
4865 ceph_mdsc_force_umount(struct ceph_mds_client *mdsc) ceph_mdsc_force_umount() argument
4899 ceph_mdsc_stop(struct ceph_mds_client *mdsc) ceph_mdsc_stop() argument
4921 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_mdsc_destroy() local
4939 ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) ceph_mdsc_handle_fsmap() argument
5018 ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) ceph_mdsc_handle_mdsmap() argument
5101 struct ceph_mds_client *mdsc = s->s_mdsc; peer_reset() local
5110 struct ceph_mds_client *mdsc = s->s_mdsc; dispatch() local
5169 struct ceph_mds_client *mdsc = s->s_mdsc; get_authorizer() local
5197 struct ceph_mds_client *mdsc = s->s_mdsc; add_authorizer_challenge() local
5207 struct ceph_mds_client *mdsc = s->s_mdsc; verify_authorizer_reply() local
5216 struct ceph_mds_client *mdsc = s->s_mdsc; invalidate_authorizer() local
[all...] |
| H A D | quota.c | 15 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in ceph_adjust_quota_realms_count() local
17 atomic64_inc(&mdsc->quotarealms_count); in ceph_adjust_quota_realms_count()
19 atomic64_dec(&mdsc->quotarealms_count); in ceph_adjust_quota_realms_count()
25 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(sb); in ceph_has_realms_with_quotas() local
28 if (atomic64_read(&mdsc->quotarealms_count) > 0) in ceph_has_realms_with_quotas()
37 void ceph_handle_quota(struct ceph_mds_client *mdsc, in ceph_handle_quota() argument
41 struct super_block *sb = mdsc->fsc->sb; in ceph_handle_quota()
82 find_quotarealm_inode(struct ceph_mds_client *mdsc, u64 ino) in find_quotarealm_inode() argument
87 mutex_lock(&mdsc->quotarealms_inodes_mutex); in find_quotarealm_inode()
88 node = &(mdsc in find_quotarealm_inode()
126 lookup_quotarealm_inode(struct ceph_mds_client *mdsc, struct super_block *sb, struct ceph_snap_realm *realm) lookup_quotarealm_inode() argument
174 ceph_cleanup_quotarealms_inodes(struct ceph_mds_client *mdsc) ceph_cleanup_quotarealms_inodes() argument
209 get_quota_realm(struct ceph_mds_client *mdsc, struct inode *inode, bool retry) get_quota_realm() argument
269 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old->i_sb); ceph_quota_is_same_realm() local
316 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); check_quota_exceeded() local
478 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_quota_update_statfs() local
533 ceph_quota_check_rename(struct ceph_mds_client *mdsc, struct inode *old, struct inode *new) ceph_quota_check_rename() argument
[all...] |
| H A D | snap.c | 65 void ceph_get_snap_realm(struct ceph_mds_client *mdsc, in ceph_get_snap_realm() argument
68 lockdep_assert_held(&mdsc->snap_rwsem); in ceph_get_snap_realm()
79 spin_lock(&mdsc->snap_empty_lock); in ceph_get_snap_realm()
82 spin_unlock(&mdsc->snap_empty_lock); in ceph_get_snap_realm()
113 struct ceph_mds_client *mdsc, in ceph_create_snap_realm()
118 lockdep_assert_held_write(&mdsc->snap_rwsem); in ceph_create_snap_realm()
132 __insert_snap_realm(&mdsc->snap_realms, realm); in ceph_create_snap_realm()
133 mdsc->num_snap_realms++; in ceph_create_snap_realm()
144 static struct ceph_snap_realm *__lookup_snap_realm(struct ceph_mds_client *mdsc, in __lookup_snap_realm() argument
147 struct rb_node *n = mdsc in __lookup_snap_realm()
112 ceph_create_snap_realm( struct ceph_mds_client *mdsc, u64 ino) ceph_create_snap_realm() argument
166 ceph_lookup_snap_realm(struct ceph_mds_client *mdsc, u64 ino) ceph_lookup_snap_realm() argument
182 __destroy_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) __destroy_snap_realm() argument
206 __put_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) __put_snap_realm() argument
222 ceph_put_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) ceph_put_snap_realm() argument
245 __cleanup_empty_realms(struct ceph_mds_client *mdsc) __cleanup_empty_realms() argument
263 ceph_cleanup_empty_realms(struct ceph_mds_client *mdsc) ceph_cleanup_empty_realms() argument
278 adjust_snap_realm_parent(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm, u64 parentino) adjust_snap_realm_parent() argument
622 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); __ceph_finish_cap_snap() local
695 ceph_update_snap_trace(struct ceph_mds_client *mdsc, void *p, void *e, bool deletion, struct ceph_snap_realm **realm_ret) ceph_update_snap_trace() argument
833 flush_snaps(struct ceph_mds_client *mdsc) flush_snaps() argument
874 ceph_handle_snap(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) ceph_handle_snap() argument
1055 ceph_get_snapid_map(struct ceph_mds_client *mdsc, u64 snap) ceph_get_snapid_map() argument
1132 ceph_put_snapid_map(struct ceph_mds_client* mdsc, struct ceph_snapid_map *sm) ceph_put_snapid_map() argument
1151 ceph_trim_snapid_map(struct ceph_mds_client *mdsc) ceph_trim_snapid_map() argument
1180 ceph_cleanup_snapid_map(struct ceph_mds_client *mdsc) ceph_cleanup_snapid_map() argument
[all...] |
| H A D | caps.c | 45 static u64 __get_oldest_flush_tid(struct ceph_mds_client *mdsc);
46 static void __kick_flushing_caps(struct ceph_mds_client *mdsc,
127 void ceph_caps_init(struct ceph_mds_client *mdsc) in ceph_caps_init() argument
129 INIT_LIST_HEAD(&mdsc->caps_list); in ceph_caps_init()
130 spin_lock_init(&mdsc->caps_list_lock); in ceph_caps_init()
133 void ceph_caps_finalize(struct ceph_mds_client *mdsc) in ceph_caps_finalize() argument
137 spin_lock(&mdsc->caps_list_lock); in ceph_caps_finalize()
138 while (!list_empty(&mdsc->caps_list)) { in ceph_caps_finalize()
139 cap = list_first_entry(&mdsc->caps_list, in ceph_caps_finalize()
144 mdsc in ceph_caps_finalize()
152 ceph_adjust_caps_max_min(struct ceph_mds_client *mdsc, struct ceph_mount_options *fsopt) ceph_adjust_caps_max_min() argument
166 __ceph_unreserve_caps(struct ceph_mds_client *mdsc, int nr_caps) __ceph_unreserve_caps() argument
200 ceph_reserve_caps(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx, int need) ceph_reserve_caps() argument
305 ceph_unreserve_caps(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx) ceph_unreserve_caps() argument
326 ceph_get_cap(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx) ceph_get_cap() argument
381 ceph_put_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap) ceph_put_cap() argument
410 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_reservation_status() local
489 __cap_set_timeouts(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) __cap_set_timeouts() argument
507 __cap_delay_requeue(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) __cap_delay_requeue() argument
531 __cap_delay_requeue_front(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) __cap_delay_requeue_front() argument
548 __cap_delay_cancel(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) __cap_delay_cancel() argument
636 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; ceph_add_cap() local
1143 struct ceph_mds_client *mdsc; __ceph_remove_cap() local
1545 struct ceph_mds_client *mdsc = session->s_mdsc; global() variable
1638 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; ceph_flush_snaps() local
1709 struct ceph_mds_client *mdsc = __ceph_mark_dirty_caps() local
1778 __get_oldest_flush_tid(struct ceph_mds_client *mdsc) __get_oldest_flush_tid() argument
1793 __detach_cap_flush_from_mdsc(struct ceph_mds_client *mdsc, struct ceph_cap_flush *cf) __detach_cap_flush_from_mdsc() argument
1833 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; __mark_caps_flushing() local
1929 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); ceph_check_caps() local
2214 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; try_flush_caps() local
2304 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; unsafe_request_wait() local
2482 struct ceph_mds_client *mdsc = ceph_write_inode() local
2571 ceph_early_kick_flushing_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_early_kick_flushing_caps() argument
2619 ceph_kick_flushing_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_kick_flushing_caps() argument
2654 struct ceph_mds_client *mdsc = session->s_mdsc; ceph_kick_flushing_inode_caps() local
2732 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; try_get_cap_refs() local
2974 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_get_caps() local
3654 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; global() variable
3760 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; __ceph_remove_capsnap() local
3804 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; handle_cap_flushsnap_ack() local
3888 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; handle_cap_export() local
4013 handle_cap_import(struct ceph_mds_client *mdsc, struct inode *inode, struct ceph_mds_caps *im, struct ceph_mds_cap_peer *ph, struct ceph_mds_session *session, struct ceph_cap **target_cap, int *old_issued) handle_cap_import() argument
4096 struct ceph_mds_client *mdsc = session->s_mdsc; ceph_handle_caps() local
4338 ceph_check_delayed_caps(struct ceph_mds_client *mdsc) ceph_check_delayed_caps() argument
4383 struct ceph_mds_client *mdsc = s->s_mdsc; flush_dirty_session_caps() local
4404 ceph_flush_dirty_caps(struct ceph_mds_client *mdsc) ceph_flush_dirty_caps() argument
4409 __ceph_touch_fmode(struct ceph_inode_info *ci, struct ceph_mds_client *mdsc, int fmode) __ceph_touch_fmode() argument
4426 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(ci->vfs_inode.i_sb); ceph_get_fmode() local
4460 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(ci->vfs_inode.i_sb); ceph_put_fmode() local
4505 struct ceph_mds_client *mdsc = ceph_drop_caps_for_unlink() 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()
50 * mdsc debugfs
55 struct ceph_mds_client *mdsc = fsc->mdsc; in mdsc_show() local
62 mutex_lock(&mdsc->mutex); in mdsc_show()
63 for (rp = rb_first(&mdsc->request_tree); rp; rp = rb_next(rp)) { in mdsc_show()
125 mutex_unlock(&mdsc->mutex); in mdsc_show()
146 struct ceph_mds_client *mdsc in metric_show() local
226 struct ceph_mds_client *mdsc = fsc->mdsc; caps_show() local
274 struct ceph_mds_client *mdsc = fsc->mdsc; mds_sessions_show() local
308 DEFINE_SHOW_ATTRIBUTE(mdsc); global() variable
[all...] |
| H A D | ioctl.c | 37 static long __validate_layout(struct ceph_mds_client *mdsc, in __validate_layout() argument
50 mutex_lock(&mdsc->mutex); in __validate_layout()
52 for (i = 0; i < mdsc->mdsmap->m_num_data_pg_pools; i++) in __validate_layout()
53 if (mdsc->mdsmap->m_data_pg_pools[i] == l->data_pool) { in __validate_layout()
57 mutex_unlock(&mdsc->mutex); in __validate_layout()
67 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; in ceph_ioctl_set_layout() local
103 err = __validate_layout(mdsc, &nl); in ceph_ioctl_set_layout()
107 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETLAYOUT, in ceph_ioctl_set_layout()
125 err = ceph_mdsc_do_request(mdsc, NUL in ceph_ioctl_set_layout()
142 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; ceph_ioctl_set_layout_policy() local
246 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; ceph_ioctl_lazyio() local
[all...] |
| H A D | dir.c | 41 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dentry->d_sb); in ceph_d_init() local
53 atomic64_inc(&mdsc->metric.total_dentries); in ceph_d_init()
311 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_readdir() local
346 __ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_WR); in ceph_readdir()
389 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); in ceph_readdir()
426 err = ceph_mdsc_do_request(mdsc, NULL, req); in ceph_readdir()
749 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); in ceph_lookup() local
775 __ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_RD); in ceph_lookup()
787 req = ceph_mdsc_create_request(mdsc, o in ceph_lookup()
838 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); ceph_mknod() local
899 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); ceph_symlink() local
951 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); ceph_mkdir() local
1018 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); ceph_link() local
1052 ceph_async_unlink_cb(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) ceph_async_unlink_cb() argument
1130 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_unlink() local
1199 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old_dir->i_sb); ceph_rename() local
1266 struct ceph_mds_client *mdsc; __ceph_dentry_lease_touch() local
1282 __dentry_dir_lease_touch(struct ceph_mds_client* mdsc, struct ceph_dentry_info *di) __dentry_dir_lease_touch() argument
1300 struct ceph_mds_client *mdsc; __ceph_dentry_dir_lease_touch() local
1331 struct ceph_mds_client *mdsc; __dentry_lease_unlist() local
1358 __dentry_leases_walk(struct ceph_mds_client *mdsc, struct ceph_lease_walk_control *lwc, int (*check)(struct dentry*, void*)) __dentry_leases_walk() argument
1485 ceph_trim_dentries(struct ceph_mds_client *mdsc) ceph_trim_dentries() argument
1637 dir_lease_is_valid(struct inode *dir, struct dentry *dentry, struct ceph_mds_client *mdsc) dir_lease_is_valid() argument
1675 struct ceph_mds_client *mdsc; ceph_d_revalidate() local
[all...] |
| H A D | metric.c | 11 static bool ceph_mdsc_send_metrics(struct ceph_mds_client *mdsc, in ceph_mdsc_send_metrics() argument
19 struct ceph_client_metric *m = &mdsc->metric; in ceph_mdsc_send_metrics()
45 cap->hit = cpu_to_le64(percpu_counter_sum(&mdsc->metric.i_caps_hit)); in ceph_mdsc_send_metrics()
46 cap->mis = cpu_to_le64(percpu_counter_sum(&mdsc->metric.i_caps_mis)); in ceph_mdsc_send_metrics()
92 ceph_client_gid(mdsc->fsc->client), s->s_mds); in ceph_mdsc_send_metrics()
99 static void metric_get_session(struct ceph_mds_client *mdsc) in metric_get_session() argument
104 mutex_lock(&mdsc->mutex); in metric_get_session()
105 for (i = 0; i < mdsc->max_sessions; i++) { in metric_get_session()
106 s = __ceph_lookup_mds_session(mdsc, i); in metric_get_session()
117 mdsc in metric_get_session()
130 struct ceph_mds_client *mdsc = metric_delayed_work() local
[all...] |
| H A D | mds_client.h | 51 * mdsc->mutex
53 * mdsc->snap_rwsem
56 * mdsc->snap_flush_lock
57 * mdsc->cap_delay_lock
228 typedef void (*ceph_mds_request_callback_t) (struct ceph_mds_client *mdsc,
233 typedef int (*ceph_mds_request_wait_callback_t) (struct ceph_mds_client *mdsc,
493 extern int ceph_send_msg_mds(struct ceph_mds_client *mdsc,
497 extern void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc);
498 extern void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc);
501 extern void ceph_mdsc_sync(struct ceph_mds_client *mdsc);
[all...] |
| H A D | super.h | 119 struct ceph_mds_client *mdsc; member
359 * is protected by the mdsc->cap_dirty_lock, but each individual item
361 * requires the mdsc->cap_dirty_lock. List presence for an item can
457 return (struct ceph_mds_client *)ceph_sb_to_client(sb)->mdsc; in ceph_sb_to_mdsc()
747 extern void ceph_caps_init(struct ceph_mds_client *mdsc);
748 extern void ceph_caps_finalize(struct ceph_mds_client *mdsc);
749 extern void ceph_adjust_caps_max_min(struct ceph_mds_client *mdsc,
751 extern int ceph_reserve_caps(struct ceph_mds_client *mdsc,
753 extern void ceph_unreserve_caps(struct ceph_mds_client *mdsc,
917 struct ceph_snap_realm *ceph_lookup_snap_realm(struct ceph_mds_client *mdsc,
[all...] |
| H A D | export.c | 125 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc; in __lookup_inode() local
141 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO, in __lookup_inode()
153 err = ceph_mdsc_do_request(mdsc, NULL, req); in __lookup_inode()
201 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc; in __snapfh_to_dentry() local
229 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO, in __snapfh_to_dentry()
250 err = ceph_mdsc_do_request(mdsc, NULL, req); in __snapfh_to_dentry()
307 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc; in __get_parent() local
524 struct ceph_mds_client *mdsc; ceph_get_name() local
[all...] |
| H A D | locks.c | 13 static int ceph_lock_wait_for_completion(struct ceph_mds_client *mdsc,
62 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in ceph_lock_message() local
82 req = ceph_mdsc_create_request(mdsc, operation, USE_AUTH_MDS); in ceph_lock_message()
113 err = ceph_mdsc_do_request(mdsc, inode, req); in ceph_lock_message()
140 static int ceph_lock_wait_for_completion(struct ceph_mds_client *mdsc, in ceph_lock_wait_for_completion() argument
163 mutex_lock(&mdsc->mutex); in ceph_lock_wait_for_completion()
182 mutex_unlock(&mdsc->mutex); in ceph_lock_wait_for_completion()
186 intr_req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETFILELOCK, in ceph_lock_wait_for_completion()
199 err = ceph_mdsc_do_request(mdsc, inode, intr_req); in ceph_lock_wait_for_completion()
|
| /kernel/linux/linux-6.6/fs/ceph/ |
| H A D | mds_client.c | 62 static void __wake_requests(struct ceph_mds_client *mdsc,
926 * called under mdsc->mutex
928 struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc, in __ceph_lookup_mds_session() argument
931 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __ceph_lookup_mds_session()
933 return ceph_get_mds_session(mdsc->sessions[mds]); in __ceph_lookup_mds_session()
936 static bool __have_session(struct ceph_mds_client *mdsc, int mds) in __have_session() argument
938 if (mds >= mdsc->max_sessions || !mdsc->sessions[mds]) in __have_session()
944 static int __verify_registered_session(struct ceph_mds_client *mdsc, in __verify_registered_session() argument
957 register_session(struct ceph_mds_client *mdsc, int mds) register_session() argument
1029 __unregister_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *s) __unregister_session() argument
1053 ceph_mdsc_iterate_sessions(struct ceph_mds_client *mdsc, void (*cb)(struct ceph_mds_session *), bool check_state) ceph_mdsc_iterate_sessions() argument
1137 lookup_get_request(struct ceph_mds_client *mdsc, u64 tid) lookup_get_request() argument
1154 __register_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, struct inode *dir) __register_request() argument
1192 __unregister_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) __unregister_request() argument
1270 __choose_mds(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, bool *random) __choose_mds() argument
1523 create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) create_session_open_msg() argument
1633 __open_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) __open_session() argument
1664 __open_export_target_session(struct ceph_mds_client *mdsc, int target) __open_export_target_session() argument
1686 ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target) ceph_mdsc_open_export_target_session() argument
1699 __open_export_target_sessions(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) __open_export_target_sessions() argument
1719 ceph_mdsc_open_export_target_sessions(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_mdsc_open_export_target_sessions() argument
1741 dispose_cap_releases(struct ceph_mds_client *mdsc, struct list_head *dispose) dispose_cap_releases() argument
1753 cleanup_session_requests(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) cleanup_session_requests() argument
1985 send_renew_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) send_renew_caps() argument
2015 send_flushmsg_ack(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, u64 seq) send_flushmsg_ack() argument
2035 renewed_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, int is_renew) renewed_caps() argument
2085 __close_session(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) __close_session() argument
2206 ceph_trim_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, int max_caps) ceph_trim_caps() argument
2227 check_caps_flush(struct ceph_mds_client *mdsc, u64 want_flush_tid) check_caps_flush() argument
2252 wait_caps_flush(struct ceph_mds_client *mdsc, u64 want_flush_tid) wait_caps_flush() argument
2266 ceph_send_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_send_cap_releases() argument
2373 ceph_flush_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_flush_cap_releases() argument
2404 struct ceph_mds_client *mdsc = ceph_cap_reclaim_work() local
2411 ceph_queue_cap_reclaim_work(struct ceph_mds_client *mdsc) ceph_queue_cap_reclaim_work() argument
2423 ceph_reclaim_caps_nr(struct ceph_mds_client *mdsc, int nr) ceph_reclaim_caps_nr() argument
2482 ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode) ceph_mdsc_create_request() argument
2518 __get_oldest_req(struct ceph_mds_client *mdsc) __get_oldest_req() argument
2526 __get_oldest_tid(struct ceph_mds_client *mdsc) __get_oldest_tid() argument
2863 struct ceph_mds_client *mdsc = session->s_mdsc; create_request_message() local
3083 complete_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) complete_request() argument
3101 struct ceph_mds_client *mdsc = session->s_mdsc; __prepare_send_request() local
3230 __do_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) __do_request() argument
3435 __wake_requests(struct ceph_mds_client *mdsc, struct list_head *head) __wake_requests() argument
3456 kick_requests(struct ceph_mds_client *mdsc, int mds) kick_requests() argument
3478 ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, struct inode *dir, struct ceph_mds_request *req) ceph_mdsc_submit_request() argument
3526 ceph_mdsc_wait_request(struct ceph_mds_client *mdsc, struct ceph_mds_request *req, ceph_mds_request_wait_callback_t wait_func) ceph_mdsc_wait_request() argument
3581 ceph_mdsc_do_request(struct ceph_mds_client *mdsc, struct inode *dir, struct ceph_mds_request *req) ceph_mdsc_do_request() argument
3626 struct ceph_mds_client *mdsc = session->s_mdsc; handle_reply() local
3834 handle_forward(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) handle_forward() argument
3935 struct ceph_mds_client *mdsc = session->s_mdsc; handle_session() local
4143 replay_unsafe_requests(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) replay_unsafe_requests() argument
4476 encode_snap_realms(struct ceph_mds_client *mdsc, struct ceph_reconnect_state *recon_state) encode_snap_realms() argument
4546 send_mds_reconnect(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) send_mds_reconnect() argument
4719 check_new_map(struct ceph_mds_client *mdsc, struct ceph_mdsmap *newmap, struct ceph_mdsmap *oldmap) check_new_map() argument
4892 handle_lease(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) handle_lease() argument
5043 maybe_recover_session(struct ceph_mds_client *mdsc) maybe_recover_session() argument
5106 schedule_delayed(struct ceph_mds_client *mdsc, unsigned long delay) schedule_delayed() argument
5119 struct ceph_mds_client *mdsc = delayed_work() local
5178 struct ceph_mds_client *mdsc; ceph_mdsc_init() local
5253 wait_requests(struct ceph_mds_client *mdsc) wait_requests() argument
5307 ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc) ceph_mdsc_pre_umount() argument
5329 flush_mdlog_and_wait_mdsc_unsafe_requests(struct ceph_mds_client *mdsc, u64 want_tid) flush_mdlog_and_wait_mdsc_unsafe_requests() argument
5393 ceph_mdsc_sync(struct ceph_mds_client *mdsc) ceph_mdsc_sync() argument
5426 done_closing_sessions(struct ceph_mds_client *mdsc, int skipped) done_closing_sessions() argument
5436 ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc) ceph_mdsc_close_sessions() argument
5492 ceph_mdsc_force_umount(struct ceph_mds_client *mdsc) ceph_mdsc_force_umount() argument
5526 ceph_mdsc_stop(struct ceph_mds_client *mdsc) ceph_mdsc_stop() argument
5548 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_mdsc_destroy() local
5566 ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) ceph_mdsc_handle_fsmap() argument
5638 ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) ceph_mdsc_handle_mdsmap() argument
5723 struct ceph_mds_client *mdsc = s->s_mdsc; mds_peer_reset() local
5733 struct ceph_mds_client *mdsc = s->s_mdsc; mds_dispatch() local
5792 struct ceph_mds_client *mdsc = s->s_mdsc; mds_get_authorizer() local
5809 struct ceph_mds_client *mdsc = s->s_mdsc; mds_add_authorizer_challenge() local
5819 struct ceph_mds_client *mdsc = s->s_mdsc; mds_verify_authorizer_reply() local
5831 struct ceph_mds_client *mdsc = s->s_mdsc; mds_invalidate_authorizer() local
[all...] |
| H A D | quota.c | 15 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in ceph_adjust_quota_realms_count() local
17 atomic64_inc(&mdsc->quotarealms_count); in ceph_adjust_quota_realms_count()
19 atomic64_dec(&mdsc->quotarealms_count); in ceph_adjust_quota_realms_count()
25 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(sb); in ceph_has_realms_with_quotas() local
28 if (atomic64_read(&mdsc->quotarealms_count) > 0) in ceph_has_realms_with_quotas()
40 void ceph_handle_quota(struct ceph_mds_client *mdsc, in ceph_handle_quota() argument
44 struct super_block *sb = mdsc->fsc->sb; in ceph_handle_quota()
50 if (!ceph_inc_mds_stopping_blocker(mdsc, session)) in ceph_handle_quota()
80 ceph_dec_mds_stopping_blocker(mdsc); in ceph_handle_quota()
84 find_quotarealm_inode(struct ceph_mds_client *mdsc, u6 argument
128 lookup_quotarealm_inode(struct ceph_mds_client *mdsc, struct super_block *sb, struct ceph_snap_realm *realm) lookup_quotarealm_inode() argument
176 ceph_cleanup_quotarealms_inodes(struct ceph_mds_client *mdsc) ceph_cleanup_quotarealms_inodes() argument
211 get_quota_realm(struct ceph_mds_client *mdsc, struct inode *inode, enum quota_get_realm which_quota, struct ceph_snap_realm **realmp, bool retry) get_quota_realm() argument
276 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old->i_sb); ceph_quota_is_same_realm() local
324 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); check_quota_exceeded() local
485 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_quota_update_statfs() local
[all...] |
| H A D | snap.c | 66 void ceph_get_snap_realm(struct ceph_mds_client *mdsc, in ceph_get_snap_realm() argument
69 lockdep_assert_held(&mdsc->snap_rwsem); in ceph_get_snap_realm()
80 spin_lock(&mdsc->snap_empty_lock); in ceph_get_snap_realm()
83 spin_unlock(&mdsc->snap_empty_lock); in ceph_get_snap_realm()
114 struct ceph_mds_client *mdsc, in ceph_create_snap_realm()
119 lockdep_assert_held_write(&mdsc->snap_rwsem); in ceph_create_snap_realm()
138 __insert_snap_realm(&mdsc->snap_realms, realm); in ceph_create_snap_realm()
139 mdsc->num_snap_realms++; in ceph_create_snap_realm()
150 static struct ceph_snap_realm *__lookup_snap_realm(struct ceph_mds_client *mdsc, in __lookup_snap_realm() argument
153 struct rb_node *n = mdsc in __lookup_snap_realm()
113 ceph_create_snap_realm( struct ceph_mds_client *mdsc, u64 ino) ceph_create_snap_realm() argument
172 ceph_lookup_snap_realm(struct ceph_mds_client *mdsc, u64 ino) ceph_lookup_snap_realm() argument
188 __destroy_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) __destroy_snap_realm() argument
212 __put_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) __put_snap_realm() argument
228 ceph_put_snap_realm(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm) ceph_put_snap_realm() argument
251 __cleanup_empty_realms(struct ceph_mds_client *mdsc) __cleanup_empty_realms() argument
269 ceph_cleanup_global_and_empty_realms(struct ceph_mds_client *mdsc) ceph_cleanup_global_and_empty_realms() argument
289 adjust_snap_realm_parent(struct ceph_mds_client *mdsc, struct ceph_snap_realm *realm, u64 parentino) adjust_snap_realm_parent() argument
657 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); __ceph_finish_cap_snap() local
765 ceph_update_snap_trace(struct ceph_mds_client *mdsc, void *p, void *e, bool deletion, struct ceph_snap_realm **realm_ret) ceph_update_snap_trace() argument
926 flush_snaps(struct ceph_mds_client *mdsc) flush_snaps() argument
963 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; ceph_change_snap_realm() local
999 ceph_handle_snap(struct ceph_mds_client *mdsc, struct ceph_mds_session *session, struct ceph_msg *msg) ceph_handle_snap() argument
1170 ceph_get_snapid_map(struct ceph_mds_client *mdsc, u64 snap) ceph_get_snapid_map() argument
1250 ceph_put_snapid_map(struct ceph_mds_client* mdsc, struct ceph_snapid_map *sm) ceph_put_snapid_map() argument
1269 ceph_trim_snapid_map(struct ceph_mds_client *mdsc) ceph_trim_snapid_map() argument
1298 ceph_cleanup_snapid_map(struct ceph_mds_client *mdsc) ceph_cleanup_snapid_map() argument
[all...] |
| H A D | caps.c | 47 static u64 __get_oldest_flush_tid(struct ceph_mds_client *mdsc);
48 static void __kick_flushing_caps(struct ceph_mds_client *mdsc,
129 void ceph_caps_init(struct ceph_mds_client *mdsc) in ceph_caps_init() argument
131 INIT_LIST_HEAD(&mdsc->caps_list); in ceph_caps_init()
132 spin_lock_init(&mdsc->caps_list_lock); in ceph_caps_init()
135 void ceph_caps_finalize(struct ceph_mds_client *mdsc) in ceph_caps_finalize() argument
139 spin_lock(&mdsc->caps_list_lock); in ceph_caps_finalize()
140 while (!list_empty(&mdsc->caps_list)) { in ceph_caps_finalize()
141 cap = list_first_entry(&mdsc->caps_list, in ceph_caps_finalize()
146 mdsc in ceph_caps_finalize()
154 ceph_adjust_caps_max_min(struct ceph_mds_client *mdsc, struct ceph_mount_options *fsopt) ceph_adjust_caps_max_min() argument
168 __ceph_unreserve_caps(struct ceph_mds_client *mdsc, int nr_caps) __ceph_unreserve_caps() argument
202 ceph_reserve_caps(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx, int need) ceph_reserve_caps() argument
307 ceph_unreserve_caps(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx) ceph_unreserve_caps() argument
328 ceph_get_cap(struct ceph_mds_client *mdsc, struct ceph_cap_reservation *ctx) ceph_get_cap() argument
383 ceph_put_cap(struct ceph_mds_client *mdsc, struct ceph_cap *cap) ceph_put_cap() argument
412 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_reservation_status() local
491 __cap_set_timeouts(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) __cap_set_timeouts() argument
509 __cap_delay_requeue(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) __cap_delay_requeue() argument
533 __cap_delay_requeue_front(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) __cap_delay_requeue_front() argument
550 __cap_delay_cancel(struct ceph_mds_client *mdsc, struct ceph_inode_info *ci) __cap_delay_cancel() argument
638 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; ceph_add_cap() local
1111 struct ceph_mds_client *mdsc; __ceph_remove_cap() local
1595 struct ceph_mds_client *mdsc = session->s_mdsc; global() variable
1689 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; ceph_flush_snaps() local
1753 struct ceph_mds_client *mdsc = __ceph_mark_dirty_caps() local
1822 __get_oldest_flush_tid(struct ceph_mds_client *mdsc) __get_oldest_flush_tid() argument
1837 __detach_cap_flush_from_mdsc(struct ceph_mds_client *mdsc, struct ceph_cap_flush *cf) __detach_cap_flush_from_mdsc() argument
1877 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; __mark_caps_flushing() local
1972 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); ceph_check_caps() local
2236 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; try_flush_caps() local
2314 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; flush_mdlog_and_wait_inode_unsafe_requests() local
2496 struct ceph_mds_client *mdsc = ceph_write_inode() local
2589 ceph_early_kick_flushing_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_early_kick_flushing_caps() argument
2637 ceph_kick_flushing_caps(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_kick_flushing_caps() argument
2672 struct ceph_mds_client *mdsc = session->s_mdsc; ceph_kick_flushing_inode_caps() local
2750 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; try_get_cap_refs() local
2990 struct ceph_mds_client *mdsc = fsc->mdsc; __ceph_get_caps() local
3731 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; global() variable
3837 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; __ceph_remove_capsnap() local
3881 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; handle_cap_flushsnap_ack() local
3973 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; handle_cap_export() local
4101 handle_cap_import(struct ceph_mds_client *mdsc, struct inode *inode, struct ceph_mds_caps *im, struct ceph_mds_cap_peer *ph, struct ceph_mds_session *session, struct ceph_cap **target_cap, int *old_issued) handle_cap_import() argument
4230 struct ceph_mds_client *mdsc = session->s_mdsc; ceph_handle_caps() local
4508 ceph_check_delayed_caps(struct ceph_mds_client *mdsc) ceph_check_delayed_caps() argument
4552 struct ceph_mds_client *mdsc = s->s_mdsc; flush_dirty_session_caps() local
4574 ceph_flush_dirty_caps(struct ceph_mds_client *mdsc) ceph_flush_dirty_caps() argument
4579 __ceph_touch_fmode(struct ceph_inode_info *ci, struct ceph_mds_client *mdsc, int fmode) __ceph_touch_fmode() argument
4596 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(ci->netfs.inode.i_sb); ceph_get_fmode() local
4630 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(ci->netfs.inode.i_sb); ceph_put_fmode() local
4675 struct ceph_mds_client *mdsc = ceph_drop_caps_for_unlink() local
4831 remove_capsnaps(struct ceph_mds_client *mdsc, struct inode *inode) remove_capsnaps() argument
4857 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_purge_inode_cap() 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()
50 * mdsc debugfs
55 struct ceph_mds_client *mdsc = fsc->mdsc; in mdsc_show() local
62 mutex_lock(&mdsc->mutex); in mdsc_show()
63 for (rp = rb_first(&mdsc->request_tree); rp; rp = rb_next(rp)) { in mdsc_show()
125 mutex_unlock(&mdsc->mutex); in mdsc_show()
152 struct ceph_client_metric *m = &fsc->mdsc in metrics_file_show()
271 struct ceph_mds_client *mdsc = fsc->mdsc; caps_show() local
319 struct ceph_mds_client *mdsc = fsc->mdsc; mds_sessions_show() local
366 DEFINE_SHOW_ATTRIBUTE(mdsc); global() variable
[all...] |
| H A D | dir.c | 42 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dentry->d_sb); in ceph_d_init() local
54 atomic64_inc(&mdsc->metric.total_dentries); in ceph_d_init()
314 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_readdir() local
353 __ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_WR); in ceph_readdir()
396 req = ceph_mdsc_create_request(mdsc, op, USE_AUTH_MDS); in ceph_readdir()
444 err = ceph_mdsc_do_request(mdsc, NULL, req); in ceph_readdir()
775 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); in ceph_lookup() local
813 __ceph_touch_fmode(ci, mdsc, CEPH_FILE_MODE_RD); in ceph_lookup()
825 req = ceph_mdsc_create_request(mdsc, o in ceph_lookup()
887 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); ceph_mknod() local
995 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); ceph_symlink() local
1066 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); ceph_mkdir() local
1146 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(dir->i_sb); ceph_link() local
1198 ceph_async_unlink_cb(struct ceph_mds_client *mdsc, struct ceph_mds_request *req) ceph_async_unlink_cb() argument
1294 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_unlink() local
1386 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(old_dir->i_sb); ceph_rename() local
1462 struct ceph_mds_client *mdsc; __ceph_dentry_lease_touch() local
1478 __dentry_dir_lease_touch(struct ceph_mds_client* mdsc, struct ceph_dentry_info *di) __dentry_dir_lease_touch() argument
1496 struct ceph_mds_client *mdsc; __ceph_dentry_dir_lease_touch() local
1527 struct ceph_mds_client *mdsc; __dentry_lease_unlist() local
1554 __dentry_leases_walk(struct ceph_mds_client *mdsc, struct ceph_lease_walk_control *lwc, int (*check)(struct dentry*, void*)) __dentry_leases_walk() argument
1681 ceph_trim_dentries(struct ceph_mds_client *mdsc) ceph_trim_dentries() argument
1831 dir_lease_is_valid(struct inode *dir, struct dentry *dentry, struct ceph_mds_client *mdsc) dir_lease_is_valid() argument
1869 struct ceph_mds_client *mdsc; ceph_d_revalidate() local
[all...] |
| H A D | ioctl.c | 38 static long __validate_layout(struct ceph_mds_client *mdsc, in __validate_layout() argument
51 mutex_lock(&mdsc->mutex); in __validate_layout()
53 for (i = 0; i < mdsc->mdsmap->m_num_data_pg_pools; i++) in __validate_layout()
54 if (mdsc->mdsmap->m_data_pg_pools[i] == l->data_pool) { in __validate_layout()
58 mutex_unlock(&mdsc->mutex); in __validate_layout()
68 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; in ceph_ioctl_set_layout() local
104 err = __validate_layout(mdsc, &nl); in ceph_ioctl_set_layout()
108 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_SETLAYOUT, in ceph_ioctl_set_layout()
126 err = ceph_mdsc_do_request(mdsc, NUL in ceph_ioctl_set_layout()
143 struct ceph_mds_client *mdsc = ceph_sb_to_client(inode->i_sb)->mdsc; ceph_ioctl_set_layout_policy() local
247 struct ceph_mds_client *mdsc = ceph_inode_to_client(inode)->mdsc; ceph_ioctl_lazyio() local
275 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(file_inode(file)->i_sb); vet_mds_for_fscrypt() local
[all...] |
| H A D | super.c | 51 ceph_mdsc_close_sessions(fsc->mdsc); in ceph_put_super()
62 if (fsc->mdsc->mdsmap->m_num_data_pg_pools == 1) { in ceph_statfs()
63 data_pool = fsc->mdsc->mdsmap->m_data_pg_pools[0]; in ceph_statfs()
125 ceph_flush_dirty_caps(fsc->mdsc); in ceph_sync_fs()
132 ceph_mdsc_sync(fsc->mdsc); in ceph_sync_fs()
788 ceph_mdsc_handle_mdsmap(fsc->mdsc, msg); in extra_mon_dispatch()
791 ceph_mdsc_handle_fsmap(fsc->mdsc, msg); in extra_mon_dispatch()
1008 ceph_mdsc_force_umount(fsc->mdsc); in __ceph_umount_begin()
1048 struct ceph_mds_client *mdsc = fsc->mdsc; in open_root_dentry() local
1469 __inc_stopping_blocker(struct ceph_mds_client *mdsc) __inc_stopping_blocker() argument
1481 __dec_stopping_blocker(struct ceph_mds_client *mdsc) __dec_stopping_blocker() argument
1491 ceph_inc_mds_stopping_blocker(struct ceph_mds_client *mdsc, struct ceph_mds_session *session) ceph_inc_mds_stopping_blocker() argument
1501 ceph_dec_mds_stopping_blocker(struct ceph_mds_client *mdsc) ceph_dec_mds_stopping_blocker() argument
1507 ceph_inc_osd_stopping_blocker(struct ceph_mds_client *mdsc) ceph_inc_osd_stopping_blocker() argument
1512 ceph_dec_osd_stopping_blocker(struct ceph_mds_client *mdsc) ceph_dec_osd_stopping_blocker() argument
1520 struct ceph_mds_client *mdsc = fsc->mdsc; ceph_kill_sb() local
[all...] |
| H A D | mds_client.h | 58 * mdsc->mutex
60 * mdsc->snap_rwsem
63 * mdsc->snap_flush_lock
64 * mdsc->cap_delay_lock
248 typedef void (*ceph_mds_request_callback_t) (struct ceph_mds_client *mdsc,
253 typedef int (*ceph_mds_request_wait_callback_t) (struct ceph_mds_client *mdsc,
526 extern int ceph_send_msg_mds(struct ceph_mds_client *mdsc,
530 extern void ceph_mdsc_close_sessions(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);
[all...] |
| H A D | metric.c | 17 static bool ceph_mdsc_send_metrics(struct ceph_mds_client *mdsc, in ceph_mdsc_send_metrics() argument
31 struct ceph_client_metric *m = &mdsc->metric; in ceph_mdsc_send_metrics()
40 mutex_lock(&mdsc->mutex); in ceph_mdsc_send_metrics()
41 if (ceph_mdsmap_get_state(mdsc->mdsmap, s->s_mds) != CEPH_MDS_STATE_ACTIVE) { 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()
185 static void metric_get_session(struct ceph_mds_client *mdsc) in metric_get_session() argument
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, in metric_get_session()
216 struct ceph_mds_client *mdsc = metric_delayed_work() local
[all...] |
| H A D | export.c | 126 struct ceph_mds_client *mdsc = ceph_sb_to_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_client(sb)->mdsc; in __snapfh_to_dentry() local
241 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_LOOKUPINO, in __snapfh_to_dentry()
262 err = ceph_mdsc_do_request(mdsc, NULL, req); in __snapfh_to_dentry()
320 struct ceph_mds_client *mdsc = ceph_sb_to_client(sb)->mdsc; in __get_parent() local
537 struct ceph_mds_client *mdsc; ceph_get_name() local
[all...] |
| H A D | super.h | 136 struct ceph_mds_client *mdsc; member
389 * is protected by the mdsc->cap_dirty_lock, but each individual item
391 * requires the mdsc->cap_dirty_lock. List presence for an item can
505 return (struct ceph_mds_client *)ceph_sb_to_client(sb)->mdsc; in ceph_sb_to_mdsc()
804 extern void ceph_caps_init(struct ceph_mds_client *mdsc);
805 extern void ceph_caps_finalize(struct ceph_mds_client *mdsc);
806 extern void ceph_adjust_caps_max_min(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,
978 struct ceph_snap_realm *ceph_lookup_snap_realm(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, inod in ceph_lock_wait_for_completion()
[all...] |