Lines Matching refs:ceph_mds_client

54 static void __wake_requests(struct ceph_mds_client *mdsc,
426 struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc, in __ceph_lookup_mds_session()
440 static bool __have_session(struct ceph_mds_client *mdsc, int mds) in __have_session()
448 static int __verify_registered_session(struct ceph_mds_client *mdsc, in __verify_registered_session()
461 static struct ceph_mds_session *register_session(struct ceph_mds_client *mdsc, in register_session()
536 static void __unregister_session(struct ceph_mds_client *mdsc, in __unregister_session()
609 lookup_get_request(struct ceph_mds_client *mdsc, u64 tid) in DEFINE_RB_FUNCS()
626 static void __register_request(struct ceph_mds_client *mdsc, in __register_request()
660 static void __unregister_request(struct ceph_mds_client *mdsc, in __unregister_request()
739 static int __choose_mds(struct ceph_mds_client *mdsc, in __choose_mds()
930 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq) in create_session_open_msg()
1013 static int __open_session(struct ceph_mds_client *mdsc, in __open_session()
1041 __open_export_target_session(struct ceph_mds_client *mdsc, int target) in __open_export_target_session()
1059 ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target) in ceph_mdsc_open_export_target_session()
1072 static void __open_export_target_sessions(struct ceph_mds_client *mdsc, in __open_export_target_sessions()
1093 void ceph_mdsc_open_export_target_sessions(struct ceph_mds_client *mdsc, in ceph_mdsc_open_export_target_sessions()
1115 static void dispose_cap_releases(struct ceph_mds_client *mdsc, in dispose_cap_releases()
1127 static void cleanup_session_requests(struct ceph_mds_client *mdsc, in cleanup_session_requests()
1242 struct ceph_mds_client *mdsc = fsc->mdsc; in remove_session_caps_cb()
1406 static int send_renew_caps(struct ceph_mds_client *mdsc, in send_renew_caps()
1436 static int send_flushmsg_ack(struct ceph_mds_client *mdsc, in send_flushmsg_ack()
1456 static void renewed_caps(struct ceph_mds_client *mdsc, in renewed_caps()
1488 static int request_close_session(struct ceph_mds_client *mdsc, in request_close_session()
1506 static int __close_session(struct ceph_mds_client *mdsc, in __close_session()
1620 int ceph_trim_caps(struct ceph_mds_client *mdsc, in ceph_trim_caps()
1641 static int check_caps_flush(struct ceph_mds_client *mdsc, in check_caps_flush()
1666 static void wait_caps_flush(struct ceph_mds_client *mdsc, in wait_caps_flush()
1680 void ceph_send_cap_releases(struct ceph_mds_client *mdsc, in ceph_send_cap_releases()
1818 ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode) in ceph_mdsc_create_request()
1853 static struct ceph_mds_request *__get_oldest_req(struct ceph_mds_client *mdsc) in __get_oldest_req()
1861 static inline u64 __get_oldest_tid(struct ceph_mds_client *mdsc) in __get_oldest_tid()
2073 static struct ceph_msg *create_request_message(struct ceph_mds_client *mdsc, in create_request_message()
2210 static void complete_request(struct ceph_mds_client *mdsc, in complete_request()
2222 static int __prepare_send_request(struct ceph_mds_client *mdsc, in __prepare_send_request()
2308 static void __do_request(struct ceph_mds_client *mdsc, in __do_request()
2414 static void __wake_requests(struct ceph_mds_client *mdsc, in __wake_requests()
2435 static void kick_requests(struct ceph_mds_client *mdsc, int mds) in kick_requests()
2457 void ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, in ceph_mdsc_submit_request()
2471 int ceph_mdsc_do_request(struct ceph_mds_client *mdsc, in ceph_mdsc_do_request()
2575 struct ceph_mds_client *mdsc = session->s_mdsc; in handle_reply()
2766 static void handle_forward(struct ceph_mds_client *mdsc, in handle_forward()
2821 struct ceph_mds_client *mdsc = session->s_mdsc; in handle_session()
2942 static void replay_unsafe_requests(struct ceph_mds_client *mdsc, in replay_unsafe_requests()
3162 static void send_mds_reconnect(struct ceph_mds_client *mdsc, in send_mds_reconnect()
3311 static void check_new_map(struct ceph_mds_client *mdsc, in check_new_map()
3433 static void handle_lease(struct ceph_mds_client *mdsc, in handle_lease()
3577 static void lock_unlock_sessions(struct ceph_mds_client *mdsc) in lock_unlock_sessions()
3600 static void schedule_delayed(struct ceph_mds_client *mdsc) in schedule_delayed()
3610 struct ceph_mds_client *mdsc = in delayed_work()
3611 container_of(work, struct ceph_mds_client, delayed_work.work); in delayed_work()
3675 struct ceph_mds_client *mdsc; in ceph_mdsc_init()
3677 mdsc = kzalloc(sizeof(struct ceph_mds_client), GFP_NOFS); in ceph_mdsc_init()
3737 static void wait_requests(struct ceph_mds_client *mdsc) in wait_requests()
3766 void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc) in ceph_mdsc_pre_umount()
3785 static void wait_unsafe_requests(struct ceph_mds_client *mdsc, u64 want_tid) in wait_unsafe_requests()
3828 void ceph_mdsc_sync(struct ceph_mds_client *mdsc) in ceph_mdsc_sync()
3861 static bool done_closing_sessions(struct ceph_mds_client *mdsc, int skipped) in done_closing_sessions()
3871 void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc) in ceph_mdsc_close_sessions()
3925 void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc) in ceph_mdsc_force_umount()
3953 static void ceph_mdsc_stop(struct ceph_mds_client *mdsc) in ceph_mdsc_stop()
3975 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_mdsc_destroy()
3991 void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) in ceph_mdsc_handle_fsmap()
4070 void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg) in ceph_mdsc_handle_mdsmap()
4157 struct ceph_mds_client *mdsc = s->s_mdsc; in peer_reset()
4166 struct ceph_mds_client *mdsc = s->s_mdsc; in dispatch()
4225 struct ceph_mds_client *mdsc = s->s_mdsc; in get_authorizer()
4253 struct ceph_mds_client *mdsc = s->s_mdsc; in add_authorizer_challenge()
4263 struct ceph_mds_client *mdsc = s->s_mdsc; in verify_authorizer_reply()
4272 struct ceph_mds_client *mdsc = s->s_mdsc; in invalidate_authorizer()