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