Lines Matching refs:ceph_mds_client
60 static void __wake_requests(struct ceph_mds_client *mdsc,
681 struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc,
689 static bool __have_session(struct ceph_mds_client *mdsc, int mds)
697 static int __verify_registered_session(struct ceph_mds_client *mdsc,
710 static struct ceph_mds_session *register_session(struct ceph_mds_client *mdsc,
788 static void __unregister_session(struct ceph_mds_client *mdsc,
812 void ceph_mdsc_iterate_sessions(struct ceph_mds_client *mdsc,
893 lookup_get_request(struct ceph_mds_client *mdsc, u64 tid)
910 static void __register_request(struct ceph_mds_client *mdsc,
949 static void __unregister_request(struct ceph_mds_client *mdsc,
1028 static int __choose_mds(struct ceph_mds_client *mdsc,
1283 static struct ceph_msg *create_session_open_msg(struct ceph_mds_client *mdsc, u64 seq)
1393 static int __open_session(struct ceph_mds_client *mdsc,
1421 __open_export_target_session(struct ceph_mds_client *mdsc, int target)
1443 ceph_mdsc_open_export_target_session(struct ceph_mds_client *mdsc, int target)
1456 static void __open_export_target_sessions(struct ceph_mds_client *mdsc,
1476 void ceph_mdsc_open_export_target_sessions(struct ceph_mds_client *mdsc,
1498 static void dispose_cap_releases(struct ceph_mds_client *mdsc,
1510 static void cleanup_session_requests(struct ceph_mds_client *mdsc,
1614 static int remove_capsnaps(struct ceph_mds_client *mdsc, struct inode *inode)
1641 struct ceph_mds_client *mdsc = fsc->mdsc;
1842 static int send_renew_caps(struct ceph_mds_client *mdsc,
1872 static int send_flushmsg_ack(struct ceph_mds_client *mdsc,
1892 static void renewed_caps(struct ceph_mds_client *mdsc,
1942 static int __close_session(struct ceph_mds_client *mdsc,
2057 int ceph_trim_caps(struct ceph_mds_client *mdsc,
2078 static int check_caps_flush(struct ceph_mds_client *mdsc,
2103 static void wait_caps_flush(struct ceph_mds_client *mdsc,
2117 static void ceph_send_cap_releases(struct ceph_mds_client *mdsc,
2224 void ceph_flush_cap_releases(struct ceph_mds_client *mdsc,
2255 struct ceph_mds_client *mdsc =
2256 container_of(work, struct ceph_mds_client, cap_reclaim_work);
2262 void ceph_queue_cap_reclaim_work(struct ceph_mds_client *mdsc)
2274 void ceph_reclaim_caps_nr(struct ceph_mds_client *mdsc, int nr)
2332 ceph_mdsc_create_request(struct ceph_mds_client *mdsc, int op, int mode)
2367 static struct ceph_mds_request *__get_oldest_req(struct ceph_mds_client *mdsc)
2375 static inline u64 __get_oldest_tid(struct ceph_mds_client *mdsc)
2549 static struct ceph_msg *create_request_message(struct ceph_mds_client *mdsc,
2692 static void complete_request(struct ceph_mds_client *mdsc,
2705 static int __prepare_send_request(struct ceph_mds_client *mdsc,
2792 static int __send_request(struct ceph_mds_client *mdsc,
2812 static void __do_request(struct ceph_mds_client *mdsc,
2934 static void __wake_requests(struct ceph_mds_client *mdsc,
2955 static void kick_requests(struct ceph_mds_client *mdsc, int mds)
2977 int ceph_mdsc_submit_request(struct ceph_mds_client *mdsc, struct inode *dir,
3026 static int ceph_mdsc_wait_request(struct ceph_mds_client *mdsc,
3080 int ceph_mdsc_do_request(struct ceph_mds_client *mdsc,
3125 struct ceph_mds_client *mdsc = session->s_mdsc;
3320 static void handle_forward(struct ceph_mds_client *mdsc,
3403 struct ceph_mds_client *mdsc = session->s_mdsc;
3577 static void replay_unsafe_requests(struct ceph_mds_client *mdsc,
3904 static int encode_snap_realms(struct ceph_mds_client *mdsc,
3974 static void send_mds_reconnect(struct ceph_mds_client *mdsc,
4149 static void check_new_map(struct ceph_mds_client *mdsc,
4268 static void handle_lease(struct ceph_mds_client *mdsc,
4421 static void maybe_recover_session(struct ceph_mds_client *mdsc)
4492 static void schedule_delayed(struct ceph_mds_client *mdsc, unsigned long delay)
4505 struct ceph_mds_client *mdsc =
4506 container_of(work, struct ceph_mds_client, delayed_work.work);
4564 struct ceph_mds_client *mdsc;
4567 mdsc = kzalloc(sizeof(struct ceph_mds_client), GFP_NOFS);
4647 static void wait_requests(struct ceph_mds_client *mdsc)
4701 void ceph_mdsc_pre_umount(struct ceph_mds_client *mdsc)
4723 static void wait_unsafe_requests(struct ceph_mds_client *mdsc, u64 want_tid)
4766 void ceph_mdsc_sync(struct ceph_mds_client *mdsc)
4799 static bool done_closing_sessions(struct ceph_mds_client *mdsc, int skipped)
4809 void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc)
4865 void ceph_mdsc_force_umount(struct ceph_mds_client *mdsc)
4899 static void ceph_mdsc_stop(struct ceph_mds_client *mdsc)
4921 struct ceph_mds_client *mdsc = fsc->mdsc;
4939 void ceph_mdsc_handle_fsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
5018 void ceph_mdsc_handle_mdsmap(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
5101 struct ceph_mds_client *mdsc = s->s_mdsc;
5110 struct ceph_mds_client *mdsc = s->s_mdsc;
5169 struct ceph_mds_client *mdsc = s->s_mdsc;
5197 struct ceph_mds_client *mdsc = s->s_mdsc;
5207 struct ceph_mds_client *mdsc = s->s_mdsc;
5216 struct ceph_mds_client *mdsc = s->s_mdsc;