Commit f7fa857f authored by Marian Triebe's avatar Marian Triebe

Add missing config parameters for crdt module

parent fc608d33
...@@ -279,7 +279,10 @@ public: ...@@ -279,7 +279,10 @@ public:
// -- config parameters of the replication module ---------------------------- // -- config parameters of the replication module ----------------------------
std::string replication_hosts; size_t crdt_flush_buffer_interval_ms;
size_t crdt_notify_interval_ms;
size_t crdt_state_interval_ms;
size_t crdt_ids_interval_ms;
// -- factories -------------------------------------------------------------- // -- factories --------------------------------------------------------------
......
...@@ -120,6 +120,10 @@ actor_system_config::actor_system_config() ...@@ -120,6 +120,10 @@ actor_system_config::actor_system_config()
middleman_enable_automatic_connections = false; middleman_enable_automatic_connections = false;
middleman_max_consecutive_reads = 50; middleman_max_consecutive_reads = 50;
middleman_heartbeat_interval = 0; middleman_heartbeat_interval = 0;
crdt_flush_buffer_interval_ms = 2000;
crdt_notify_interval_ms = 500;
crdt_state_interval_ms = 120000;
crdt_ids_interval_ms = 1000;
// fill our options vector for creating INI and CLI parsers // fill our options vector for creating INI and CLI parsers
opt_group{options_, "scheduler"} opt_group{options_, "scheduler"}
.add(scheduler_policy, "policy", .add(scheduler_policy, "policy",
...@@ -172,9 +176,15 @@ actor_system_config::actor_system_config() ...@@ -172,9 +176,15 @@ actor_system_config::actor_system_config()
opt_group(options_, "opencl") opt_group(options_, "opencl")
.add(opencl_device_ids, "device-ids", .add(opencl_device_ids, "device-ids",
"restricts which OpenCL devices are accessed by CAF"); "restricts which OpenCL devices are accessed by CAF");
opt_group(options_, "replication") opt_group(options_, "crdt")
.add(replication_hosts, "nodes", .add(crdt_flush_buffer_interval_ms, "flush",
"connects to other CAF nodes at init"); "sets the flush interval in milliseconds")
.add(crdt_notify_interval_ms, "notify",
"sets the notify interval in milliseconds")
.add(crdt_state_interval_ms, "state",
"state reconciliation in milliseconds")
.add(crdt_ids_interval_ms, "ids",
"id synchronization in milliseconds");
// add renderers for default error categories // add renderers for default error categories
error_renderers.emplace(atom("system"), render_sec); error_renderers.emplace(atom("system"), render_sec);
error_renderers.emplace(atom("exit"), render_exit_reason); error_renderers.emplace(atom("exit"), render_exit_reason);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment