cephfs-mirror: carve out (and implement) mirroring snapshots to peers

Remote file synchronization by @mchangir. Signed-off-by: Milind Changire <[email protected]> Signed-off-by: Venky Shankar <[email protected]>
areed · Jan 12, 2021 · 0d96a31 · 0d96a31
1 parent 493a050
commit 0d96a31
Show file tree

Hide file tree

Showing 4 changed files with 1,172 additions and 1 deletion.
diff --git a/src/common/options.cc b/src/common/options.cc
@@ -8910,7 +8910,18 @@ std::vector<Option> get_cephfs_mirror_options() {
     .set_description("interval to restart blocklisted instances")
     .set_long_description("Interval in seconds to restart blocklisted mirror instances. Setting to zero (0) disables restarting blocklisted instances."),
 
-    });
+    Option("cephfs_mirror_max_snapshot_sync_per_cycle", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
+    .set_default(3)
+    .set_min(1)
+    .set_description("number of snapshots to mirror in one cycle")
+    .set_long_description("maximum number of snapshots to mirror when a directory is picked up for mirroring by worker threads."),
+
+    Option("cephfs_mirror_directory_scan_interval", Option::TYPE_UINT, Option::LEVEL_ADVANCED)
+    .set_default(10)
+    .set_min(1)
+    .set_description("interval to scan directories to mirror snapshots")
+    .set_long_description("interval in seconds to scan configured directories for snapshot mirroring."),
+   });
 }
 
 static std::vector<Option> build_options()

diff --git a/src/tools/cephfs_mirror/CMakeLists.txt b/src/tools/cephfs_mirror/CMakeLists.txt
@@ -4,6 +4,7 @@ set(cephfs_mirror_internal
   FSMirror.cc
   InstanceWatcher.cc
   MirrorWatcher.cc
+  PeerReplayer.cc
   Types.cc
   Utils.cc
   Watcher.cc