Lines Matching refs:mdsc
51 ceph_mdsc_close_sessions(fsc->mdsc); in ceph_put_super()
62 if (fsc->mdsc->mdsmap->m_num_data_pg_pools == 1) { in ceph_statfs()
63 data_pool = fsc->mdsc->mdsmap->m_data_pg_pools[0]; in ceph_statfs()
125 ceph_flush_dirty_caps(fsc->mdsc); in ceph_sync_fs()
132 ceph_mdsc_sync(fsc->mdsc); in ceph_sync_fs()
788 ceph_mdsc_handle_mdsmap(fsc->mdsc, msg); in extra_mon_dispatch()
791 ceph_mdsc_handle_fsmap(fsc->mdsc, msg); in extra_mon_dispatch()
1008 ceph_mdsc_force_umount(fsc->mdsc); in __ceph_umount_begin()
1048 struct ceph_mds_client *mdsc = fsc->mdsc; in open_root_dentry() local
1055 req = ceph_mdsc_create_request(mdsc, CEPH_MDS_OP_GETATTR, USE_ANY_MDS); in open_root_dentry()
1070 err = ceph_mdsc_do_request(mdsc, NULL, req); in open_root_dentry()
1347 if (!ceph_mdsmap_is_cluster_available(fsc->mdsc->mdsmap)) { in ceph_get_tree()
1352 ceph_mdsc_close_sessions(fsc->mdsc); in ceph_get_tree()
1469 static bool __inc_stopping_blocker(struct ceph_mds_client *mdsc) in __inc_stopping_blocker() argument
1471 spin_lock(&mdsc->stopping_lock); in __inc_stopping_blocker()
1472 if (mdsc->stopping >= CEPH_MDSC_STOPPING_FLUSHING) { in __inc_stopping_blocker()
1473 spin_unlock(&mdsc->stopping_lock); in __inc_stopping_blocker()
1476 atomic_inc(&mdsc->stopping_blockers); in __inc_stopping_blocker()
1477 spin_unlock(&mdsc->stopping_lock); in __inc_stopping_blocker()
1481 static void __dec_stopping_blocker(struct ceph_mds_client *mdsc) in __dec_stopping_blocker() argument
1483 spin_lock(&mdsc->stopping_lock); in __dec_stopping_blocker()
1484 if (!atomic_dec_return(&mdsc->stopping_blockers) && in __dec_stopping_blocker()
1485 mdsc->stopping >= CEPH_MDSC_STOPPING_FLUSHING) in __dec_stopping_blocker()
1486 complete_all(&mdsc->stopping_waiter); in __dec_stopping_blocker()
1487 spin_unlock(&mdsc->stopping_lock); in __dec_stopping_blocker()
1491 bool ceph_inc_mds_stopping_blocker(struct ceph_mds_client *mdsc, in ceph_inc_mds_stopping_blocker() argument
1498 return __inc_stopping_blocker(mdsc); in ceph_inc_mds_stopping_blocker()
1501 void ceph_dec_mds_stopping_blocker(struct ceph_mds_client *mdsc) in ceph_dec_mds_stopping_blocker() argument
1503 __dec_stopping_blocker(mdsc); in ceph_dec_mds_stopping_blocker()
1507 bool ceph_inc_osd_stopping_blocker(struct ceph_mds_client *mdsc) in ceph_inc_osd_stopping_blocker() argument
1509 return __inc_stopping_blocker(mdsc); in ceph_inc_osd_stopping_blocker()
1512 void ceph_dec_osd_stopping_blocker(struct ceph_mds_client *mdsc) in ceph_dec_osd_stopping_blocker() argument
1514 __dec_stopping_blocker(mdsc); in ceph_dec_osd_stopping_blocker()
1520 struct ceph_mds_client *mdsc = fsc->mdsc; in ceph_kill_sb() local
1525 ceph_mdsc_pre_umount(mdsc); in ceph_kill_sb()
1544 spin_lock(&mdsc->stopping_lock); in ceph_kill_sb()
1545 mdsc->stopping = CEPH_MDSC_STOPPING_FLUSHING; in ceph_kill_sb()
1546 wait = !!atomic_read(&mdsc->stopping_blockers); in ceph_kill_sb()
1547 spin_unlock(&mdsc->stopping_lock); in ceph_kill_sb()
1549 if (wait && atomic_read(&mdsc->stopping_blockers)) { in ceph_kill_sb()
1551 &mdsc->stopping_waiter, in ceph_kill_sb()
1559 mdsc->stopping = CEPH_MDSC_STOPPING_FLUSHED; in ceph_kill_sb()
1649 metric_schedule_delayed(&fsc->mdsc->metric); in param_set_metrics()