Commit 606b75da authored by Dominik Charousset's avatar Dominik Charousset

Set conservative heartbeat defaults

The new default values (10s for heartbeats, 30s for disconnects) enable
CAF to detect frozen nodes eventually by default.
parent f2b1460c
...@@ -110,8 +110,8 @@ namespace middleman { ...@@ -110,8 +110,8 @@ namespace middleman {
std::vector<std::string> app_identifiers{"generic-caf-app"}; std::vector<std::string> app_identifiers{"generic-caf-app"};
const atom_value network_backend = atom("default"); const atom_value network_backend = atom("default");
const size_t max_consecutive_reads = 50; const size_t max_consecutive_reads = 50;
const timespan heartbeat_interval = timespan{0}; const timespan heartbeat_interval = ms(10000);
const timespan connection_timeout = timespan{0}; const timespan connection_timeout = ms(30000);
const size_t cached_udp_buffers = 10; const size_t cached_udp_buffers = 10;
const size_t max_pending_msgs = 10; const size_t max_pending_msgs = 10;
const size_t workers = min(3u, std::thread::hardware_concurrency() / 4u) + 1; const size_t workers = min(3u, std::thread::hardware_concurrency() / 4u) + 1;
......
...@@ -693,6 +693,7 @@ public: ...@@ -693,6 +693,7 @@ public:
cfg.set("logger.inline-output", true); cfg.set("logger.inline-output", true);
cfg.set("middleman.network-backend", caf::atom("testing")); cfg.set("middleman.network-backend", caf::atom("testing"));
cfg.set("middleman.manual-multiplexing", true); cfg.set("middleman.manual-multiplexing", true);
cfg.set("middleman.heartbeat-interval", caf::timespan{0});
cfg.set("middleman.workers", size_t{0}); cfg.set("middleman.workers", size_t{0});
return cfg; return cfg;
} }
......
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