Commit b3dc91e7 authored by Sebastian Wölke's avatar Sebastian Wölke Committed by Dominik Charousset

Fix typo commplexity to complexity

parent 4c136929
...@@ -260,7 +260,7 @@ public: ...@@ -260,7 +260,7 @@ public:
// -- streaming parameters --------------------------------------------------- // -- streaming parameters ---------------------------------------------------
/// Maximum delay for sending underfull batches. /// Maximum delay for sending underfull batches.
size_t streaming_desired_batch_commplexity_us; size_t streaming_desired_batch_complexity_us;
/// Maximum delay for sending underfull batches. /// Maximum delay for sending underfull batches.
size_t streaming_max_batch_delay_us; size_t streaming_max_batch_delay_us;
......
...@@ -92,7 +92,7 @@ public: ...@@ -92,7 +92,7 @@ public:
struct calculation_result { struct calculation_result {
/// Number of items per credit cycle. /// Number of items per credit cycle.
long max_throughput; long max_throughput;
/// Number of items per batch to reach the desired batch commplexity. /// Number of items per batch to reach the desired batch complexity.
long items_per_batch; long items_per_batch;
}; };
......
...@@ -112,7 +112,7 @@ actor_system_config::actor_system_config() ...@@ -112,7 +112,7 @@ actor_system_config::actor_system_config()
add_message_type_impl<std::vector<atom_value>>("std::vector<@atom>"); add_message_type_impl<std::vector<atom_value>>("std::vector<@atom>");
add_message_type_impl<std::vector<message>>("std::vector<@message>"); add_message_type_impl<std::vector<message>>("std::vector<@message>");
// (1) hard-coded defaults // (1) hard-coded defaults
streaming_desired_batch_commplexity_us = 50; streaming_desired_batch_complexity_us = 50;
streaming_max_batch_delay_us = 50000; streaming_max_batch_delay_us = 50000;
streaming_credit_round_interval_us = 100000; streaming_credit_round_interval_us = 100000;
streaming_tick_duration_us = 50000; streaming_tick_duration_us = 50000;
...@@ -146,7 +146,7 @@ actor_system_config::actor_system_config() ...@@ -146,7 +146,7 @@ actor_system_config::actor_system_config()
middleman_max_pending_msgs = 10; middleman_max_pending_msgs = 10;
// fill our options vector for creating INI and CLI parsers // fill our options vector for creating INI and CLI parsers
opt_group{options_, "streaming"} opt_group{options_, "streaming"}
.add(streaming_desired_batch_commplexity_us, "desired-batch-commplexity-us", .add(streaming_desired_batch_complexity_us, "desired-batch-complexity-us",
"sets the desired timespan for a single batch") "sets the desired timespan for a single batch")
.add(streaming_max_batch_delay_us, "max-batch-delay-us", .add(streaming_max_batch_delay_us, "max-batch-delay-us",
"sets the maximum delay for sending underfull batches in microseconds") "sets the maximum delay for sending underfull batches in microseconds")
......
...@@ -1071,7 +1071,7 @@ scheduled_actor::advance_streams(actor_clock::time_point now) { ...@@ -1071,7 +1071,7 @@ scheduled_actor::advance_streams(actor_clock::time_point now) {
if ((bitmask & 0x02) != 0) { if ((bitmask & 0x02) != 0) {
auto cycle = stream_ticks_.interval(); auto cycle = stream_ticks_.interval();
cycle *= credit_round_ticks_; cycle *= credit_round_ticks_;
auto bc_us = home_system().config().streaming_desired_batch_commplexity_us; auto bc_us = home_system().config().streaming_desired_batch_complexity_us;
auto bc = std::chrono::microseconds(bc_us); auto bc = std::chrono::microseconds(bc_us);
auto& qs = get<2>(mailbox_.queue().queues()).queues(); auto& qs = get<2>(mailbox_.queue().queues()).queues();
for (auto& kvp : qs) { for (auto& kvp : qs) {
......
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