|
|
@ -44,6 +44,7 @@ |
|
|
|
#include <thread> |
|
|
|
#include <thread> |
|
|
|
#include <deque> |
|
|
|
#include <deque> |
|
|
|
#include <vector> |
|
|
|
#include <vector> |
|
|
|
|
|
|
|
#include <unistd.h> |
|
|
|
#include "test/cpp/qps/histogram.h" |
|
|
|
#include "test/cpp/qps/histogram.h" |
|
|
|
#include "test/cpp/qps/qps_worker.h" |
|
|
|
#include "test/cpp/qps/qps_worker.h" |
|
|
|
#include "test/core/util/port.h" |
|
|
|
#include "test/core/util/port.h" |
|
|
@ -89,6 +90,8 @@ ScenarioResult RunScenario(const ClientConfig& initial_client_config, |
|
|
|
return &contexts.back(); |
|
|
|
return &contexts.back(); |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
srand(time(NULL) ^ getpid()); |
|
|
|
|
|
|
|
|
|
|
|
// Get client, server lists
|
|
|
|
// Get client, server lists
|
|
|
|
auto workers = get_hosts("QPS_WORKERS"); |
|
|
|
auto workers = get_hosts("QPS_WORKERS"); |
|
|
|
ClientConfig client_config = initial_client_config; |
|
|
|
ClientConfig client_config = initial_client_config; |
|
|
|