Lines Matching refs:fsc
415 struct ceph_client *cl = req->r_mdsc->fsc->client; in parse_reply_info_readdir()
575 struct ceph_client *cl = s->s_mdsc->fsc->client; in ceph_parse_deleg_inos()
751 struct ceph_client *cl = s->s_mdsc->fsc->client; in parse_reply_info()
838 struct ceph_fs_client *fsc = ceph_sb_to_fs_client(dentry->d_sb); in ceph_wait_on_conflict_unlink() local
839 struct ceph_client *cl = fsc->client; in ceph_wait_on_conflict_unlink()
851 hash_for_each_possible_rcu(fsc->async_unlink_conflict, di, in ceph_wait_on_conflict_unlink()
966 struct ceph_client *cl = mdsc->fsc->client; in register_session()
969 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_FENCE_IO) in register_session()
1002 ceph_con_init(&s->s_con, s, &mds_con_ops, &mdsc->fsc->client->msgr); in register_session()
1039 doutc(mdsc->fsc->client, "mds%d %p\n", s->s_mds, s); in __unregister_session()
1167 struct ceph_client *cl = mdsc->fsc->client; in __register_request()
1207 doutc(mdsc->fsc->client, "%p tid %lld\n", req, req->r_tid); in __unregister_request()
1293 struct ceph_client *cl = mdsc->fsc->client; in __choose_mds()
1334 if (!dir || dir->i_sb != mdsc->fsc->sb) { in __choose_mds()
1545 struct ceph_options *opt = mdsc->fsc->client->options; in create_session_full_msg()
1546 struct ceph_mount_options *fsopt = mdsc->fsc->mount_options; in create_session_full_msg()
1547 struct ceph_client *cl = mdsc->fsc->client; in create_session_full_msg()
1668 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_FENCE_IO) in __open_session()
1673 doutc(mdsc->fsc->client, "open_session to mds%d (%s)\n", mds, in __open_session()
1718 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_open_export_target_session()
1735 struct ceph_client *cl = mdsc->fsc->client; in __open_export_target_sessions()
1757 struct ceph_client *cl = session->s_mdsc->fsc->client; in detach_cap_releases()
1781 struct ceph_client *cl = mdsc->fsc->client; in cleanup_session_requests()
1820 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_iterate_session_caps()
1916 struct ceph_fs_client *fsc = session->s_mdsc->fsc; in remove_session_caps() local
1917 struct super_block *sb = fsc->sb; 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()
1923 wake_up_all(&fsc->mdsc->cap_flushing_wq); in remove_session_caps()
2001 struct ceph_client *cl = session->s_mdsc->fsc->client; in wake_up_session_caps()
2017 struct ceph_client *cl = mdsc->fsc->client; in send_renew_caps()
2048 struct ceph_client *cl = mdsc->fsc->client; in send_flushmsg_ack()
2069 struct ceph_client *cl = mdsc->fsc->client; in renewed_caps()
2103 struct ceph_client *cl = session->s_mdsc->fsc->client; in request_close_session()
2164 struct ceph_client *cl = mdsc->fsc->client; in trim_caps_cb()
2247 struct ceph_client *cl = mdsc->fsc->client; in ceph_trim_caps()
2268 struct ceph_client *cl = mdsc->fsc->client; in check_caps_flush()
2294 struct ceph_client *cl = mdsc->fsc->client; in wait_caps_flush()
2310 struct ceph_client *cl = mdsc->fsc->client; in ceph_send_cap_releases()
2314 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_send_cap_releases()
2418 struct ceph_client *cl = mdsc->fsc->client; in ceph_flush_session_cap_releases()
2423 if (queue_work(mdsc->fsc->cap_wq, in ceph_flush_session_cap_releases()
2456 struct ceph_client *cl = mdsc->fsc->client; in ceph_queue_cap_reclaim_work()
2460 if (queue_work(mdsc->fsc->cap_wq, &mdsc->cap_reclaim_work)) { in ceph_queue_cap_reclaim_work()
2481 struct ceph_client *cl = mdsc->fsc->client; in ceph_queue_cap_unlink_work()
2485 if (queue_work(mdsc->fsc->cap_wq, &mdsc->cap_unlink_work)) { in ceph_queue_cap_unlink_work()
2496 struct ceph_client *cl = mdsc->fsc->client; in ceph_cap_unlink_work()
2532 struct ceph_mount_options *opt = req->r_mdsc->fsc->mount_options; in ceph_alloc_readdir_reply_buffer()
2705 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_build_path()
2879 struct ceph_client *cl = mdsc->fsc->client; in set_request_path_attr()
2968 struct ceph_client *cl = mdsc->fsc->client; in create_request_message()
3257 struct ceph_client *cl = mdsc->fsc->client; in __prepare_send_request()
3389 struct ceph_client *cl = mdsc->fsc->client; in __do_request()
3401 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_FENCE_IO) { in __do_request()
3412 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN) { in __do_request()
3417 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_MOUNTING) { in __do_request()
3428 if (!(mdsc->fsc->mount_options->flags & in __do_request()
3491 if (ceph_test_mount_opt(mdsc->fsc, CLEANRECOVER)) in __do_request()
3595 struct ceph_client *cl = mdsc->fsc->client; in __wake_requests()
3617 struct ceph_client *cl = mdsc->fsc->client; in kick_requests()
3641 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_submit_request()
3689 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_wait_request()
3745 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_do_request()
3766 struct ceph_client *cl = req->r_mdsc->fsc->client; in ceph_invalidate_dir_request()
3790 struct ceph_client *cl = mdsc->fsc->client; in handle_reply()
3898 in = ceph_get_inode(mdsc->fsc->sb, tvino, in); in handle_reply()
3938 err = ceph_fill_trace(mdsc->fsc->sb, req); in handle_reply()
4003 struct ceph_client *cl = mdsc->fsc->client; in handle_forward()
4103 struct ceph_client *cl = mdsc->fsc->client; in handle_session()
4359 mdsc->fsc->blocklisted = true; in handle_session()
4396 struct ceph_client *cl = req->r_mdsc->fsc->client; in ceph_mdsc_release_dir_caps()
4408 struct ceph_client *cl = req->r_mdsc->fsc->client; in ceph_mdsc_release_dir_caps_async()
4427 doutc(mdsc->fsc->client, "mds%d\n", session->s_mds); in replay_unsafe_requests()
4765 struct ceph_client *cl = mdsc->fsc->client; in encode_snap_realms()
4834 struct ceph_client *cl = mdsc->fsc->client; in send_mds_reconnect()
4879 if (mdsc->fsc->sb->s_root) in send_mds_reconnect()
4880 shrink_dcache_parent(mdsc->fsc->sb->s_root); in send_mds_reconnect()
5014 struct ceph_client *cl = mdsc->fsc->client; in check_new_map()
5184 struct ceph_client *cl = mdsc->fsc->client; in handle_lease()
5185 struct super_block *sb = mdsc->fsc->sb; in handle_lease()
5294 struct ceph_client *cl = session->s_mdsc->fsc->client; in ceph_mdsc_lease_send_msg()
5334 struct ceph_client *cl = mdsc->fsc->client; in maybe_recover_session()
5335 struct ceph_fs_client *fsc = mdsc->fsc; in maybe_recover_session() local
5337 if (!ceph_test_mount_opt(fsc, CLEANRECOVER)) in maybe_recover_session()
5340 if (READ_ONCE(fsc->mount_state) != CEPH_MOUNT_MOUNTED) in maybe_recover_session()
5343 if (!READ_ONCE(fsc->blocklisted)) in maybe_recover_session()
5347 ceph_force_reconnect(fsc->sb); in maybe_recover_session()
5352 struct ceph_client *cl = s->s_mdsc->fsc->client; in check_session_state()
5378 struct ceph_client *cl = s->s_mdsc->fsc->client; in inc_session_sequence()
5420 doutc(mdsc->fsc->client, "mdsc delayed_work\n"); in delayed_work()
5471 int ceph_mdsc_init(struct ceph_fs_client *fsc) in ceph_mdsc_init() argument
5480 mdsc->fsc = fsc; in ceph_mdsc_init()
5529 ceph_adjust_caps_max_min(mdsc, fsc->mount_options); in ceph_mdsc_init()
5541 fsc->mdsc = mdsc; in ceph_mdsc_init()
5557 struct ceph_client *cl = mdsc->fsc->client; in wait_requests()
5558 struct ceph_options *opts = mdsc->fsc->client->options; in wait_requests()
5583 struct ceph_client *cl = s->s_mdsc->fsc->client; in send_flush_mdlog()
5613 struct ceph_client *cl = mdsc->fsc->client; in ceph_mds_auth_match()
5614 const char *spath = mdsc->fsc->mount_options->server_path; in ceph_mds_auth_match()
5723 struct ceph_client *cl = mdsc->fsc->client; in ceph_mds_check_access()
5779 doutc(mdsc->fsc->client, "begin\n"); in ceph_mdsc_pre_umount()
5794 doutc(mdsc->fsc->client, "done\n"); in ceph_mdsc_pre_umount()
5803 struct ceph_client *cl = mdsc->fsc->client; in flush_mdlog_and_wait_mdsc_unsafe_requests()
5867 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_sync()
5870 if (READ_ONCE(mdsc->fsc->mount_state) >= CEPH_MOUNT_SHUTDOWN) in ceph_mdsc_sync()
5901 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN) in done_closing_sessions()
5911 struct ceph_options *opts = mdsc->fsc->client->options; in ceph_mdsc_close_sessions()
5912 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_close_sessions()
5972 doutc(mdsc->fsc->client, "force umount\n"); in ceph_mdsc_force_umount()
6003 doutc(mdsc->fsc->client, "stop\n"); in ceph_mdsc_stop()
6033 void ceph_mdsc_destroy(struct ceph_fs_client *fsc) in ceph_mdsc_destroy() argument
6035 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_mdsc_destroy()
6036 doutc(fsc->client, "%p\n", mdsc); in ceph_mdsc_destroy()
6048 fsc->mdsc = NULL; in ceph_mdsc_destroy()
6050 doutc(fsc->client, "%p done\n", mdsc); in ceph_mdsc_destroy()
6055 struct ceph_fs_client *fsc = mdsc->fsc; in ceph_mdsc_handle_fsmap() local
6056 struct ceph_client *cl = fsc->client; in ceph_mdsc_handle_fsmap()
6057 const char *mds_namespace = fsc->mount_options->mds_namespace; in ceph_mdsc_handle_fsmap()
6100 ceph_monc_got_map(&fsc->client->monc, CEPH_SUB_FSMAP, epoch); in ceph_mdsc_handle_fsmap()
6102 fsc->client->monc.fs_cluster_id = mount_fscid; in ceph_mdsc_handle_fsmap()
6103 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_fsmap()
6105 ceph_monc_renew_subs(&fsc->client->monc); in ceph_mdsc_handle_fsmap()
6115 ceph_umount_begin(mdsc->fsc->sb); in ceph_mdsc_handle_fsmap()
6129 struct ceph_client *cl = mdsc->fsc->client; in ceph_mdsc_handle_mdsmap()
6140 if (ceph_check_fsid(mdsc->fsc->client, &fsid) < 0) in ceph_mdsc_handle_mdsmap()
6154 newmap = ceph_mdsmap_decode(mdsc, &p, end, ceph_msgr2(mdsc->fsc->client)); in ceph_mdsc_handle_mdsmap()
6169 mdsc->fsc->max_file_size = min((loff_t)mdsc->mdsmap->m_max_file_size, in ceph_mdsc_handle_mdsmap()
6173 ceph_monc_got_map(&mdsc->fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_mdsmap()
6185 ceph_umount_begin(mdsc->fsc->sb); in ceph_mdsc_handle_mdsmap()
6215 pr_warn_client(mdsc->fsc->client, "mds%d closed our session\n", in mds_peer_reset()
6217 if (READ_ONCE(mdsc->fsc->mount_state) != CEPH_MOUNT_FENCE_IO && in mds_peer_reset()
6226 struct ceph_client *cl = mdsc->fsc->client; in mds_dispatch()
6286 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_get_authorizer()
6303 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_add_authorizer_challenge()
6313 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_verify_authorizer_reply()
6325 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_invalidate_authorizer()
6329 return ceph_monc_validate_auth(&mdsc->fsc->client->monc); in mds_invalidate_authorizer()
6337 struct ceph_auth_client *ac = s->s_mdsc->fsc->client->monc.auth; in mds_get_auth_request()
6357 struct ceph_auth_client *ac = s->s_mdsc->fsc->client->monc.auth; in mds_handle_auth_reply_more()
6377 struct ceph_auth_client *ac = s->s_mdsc->fsc->client->monc.auth; in mds_handle_auth_done()
6391 struct ceph_mon_client *monc = &s->s_mdsc->fsc->client->monc; in mds_handle_auth_bad_method()