diff --git a/src/conf.cpp b/src/conf.cpp index c8dce184..7bcd5c48 100644 --- a/src/conf.cpp +++ b/src/conf.cpp @@ -465,7 +465,7 @@ namespace conf cfg.user.max_bytes_per_msg = user["max_bytes_per_msg"].as(); cfg.user.max_bytes_per_min = user["max_bytes_per_min"].as(); cfg.user.max_bad_msgs_per_min = user["max_bad_msgs_per_min"].as(); - cfg.user.concurrent_read_reqeuests = user["concurrent_read_reqeuests"].as(); + cfg.user.concurrent_read_requests = user["concurrent_read_requests"].as(); } catch (const std::exception &e) { @@ -596,7 +596,7 @@ namespace conf user_config.insert_or_assign("max_bad_msgs_per_min", cfg.user.max_bad_msgs_per_min); user_config.insert_or_assign("max_connections", cfg.user.max_connections); user_config.insert_or_assign("max_in_connections_per_host", cfg.user.max_in_connections_per_host); - user_config.insert_or_assign("concurrent_read_reqeuests", cfg.user.concurrent_read_reqeuests); + user_config.insert_or_assign("concurrent_read_requests", cfg.user.concurrent_read_requests); d.insert_or_assign("user", user_config); } @@ -665,9 +665,9 @@ namespace conf } // User settings - if (cfg.user.concurrent_read_reqeuests > CONCURRENT_READ_REQUEST_MAX_LIMIT) + if (cfg.user.concurrent_read_requests > CONCURRENT_READ_REQUEST_MAX_LIMIT) { - std::cerr << "User concurrent_read_reqeuests cannot exceed " << CONCURRENT_READ_REQUEST_MAX_LIMIT << "\n"; + std::cerr << "User concurrent_read_requests cannot exceed " << CONCURRENT_READ_REQUEST_MAX_LIMIT << "\n"; return -1; } diff --git a/src/conf.hpp b/src/conf.hpp index 7674cfe6..ec991d7c 100644 --- a/src/conf.hpp +++ b/src/conf.hpp @@ -174,7 +174,7 @@ namespace conf uint64_t max_bad_msgs_per_min = 0; // User bad messages per minute uint16_t max_connections = 0; // Max inbound user connections uint16_t max_in_connections_per_host = 0; // Max inbound user connections per remote host (IP). - uint64_t concurrent_read_reqeuests = 4; // Supported concurrent read requests count. + uint64_t concurrent_read_requests = 4; // Supported concurrent read requests count. }; struct peer_discovery_config diff --git a/src/msg/bson/usrmsg_bson.cpp b/src/msg/bson/usrmsg_bson.cpp index f053ae55..41c23116 100644 --- a/src/msg/bson/usrmsg_bson.cpp +++ b/src/msg/bson/usrmsg_bson.cpp @@ -51,7 +51,7 @@ namespace msg::usrmsg::bson encoder.key(msg::usrmsg::FLD_CONTARCT_EXECUTION_ENABLED); encoder.bool_value(conf::cfg.contract.execute); encoder.key(msg::usrmsg::FLD_READ_REQUESTS_ENABLED); - encoder.bool_value(conf::cfg.user.concurrent_read_reqeuests != 0); + encoder.bool_value(conf::cfg.user.concurrent_read_requests != 0); encoder.key(msg::usrmsg::FLD_IS_FULL_HISTORY_NODE); encoder.bool_value(conf::cfg.node.history == conf::HISTORY::FULL); diff --git a/src/msg/json/usrmsg_json.cpp b/src/msg/json/usrmsg_json.cpp index 5f9656d7..6f3339cf 100644 --- a/src/msg/json/usrmsg_json.cpp +++ b/src/msg/json/usrmsg_json.cpp @@ -185,7 +185,7 @@ namespace msg::usrmsg::json msg += SEP_COMMA_NOQUOTE; msg += msg::usrmsg::FLD_READ_REQUESTS_ENABLED; msg += SEP_COLON_NOQUOTE; - msg += conf::cfg.user.concurrent_read_reqeuests != 0 ? STR_TRUE : STR_FALSE; + msg += conf::cfg.user.concurrent_read_requests != 0 ? STR_TRUE : STR_FALSE; msg += SEP_COMMA_NOQUOTE; msg += msg::usrmsg::FLD_IS_FULL_HISTORY_NODE; msg += SEP_COLON_NOQUOTE; diff --git a/src/usr/read_req.cpp b/src/usr/read_req.cpp index f4d6e36a..5a2db3ab 100644 --- a/src/usr/read_req.cpp +++ b/src/usr/read_req.cpp @@ -90,7 +90,7 @@ namespace read_req } } - if (read_req_queue.size_approx() != 0 && read_req_threads.size() <= conf::cfg.user.concurrent_read_reqeuests) + if (read_req_queue.size_approx() != 0 && read_req_threads.size() <= conf::cfg.user.concurrent_read_requests) { read_req_threads.push_back(std::thread(read_request_processor)); if (read_req_queue.size_approx() == 1) diff --git a/src/usr/usr.cpp b/src/usr/usr.cpp index ad2ec01b..6a96c68e 100644 --- a/src/usr/usr.cpp +++ b/src/usr/usr.cpp @@ -146,7 +146,7 @@ namespace usr if (msg_type == msg::usrmsg::MSGTYPE_CONTRACT_READ_REQUEST) { // Ignore the request if contract execution is disabled or read requests disallowed. - if (!conf::cfg.contract.execute || conf::cfg.user.concurrent_read_reqeuests == 0) + if (!conf::cfg.contract.execute || conf::cfg.user.concurrent_read_requests == 0) return 0; std::string content;