Lines Matching refs:session
56 struct ceph_mds_session *session; member
1419 mds = cap->session->s_mds; in __choose_mds()
1662 struct ceph_mds_session *session) in __open_session() argument
1666 int mds = session->s_mds; in __open_session()
1675 session->s_state = CEPH_MDS_SESSION_OPENING; in __open_session()
1676 session->s_renew_requested = jiffies; in __open_session()
1680 session->s_seq); in __open_session()
1683 ceph_con_send(&session->s_con, msg); in __open_session()
1695 struct ceph_mds_session *session; in __open_export_target_session() local
1698 session = __ceph_lookup_mds_session(mdsc, target); in __open_export_target_session()
1699 if (!session) { in __open_export_target_session()
1700 session = register_session(mdsc, target); in __open_export_target_session()
1701 if (IS_ERR(session)) in __open_export_target_session()
1702 return session; in __open_export_target_session()
1704 if (session->s_state == CEPH_MDS_SESSION_NEW || in __open_export_target_session()
1705 session->s_state == CEPH_MDS_SESSION_CLOSING) { in __open_export_target_session()
1706 ret = __open_session(mdsc, session); in __open_export_target_session()
1711 return session; in __open_export_target_session()
1717 struct ceph_mds_session *session; in ceph_mdsc_open_export_target_session() local
1723 session = __open_export_target_session(mdsc, target); in ceph_mdsc_open_export_target_session()
1726 return session; in ceph_mdsc_open_export_target_session()
1730 struct ceph_mds_session *session) in __open_export_target_sessions() argument
1734 int i, mds = session->s_mds; in __open_export_target_sessions()
1741 doutc(cl, "for mds%d (%d targets)\n", session->s_mds, in __open_export_target_sessions()
1754 static void detach_cap_releases(struct ceph_mds_session *session, in detach_cap_releases() argument
1757 struct ceph_client *cl = session->s_mdsc->fsc->client; in detach_cap_releases()
1759 lockdep_assert_held(&session->s_cap_lock); in detach_cap_releases()
1761 list_splice_init(&session->s_cap_releases, target); in detach_cap_releases()
1762 session->s_num_cap_releases = 0; in detach_cap_releases()
1763 doutc(cl, "mds%d\n", session->s_mds); in detach_cap_releases()
1779 struct ceph_mds_session *session) in cleanup_session_requests() argument
1785 doutc(cl, "mds%d\n", session->s_mds); in cleanup_session_requests()
1787 while (!list_empty(&session->s_unsafe)) { in cleanup_session_requests()
1788 req = list_first_entry(&session->s_unsafe, in cleanup_session_requests()
1804 req->r_session->s_mds == session->s_mds) in cleanup_session_requests()
1816 int ceph_iterate_session_caps(struct ceph_mds_session *session, in ceph_iterate_session_caps() argument
1820 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_iterate_session_caps()
1827 doutc(cl, "%p mds%d\n", session, session->s_mds); in ceph_iterate_session_caps()
1828 spin_lock(&session->s_cap_lock); in ceph_iterate_session_caps()
1829 p = session->s_caps.next; in ceph_iterate_session_caps()
1830 while (p != &session->s_caps) { in ceph_iterate_session_caps()
1839 session->s_cap_iterator = cap; in ceph_iterate_session_caps()
1841 spin_unlock(&session->s_cap_lock); in ceph_iterate_session_caps()
1848 ceph_put_cap(session->s_mdsc, old_cap); in ceph_iterate_session_caps()
1855 spin_lock(&session->s_cap_lock); in ceph_iterate_session_caps()
1859 BUG_ON(cap->session != session); in ceph_iterate_session_caps()
1860 cap->session = NULL; in ceph_iterate_session_caps()
1862 session->s_nr_caps--; in ceph_iterate_session_caps()
1863 atomic64_dec(&session->s_mdsc->metric.total_caps); in ceph_iterate_session_caps()
1865 __ceph_queue_cap_release(session, cap); in ceph_iterate_session_caps()
1874 session->s_cap_iterator = NULL; in ceph_iterate_session_caps()
1875 spin_unlock(&session->s_cap_lock); in ceph_iterate_session_caps()
1879 ceph_put_cap(session->s_mdsc, old_cap); in ceph_iterate_session_caps()
1914 static void remove_session_caps(struct ceph_mds_session *session) in remove_session_caps() argument
1916 struct ceph_fs_client *fsc = session->s_mdsc->fsc; in remove_session_caps()
1920 doutc(fsc->client, "on %p\n", session); in remove_session_caps()
1921 ceph_iterate_session_caps(session, remove_session_caps_cb, fsc); in remove_session_caps()
1925 spin_lock(&session->s_cap_lock); in remove_session_caps()
1926 if (session->s_nr_caps > 0) { in remove_session_caps()
1937 while (!list_empty(&session->s_caps)) { in remove_session_caps()
1938 cap = list_entry(session->s_caps.next, in remove_session_caps()
1944 spin_unlock(&session->s_cap_lock); in remove_session_caps()
1949 spin_lock(&session->s_cap_lock); in remove_session_caps()
1954 detach_cap_releases(session, &dispose); in remove_session_caps()
1956 BUG_ON(session->s_nr_caps > 0); in remove_session_caps()
1957 BUG_ON(!list_empty(&session->s_cap_flushing)); in remove_session_caps()
1958 spin_unlock(&session->s_cap_lock); in remove_session_caps()
1959 dispose_cap_releases(session->s_mdsc, &dispose); in remove_session_caps()
1990 if (cap && cap->cap_gen < atomic_read(&cap->session->s_cap_gen)) in wake_up_session_cb()
1999 static void wake_up_session_caps(struct ceph_mds_session *session, int ev) in wake_up_session_caps() argument
2001 struct ceph_client *cl = session->s_mdsc->fsc->client; in wake_up_session_caps()
2003 doutc(cl, "session %p mds%d\n", session, session->s_mds); in wake_up_session_caps()
2004 ceph_iterate_session_caps(session, wake_up_session_cb, in wake_up_session_caps()
2015 struct ceph_mds_session *session) in send_renew_caps() argument
2021 if (time_after_eq(jiffies, session->s_cap_ttl) && in send_renew_caps()
2022 time_after_eq(session->s_cap_ttl, session->s_renew_requested)) in send_renew_caps()
2023 pr_info_client(cl, "mds%d caps stale\n", session->s_mds); in send_renew_caps()
2024 session->s_renew_requested = jiffies; in send_renew_caps()
2028 state = ceph_mdsmap_get_state(mdsc->mdsmap, session->s_mds); in send_renew_caps()
2030 doutc(cl, "ignoring mds%d (%s)\n", session->s_mds, in send_renew_caps()
2035 doutc(cl, "to mds%d (%s)\n", session->s_mds, in send_renew_caps()
2038 ++session->s_renew_seq); in send_renew_caps()
2041 ceph_con_send(&session->s_con, msg); in send_renew_caps()
2046 struct ceph_mds_session *session, u64 seq) in send_flushmsg_ack() argument
2051 doutc(cl, "to mds%d (%s)s seq %lld\n", session->s_mds, in send_flushmsg_ack()
2052 ceph_session_state_name(session->s_state), seq); in send_flushmsg_ack()
2056 ceph_con_send(&session->s_con, msg); in send_flushmsg_ack()
2067 struct ceph_mds_session *session, int is_renew) in renewed_caps() argument
2073 spin_lock(&session->s_cap_lock); in renewed_caps()
2074 was_stale = is_renew && time_after_eq(jiffies, session->s_cap_ttl); in renewed_caps()
2076 session->s_cap_ttl = session->s_renew_requested + in renewed_caps()
2080 if (time_before(jiffies, session->s_cap_ttl)) { in renewed_caps()
2082 session->s_mds); in renewed_caps()
2086 session->s_mds); in renewed_caps()
2089 doutc(cl, "mds%d ttl now %lu, was %s, now %s\n", session->s_mds, in renewed_caps()
2090 session->s_cap_ttl, was_stale ? "stale" : "fresh", in renewed_caps()
2091 time_before(jiffies, session->s_cap_ttl) ? "stale" : "fresh"); in renewed_caps()
2092 spin_unlock(&session->s_cap_lock); in renewed_caps()
2095 wake_up_session_caps(session, RENEWCAPS); in renewed_caps()
2101 static int request_close_session(struct ceph_mds_session *session) in request_close_session() argument
2103 struct ceph_client *cl = session->s_mdsc->fsc->client; in request_close_session()
2106 doutc(cl, "mds%d state %s seq %lld\n", session->s_mds, in request_close_session()
2107 ceph_session_state_name(session->s_state), session->s_seq); in request_close_session()
2109 session->s_seq); in request_close_session()
2112 ceph_con_send(&session->s_con, msg); in request_close_session()
2120 struct ceph_mds_session *session) in __close_session() argument
2122 if (session->s_state >= CEPH_MDS_SESSION_CLOSING) in __close_session()
2124 session->s_state = CEPH_MDS_SESSION_CLOSING; in __close_session()
2125 return request_close_session(session); in __close_session()
2244 struct ceph_mds_session *session, in ceph_trim_caps() argument
2248 int trim_caps = session->s_nr_caps - max_caps; in ceph_trim_caps()
2250 doutc(cl, "mds%d start: %d / %d, trim %d\n", session->s_mds, in ceph_trim_caps()
2251 session->s_nr_caps, max_caps, trim_caps); in ceph_trim_caps()
2255 ceph_iterate_session_caps(session, trim_caps_cb, &remaining); in ceph_trim_caps()
2257 session->s_mds, session->s_nr_caps, max_caps, in ceph_trim_caps()
2261 ceph_flush_session_cap_releases(mdsc, session); in ceph_trim_caps()
2308 struct ceph_mds_session *session) in ceph_send_cap_releases() argument
2324 spin_lock(&session->s_cap_lock); in ceph_send_cap_releases()
2326 list_splice_init(&session->s_cap_releases, &tmp_list); in ceph_send_cap_releases()
2327 num_cap_releases = session->s_num_cap_releases; in ceph_send_cap_releases()
2328 session->s_num_cap_releases = 0; in ceph_send_cap_releases()
2329 spin_unlock(&session->s_cap_lock); in ceph_send_cap_releases()
2369 doutc(cl, "mds%d %p\n", session->s_mds, msg); in ceph_send_cap_releases()
2370 ceph_con_send(&session->s_con, msg); in ceph_send_cap_releases()
2377 spin_lock(&session->s_cap_lock); in ceph_send_cap_releases()
2378 if (!list_empty(&session->s_cap_releases)) in ceph_send_cap_releases()
2380 spin_unlock(&session->s_cap_lock); in ceph_send_cap_releases()
2389 doutc(cl, "mds%d %p\n", session->s_mds, msg); in ceph_send_cap_releases()
2390 ceph_con_send(&session->s_con, msg); in ceph_send_cap_releases()
2395 session->s_mds); in ceph_send_cap_releases()
2396 spin_lock(&session->s_cap_lock); in ceph_send_cap_releases()
2397 list_splice(&tmp_list, &session->s_cap_releases); in ceph_send_cap_releases()
2398 session->s_num_cap_releases += num_cap_releases; in ceph_send_cap_releases()
2399 spin_unlock(&session->s_cap_lock); in ceph_send_cap_releases()
2404 struct ceph_mds_session *session = in ceph_cap_release_work() local
2407 mutex_lock(&session->s_mutex); in ceph_cap_release_work()
2408 if (session->s_state == CEPH_MDS_SESSION_OPEN || in ceph_cap_release_work()
2409 session->s_state == CEPH_MDS_SESSION_HUNG) in ceph_cap_release_work()
2410 ceph_send_cap_releases(session->s_mdsc, session); in ceph_cap_release_work()
2411 mutex_unlock(&session->s_mutex); in ceph_cap_release_work()
2412 ceph_put_mds_session(session); in ceph_cap_release_work()
2416 struct ceph_mds_session *session) in ceph_flush_session_cap_releases() argument
2422 ceph_get_mds_session(session); in ceph_flush_session_cap_releases()
2424 &session->s_cap_release_work)) { in ceph_flush_session_cap_releases()
2427 ceph_put_mds_session(session); in ceph_flush_session_cap_releases()
2435 void __ceph_queue_cap_release(struct ceph_mds_session *session, in __ceph_queue_cap_release() argument
2438 list_add_tail(&cap->session_caps, &session->s_cap_releases); in __ceph_queue_cap_release()
2439 session->s_num_cap_releases++; in __ceph_queue_cap_release()
2441 if (!(session->s_num_cap_releases % CEPH_CAPS_PER_RELEASE)) in __ceph_queue_cap_release()
2442 ceph_flush_session_cap_releases(session->s_mdsc, session); in __ceph_queue_cap_release()
2936 static inline u16 mds_supported_head_version(struct ceph_mds_session *session) in mds_supported_head_version() argument
2938 if (!test_bit(CEPHFS_FEATURE_32BITS_RETRY_FWD, &session->s_features)) in mds_supported_head_version()
2941 if (!test_bit(CEPHFS_FEATURE_HAS_OWNER_UIDGID, &session->s_features)) in mds_supported_head_version()
2962 static struct ceph_msg *create_request_message(struct ceph_mds_session *session, in create_request_message() argument
2966 int mds = session->s_mds; in create_request_message()
2967 struct ceph_mds_client *mdsc = session->s_mdsc; in create_request_message()
2981 bool legacy = !(session->s_con.peer_features & CEPH_FEATURE_FS_BTIME); in create_request_message()
2982 u16 request_head_version = mds_supported_head_version(session); in create_request_message()
3076 session->s_con.peer_features); in create_request_message()
3079 !test_bit(CEPHFS_FEATURE_HAS_OWNER_UIDGID, &session->s_features)) { in create_request_message()
3251 static int __prepare_send_request(struct ceph_mds_session *session, in __prepare_send_request() argument
3255 int mds = session->s_mds; in __prepare_send_request()
3256 struct ceph_mds_client *mdsc = session->s_mdsc; in __prepare_send_request()
3263 &session->s_features); in __prepare_send_request()
3306 session->s_con.peer_features); in __prepare_send_request()
3336 msg = create_request_message(session, req, drop_cap_releases); in __prepare_send_request()
3344 session->s_con.peer_features); in __prepare_send_request()
3368 static int __send_request(struct ceph_mds_session *session, in __send_request() argument
3374 err = __prepare_send_request(session, req, drop_cap_releases); in __send_request()
3377 ceph_con_send(&session->s_con, req->r_request); in __send_request()
3390 struct ceph_mds_session *session = NULL; in __do_request() local
3451 session = __ceph_lookup_mds_session(mdsc, mds); in __do_request()
3452 if (!session) { in __do_request()
3453 session = register_session(mdsc, mds); in __do_request()
3454 if (IS_ERR(session)) { in __do_request()
3455 err = PTR_ERR(session); in __do_request()
3459 req->r_session = ceph_get_mds_session(session); in __do_request()
3461 doutc(cl, "mds%d session %p state %s\n", mds, session, in __do_request()
3462 ceph_session_state_name(session->s_state)); in __do_request()
3468 !test_bit(req->r_feature_needed, &session->s_features)) { in __do_request()
3473 if (session->s_state != CEPH_MDS_SESSION_OPEN && in __do_request()
3474 session->s_state != CEPH_MDS_SESSION_HUNG) { in __do_request()
3490 if (session->s_state == CEPH_MDS_SESSION_REJECTED) { in __do_request()
3498 if (session->s_state == CEPH_MDS_SESSION_NEW || in __do_request()
3499 session->s_state == CEPH_MDS_SESSION_CLOSING) { in __do_request()
3500 err = __open_session(mdsc, session); in __do_request()
3507 list_add(&req->r_wait, &session->s_waiting); in __do_request()
3554 cap->session->s_mds, session->s_mds); in __do_request()
3557 spin_lock(&cap->session->s_cap_lock); in __do_request()
3558 cap->session->s_nr_caps--; in __do_request()
3560 spin_unlock(&cap->session->s_cap_lock); in __do_request()
3564 cap->session = session; in __do_request()
3565 spin_lock(&session->s_cap_lock); in __do_request()
3566 session->s_nr_caps++; in __do_request()
3567 list_add_tail(&cap->session_caps, &session->s_caps); in __do_request()
3568 spin_unlock(&session->s_cap_lock); in __do_request()
3570 change_auth_cap_ses(ci, session); in __do_request()
3575 err = __send_request(session, req, false); in __do_request()
3578 ceph_put_mds_session(session); in __do_request()
3787 static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg) in handle_reply() argument
3789 struct ceph_mds_client *mdsc = session->s_mdsc; in handle_reply()
3797 int mds = session->s_mds; in handle_reply()
3818 if (req->r_session != session) { in handle_reply()
3820 tid, session->s_mds, in handle_reply()
3870 if (test_bit(CEPHFS_FEATURE_REPLY_ENCODING, &session->s_features)) in handle_reply()
3871 err = parse_reply_info(session, msg, req, (u64)-1); in handle_reply()
3873 err = parse_reply_info(session, msg, req, in handle_reply()
3874 session->s_con.peer_features); in handle_reply()
3901 mutex_lock(&session->s_mutex); in handle_reply()
3907 mutex_lock(&session->s_mutex); in handle_reply()
3978 mutex_unlock(&session->s_mutex); in handle_reply()
4000 struct ceph_mds_session *session, in handle_forward() argument
4099 static void handle_session(struct ceph_mds_session *session, in handle_session() argument
4102 struct ceph_mds_client *mdsc = session->s_mdsc; in handle_session()
4104 int mds = session->s_mds; in handle_session()
4155 session->s_mds); in handle_session()
4256 ceph_get_mds_session(session); in handle_session()
4257 __unregister_session(mdsc, session); in handle_session()
4260 session->s_ttl = jiffies + HZ*mdsc->mdsmap->m_session_autoclose; in handle_session()
4263 mutex_lock(&session->s_mutex); in handle_session()
4266 ceph_session_op_name(op), session, in handle_session()
4267 ceph_session_state_name(session->s_state), seq); in handle_session()
4269 if (session->s_state == CEPH_MDS_SESSION_HUNG) { in handle_session()
4270 session->s_state = CEPH_MDS_SESSION_OPEN; in handle_session()
4271 pr_info_client(cl, "mds%d came back\n", session->s_mds); in handle_session()
4276 if (session->s_state == CEPH_MDS_SESSION_RECONNECTING) in handle_session()
4278 session->s_mds); in handle_session()
4280 session->s_features = features; in handle_session()
4281 if (session->s_state == CEPH_MDS_SESSION_OPEN) { in handle_session()
4283 session->s_mds); in handle_session()
4285 session->s_state = CEPH_MDS_SESSION_OPEN; in handle_session()
4286 renewed_caps(mdsc, session, 0); in handle_session()
4288 &session->s_features)) in handle_session()
4297 if (!session->s_seq && seq) in handle_session()
4298 session->s_seq = seq; in handle_session()
4302 __close_session(mdsc, session); in handle_session()
4306 if (session->s_renew_seq == seq) in handle_session()
4307 renewed_caps(mdsc, session, 1); in handle_session()
4311 if (session->s_state == CEPH_MDS_SESSION_RECONNECTING) in handle_session()
4313 session->s_mds); in handle_session()
4314 session->s_state = CEPH_MDS_SESSION_CLOSED; in handle_session()
4315 cleanup_session_requests(mdsc, session); in handle_session()
4316 remove_session_caps(session); in handle_session()
4323 session->s_mds); in handle_session()
4324 atomic_inc(&session->s_cap_gen); in handle_session()
4325 session->s_cap_ttl = jiffies - 1; in handle_session()
4326 send_renew_caps(mdsc, session); in handle_session()
4330 ceph_trim_caps(mdsc, session, le32_to_cpu(h->max_caps)); in handle_session()
4335 spin_lock(&session->s_cap_lock); in handle_session()
4336 if (session->s_num_cap_releases) in handle_session()
4337 ceph_flush_session_cap_releases(mdsc, session); in handle_session()
4338 spin_unlock(&session->s_cap_lock); in handle_session()
4340 send_flushmsg_ack(mdsc, session, seq); in handle_session()
4344 doutc(cl, "force_session_readonly %p\n", session); in handle_session()
4345 spin_lock(&session->s_cap_lock); in handle_session()
4346 session->s_readonly = true; in handle_session()
4347 spin_unlock(&session->s_cap_lock); in handle_session()
4348 wake_up_session_caps(session, FORCE_RO); in handle_session()
4352 WARN_ON(session->s_state != CEPH_MDS_SESSION_OPENING); in handle_session()
4354 session->s_mds); in handle_session()
4355 session->s_state = CEPH_MDS_SESSION_REJECTED; in handle_session()
4356 cleanup_session_requests(mdsc, session); in handle_session()
4357 remove_session_caps(session); in handle_session()
4368 mutex_unlock(&session->s_mutex); in handle_session()
4371 __wake_requests(mdsc, &session->s_waiting); in handle_session()
4377 ceph_put_mds_session(session); in handle_session()
4422 struct ceph_mds_session *session) in replay_unsafe_requests() argument
4427 doutc(mdsc->fsc->client, "mds%d\n", session->s_mds); in replay_unsafe_requests()
4430 list_for_each_entry_safe(req, nreq, &session->s_unsafe, r_unsafe_item) in replay_unsafe_requests()
4431 __send_request(session, req, true); in replay_unsafe_requests()
4447 if (req->r_session->s_mds != session->s_mds) in replay_unsafe_requests()
4452 __send_request(session, req, true); in replay_unsafe_requests()
4518 ceph_con_send(&recon_state->session->s_con, reply); in send_reconnect_partial()
4616 cap->cap_gen = atomic_read(&cap->session->s_cap_gen); in reconnect_caps_cb()
4832 struct ceph_mds_session *session) in send_mds_reconnect() argument
4836 int mds = session->s_mds; in send_mds_reconnect()
4839 .session = session, in send_mds_reconnect()
4853 xa_destroy(&session->s_delegated_inos); in send_mds_reconnect()
4855 mutex_lock(&session->s_mutex); in send_mds_reconnect()
4856 session->s_state = CEPH_MDS_SESSION_RECONNECTING; in send_mds_reconnect()
4857 session->s_seq = 0; in send_mds_reconnect()
4859 doutc(cl, "session %p state %s\n", session, in send_mds_reconnect()
4860 ceph_session_state_name(session->s_state)); in send_mds_reconnect()
4862 atomic_inc(&session->s_cap_gen); in send_mds_reconnect()
4864 spin_lock(&session->s_cap_lock); in send_mds_reconnect()
4866 session->s_readonly = 0; in send_mds_reconnect()
4872 session->s_cap_reconnect = 1; in send_mds_reconnect()
4874 detach_cap_releases(session, &dispose); in send_mds_reconnect()
4875 spin_unlock(&session->s_cap_lock); in send_mds_reconnect()
4882 ceph_con_close(&session->s_con); in send_mds_reconnect()
4883 ceph_con_open(&session->s_con, in send_mds_reconnect()
4888 replay_unsafe_requests(mdsc, session); in send_mds_reconnect()
4890 ceph_early_kick_flushing_caps(mdsc, session); in send_mds_reconnect()
4899 if (test_bit(CEPHFS_FEATURE_MULTI_RECONNECT, &session->s_features)) { in send_mds_reconnect()
4902 } else if (session->s_con.peer_features & CEPH_FEATURE_MDSENC) { in send_mds_reconnect()
4908 err = ceph_iterate_session_caps(session, reconnect_caps_cb, &recon_state); in send_mds_reconnect()
4910 spin_lock(&session->s_cap_lock); in send_mds_reconnect()
4911 session->s_cap_reconnect = 0; in send_mds_reconnect()
4912 spin_unlock(&session->s_cap_lock); in send_mds_reconnect()
4975 ceph_con_send(&session->s_con, reply); in send_mds_reconnect()
4977 mutex_unlock(&session->s_mutex); in send_mds_reconnect()
4980 __wake_requests(mdsc, &session->s_waiting); in send_mds_reconnect()
4990 mutex_unlock(&session->s_mutex); in send_mds_reconnect()
5181 struct ceph_mds_session *session, in handle_lease() argument
5189 int mds = session->s_mds; in handle_lease()
5198 if (!ceph_inc_mds_stopping_blocker(mdsc, session)) in handle_lease()
5217 mutex_lock(&session->s_mutex); in handle_lease()
5240 if (di->lease_session == session) { in handle_lease()
5249 if (di->lease_session == session && in handle_lease()
5250 di->lease_gen == atomic_read(&session->s_cap_gen) && in handle_lease()
5274 ceph_con_send(&session->s_con, msg); in handle_lease()
5277 mutex_unlock(&session->s_mutex); in handle_lease()
5290 void ceph_mdsc_lease_send_msg(struct ceph_mds_session *session, in ceph_mdsc_lease_send_msg() argument
5294 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_mdsc_lease_send_msg()
5301 session->s_mds); in ceph_mdsc_lease_send_msg()
5320 ceph_con_send(&session->s_con, msg); in ceph_mdsc_lease_send_msg()
5913 struct ceph_mds_session *session; in ceph_mdsc_close_sessions() local
5922 session = __ceph_lookup_mds_session(mdsc, i); in ceph_mdsc_close_sessions()
5923 if (!session) in ceph_mdsc_close_sessions()
5926 mutex_lock(&session->s_mutex); in ceph_mdsc_close_sessions()
5927 if (__close_session(mdsc, session) <= 0) in ceph_mdsc_close_sessions()
5929 mutex_unlock(&session->s_mutex); in ceph_mdsc_close_sessions()
5930 ceph_put_mds_session(session); in ceph_mdsc_close_sessions()
5944 session = ceph_get_mds_session(mdsc->sessions[i]); in ceph_mdsc_close_sessions()
5945 __unregister_session(mdsc, session); in ceph_mdsc_close_sessions()
5947 mutex_lock(&session->s_mutex); in ceph_mdsc_close_sessions()
5948 remove_session_caps(session); in ceph_mdsc_close_sessions()
5949 mutex_unlock(&session->s_mutex); in ceph_mdsc_close_sessions()
5950 ceph_put_mds_session(session); in ceph_mdsc_close_sessions()
5969 struct ceph_mds_session *session; in ceph_mdsc_force_umount() local
5976 session = __ceph_lookup_mds_session(mdsc, mds); in ceph_mdsc_force_umount()
5977 if (!session) in ceph_mdsc_force_umount()
5980 if (session->s_state == CEPH_MDS_SESSION_REJECTED) in ceph_mdsc_force_umount()
5981 __unregister_session(mdsc, session); in ceph_mdsc_force_umount()
5982 __wake_requests(mdsc, &session->s_waiting); in ceph_mdsc_force_umount()
5985 mutex_lock(&session->s_mutex); in ceph_mdsc_force_umount()
5986 __close_session(mdsc, session); in ceph_mdsc_force_umount()
5987 if (session->s_state == CEPH_MDS_SESSION_CLOSING) { in ceph_mdsc_force_umount()
5988 cleanup_session_requests(mdsc, session); in ceph_mdsc_force_umount()
5989 remove_session_caps(session); in ceph_mdsc_force_umount()
5991 mutex_unlock(&session->s_mutex); in ceph_mdsc_force_umount()
5992 ceph_put_mds_session(session); in ceph_mdsc_force_umount()