import ceph 16.2.6

[ceph.git] / ceph / src / tools / cephfs_mirror / PeerReplayer.h

diff --git a/ceph/src/tools/cephfs_mirror/PeerReplayer.h b/ceph/src/tools/cephfs_mirror/PeerReplayer.h
index f32064278695427b4da09f119d7f027dea6b321c..886c9532944b8828cc6936bac9a50d35e363423f 100644 (file)
--- a/ceph/src/tools/cephfs_mirror/PeerReplayer.h
+++ b/ceph/src/tools/cephfs_mirror/PeerReplayer.h
@@ -88,21 +88,13 @@ private:
       return 0;
     }
 
-    void cancel() {
-      canceled = true;
-    }
-
-    bool is_canceled() const {
-      return canceled;
-    }
-
   private:
     PeerReplayer *m_peer_replayer;
-    bool canceled = false;
   };
 
   struct DirRegistry {
     int fd;
+    bool canceled = false;
     SnapshotReplayerThread *replayer;
   };
 
@@ -244,7 +236,7 @@ private:
       return true;
     }
     auto &dr = m_registered.at(dir_root);
-    if (dr.replayer->is_canceled()) {
+    if (dr.canceled) {
       *retval = -ECANCELED;
       return true;
     }