diff --git a/openr/Main.cpp b/openr/Main.cpp index 569a95de962..a23c59cf048 100644 --- a/openr/Main.cpp +++ b/openr/Main.cpp @@ -473,7 +473,7 @@ main(int argc, char** argv) { "tcp://{}:{}", FLAGS_listen_addr, FLAGS_kvstore_rep_port)}, monitorSubmitUrl, maybeIpTos, - Constants::kStoreSyncInterval, + std::chrono::seconds(FLAGS_kvstore_sync_interval_s), Constants::kMonitorSubmitInterval, std::unordered_map{}, FLAGS_enable_legacy_flooding, diff --git a/openr/common/Flags.cpp b/openr/common/Flags.cpp index b7336651298..eba93609c33 100644 --- a/openr/common/Flags.cpp +++ b/openr/common/Flags.cpp @@ -293,6 +293,10 @@ DEFINE_int32( kvstore_key_ttl_ms, openr::Constants::kKvStoreDbTtl.count(), // 5 min "TTL of a key (in ms) in the Kvstore"); +DEFINE_int32( + kvstore_sync_interval_s, + openr::Constants::kStoreSyncInterval.count(), + "Kvstore periodic random node sync interval in seconds"); DEFINE_int32( kvstore_ttl_decrement_ms, openr::Constants::kTtlDecrement.count(), diff --git a/openr/common/Flags.h b/openr/common/Flags.h index 653c69103e8..91b72e8ec7b 100644 --- a/openr/common/Flags.h +++ b/openr/common/Flags.h @@ -115,6 +115,7 @@ DECLARE_int32(kvstore_zmq_hwm); DECLARE_int32(kvstore_flood_msg_per_sec); DECLARE_int32(kvstore_flood_msg_burst_size); DECLARE_int32(kvstore_key_ttl_ms); +DECLARE_int32(kvstore_sync_interval_s); DECLARE_int32(kvstore_ttl_decrement_ms); DECLARE_bool(enable_secure_thrift_server); diff --git a/openr/scripts/run_openr.sh b/openr/scripts/run_openr.sh index aaf92d829cd..51a1c5c677c 100755 --- a/openr/scripts/run_openr.sh +++ b/openr/scripts/run_openr.sh @@ -78,6 +78,7 @@ KEY_PREFIX_FILTERS="" KVSTORE_FLOOD_MSG_BURST_SIZE=0 KVSTORE_FLOOD_MSG_PER_SEC=0 KVSTORE_KEY_TTL_MS=300000 +KVSTORE_SYNC_INTERVAL_S=60 KVSTORE_TTL_DECREMENT_MS=1 KVSTORE_ZMQ_HWM=65536 LINK_FLAP_INITIAL_BACKOFF_MS=1000 @@ -200,6 +201,7 @@ ARGS="\ --kvstore_flood_msg_burst_size=${KVSTORE_FLOOD_MSG_BURST_SIZE} \ --kvstore_flood_msg_per_sec=${KVSTORE_FLOOD_MSG_PER_SEC} \ --kvstore_key_ttl_ms=${KVSTORE_KEY_TTL_MS} \ + --kvstore_sync_interval_s=${KVSTORE_SYNC_INTERVAL_S} \ --kvstore_ttl_decrement_ms=${KVSTORE_TTL_DECREMENT_MS} \ --kvstore_zmq_hwm=${KVSTORE_ZMQ_HWM} \ --link_flap_initial_backoff_ms=${LINK_FLAP_INITIAL_BACKOFF_MS} \