rbd-mirror: remove rbd_mirror_journal_max_fetch_bytes option

Signed-off-by: Mykola Golub <mgolub@suse.com>

diff --git a/src/common/options.cc b/src/common/options.cc
index b5b26f9915ec18424be46f85058841c7bf769b02..4ec91021c52210693a0e1aff58138826813e1aa2 100644 (file)
--- a/src/common/options.cc
+++ b/src/common/options.cc
@@ -7415,10 +7415,6 @@ static std::vector<Option> get_rbd_mirror_options() {
     .set_default(5)
     .set_description("maximum age (in seconds) between successive journal polls"),
 
-    Option("rbd_mirror_journal_max_fetch_bytes", Option::TYPE_SIZE, Option::LEVEL_ADVANCED)
-    .set_default(32768)
-    .set_description("maximum bytes to read from each journal data object per fetch"),
-
     Option("rbd_mirror_sync_point_update_age", Option::TYPE_FLOAT, Option::LEVEL_ADVANCED)
     .set_default(30)
     .set_description("number of seconds between each update of the image sync point object number"),

diff --git a/src/journal/Settings.h b/src/journal/Settings.h
index ca57125a859459b6c2cc209c2022854e3f7de052..1896ad5285a0c486318199ef0811a08c52bf5b34 100644 (file)
--- a/src/journal/Settings.h
+++ b/src/journal/Settings.h
@@ -10,7 +10,6 @@ namespace journal {
 
 struct Settings {
   double commit_interval = 5;         ///< commit position throttle (in secs)
-  uint64_t max_fetch_bytes = 0;       ///< 0 implies no limit
   uint64_t max_payload_bytes = 0;     ///< 0 implies object size limit
   int max_concurrent_object_sets = 0; ///< 0 implies no limit
   std::set<std::string> whitelisted_laggy_clients;

diff --git a/src/test/journal/RadosTestFixture.cc b/src/test/journal/RadosTestFixture.cc
index 61a9967f75f64f0aeb024c9ea8c9eaa03f571990..78fadb2b72ebf55d5531c66409f5ecdc6d584f46 100644 (file)
--- a/src/test/journal/RadosTestFixture.cc
+++ b/src/test/journal/RadosTestFixture.cc
@@ -69,11 +69,9 @@ int RadosTestFixture::create(const std::string &oid, uint8_t order,
 
 journal::JournalMetadataPtr RadosTestFixture::create_metadata(
     const std::string &oid, const std::string &client_id,
-    double commit_interval, uint64_t max_fetch_bytes,
-    int max_concurrent_object_sets) {
+    double commit_interval, int max_concurrent_object_sets) {
   journal::Settings settings;
   settings.commit_interval = commit_interval;
-  settings.max_fetch_bytes = max_fetch_bytes;
   settings.max_concurrent_object_sets = max_concurrent_object_sets;
 
   journal::JournalMetadataPtr metadata(new journal::JournalMetadata(

diff --git a/src/test/journal/RadosTestFixture.h b/src/test/journal/RadosTestFixture.h
index 1b483d459cc18ed76f4b9d52bee47e457979aa77..68a96b7d5d7f64310008bc9f807b64ddecdf8e52 100644 (file)
--- a/src/test/journal/RadosTestFixture.h
+++ b/src/test/journal/RadosTestFixture.h
@@ -26,7 +26,6 @@ public:
   journal::JournalMetadataPtr create_metadata(const std::string &oid,
                                               const std::string &client_id = "client",
                                               double commit_internal = 0.1,
-                                              uint64_t max_fetch_bytes = 0,
                                               int max_concurrent_object_sets = 0);
   int append(const std::string &oid, const bufferlist &bl);
 

diff --git a/src/test/journal/test_JournalMetadata.cc b/src/test/journal/test_JournalMetadata.cc
index bdb3107f982a11a918d83752f328bee1cfbdb3b6..ce7c1425f15f93dcb14d314faae94b01aeed1c8c 100644 (file)
--- a/src/test/journal/test_JournalMetadata.cc
+++ b/src/test/journal/test_JournalMetadata.cc
@@ -22,11 +22,9 @@ public:
   journal::JournalMetadataPtr create_metadata(const std::string &oid,
                                               const std::string &client_id,
                                               double commit_interval = 0.1,
-                                             uint64_t max_fetch_bytes = 0,
                                               int max_concurrent_object_sets = 0) {
     journal::JournalMetadataPtr metadata = RadosTestFixture::create_metadata(
-      oid, client_id, commit_interval, max_fetch_bytes,
-      max_concurrent_object_sets);
+      oid, client_id, commit_interval, max_concurrent_object_sets);
     m_metadata_list.push_back(metadata);
     metadata->add_listener(&m_listener);
     return metadata;
@@ -128,7 +126,7 @@ TEST_F(TestJournalMetadata, DisconnectLaggyClient) {
 
   int max_concurrent_object_sets = 100;
   journal::JournalMetadataPtr metadata =
-    create_metadata(oid, "client1", 0.1, 0, max_concurrent_object_sets);
+    create_metadata(oid, "client1", 0.1, max_concurrent_object_sets);
   ASSERT_EQ(0, init_metadata(metadata));
   ASSERT_TRUE(wait_for_update(metadata));
 

diff --git a/src/tools/rbd_mirror/ImageReplayer.cc b/src/tools/rbd_mirror/ImageReplayer.cc
index ccf8ef86f049d25c22902b9dccabd85d065d1d82..f3940e8dec0ad5a6b36cdc8947aa58797dcb75b6 100644 (file)
--- a/src/tools/rbd_mirror/ImageReplayer.cc
+++ b/src/tools/rbd_mirror/ImageReplayer.cc
@@ -441,8 +441,6 @@ void ImageReplayer<I>::prepare_remote_image() {
   journal::Settings journal_settings;
   journal_settings.commit_interval = cct->_conf.get_val<double>(
     "rbd_mirror_journal_commit_age");
-  journal_settings.max_fetch_bytes = cct->_conf.get_val<Option::size_t>(
-    "rbd_mirror_journal_max_fetch_bytes");
 
   Context *ctx = create_context_callback<
     ImageReplayer, &ImageReplayer<I>::handle_prepare_remote_image>(this);