Lines Matching refs:ceph_mds_client
63 static void __wake_requests(struct ceph_mds_client *mdsc,
934 struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc, in __ceph_lookup_mds_session()
942 static bool __have_session(struct ceph_mds_client *mdsc, int mds) in __have_session()
950 static int __verify_registered_session(struct ceph_mds_client *mdsc, in __verify_registered_session()
963 static struct ceph_mds_session *register_session(struct ceph_mds_client *mdsc, in register_session()
1036 static void __unregister_session(struct ceph_mds_client *mdsc, in __unregister_session()
1060 void ceph_mdsc_iterate_sessions(struct ceph_mds_client *mdsc, in ceph_mdsc_iterate_sessions()
1146 lookup_get_request(struct ceph_mds_client *mdsc, u64 tid) in DEFINE_RB_FUNCS()
1163 static void __register_request(struct ceph_mds_client *mdsc, in __register_request()
1204 static void __unregister_request(struct ceph_mds_client *mdsc, in __unregister_request()
1282 static int __choose_mds(struct ceph_mds_client *mdsc, in __choose_mds()
1538 create_session_full_msg(struct ceph_mds_client *mdsc, int op, u64 seq) in create_session_full_msg()
1661 static int __open_session(struct ceph_mds_client *mdsc, in __open_session()
1693 __open_export_target_session(struct ceph_mds_client *mdsc, int target) in __open_export_target_session()
1715 ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target) in ceph_mdsc_open_export_target_session()
1729 static void __open_export_target_sessions(struct ceph_mds_client *mdsc, in __open_export_target_sessions()
1766 static void dispose_cap_releases(struct ceph_mds_client *mdsc, in dispose_cap_releases()
1778 static void cleanup_session_requests(struct ceph_mds_client *mdsc, in cleanup_session_requests()
2014 static int send_renew_caps(struct ceph_mds_client *mdsc, in send_renew_caps()
2045 static int send_flushmsg_ack(struct ceph_mds_client *mdsc, in send_flushmsg_ack()
2066 static void renewed_caps(struct ceph_mds_client *mdsc, in renewed_caps()
2119 static int __close_session(struct ceph_mds_client *mdsc, in __close_session()
2163 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in trim_caps_cb()
2243 int ceph_trim_caps(struct ceph_mds_client *mdsc, in ceph_trim_caps()
2265 static int check_caps_flush(struct ceph_mds_client *mdsc, in check_caps_flush()
2291 static void wait_caps_flush(struct ceph_mds_client *mdsc, in wait_caps_flush()
2307 static void ceph_send_cap_releases(struct ceph_mds_client *mdsc, in ceph_send_cap_releases()
2415 void ceph_flush_session_cap_releases(struct ceph_mds_client *mdsc, in ceph_flush_session_cap_releases()
2447 struct ceph_mds_client *mdsc = in ceph_cap_reclaim_work()
2448 container_of(work, struct ceph_mds_client, cap_reclaim_work); in ceph_cap_reclaim_work()
2454 void ceph_queue_cap_reclaim_work(struct ceph_mds_client *mdsc) in ceph_queue_cap_reclaim_work()
2467 void ceph_reclaim_caps_nr(struct ceph_mds_client *mdsc, int nr) in ceph_reclaim_caps_nr()
2479 void ceph_queue_cap_unlink_work(struct ceph_mds_client *mdsc) in ceph_queue_cap_unlink_work()
2494 struct ceph_mds_client *mdsc = in ceph_cap_unlink_work()
2495 container_of(work, struct ceph_mds_client, cap_unlink_work); in ceph_cap_unlink_work()
2570 ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode) in ceph_mdsc_create_request()
2606 static struct ceph_mds_request *__get_oldest_req(struct ceph_mds_client *mdsc) in __get_oldest_req()
2614 static inline u64 __get_oldest_tid(struct ceph_mds_client *mdsc) in __get_oldest_tid()
2702 char *ceph_mdsc_build_path(struct ceph_mds_client *mdsc, struct dentry *dentry, in ceph_mdsc_build_path()
2820 static int build_dentry_path(struct ceph_mds_client *mdsc, struct dentry *dentry, in build_dentry_path()
2850 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in build_inode_path()
2873 static int set_request_path_attr(struct ceph_mds_client *mdsc, struct inode *rinode, in set_request_path_attr()
2967 struct ceph_mds_client *mdsc = session->s_mdsc; in create_request_message()
3238 static void complete_request(struct ceph_mds_client *mdsc, in complete_request()
3256 struct ceph_mds_client *mdsc = session->s_mdsc; in __prepare_send_request()
3386 static void __do_request(struct ceph_mds_client *mdsc, in __do_request()
3592 static void __wake_requests(struct ceph_mds_client *mdsc, in __wake_requests()
3615 static void kick_requests(struct ceph_mds_client *mdsc, int mds) in kick_requests()
3638 int ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, struct inode *dir, in ceph_mdsc_submit_request()
3685 int ceph_mdsc_wait_request(struct ceph_mds_client *mdsc, in ceph_mdsc_wait_request()
3741 int ceph_mdsc_do_request(struct ceph_mds_client *mdsc, in ceph_mdsc_do_request()
3789 struct ceph_mds_client *mdsc = session->s_mdsc; in handle_reply()
3999 static void handle_forward(struct ceph_mds_client *mdsc, in handle_forward()
4102 struct ceph_mds_client *mdsc = session->s_mdsc; in handle_session()
4421 static void replay_unsafe_requests(struct ceph_mds_client *mdsc, in replay_unsafe_requests()
4571 struct ceph_mds_client *mdsc = ceph_sb_to_mdsc(inode->i_sb); in reconnect_caps_cb()
4760 static int encode_snap_realms(struct ceph_mds_client *mdsc, in encode_snap_realms()
4831 static void send_mds_reconnect(struct ceph_mds_client *mdsc, in send_mds_reconnect()
5006 static void check_new_map(struct ceph_mds_client *mdsc, in check_new_map()
5180 static void handle_lease(struct ceph_mds_client *mdsc, in handle_lease()
5332 static void maybe_recover_session(struct ceph_mds_client *mdsc) in maybe_recover_session()
5400 static void schedule_delayed(struct ceph_mds_client *mdsc, unsigned long delay) in schedule_delayed()
5413 struct ceph_mds_client *mdsc = in delayed_work()
5414 container_of(work, struct ceph_mds_client, delayed_work.work); in delayed_work()
5474 struct ceph_mds_client *mdsc; in ceph_mdsc_init()
5477 mdsc = kzalloc(sizeof(struct ceph_mds_client), GFP_NOFS); in ceph_mdsc_init()
5555 static void wait_requests(struct ceph_mds_client *mdsc) in wait_requests()
5606 static int ceph_mds_auth_match(struct ceph_mds_client *mdsc, in ceph_mds_auth_match()
5717 int ceph_mds_check_access(struct ceph_mds_client *mdsc, char *tpath, int mask) in ceph_mds_check_access()
5777 void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc) in ceph_mdsc_pre_umount()
5800 static void flush_mdlog_and_wait_mdsc_unsafe_requests(struct ceph_mds_client *mdsc, in flush_mdlog_and_wait_mdsc_unsafe_requests()
5865 void ceph_mdsc_sync(struct ceph_mds_client *mdsc) in ceph_mdsc_sync()
5899 static bool done_closing_sessions(struct ceph_mds_client *mdsc, int skipped) in done_closing_sessions()
5909 void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc) in ceph_mdsc_close_sessions()
5967 void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc) in ceph_mdsc_force_umount()
6001 static void ceph_mdsc_stop(struct ceph_mds_client *mdsc) in ceph_mdsc_stop()
6035 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_mdsc_destroy()
6053 void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) in ceph_mdsc_handle_fsmap()
6127 void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) in ceph_mdsc_handle_mdsmap()
6213 struct ceph_mds_client *mdsc = s->s_mdsc; in mds_peer_reset()
6225 struct ceph_mds_client *mdsc = s->s_mdsc; in mds_dispatch()
6285 struct ceph_mds_client *mdsc = s->s_mdsc; in mds_get_authorizer()
6302 struct ceph_mds_client *mdsc = s->s_mdsc; in mds_add_authorizer_challenge()
6312 struct ceph_mds_client *mdsc = s->s_mdsc; in mds_verify_authorizer_reply()
6324 struct ceph_mds_client *mdsc = s->s_mdsc; in mds_invalidate_authorizer()