|
@@ -1166,7 +1166,7 @@ static int remove_session_caps_cb(struct inode *inode, struct ceph_cap *cap,
|
|
ci->i_ceph_flags |= CEPH_I_CAP_DROPPED;
|
|
ci->i_ceph_flags |= CEPH_I_CAP_DROPPED;
|
|
|
|
|
|
if (ci->i_wrbuffer_ref > 0 &&
|
|
if (ci->i_wrbuffer_ref > 0 &&
|
|
- ACCESS_ONCE(fsc->mount_state) == CEPH_MOUNT_SHUTDOWN)
|
|
|
|
|
|
+ READ_ONCE(fsc->mount_state) == CEPH_MOUNT_SHUTDOWN)
|
|
invalidate = true;
|
|
invalidate = true;
|
|
|
|
|
|
while (!list_empty(&ci->i_cap_flush_list)) {
|
|
while (!list_empty(&ci->i_cap_flush_list)) {
|
|
@@ -2126,12 +2126,12 @@ static int __do_request(struct ceph_mds_client *mdsc,
|
|
err = -EIO;
|
|
err = -EIO;
|
|
goto finish;
|
|
goto finish;
|
|
}
|
|
}
|
|
- if (ACCESS_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN) {
|
|
|
|
|
|
+ if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN) {
|
|
dout("do_request forced umount\n");
|
|
dout("do_request forced umount\n");
|
|
err = -EIO;
|
|
err = -EIO;
|
|
goto finish;
|
|
goto finish;
|
|
}
|
|
}
|
|
- if (ACCESS_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_MOUNTING) {
|
|
|
|
|
|
+ if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_MOUNTING) {
|
|
if (mdsc->mdsmap_err) {
|
|
if (mdsc->mdsmap_err) {
|
|
err = mdsc->mdsmap_err;
|
|
err = mdsc->mdsmap_err;
|
|
dout("do_request mdsmap err %d\n", err);
|
|
dout("do_request mdsmap err %d\n", err);
|
|
@@ -3586,7 +3586,7 @@ void ceph_mdsc_sync(struct ceph_mds_client *mdsc)
|
|
{
|
|
{
|
|
u64 want_tid, want_flush;
|
|
u64 want_tid, want_flush;
|
|
|
|
|
|
- if (ACCESS_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN)
|
|
|
|
|
|
+ if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN)
|
|
return;
|
|
return;
|
|
|
|
|
|
dout("sync\n");
|
|
dout("sync\n");
|
|
@@ -3617,7 +3617,7 @@ void ceph_mdsc_sync(struct ceph_mds_client *mdsc)
|
|
*/
|
|
*/
|
|
static bool done_closing_sessions(struct ceph_mds_client *mdsc, int skipped)
|
|
static bool done_closing_sessions(struct ceph_mds_client *mdsc, int skipped)
|
|
{
|
|
{
|
|
- if (ACCESS_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN)
|
|
|
|
|
|
+ if (READ_ONCE(mdsc->fsc->mount_state) == CEPH_MOUNT_SHUTDOWN)
|
|
return true;
|
|
return true;
|
|
return atomic_read(&mdsc->num_sessions) <= skipped;
|
|
return atomic_read(&mdsc->num_sessions) <= skipped;
|
|
}
|
|
}
|