Commit 970b1090 authored by Joseph Noir's avatar Joseph Noir

Clean up pending message config option names

parent d7656ae3
...@@ -320,7 +320,7 @@ public: ...@@ -320,7 +320,7 @@ public:
bool middleman_detach_utility_actors CAF_DEPRECATED; bool middleman_detach_utility_actors CAF_DEPRECATED;
bool middleman_detach_multiplexer CAF_DEPRECATED; bool middleman_detach_multiplexer CAF_DEPRECATED;
size_t middleman_cached_udp_buffers CAF_DEPRECATED; size_t middleman_cached_udp_buffers CAF_DEPRECATED;
size_t middleman_max_pending_msgs CAF_DEPRECATED; size_t middleman_max_pending_messages CAF_DEPRECATED;
// -- OpenCL parameters ------------------------------------------------------ // -- OpenCL parameters ------------------------------------------------------
......
...@@ -78,7 +78,7 @@ extern const atom_value network_backend; ...@@ -78,7 +78,7 @@ extern const atom_value network_backend;
extern const size_t max_consecutive_reads; extern const size_t max_consecutive_reads;
extern const size_t heartbeat_interval; extern const size_t heartbeat_interval;
extern const size_t cached_udp_buffers; extern const size_t cached_udp_buffers;
extern const size_t max_pending_msgs; extern const size_t max_pending_messages;
} // namespace middleman } // namespace middleman
......
...@@ -99,7 +99,7 @@ actor_system_config::actor_system_config() ...@@ -99,7 +99,7 @@ actor_system_config::actor_system_config()
middleman_detach_utility_actors = true; middleman_detach_utility_actors = true;
middleman_detach_multiplexer = true; middleman_detach_multiplexer = true;
middleman_cached_udp_buffers = mm::cached_udp_buffers; middleman_cached_udp_buffers = mm::cached_udp_buffers;
middleman_max_pending_msgs = mm::max_pending_msgs; middleman_max_pending_messages = mm::max_pending_messages;
// fill our options vector for creating INI and CLI parsers // fill our options vector for creating INI and CLI parsers
opt_group{custom_options_, "global"} opt_group{custom_options_, "global"}
.add<bool>("help,h?", "print help and exit") .add<bool>("help,h?", "print help and exit")
...@@ -183,7 +183,7 @@ actor_system_config::actor_system_config() ...@@ -183,7 +183,7 @@ actor_system_config::actor_system_config()
"disables background activity of the multiplexer") "disables background activity of the multiplexer")
.add(middleman_cached_udp_buffers, "cached-udp-buffers", .add(middleman_cached_udp_buffers, "cached-udp-buffers",
"sets the maximum for cached UDP send buffers (default: 10)") "sets the maximum for cached UDP send buffers (default: 10)")
.add(middleman_max_pending_msgs, "max-pending-messages", .add(middleman_max_pending_messages, "max-pending-messages",
"sets the maximum for reordering of UDP receive buffers (default: 10)") "sets the maximum for reordering of UDP receive buffers (default: 10)")
.add<bool>("disable-tcp", "disables communication via TCP") .add<bool>("disable-tcp", "disables communication via TCP")
.add<bool>("enable-udp", "enable communication via UDP"); .add<bool>("enable-udp", "enable communication via UDP");
......
...@@ -91,7 +91,7 @@ const atom_value network_backend = atom("default"); ...@@ -91,7 +91,7 @@ const atom_value network_backend = atom("default");
const size_t max_consecutive_reads = 50; const size_t max_consecutive_reads = 50;
const size_t heartbeat_interval = 0; const size_t heartbeat_interval = 0;
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_messages = 10;
} // namespace middleman } // namespace middleman
......
...@@ -67,8 +67,8 @@ basp_broker_state::basp_broker_state(broker* selfptr) ...@@ -67,8 +67,8 @@ basp_broker_state::basp_broker_state(broker* selfptr)
instance(selfptr, *this), instance(selfptr, *this),
max_buffers(get_or(self->config(), "middleman.cached-udp-buffers", max_buffers(get_or(self->config(), "middleman.cached-udp-buffers",
defaults::middleman::cached_udp_buffers)), defaults::middleman::cached_udp_buffers)),
max_pending_messages(get_or(self->config(), "middleman.max-pending-msgs", max_pending_messages(get_or(self->config(), "middleman.max-pending-messages",
defaults::middleman::max_pending_msgs)) { defaults::middleman::max_pending_messages)) {
CAF_ASSERT(this_node() != none); CAF_ASSERT(this_node() != none);
} }
......
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