Skip to content

Commit

Permalink
remove rps in client
Browse files Browse the repository at this point in the history
  • Loading branch information
wallyatgithub committed Jun 10, 2023
1 parent 4b2eca4 commit a4a0ece
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 4 deletions.
2 changes: 1 addition & 1 deletion asio_client_connection.cc
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
3 changes: 1 addition & 2 deletions base_client.cc
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down Expand Up @@ -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,
Expand Down
1 change: 0 additions & 1 deletion base_client.h
Original file line number Diff line number Diff line change
Expand Up @@ -244,7 +244,6 @@ class base_client
std::string schema;
std::string authority;
std::string preferred_authority;
double rps;
std::deque<std::string> candidate_addresses;
std::deque<std::string> used_addresses;
Unique_Id this_client_id;
Expand Down

0 comments on commit a4a0ece

Please sign in to comment.