diff options
Diffstat (limited to 'test/cpp/interop/stress_test.cc')
| -rw-r--r-- | test/cpp/interop/stress_test.cc | 222 |
1 files changed, 222 insertions, 0 deletions
diff --git a/test/cpp/interop/stress_test.cc b/test/cpp/interop/stress_test.cc new file mode 100644 index 0000000000..596a8abadf --- /dev/null +++ b/test/cpp/interop/stress_test.cc @@ -0,0 +1,222 @@ +/* + * + * Copyright 2015, Google Inc. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions are + * met: + * + * * Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * * Redistributions in binary form must reproduce the above + * copyright notice, this list of conditions and the following disclaimer + * in the documentation and/or other materials provided with the + * distribution. + * * Neither the name of Google Inc. nor the names of its + * contributors may be used to endorse or promote products derived from + * this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS + * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT + * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR + * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT + * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT + * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + *is % allowed in string + */ + +#include <memory> +#include <string> +#include <thread> +#include <utility> +#include <vector> + +#include <gflags/gflags.h> +#include <grpc/support/time.h> +#include <grpc++/create_channel.h> +#include <grpc++/grpc++.h> + +#include "test/cpp/interop/interop_client.h" +#include "test/cpp/interop/stress_interop_client.h" +#include "test/cpp/util/test_config.h" + +DEFINE_int32(sleep_duration_ms, 0, + "The duration (in millisec) between two" + " consecutive test calls (per server) issued by the server."); + +DEFINE_int32(test_duration_secs, -1, + "The length of time (in seconds) to run" + " the test. Enter -1 if the test should run continuously until" + " forcefully terminated."); + +DEFINE_string(server_addresses, "localhost:8080", + "The list of server" + " addresses in the format:\n" + " \"<name_1>:<port_1>,<name_2>:<port_1>...<name_N>:<port_N>\"\n" + " Note: <name> can be servername or IP address."); + +// TODO(sreek): Add more test cases here in future +DEFINE_string(test_cases, "", + "List of test cases to call along with the" + " relative weights in the following format:\n" + " \"<testcase_1:w_1>,<testcase_2:w_2>...<testcase_n:w_n>\"\n" + " The following testcases are currently supported:\n" + " empty_unary\n" + " large_unary\n" + " large_compressed_unary\n" + " client_streaming\n" + " server_streaming\n" + " empty_stream\n" + " Example: \"empty_unary:20,large_unary:10,empty_stream:70\"\n" + " The above will execute 'empty_unary', 20% of the time," + " 'large_unary', 10% of the time and 'empty_stream' the remaining" + " 70% of the time"); + +using std::make_pair; +using std::pair; +using std::string; +using std::thread; +using std::vector; + +using grpc::testing::kTestCaseList; +using grpc::testing::StressTestInteropClient; +using grpc::testing::TestCaseType; +using grpc::testing::WeightedRandomTestSelector; +using grpc::testing::UNKNOWN_TEST; + +TestCaseType GetTestTypeFromName(const string& test_name) { + TestCaseType test_case = UNKNOWN_TEST; + + for (auto it = kTestCaseList.begin(); it != kTestCaseList.end(); it++) { + if (test_name == it->second) { + test_case = it->first; + break; + } + } + + return test_case; +} + +// Converts a string of comma delimited tokens to a vector of tokens +bool ParseCommaDelimitedString(const string& comma_delimited_str, + vector<string>& tokens) { + size_t bpos = 0; + size_t epos = string::npos; + + while ((epos = comma_delimited_str.find(',', bpos)) != string::npos) { + tokens.emplace_back(comma_delimited_str.substr(bpos, epos - bpos)); + bpos = epos + 1; + } + + tokens.emplace_back(comma_delimited_str.substr(bpos)); // Last token + return true; +} + +// Input: Test case string "<testcase_name:weight>,<testcase_name:weight>...." +// Output: +// - Whether parsing was successful (return value) +// - Vector of (test_type_enum, weight) pairs returned via 'tests' parameter +bool ParseTestCasesString(const string& test_cases, + vector<pair<TestCaseType, int>>& tests) { + bool is_success = true; + + vector<string> tokens; + ParseCommaDelimitedString(test_cases, tokens); + + for (auto it = tokens.begin(); it != tokens.end(); it++) { + // Token is in the form <test_name>:<test_weight> + size_t colon_pos = it->find(':'); + if (colon_pos == string::npos) { + gpr_log(GPR_ERROR, "Error in parsing test case string: %s", it->c_str()); + is_success = false; + break; + } + + string test_name = it->substr(0, colon_pos); + int weight = std::stoi(it->substr(colon_pos + 1)); + TestCaseType test_case = GetTestTypeFromName(test_name); + + if (test_case == UNKNOWN_TEST) { + gpr_log(GPR_ERROR, "Unknown test case: %s", test_name.c_str()); + is_success = false; + break; + } + + tests.emplace_back(std::make_pair(test_case, weight)); + } + + return is_success; +} + +// For debugging purposes +void LogParameterInfo(const vector<string>& addresses, + const vector<pair<TestCaseType, int>>& tests) { + gpr_log(GPR_INFO, "server_addresses: %s", FLAGS_server_addresses.c_str()); + gpr_log(GPR_INFO, "test_cases : %s", FLAGS_test_cases.c_str()); + gpr_log(GPR_INFO, "sleep_duration_ms: %d", FLAGS_sleep_duration_ms); + gpr_log(GPR_INFO, "test_duration_secs: %d", FLAGS_test_duration_secs); + + int num = 0; + for (auto it = addresses.begin(); it != addresses.end(); it++) { + gpr_log(GPR_INFO, "%d:%s", ++num, it->c_str()); + } + + num = 0; + for (auto it = tests.begin(); it != tests.end(); it++) { + TestCaseType test_case = it->first; + int weight = it->second; + gpr_log(GPR_INFO, "%d. TestCaseType: %d, Weight: %d", ++num, test_case, + weight); + } +} + +int main(int argc, char** argv) { + grpc::testing::InitTest(&argc, &argv, true); + + srand(time(NULL)); + + // Parse the server addresses + vector<string> server_addresses; + ParseCommaDelimitedString(FLAGS_server_addresses, server_addresses); + + // Parse test cases and weights + if (FLAGS_test_cases.length() == 0) { + gpr_log(GPR_INFO, "Cannot start the tests. Test cases string is empty"); + return 1; + } + + vector<pair<TestCaseType, int>> tests; + if (!ParseTestCasesString(FLAGS_test_cases, tests)) { + gpr_log(GPR_ERROR, "Error in parsing test cases string %s ", + FLAGS_test_cases.c_str()); + return 1; + } + + LogParameterInfo(server_addresses, tests); + + WeightedRandomTestSelector test_selector(tests); + + gpr_log(GPR_INFO, "Starting test(s).."); + vector<thread> test_threads; + int thread_idx = 0; + for (auto it = server_addresses.begin(); it != server_addresses.end(); it++) { + StressTestInteropClient* client = new StressTestInteropClient( + ++thread_idx, *it, test_selector, FLAGS_test_duration_secs, + FLAGS_sleep_duration_ms); + + test_threads.emplace_back( + thread(&StressTestInteropClient::MainLoop, client)); + } + + for (auto it = test_threads.begin(); it != test_threads.end(); it++) { + it->join(); + } + + return 0; +} |