Skip to content
Snippets Groups Projects
Commit 3cabe69f authored by Sree Kuchibhotla's avatar Sree Kuchibhotla
Browse files

Merge pull request #4138 from dgquintas/std_thread

Fix naming issue in stress_test
parents 6b116ac8 5dc96fb5
No related branches found
No related tags found
No related merge requests found
...@@ -41,6 +41,7 @@ ...@@ -41,6 +41,7 @@
#include <grpc/support/time.h> #include <grpc/support/time.h>
#include <grpc++/create_channel.h> #include <grpc++/create_channel.h>
#include <grpc++/grpc++.h> #include <grpc++/grpc++.h>
#include <grpc++/impl/thd.h>
#include "test/cpp/interop/interop_client.h" #include "test/cpp/interop/interop_client.h"
#include "test/cpp/interop/stress_interop_client.h" #include "test/cpp/interop/stress_interop_client.h"
...@@ -80,7 +81,6 @@ DEFINE_string(test_cases, "", ...@@ -80,7 +81,6 @@ DEFINE_string(test_cases, "",
using std::make_pair; using std::make_pair;
using std::pair; using std::pair;
using std::thread;
using std::vector; using std::vector;
using grpc::testing::kTestCaseList; using grpc::testing::kTestCaseList;
...@@ -202,7 +202,7 @@ int main(int argc, char** argv) { ...@@ -202,7 +202,7 @@ int main(int argc, char** argv) {
gpr_log(GPR_INFO, "Starting test(s).."); gpr_log(GPR_INFO, "Starting test(s)..");
vector<thread> test_threads; vector<grpc::thread> test_threads;
int thread_idx = 0; int thread_idx = 0;
for (auto it = server_addresses.begin(); it != server_addresses.end(); it++) { for (auto it = server_addresses.begin(); it != server_addresses.end(); it++) {
StressTestInteropClient* client = new StressTestInteropClient( StressTestInteropClient* client = new StressTestInteropClient(
...@@ -210,7 +210,7 @@ int main(int argc, char** argv) { ...@@ -210,7 +210,7 @@ int main(int argc, char** argv) {
FLAGS_sleep_duration_ms); FLAGS_sleep_duration_ms);
test_threads.emplace_back( test_threads.emplace_back(
thread(&StressTestInteropClient::MainLoop, client)); grpc::thread(&StressTestInteropClient::MainLoop, client));
} }
for (auto it = test_threads.begin(); it != test_threads.end(); it++) { for (auto it = test_threads.begin(); it != test_threads.end(); it++) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment