feat(duplication): make the task code for incremental loading from private logs configurable

src/replica/duplication/replica_duplicator.cpp

@@ -35,17 +35,25 @@
 #include "load_from_private_log.h"
 #include "replica/mutation_log.h"
 #include "replica/replica.h"
+#include "task/task_code.h"
 #include "utils/autoref_ptr.h"
 #include "utils/error_code.h"
+#include "utils/flags.h"
 #include "utils/fmt_logging.h"
 
 METRIC_DEFINE_counter(replica,
                       dup_confirmed_mutations,
                       dsn::metric_unit::kMutations,
                       "The number of confirmed mutations for dup");
 
-namespace dsn {
-namespace replication {
+DSN_DEFINE_bool(replication,
+                load_from_private_log_level_common,
+                false,
+                "The level of load_from_private_log when doing a duplication.Be false means the "
+                "task level of replaing plog is low, otherwise the task level is common");
+DSN_TAG_VARIABLE(load_from_private_log_level_common, FT_MUTABLE);
+
+namespace dsn::replication {
 
 replica_duplicator::replica_duplicator(const duplication_entry &ent, replica *r)
     : replica_base(r),
@@ -161,7 +169,10 @@ void replica_duplicator::start_dup_log()
     _load = std::make_unique<load_mutation>(this, _replica, _load_private.get());
 
     from(*_load).link(*_ship).link(*_load);
-    fork(*_load_private, LPC_REPLICATION_LONG_LOW, 0).link(*_ship);
+    const dsn::task_code load_from_private_log_level = FLAGS_load_from_private_log_level_common
+                                                           ? LPC_REPLICATION_LONG_COMMON
+                                                           : LPC_REPLICATION_LONG_LOW;
+    fork(*_load_private, load_from_private_log_level, 0).link(*_ship);
 
     run_pipeline();
 }
@@ -317,5 +328,4 @@ void replica_duplicator::set_duplication_plog_checking(bool checking)
     _replica->set_duplication_plog_checking(checking);
 }
 
-} // namespace replication
-} // namespace dsn
+} // namespace dsn::replication