diff --git a/asio_client_connection.cc b/asio_client_connection.cc index dad7aa6..1cbb657 100644 --- a/asio_client_connection.cc +++ b/asio_client_connection.cc @@ -422,7 +422,7 @@ void asio_client_connection::start_ping_watcher() void asio_client_connection::restart_rps_timer() { - rps_timer.expires_from_now(boost::posix_time::millisec(std::max(10, 1000 / (int)rps))); + rps_timer.expires_from_now(boost::posix_time::millisec(std::max(10, 1000 / (int)config->rps))); rps_timer.async_wait ( [this](const boost::system::error_code & ec) diff --git a/base_client.cc b/base_client.cc index 6f1c338..187cad6 100644 --- a/base_client.cc +++ b/base_client.cc @@ -53,7 +53,6 @@ base_client::base_client(uint32_t id, base_worker* wrker, size_t req_todo, Confi parent_client(parent), schema(dest_schema), authority(dest_authority), - rps(conf->rps), this_client_id(), rps_duration_started(), ssl(nullptr) @@ -1231,7 +1230,7 @@ void base_client::slice_var_ids() bool base_client::rps_mode() { - return (rps > 0.0); + return (config->rps > 0.0); } void base_client::update_scenario_based_stats(size_t scenario_index, size_t request_index, bool success, diff --git a/base_client.h b/base_client.h index 5c885f7..b153669 100644 --- a/base_client.h +++ b/base_client.h @@ -244,7 +244,6 @@ class base_client std::string schema; std::string authority; std::string preferred_authority; - double rps; std::deque candidate_addresses; std::deque used_addresses; Unique_Id this_client_id;