54 	ceph_mdsc_close_sessions(fsc->mdsc);  in ceph_put_super()
67 	if (fsc->mdsc->mdsmap->m_num_data_pg_pools == 1) {  in ceph_statfs()
68 		data_pool = fsc->mdsc->mdsmap->m_data_pg_pools[0];  in ceph_statfs()
131 		ceph_flush_dirty_caps(fsc->mdsc);  in ceph_sync_fs()
132 		ceph_flush_cap_releases(fsc->mdsc);  in ceph_sync_fs()
139 	ceph_mdsc_sync(fsc->mdsc);  in ceph_sync_fs()
791 		ceph_mdsc_handle_mdsmap(fsc->mdsc, msg);  in extra_mon_dispatch()
794 		ceph_mdsc_handle_fsmap(fsc->mdsc, msg);  in extra_mon_dispatch()
1012 	ceph_mdsc_force_umount(fsc->mdsc);  in __ceph_umount_begin()
1052 	struct ceph_mds_client *mdsc = fsc->mdsc;  in open_root_dentry()  local
1059 	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_GETATTR, USE_ANY_MDS);  in open_root_dentry()
1074 	err = ceph_mdsc_do_request(mdsc, NULL, req);  in open_root_dentry()
1356 	if (!ceph_mdsmap_is_cluster_available(fsc->mdsc->mdsmap)) {  in ceph_get_tree()
1361 	ceph_mdsc_close_sessions(fsc->mdsc);  in ceph_get_tree()
1477  * or false if the mdsc is in stopping and flushed state.
1479 static bool __inc_stopping_blocker(struct ceph_mds_client *mdsc)  in __inc_stopping_blocker()  argument
1481 	spin_lock(&mdsc->stopping_lock);  in __inc_stopping_blocker()
1482 	if (mdsc->stopping >= CEPH_MDSC_STOPPING_FLUSHING) {  in __inc_stopping_blocker()
1483 		spin_unlock(&mdsc->stopping_lock);  in __inc_stopping_blocker()
1486 	atomic_inc(&mdsc->stopping_blockers);  in __inc_stopping_blocker()
1487 	spin_unlock(&mdsc->stopping_lock);  in __inc_stopping_blocker()
1491 static void __dec_stopping_blocker(struct ceph_mds_client *mdsc)  in __dec_stopping_blocker()  argument
1493 	spin_lock(&mdsc->stopping_lock);  in __dec_stopping_blocker()
1494 	if (!atomic_dec_return(&mdsc->stopping_blockers) &&  in __dec_stopping_blocker()
1495 	    mdsc->stopping >= CEPH_MDSC_STOPPING_FLUSHING)  in __dec_stopping_blocker()
1496 		complete_all(&mdsc->stopping_waiter);  in __dec_stopping_blocker()
1497 	spin_unlock(&mdsc->stopping_lock);  in __dec_stopping_blocker()
1501 bool ceph_inc_mds_stopping_blocker(struct ceph_mds_client *mdsc,  in ceph_inc_mds_stopping_blocker()  argument
1508 	return __inc_stopping_blocker(mdsc);  in ceph_inc_mds_stopping_blocker()
1511 void ceph_dec_mds_stopping_blocker(struct ceph_mds_client *mdsc)  in ceph_dec_mds_stopping_blocker()  argument
1513 	__dec_stopping_blocker(mdsc);  in ceph_dec_mds_stopping_blocker()
1517 bool ceph_inc_osd_stopping_blocker(struct ceph_mds_client *mdsc)  in ceph_inc_osd_stopping_blocker()  argument
1519 	return __inc_stopping_blocker(mdsc);  in ceph_inc_osd_stopping_blocker()
1522 void ceph_dec_osd_stopping_blocker(struct ceph_mds_client *mdsc)  in ceph_dec_osd_stopping_blocker()  argument
1524 	__dec_stopping_blocker(mdsc);  in ceph_dec_osd_stopping_blocker()
1531 	struct ceph_mds_client *mdsc = fsc->mdsc;  in ceph_kill_sb()  local
1536 	ceph_mdsc_pre_umount(mdsc);  in ceph_kill_sb()
1555 	if (atomic64_read(&mdsc->dirty_folios) > 0) {  in ceph_kill_sb()
1556 		wait_queue_head_t *wq = &mdsc->flush_end_wq;  in ceph_kill_sb()
1558 					atomic64_read(&mdsc->dirty_folios) <= 0,  in ceph_kill_sb()
1566 	spin_lock(&mdsc->stopping_lock);  in ceph_kill_sb()
1567 	mdsc->stopping = CEPH_MDSC_STOPPING_FLUSHING;  in ceph_kill_sb()
1568 	wait = !!atomic_read(&mdsc->stopping_blockers);  in ceph_kill_sb()
1569 	spin_unlock(&mdsc->stopping_lock);  in ceph_kill_sb()
1571 	if (wait && atomic_read(&mdsc->stopping_blockers)) {  in ceph_kill_sb()
1573 					&mdsc->stopping_waiter,  in ceph_kill_sb()
1581 	mdsc->stopping = CEPH_MDSC_STOPPING_FLUSHED;  in ceph_kill_sb()
1671 			metric_schedule_delayed(&fsc->mdsc->metric);  in param_set_metrics()