Lines Matching refs:ceph_mds_client
62 static void __wake_requests(struct ceph_mds_client *mdsc,
928 struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc,
936 static bool __have_session(struct ceph_mds_client *mdsc, int mds)
944 static int __verify_registered_session(struct ceph_mds_client *mdsc,
957 static struct ceph_mds_session *register_session(struct ceph_mds_client *mdsc,
1029 static void __unregister_session(struct ceph_mds_client *mdsc,
1053 void ceph_mdsc_iterate_sessions(struct ceph_mds_client *mdsc,
1137 lookup_get_request(struct ceph_mds_client *mdsc, u64 tid)
1154 static void __register_request(struct ceph_mds_client *mdsc,
1192 static void __unregister_request(struct ceph_mds_client *mdsc,
1270 static int __choose_mds(struct ceph_mds_client *mdsc,
1523 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq)
1633 static int __open_session(struct ceph_mds_client *mdsc,
1664 __open_export_target_session(struct ceph_mds_client *mdsc, int target)
1686 ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target)
1699 static void __open_export_target_sessions(struct ceph_mds_client *mdsc,
1719 void ceph_mdsc_open_export_target_sessions(struct ceph_mds_client *mdsc,
1741 static void dispose_cap_releases(struct ceph_mds_client *mdsc,
1753 static void cleanup_session_requests(struct ceph_mds_client *mdsc,
1985 static int send_renew_caps(struct ceph_mds_client *mdsc,
2015 static int send_flushmsg_ack(struct ceph_mds_client *mdsc,
2035 static void renewed_caps(struct ceph_mds_client *mdsc,
2085 static int __close_session(struct ceph_mds_client *mdsc,
2206 int ceph_trim_caps(struct ceph_mds_client *mdsc,
2227 static int check_caps_flush(struct ceph_mds_client *mdsc,
2252 static void wait_caps_flush(struct ceph_mds_client *mdsc,
2266 static void ceph_send_cap_releases(struct ceph_mds_client *mdsc,
2373 void ceph_flush_cap_releases(struct ceph_mds_client *mdsc,
2404 struct ceph_mds_client *mdsc =
2405 container_of(work, struct ceph_mds_client, cap_reclaim_work);
2411 void ceph_queue_cap_reclaim_work(struct ceph_mds_client *mdsc)
2423 void ceph_reclaim_caps_nr(struct ceph_mds_client *mdsc, int nr)
2482 ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode)
2518 static struct ceph_mds_request *__get_oldest_req(struct ceph_mds_client *mdsc)
2526 static inline u64 __get_oldest_tid(struct ceph_mds_client *mdsc)
2863 struct ceph_mds_client *mdsc = session->s_mdsc;
3083 static void complete_request(struct ceph_mds_client *mdsc,
3101 struct ceph_mds_client *mdsc = session->s_mdsc;
3230 static void __do_request(struct ceph_mds_client *mdsc,
3435 static void __wake_requests(struct ceph_mds_client *mdsc,
3456 static void kick_requests(struct ceph_mds_client *mdsc, int mds)
3478 int ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, struct inode *dir,
3526 int ceph_mdsc_wait_request(struct ceph_mds_client *mdsc,
3581 int ceph_mdsc_do_request(struct ceph_mds_client *mdsc,
3626 struct ceph_mds_client *mdsc = session->s_mdsc;
3834 static void handle_forward(struct ceph_mds_client *mdsc,
3935 struct ceph_mds_client *mdsc = session->s_mdsc;
4143 static void replay_unsafe_requests(struct ceph_mds_client *mdsc,
4476 static int encode_snap_realms(struct ceph_mds_client *mdsc,
4546 static void send_mds_reconnect(struct ceph_mds_client *mdsc,
4719 static void check_new_map(struct ceph_mds_client *mdsc,
4892 static void handle_lease(struct ceph_mds_client *mdsc,
5043 static void maybe_recover_session(struct ceph_mds_client *mdsc)
5106 static void schedule_delayed(struct ceph_mds_client *mdsc, unsigned long delay)
5119 struct ceph_mds_client *mdsc =
5120 container_of(work, struct ceph_mds_client, delayed_work.work);
5178 struct ceph_mds_client *mdsc;
5181 mdsc = kzalloc(sizeof(struct ceph_mds_client), GFP_NOFS);
5253 static void wait_requests(struct ceph_mds_client *mdsc)
5307 void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc)
5329 static void flush_mdlog_and_wait_mdsc_unsafe_requests(struct ceph_mds_client *mdsc,
5393 void ceph_mdsc_sync(struct ceph_mds_client *mdsc)
5426 static bool done_closing_sessions(struct ceph_mds_client *mdsc, int skipped)
5436 void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc)
5492 void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc)
5526 static void ceph_mdsc_stop(struct ceph_mds_client *mdsc)
5548 struct ceph_mds_client *mdsc = fsc->mdsc;
5566 void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
5638 void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
5723 struct ceph_mds_client *mdsc = s->s_mdsc;
5733 struct ceph_mds_client *mdsc = s->s_mdsc;
5792 struct ceph_mds_client *mdsc = s->s_mdsc;
5809 struct ceph_mds_client *mdsc = s->s_mdsc;
5819 struct ceph_mds_client *mdsc = s->s_mdsc;
5831 struct ceph_mds_client *mdsc = s->s_mdsc;