fs/ceph/super.c

51 	ceph_mdsc_close_sessions(fsc->mdsc);
64 	if (fsc->mdsc->mdsmap->m_num_data_pg_pools == 1) {
65 		data_pool = fsc->mdsc->mdsmap->m_data_pg_pools[0];
128 		ceph_flush_dirty_caps(fsc->mdsc);
135 	ceph_mdsc_sync(fsc->mdsc);
791 		ceph_mdsc_handle_mdsmap(fsc->mdsc, msg);
794 		ceph_mdsc_handle_fsmap(fsc->mdsc, msg);
1011 	ceph_mdsc_force_umount(fsc->mdsc);
1052 	struct ceph_mds_client *mdsc = fsc->mdsc;
1059 	req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_GETATTR, USE_ANY_MDS);
1074 	err = ceph_mdsc_do_request(mdsc, NULL, req);
1355 	if (!ceph_mdsmap_is_cluster_available(fsc->mdsc->mdsmap)) {
1360 	ceph_mdsc_close_sessions(fsc->mdsc);
1476  * or false if the mdsc is in stopping and flushed state.
1478 static bool __inc_stopping_blocker(struct ceph_mds_client *mdsc)
1480 	spin_lock(&mdsc->stopping_lock);
1481 	if (mdsc->stopping >= CEPH_MDSC_STOPPING_FLUSHING) {
1482 		spin_unlock(&mdsc->stopping_lock);
1485 	atomic_inc(&mdsc->stopping_blockers);
1486 	spin_unlock(&mdsc->stopping_lock);
1490 static void __dec_stopping_blocker(struct ceph_mds_client *mdsc)
1492 	spin_lock(&mdsc->stopping_lock);
1493 	if (!atomic_dec_return(&mdsc->stopping_blockers) &&
1494 	    mdsc->stopping >= CEPH_MDSC_STOPPING_FLUSHING)
1495 		complete_all(&mdsc->stopping_waiter);
1496 	spin_unlock(&mdsc->stopping_lock);
1500 bool ceph_inc_mds_stopping_blocker(struct ceph_mds_client *mdsc,
1507 	return __inc_stopping_blocker(mdsc);
1510 void ceph_dec_mds_stopping_blocker(struct ceph_mds_client *mdsc)
1512 	__dec_stopping_blocker(mdsc);
1516 bool ceph_inc_osd_stopping_blocker(struct ceph_mds_client *mdsc)
1518 	return __inc_stopping_blocker(mdsc);
1521 void ceph_dec_osd_stopping_blocker(struct ceph_mds_client *mdsc)
1523 	__dec_stopping_blocker(mdsc);
1530 	struct ceph_mds_client *mdsc = fsc->mdsc;
1535 	ceph_mdsc_pre_umount(mdsc);
1554 	spin_lock(&mdsc->stopping_lock);
1555 	mdsc->stopping = CEPH_MDSC_STOPPING_FLUSHING;
1556 	wait = !!atomic_read(&mdsc->stopping_blockers);
1557 	spin_unlock(&mdsc->stopping_lock);
1559 	if (wait && atomic_read(&mdsc->stopping_blockers)) {
1561 					&mdsc->stopping_waiter,
1569 	mdsc->stopping = CEPH_MDSC_STOPPING_FLUSHED;
1659 			metric_schedule_delayed(&fsc->mdsc->metric);