|
|
|
@ -18,7 +18,6 @@ |
|
|
|
|
|
|
|
|
|
#include "test/cpp/qps/driver.h" |
|
|
|
|
|
|
|
|
|
#include <chrono> |
|
|
|
|
#include <cinttypes> |
|
|
|
|
#include <deque> |
|
|
|
|
#include <list> |
|
|
|
@ -26,8 +25,6 @@ |
|
|
|
|
#include <unordered_map> |
|
|
|
|
#include <vector> |
|
|
|
|
|
|
|
|
|
#include <google/protobuf/util/time_util.h> |
|
|
|
|
|
|
|
|
|
#include <grpc/support/alloc.h> |
|
|
|
|
#include <grpc/support/log.h> |
|
|
|
|
#include <grpc/support/string_util.h> |
|
|
|
@ -576,10 +573,6 @@ std::unique_ptr<ScenarioResult> RunScenario( |
|
|
|
|
|
|
|
|
|
// Start a run
|
|
|
|
|
gpr_log(GPR_INFO, "Starting"); |
|
|
|
|
|
|
|
|
|
google::protobuf::Timestamp start_timestamp = |
|
|
|
|
google::protobuf::util::TimeUtil::GetCurrentTime(); |
|
|
|
|
|
|
|
|
|
for (size_t i = 0; i < num_servers; i++) { |
|
|
|
|
auto server = &servers[i]; |
|
|
|
|
if (!server->stream->Write(server_mark)) { |
|
|
|
@ -631,9 +624,6 @@ std::unique_ptr<ScenarioResult> RunScenario( |
|
|
|
|
bool client_finish_first = |
|
|
|
|
(client_config.rpc_type() != STREAMING_FROM_SERVER); |
|
|
|
|
|
|
|
|
|
google::protobuf::Timestamp end_timestamp = |
|
|
|
|
google::protobuf::util::TimeUtil::GetCurrentTime(); |
|
|
|
|
|
|
|
|
|
FinishClients(clients, client_mark); |
|
|
|
|
|
|
|
|
|
if (!client_finish_first) { |
|
|
|
@ -660,10 +650,6 @@ std::unique_ptr<ScenarioResult> RunScenario( |
|
|
|
|
rrc->set_status_code(it->first); |
|
|
|
|
rrc->set_count(it->second); |
|
|
|
|
} |
|
|
|
|
// Fill in start and end time for the test scenario
|
|
|
|
|
result->mutable_summary()->mutable_start_time()->CopyFrom(start_timestamp); |
|
|
|
|
result->mutable_summary()->mutable_end_time()->CopyFrom(end_timestamp); |
|
|
|
|
|
|
|
|
|
postprocess_scenario_result(result.get()); |
|
|
|
|
return result; |
|
|
|
|
} |
|
|
|
|