Lines Matching refs:fsc

833 	struct ceph_fs_client *fsc = ceph_sb_to_fs_client(dentry->d_sb);  in ceph_wait_on_conflict_unlink()  local
845 hash_for_each_possible_rcu(fsc->async_unlink_conflict, di, in ceph_wait_on_conflict_unlink()
962 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_FENCE_IO) in register_session()
995 ceph_con_init(&s->s_con, s, &mds_con_ops, &mdsc->fsc->client->msgr); in register_session()
1321 if (!dir || dir->i_sb != mdsc->fsc->sb) { in __choose_mds()
1530 struct ceph_options *opt = mdsc->fsc->client->options; in create_session_open_msg()
1531 struct ceph_mount_options *fsopt = mdsc->fsc->mount_options; in create_session_open_msg()
1640 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_FENCE_IO) in __open_session()
1889 struct ceph_fs_client *fsc = session->s_mdsc->fsc; in remove_session_caps() local
1890 struct super_block *sb = fsc->sb; in remove_session_caps()
1894 ceph_iterate_session_caps(session, remove_session_caps_cb, fsc); in remove_session_caps()
1896 wake_up_all(&fsc->mdsc->cap_flushing_wq); in remove_session_caps()
2273 struct ceph_osd_client *osdc = &mdsc->fsc->client->osdc; in ceph_send_cap_releases()
2381 if (queue_work(mdsc->fsc->cap_wq, in ceph_flush_cap_releases()
2417 if (queue_work(mdsc->fsc->cap_wq, &mdsc->cap_reclaim_work)) { in ceph_queue_cap_reclaim_work()
2445 struct ceph_mount_options *opt = req->r_mdsc->fsc->mount_options; in ceph_alloc_readdir_reply_buffer()
3248 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_FENCE_IO) { in __do_request()
3259 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN) { in __do_request()
3264 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_MOUNTING) { in __do_request()
3275 if (!(mdsc->fsc->mount_options->flags & in __do_request()
3338 if (ceph_test_mount_opt(mdsc->fsc, CLEANRECOVER)) in __do_request()
3738 in = ceph_get_inode(mdsc->fsc->sb, tvino, in); in handle_reply()
3777 err = ceph_fill_trace(mdsc->fsc->sb, req); in handle_reply()
4093 mdsc->fsc->blocklisted = true; in handle_session()
4598 if (mdsc->fsc->sb->s_root) in send_mds_reconnect()
4599 shrink_dcache_parent(mdsc->fsc->sb->s_root); in send_mds_reconnect()
4901 struct super_block *sb = mdsc->fsc->sb; in handle_lease()
5050 struct ceph_fs_client *fsc = mdsc->fsc; in maybe_recover_session() local
5052 if (!ceph_test_mount_opt(fsc, CLEANRECOVER)) in maybe_recover_session()
5055 if (READ_ONCE(fsc->mount_state) != CEPH_MOUNT_MOUNTED) in maybe_recover_session()
5058 if (!READ_ONCE(fsc->blocklisted)) in maybe_recover_session()
5062 ceph_force_reconnect(fsc->sb); in maybe_recover_session()
5180 int ceph_mdsc_init(struct ceph_fs_client *fsc) in ceph_mdsc_init() argument
5189 mdsc->fsc = fsc; in ceph_mdsc_init()
5232 ceph_adjust_caps_max_min(mdsc, fsc->mount_options); in ceph_mdsc_init()
5244 fsc->mdsc = mdsc; in ceph_mdsc_init()
5260 struct ceph_options *opts = mdsc->fsc->client->options; in wait_requests()
5402 if (READ_ONCE(mdsc->fsc->mount_state) >= CEPH_MOUNT_SHUTDOWN) in ceph_mdsc_sync()
5433 if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN) in done_closing_sessions()
5443 struct ceph_options *opts = mdsc->fsc->client->options; in ceph_mdsc_close_sessions()
5551 void ceph_mdsc_destroy(struct ceph_fs_client *fsc) in ceph_mdsc_destroy() argument
5553 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_mdsc_destroy()
5566 fsc->mdsc = NULL; in ceph_mdsc_destroy()
5573 struct ceph_fs_client *fsc = mdsc->fsc; in ceph_mdsc_handle_fsmap() local
5574 const char *mds_namespace = fsc->mount_options->mds_namespace; in ceph_mdsc_handle_fsmap()
5617 ceph_monc_got_map(&fsc->client->monc, CEPH_SUB_FSMAP, epoch); in ceph_mdsc_handle_fsmap()
5619 fsc->client->monc.fs_cluster_id = mount_fscid; in ceph_mdsc_handle_fsmap()
5620 ceph_monc_want_map(&fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_fsmap()
5622 ceph_monc_renew_subs(&fsc->client->monc); in ceph_mdsc_handle_fsmap()
5631 ceph_umount_begin(mdsc->fsc->sb); in ceph_mdsc_handle_fsmap()
5655 if (ceph_check_fsid(mdsc->fsc->client, &fsid) < 0) in ceph_mdsc_handle_mdsmap()
5670 newmap = ceph_mdsmap_decode(mdsc, &p, end, ceph_msgr2(mdsc->fsc->client)); in ceph_mdsc_handle_mdsmap()
5685 mdsc->fsc->max_file_size = min((loff_t)mdsc->mdsmap->m_max_file_size, in ceph_mdsc_handle_mdsmap()
5689 ceph_monc_got_map(&mdsc->fsc->client->monc, CEPH_SUB_MDSMAP, in ceph_mdsc_handle_mdsmap()
5700 ceph_umount_begin(mdsc->fsc->sb); in ceph_mdsc_handle_mdsmap()
5731 if (READ_ONCE(mdsc->fsc->mount_state) != CEPH_MOUNT_FENCE_IO) in mds_peer_reset()
5798 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_get_authorizer()
5815 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_add_authorizer_challenge()
5825 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_verify_authorizer_reply()
5837 struct ceph_auth_client *ac = mdsc->fsc->client->monc.auth; in mds_invalidate_authorizer()
5841 return ceph_monc_validate_auth(&mdsc->fsc->client->monc); in mds_invalidate_authorizer()
5849 struct ceph_auth_client *ac = s->s_mdsc->fsc->client->monc.auth; in mds_get_auth_request()
5869 struct ceph_auth_client *ac = s->s_mdsc->fsc->client->monc.auth; in mds_handle_auth_reply_more()
5889 struct ceph_auth_client *ac = s->s_mdsc->fsc->client->monc.auth; in mds_handle_auth_done()
5903 struct ceph_mon_client *monc = &s->s_mdsc->fsc->client->monc; in mds_handle_auth_bad_method()