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()
1751 struct ceph_mds_session *session) in ceph_mdsc_open_export_target_sessions() argument
1754 __open_export_target_sessions(mdsc, session); in ceph_mdsc_open_export_target_sessions()
1762 static void detach_cap_releases(struct ceph_mds_session *session, in detach_cap_releases() argument
1765 struct ceph_client *cl = session->s_mdsc->fsc->client; in detach_cap_releases()
1767 lockdep_assert_held(&session->s_cap_lock); in detach_cap_releases()
1769 list_splice_init(&session->s_cap_releases, target); in detach_cap_releases()
1770 session->s_num_cap_releases = 0; in detach_cap_releases()
1771 doutc(cl, "mds%d\n", session->s_mds); in detach_cap_releases()
1787 struct ceph_mds_session *session) in cleanup_session_requests() argument
1793 doutc(cl, "mds%d\n", session->s_mds); in cleanup_session_requests()
1795 while (!list_empty(&session->s_unsafe)) { in cleanup_session_requests()
1796 req = list_first_entry(&session->s_unsafe, in cleanup_session_requests()
1812 req->r_session->s_mds == session->s_mds) in cleanup_session_requests()
1824 int ceph_iterate_session_caps(struct ceph_mds_session *session, in ceph_iterate_session_caps() argument
1828 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_iterate_session_caps()
1835 doutc(cl, "%p mds%d\n", session, session->s_mds); in ceph_iterate_session_caps()
1836 spin_lock(&session->s_cap_lock); in ceph_iterate_session_caps()
1837 p = session->s_caps.next; in ceph_iterate_session_caps()
1838 while (p != &session->s_caps) { in ceph_iterate_session_caps()
1847 session->s_cap_iterator = cap; in ceph_iterate_session_caps()
1849 spin_unlock(&session->s_cap_lock); in ceph_iterate_session_caps()
1856 ceph_put_cap(session->s_mdsc, old_cap); in ceph_iterate_session_caps()
1863 spin_lock(&session->s_cap_lock); in ceph_iterate_session_caps()
1867 BUG_ON(cap->session != session); in ceph_iterate_session_caps()
1868 cap->session = NULL; in ceph_iterate_session_caps()
1870 session->s_nr_caps--; in ceph_iterate_session_caps()
1871 atomic64_dec(&session->s_mdsc->metric.total_caps); in ceph_iterate_session_caps()
1873 __ceph_queue_cap_release(session, cap); in ceph_iterate_session_caps()
1882 session->s_cap_iterator = NULL; in ceph_iterate_session_caps()
1883 spin_unlock(&session->s_cap_lock); in ceph_iterate_session_caps()
1887 ceph_put_cap(session->s_mdsc, old_cap); in ceph_iterate_session_caps()
1922 static void remove_session_caps(struct ceph_mds_session *session) in remove_session_caps() argument
1924 struct ceph_fs_client *fsc = session->s_mdsc->fsc; in remove_session_caps()
1928 doutc(fsc->client, "on %p\n", session); in remove_session_caps()
1929 ceph_iterate_session_caps(session, remove_session_caps_cb, fsc); in remove_session_caps()
1933 spin_lock(&session->s_cap_lock); in remove_session_caps()
1934 if (session->s_nr_caps > 0) { in remove_session_caps()
1945 while (!list_empty(&session->s_caps)) { in remove_session_caps()
1946 cap = list_entry(session->s_caps.next, in remove_session_caps()
1952 spin_unlock(&session->s_cap_lock); in remove_session_caps()
1957 spin_lock(&session->s_cap_lock); in remove_session_caps()
1962 detach_cap_releases(session, &dispose); in remove_session_caps()
1964 BUG_ON(session->s_nr_caps > 0); in remove_session_caps()
1965 BUG_ON(!list_empty(&session->s_cap_flushing)); in remove_session_caps()
1966 spin_unlock(&session->s_cap_lock); in remove_session_caps()
1967 dispose_cap_releases(session->s_mdsc, &dispose); in remove_session_caps()
1998 if (cap && cap->cap_gen < atomic_read(&cap->session->s_cap_gen)) in wake_up_session_cb()
2007 static void wake_up_session_caps(struct ceph_mds_session *session, int ev) in wake_up_session_caps() argument
2009 struct ceph_client *cl = session->s_mdsc->fsc->client; in wake_up_session_caps()
2011 doutc(cl, "session %p mds%d\n", session, session->s_mds); in wake_up_session_caps()
2012 ceph_iterate_session_caps(session, wake_up_session_cb, in wake_up_session_caps()
2023 struct ceph_mds_session *session) in send_renew_caps() argument
2029 if (time_after_eq(jiffies, session->s_cap_ttl) && in send_renew_caps()
2030 time_after_eq(session->s_cap_ttl, session->s_renew_requested)) in send_renew_caps()
2031 pr_info_client(cl, "mds%d caps stale\n", session->s_mds); in send_renew_caps()
2032 session->s_renew_requested = jiffies; in send_renew_caps()
2036 state = ceph_mdsmap_get_state(mdsc->mdsmap, session->s_mds); in send_renew_caps()
2038 doutc(cl, "ignoring mds%d (%s)\n", session->s_mds, in send_renew_caps()
2043 doutc(cl, "to mds%d (%s)\n", session->s_mds, in send_renew_caps()
2046 ++session->s_renew_seq); in send_renew_caps()
2049 ceph_con_send(&session->s_con, msg); in send_renew_caps()
2054 struct ceph_mds_session *session, u64 seq) in send_flushmsg_ack() argument
2059 doutc(cl, "to mds%d (%s)s seq %lld\n", session->s_mds, in send_flushmsg_ack()
2060 ceph_session_state_name(session->s_state), seq); in send_flushmsg_ack()
2064 ceph_con_send(&session->s_con, msg); in send_flushmsg_ack()
2075 struct ceph_mds_session *session, int is_renew) in renewed_caps() argument
2081 spin_lock(&session->s_cap_lock); in renewed_caps()
2082 was_stale = is_renew && time_after_eq(jiffies, session->s_cap_ttl); in renewed_caps()
2084 session->s_cap_ttl = session->s_renew_requested + in renewed_caps()
2088 if (time_before(jiffies, session->s_cap_ttl)) { in renewed_caps()
2090 session->s_mds); in renewed_caps()
2094 session->s_mds); in renewed_caps()
2097 doutc(cl, "mds%d ttl now %lu, was %s, now %s\n", session->s_mds, in renewed_caps()
2098 session->s_cap_ttl, was_stale ? "stale" : "fresh", in renewed_caps()
2099 time_before(jiffies, session->s_cap_ttl) ? "stale" : "fresh"); in renewed_caps()
2100 spin_unlock(&session->s_cap_lock); in renewed_caps()
2103 wake_up_session_caps(session, RENEWCAPS); in renewed_caps()
2109 static int request_close_session(struct ceph_mds_session *session) in request_close_session() argument
2111 struct ceph_client *cl = session->s_mdsc->fsc->client; in request_close_session()
2114 doutc(cl, "mds%d state %s seq %lld\n", session->s_mds, in request_close_session()
2115 ceph_session_state_name(session->s_state), session->s_seq); in request_close_session()
2117 session->s_seq); in request_close_session()
2120 ceph_con_send(&session->s_con, msg); in request_close_session()
2128 struct ceph_mds_session *session) in __close_session() argument
2130 if (session->s_state >= CEPH_MDS_SESSION_CLOSING) in __close_session()
2132 session->s_state = CEPH_MDS_SESSION_CLOSING; in __close_session()
2133 return request_close_session(session); in __close_session()
2252 struct ceph_mds_session *session, in ceph_trim_caps() argument
2256 int trim_caps = session->s_nr_caps - max_caps; in ceph_trim_caps()
2258 doutc(cl, "mds%d start: %d / %d, trim %d\n", session->s_mds, in ceph_trim_caps()
2259 session->s_nr_caps, max_caps, trim_caps); in ceph_trim_caps()
2263 ceph_iterate_session_caps(session, trim_caps_cb, &remaining); in ceph_trim_caps()
2265 session->s_mds, session->s_nr_caps, max_caps, in ceph_trim_caps()
2269 ceph_flush_session_cap_releases(mdsc, session); in ceph_trim_caps()
2316 struct ceph_mds_session *session) in ceph_send_cap_releases() argument
2332 spin_lock(&session->s_cap_lock); in ceph_send_cap_releases()
2334 list_splice_init(&session->s_cap_releases, &tmp_list); in ceph_send_cap_releases()
2335 num_cap_releases = session->s_num_cap_releases; in ceph_send_cap_releases()
2336 session->s_num_cap_releases = 0; in ceph_send_cap_releases()
2337 spin_unlock(&session->s_cap_lock); in ceph_send_cap_releases()
2377 doutc(cl, "mds%d %p\n", session->s_mds, msg); in ceph_send_cap_releases()
2378 ceph_con_send(&session->s_con, msg); in ceph_send_cap_releases()
2385 spin_lock(&session->s_cap_lock); in ceph_send_cap_releases()
2386 if (!list_empty(&session->s_cap_releases)) in ceph_send_cap_releases()
2388 spin_unlock(&session->s_cap_lock); in ceph_send_cap_releases()
2397 doutc(cl, "mds%d %p\n", session->s_mds, msg); in ceph_send_cap_releases()
2398 ceph_con_send(&session->s_con, msg); in ceph_send_cap_releases()
2403 session->s_mds); in ceph_send_cap_releases()
2404 spin_lock(&session->s_cap_lock); in ceph_send_cap_releases()
2405 list_splice(&tmp_list, &session->s_cap_releases); in ceph_send_cap_releases()
2406 session->s_num_cap_releases += num_cap_releases; in ceph_send_cap_releases()
2407 spin_unlock(&session->s_cap_lock); in ceph_send_cap_releases()
2412 struct ceph_mds_session *session = in ceph_cap_release_work() local
2415 mutex_lock(&session->s_mutex); in ceph_cap_release_work()
2416 if (session->s_state == CEPH_MDS_SESSION_OPEN || in ceph_cap_release_work()
2417 session->s_state == CEPH_MDS_SESSION_HUNG) in ceph_cap_release_work()
2418 ceph_send_cap_releases(session->s_mdsc, session); in ceph_cap_release_work()
2419 mutex_unlock(&session->s_mutex); in ceph_cap_release_work()
2420 ceph_put_mds_session(session); in ceph_cap_release_work()
2424 struct ceph_mds_session *session) in ceph_flush_session_cap_releases() argument
2430 ceph_get_mds_session(session); in ceph_flush_session_cap_releases()
2432 &session->s_cap_release_work)) { in ceph_flush_session_cap_releases()
2435 ceph_put_mds_session(session); in ceph_flush_session_cap_releases()
2443 void __ceph_queue_cap_release(struct ceph_mds_session *session, in __ceph_queue_cap_release() argument
2446 list_add_tail(&cap->session_caps, &session->s_cap_releases); in __ceph_queue_cap_release()
2447 session->s_num_cap_releases++; in __ceph_queue_cap_release()
2449 if (!(session->s_num_cap_releases % CEPH_CAPS_PER_RELEASE)) in __ceph_queue_cap_release()
2450 ceph_flush_session_cap_releases(session->s_mdsc, session); in __ceph_queue_cap_release()
2942 static inline u16 mds_supported_head_version(struct ceph_mds_session *session) in mds_supported_head_version() argument
2944 if (!test_bit(CEPHFS_FEATURE_32BITS_RETRY_FWD, &session->s_features)) in mds_supported_head_version()
2947 if (!test_bit(CEPHFS_FEATURE_HAS_OWNER_UIDGID, &session->s_features)) in mds_supported_head_version()
2968 static struct ceph_msg *create_request_message(struct ceph_mds_session *session, in create_request_message() argument
2972 int mds = session->s_mds; in create_request_message()
2973 struct ceph_mds_client *mdsc = session->s_mdsc; in create_request_message()
2987 bool legacy = !(session->s_con.peer_features & CEPH_FEATURE_FS_BTIME); in create_request_message()
2988 u16 request_head_version = mds_supported_head_version(session); in create_request_message()
3082 session->s_con.peer_features); in create_request_message()
3085 !test_bit(CEPHFS_FEATURE_HAS_OWNER_UIDGID, &session->s_features)) { in create_request_message()
3257 static int __prepare_send_request(struct ceph_mds_session *session, in __prepare_send_request() argument
3261 int mds = session->s_mds; in __prepare_send_request()
3262 struct ceph_mds_client *mdsc = session->s_mdsc; in __prepare_send_request()
3269 &session->s_features); in __prepare_send_request()
3312 session->s_con.peer_features); in __prepare_send_request()
3342 msg = create_request_message(session, req, drop_cap_releases); in __prepare_send_request()
3350 session->s_con.peer_features); in __prepare_send_request()
3374 static int __send_request(struct ceph_mds_session *session, in __send_request() argument
3380 err = __prepare_send_request(session, req, drop_cap_releases); in __send_request()
3383 ceph_con_send(&session->s_con, req->r_request); in __send_request()
3396 struct ceph_mds_session *session = NULL; in __do_request() local
3457 session = __ceph_lookup_mds_session(mdsc, mds); in __do_request()
3458 if (!session) { in __do_request()
3459 session = register_session(mdsc, mds); in __do_request()
3460 if (IS_ERR(session)) { in __do_request()
3461 err = PTR_ERR(session); in __do_request()
3465 req->r_session = ceph_get_mds_session(session); in __do_request()
3467 doutc(cl, "mds%d session %p state %s\n", mds, session, in __do_request()
3468 ceph_session_state_name(session->s_state)); in __do_request()
3474 !test_bit(req->r_feature_needed, &session->s_features)) { in __do_request()
3479 if (session->s_state != CEPH_MDS_SESSION_OPEN && in __do_request()
3480 session->s_state != CEPH_MDS_SESSION_HUNG) { in __do_request()
3496 if (session->s_state == CEPH_MDS_SESSION_REJECTED) { in __do_request()
3504 if (session->s_state == CEPH_MDS_SESSION_NEW || in __do_request()
3505 session->s_state == CEPH_MDS_SESSION_CLOSING) { in __do_request()
3506 err = __open_session(mdsc, session); in __do_request()
3513 list_add(&req->r_wait, &session->s_waiting); in __do_request()
3560 cap->session->s_mds, session->s_mds); in __do_request()
3563 spin_lock(&cap->session->s_cap_lock); in __do_request()
3564 cap->session->s_nr_caps--; in __do_request()
3566 spin_unlock(&cap->session->s_cap_lock); in __do_request()
3570 cap->session = session; in __do_request()
3571 spin_lock(&session->s_cap_lock); in __do_request()
3572 session->s_nr_caps++; in __do_request()
3573 list_add_tail(&cap->session_caps, &session->s_caps); in __do_request()
3574 spin_unlock(&session->s_cap_lock); in __do_request()
3576 change_auth_cap_ses(ci, session); in __do_request()
3581 err = __send_request(session, req, false); in __do_request()
3584 ceph_put_mds_session(session); in __do_request()
3793 static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg) in handle_reply() argument
3795 struct ceph_mds_client *mdsc = session->s_mdsc; in handle_reply()
3803 int mds = session->s_mds; in handle_reply()
3824 if (req->r_session != session) { in handle_reply()
3826 tid, session->s_mds, in handle_reply()
3876 if (test_bit(CEPHFS_FEATURE_REPLY_ENCODING, &session->s_features)) in handle_reply()
3877 err = parse_reply_info(session, msg, req, (u64)-1); in handle_reply()
3879 err = parse_reply_info(session, msg, req, in handle_reply()
3880 session->s_con.peer_features); in handle_reply()
3907 mutex_lock(&session->s_mutex); in handle_reply()
3913 mutex_lock(&session->s_mutex); in handle_reply()
3984 mutex_unlock(&session->s_mutex); in handle_reply()
4006 struct ceph_mds_session *session, in handle_forward() argument
4105 static void handle_session(struct ceph_mds_session *session, in handle_session() argument
4108 struct ceph_mds_client *mdsc = session->s_mdsc; in handle_session()
4110 int mds = session->s_mds; in handle_session()
4161 session->s_mds); in handle_session()
4262 ceph_get_mds_session(session); in handle_session()
4263 __unregister_session(mdsc, session); in handle_session()
4266 session->s_ttl = jiffies + HZ*mdsc->mdsmap->m_session_autoclose; in handle_session()
4269 mutex_lock(&session->s_mutex); in handle_session()
4272 ceph_session_op_name(op), session, in handle_session()
4273 ceph_session_state_name(session->s_state), seq); in handle_session()
4275 if (session->s_state == CEPH_MDS_SESSION_HUNG) { in handle_session()
4276 session->s_state = CEPH_MDS_SESSION_OPEN; in handle_session()
4277 pr_info_client(cl, "mds%d came back\n", session->s_mds); in handle_session()
4282 if (session->s_state == CEPH_MDS_SESSION_RECONNECTING) in handle_session()
4284 session->s_mds); in handle_session()
4286 session->s_features = features; in handle_session()
4287 if (session->s_state == CEPH_MDS_SESSION_OPEN) { in handle_session()
4289 session->s_mds); in handle_session()
4291 session->s_state = CEPH_MDS_SESSION_OPEN; in handle_session()
4292 renewed_caps(mdsc, session, 0); in handle_session()
4294 &session->s_features)) in handle_session()
4303 if (!session->s_seq && seq) in handle_session()
4304 session->s_seq = seq; in handle_session()
4308 __close_session(mdsc, session); in handle_session()
4312 if (session->s_renew_seq == seq) in handle_session()
4313 renewed_caps(mdsc, session, 1); in handle_session()
4317 if (session->s_state == CEPH_MDS_SESSION_RECONNECTING) in handle_session()
4319 session->s_mds); in handle_session()
4320 session->s_state = CEPH_MDS_SESSION_CLOSED; in handle_session()
4321 cleanup_session_requests(mdsc, session); in handle_session()
4322 remove_session_caps(session); in handle_session()
4329 session->s_mds); in handle_session()
4330 atomic_inc(&session->s_cap_gen); in handle_session()
4331 session->s_cap_ttl = jiffies - 1; in handle_session()
4332 send_renew_caps(mdsc, session); in handle_session()
4336 ceph_trim_caps(mdsc, session, le32_to_cpu(h->max_caps)); in handle_session()
4341 spin_lock(&session->s_cap_lock); in handle_session()
4342 if (session->s_num_cap_releases) in handle_session()
4343 ceph_flush_session_cap_releases(mdsc, session); in handle_session()
4344 spin_unlock(&session->s_cap_lock); in handle_session()
4346 send_flushmsg_ack(mdsc, session, seq); in handle_session()
4350 doutc(cl, "force_session_readonly %p\n", session); in handle_session()
4351 spin_lock(&session->s_cap_lock); in handle_session()
4352 session->s_readonly = true; in handle_session()
4353 spin_unlock(&session->s_cap_lock); in handle_session()
4354 wake_up_session_caps(session, FORCE_RO); in handle_session()
4358 WARN_ON(session->s_state != CEPH_MDS_SESSION_OPENING); in handle_session()
4360 session->s_mds); in handle_session()
4361 session->s_state = CEPH_MDS_SESSION_REJECTED; in handle_session()
4362 cleanup_session_requests(mdsc, session); in handle_session()
4363 remove_session_caps(session); in handle_session()
4374 mutex_unlock(&session->s_mutex); in handle_session()
4377 __wake_requests(mdsc, &session->s_waiting); in handle_session()
4383 ceph_put_mds_session(session); in handle_session()
4428 struct ceph_mds_session *session) in replay_unsafe_requests() argument
4433 doutc(mdsc->fsc->client, "mds%d\n", session->s_mds); in replay_unsafe_requests()
4436 list_for_each_entry_safe(req, nreq, &session->s_unsafe, r_unsafe_item) in replay_unsafe_requests()
4437 __send_request(session, req, true); in replay_unsafe_requests()
4453 if (req->r_session->s_mds != session->s_mds) in replay_unsafe_requests()
4458 __send_request(session, req, true); in replay_unsafe_requests()
4524 ceph_con_send(&recon_state->session->s_con, reply); in send_reconnect_partial()
4622 cap->cap_gen = atomic_read(&cap->session->s_cap_gen); in reconnect_caps_cb()
4838 struct ceph_mds_session *session) in send_mds_reconnect() argument
4842 int mds = session->s_mds; in send_mds_reconnect()
4845 .session = session, in send_mds_reconnect()
4859 xa_destroy(&session->s_delegated_inos); in send_mds_reconnect()
4861 mutex_lock(&session->s_mutex); in send_mds_reconnect()
4862 session->s_state = CEPH_MDS_SESSION_RECONNECTING; in send_mds_reconnect()
4863 session->s_seq = 0; in send_mds_reconnect()
4865 doutc(cl, "session %p state %s\n", session, in send_mds_reconnect()
4866 ceph_session_state_name(session->s_state)); in send_mds_reconnect()
4868 atomic_inc(&session->s_cap_gen); in send_mds_reconnect()
4870 spin_lock(&session->s_cap_lock); in send_mds_reconnect()
4872 session->s_readonly = 0; in send_mds_reconnect()
4878 session->s_cap_reconnect = 1; in send_mds_reconnect()
4880 detach_cap_releases(session, &dispose); in send_mds_reconnect()
4881 spin_unlock(&session->s_cap_lock); in send_mds_reconnect()
4888 ceph_con_close(&session->s_con); in send_mds_reconnect()
4889 ceph_con_open(&session->s_con, in send_mds_reconnect()
4894 replay_unsafe_requests(mdsc, session); in send_mds_reconnect()
4896 ceph_early_kick_flushing_caps(mdsc, session); in send_mds_reconnect()
4905 if (test_bit(CEPHFS_FEATURE_MULTI_RECONNECT, &session->s_features)) { in send_mds_reconnect()
4908 } else if (session->s_con.peer_features & CEPH_FEATURE_MDSENC) { in send_mds_reconnect()
4914 err = ceph_iterate_session_caps(session, reconnect_caps_cb, &recon_state); in send_mds_reconnect()
4916 spin_lock(&session->s_cap_lock); in send_mds_reconnect()
4917 session->s_cap_reconnect = 0; in send_mds_reconnect()
4918 spin_unlock(&session->s_cap_lock); in send_mds_reconnect()
4981 ceph_con_send(&session->s_con, reply); in send_mds_reconnect()
4983 mutex_unlock(&session->s_mutex); in send_mds_reconnect()
4986 __wake_requests(mdsc, &session->s_waiting); in send_mds_reconnect()
4996 mutex_unlock(&session->s_mutex); in send_mds_reconnect()
5187 struct ceph_mds_session *session, in handle_lease() argument
5195 int mds = session->s_mds; in handle_lease()
5204 if (!ceph_inc_mds_stopping_blocker(mdsc, session)) in handle_lease()
5223 mutex_lock(&session->s_mutex); in handle_lease()
5246 if (di->lease_session == session) { in handle_lease()
5255 if (di->lease_session == session && in handle_lease()
5256 di->lease_gen == atomic_read(&session->s_cap_gen) && in handle_lease()
5280 ceph_con_send(&session->s_con, msg); in handle_lease()
5283 mutex_unlock(&session->s_mutex); in handle_lease()
5296 void ceph_mdsc_lease_send_msg(struct ceph_mds_session *session, in ceph_mdsc_lease_send_msg() argument
5300 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_mdsc_lease_send_msg()
5307 session->s_mds); in ceph_mdsc_lease_send_msg()
5326 ceph_con_send(&session->s_con, msg); in ceph_mdsc_lease_send_msg()
5914 struct ceph_mds_session *session; in ceph_mdsc_close_sessions() local
5923 session = __ceph_lookup_mds_session(mdsc, i); in ceph_mdsc_close_sessions()
5924 if (!session) in ceph_mdsc_close_sessions()
5927 mutex_lock(&session->s_mutex); in ceph_mdsc_close_sessions()
5928 if (__close_session(mdsc, session) <= 0) in ceph_mdsc_close_sessions()
5930 mutex_unlock(&session->s_mutex); in ceph_mdsc_close_sessions()
5931 ceph_put_mds_session(session); in ceph_mdsc_close_sessions()
5945 session = ceph_get_mds_session(mdsc->sessions[i]); in ceph_mdsc_close_sessions()
5946 __unregister_session(mdsc, session); in ceph_mdsc_close_sessions()
5948 mutex_lock(&session->s_mutex); in ceph_mdsc_close_sessions()
5949 remove_session_caps(session); in ceph_mdsc_close_sessions()
5950 mutex_unlock(&session->s_mutex); in ceph_mdsc_close_sessions()
5951 ceph_put_mds_session(session); in ceph_mdsc_close_sessions()
5970 struct ceph_mds_session *session; in ceph_mdsc_force_umount() local
5977 session = __ceph_lookup_mds_session(mdsc, mds); in ceph_mdsc_force_umount()
5978 if (!session) in ceph_mdsc_force_umount()
5981 if (session->s_state == CEPH_MDS_SESSION_REJECTED) in ceph_mdsc_force_umount()
5982 __unregister_session(mdsc, session); in ceph_mdsc_force_umount()
5983 __wake_requests(mdsc, &session->s_waiting); in ceph_mdsc_force_umount()
5986 mutex_lock(&session->s_mutex); in ceph_mdsc_force_umount()
5987 __close_session(mdsc, session); in ceph_mdsc_force_umount()
5988 if (session->s_state == CEPH_MDS_SESSION_CLOSING) { in ceph_mdsc_force_umount()
5989 cleanup_session_requests(mdsc, session); in ceph_mdsc_force_umount()
5990 remove_session_caps(session); in ceph_mdsc_force_umount()
5992 mutex_unlock(&session->s_mutex); in ceph_mdsc_force_umount()
5993 ceph_put_mds_session(session); in ceph_mdsc_force_umount()