thread_stress_test.cc File Reference

#include <cinttypes>
#include <mutex>
#include <thread>
#include <gtest/gtest.h>
#include <grpc/grpc.h>
#include <grpc/support/time.h>
#include <grpcpp/channel.h>
#include <grpcpp/client_context.h>
#include <grpcpp/create_channel.h>
#include <grpcpp/impl/codegen/sync.h>
#include <grpcpp/resource_quota.h>
#include <grpcpp/server.h>
#include <grpcpp/server_builder.h>
#include <grpcpp/server_context.h>
#include "src/core/lib/gpr/env.h"
#include "src/core/lib/surface/api_trace.h"
#include "src/proto/grpc/testing/duplicate/echo_duplicate.grpc.pb.h"
#include "src/proto/grpc/testing/echo.grpc.pb.h"
#include "test/core/util/port.h"
#include "test/core/util/test_config.h"

Include dependency graph for thread_stress_test.cc:

Go to the source code of this file.

Classes
struct	grpc::testing::AsyncClientEnd2endTest< Common >::AsyncClientCall
class	grpc::testing::AsyncClientEnd2endTest< Common >
class	grpc::testing::CommonStressTest< Service >
class	grpc::testing::CommonStressTestAsyncServer< BaseClass >
class	grpc::testing::CommonStressTestInproc< Service, allow_resource_exhaustion >
class	grpc::testing::CommonStressTestInsecure< Service >
class	grpc::testing::CommonStressTestSyncServer< BaseClass >
class	grpc::testing::CommonStressTestSyncServerLowThreadCount< BaseClass >
struct	grpc::testing::CommonStressTestAsyncServer< BaseClass >::Context
class	grpc::testing::End2endTest< Common >
class	grpc::testing::TestServiceImpl

Namespaces
	grpc
	grpc::testing

Typedefs
typedef ::testing::Types< CommonStressTestSyncServer< CommonStressTestInsecure< TestServiceImpl > >, CommonStressTestSyncServer< CommonStressTestInproc< TestServiceImpl, false > >, CommonStressTestSyncServerLowThreadCount< CommonStressTestInproc< TestServiceImpl, true > >, CommonStressTestAsyncServer< CommonStressTestInsecure< grpc::testing::EchoTestService::AsyncService > >, CommonStressTestAsyncServer< CommonStressTestInproc< grpc::testing::EchoTestService::AsyncService, false > > >	grpc::testing::CommonTypes

Functions
int	main (int argc, char **argv)
static void	grpc::testing::SendRpc (grpc::testing::EchoTestService::Stub *stub, int num_rpcs, bool allow_exhaustion, gpr_atm *errors)
	grpc::testing::TYPED_TEST (AsyncClientEnd2endTest, ThreadStress)
	grpc::testing::TYPED_TEST (End2endTest, ThreadStress)
	grpc::testing::TYPED_TEST_SUITE (AsyncClientEnd2endTest, CommonTypes)
	grpc::testing::TYPED_TEST_SUITE (End2endTest, CommonTypes)

Variables
const int	kNumAsyncReceiveThreads = 50
const int	kNumAsyncSendThreads = 2
const int	kNumAsyncServerThreads = 50
const int	kNumRpcs = 1000
const int	kNumThreads = 300

Function Documentation

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 436 of file thread_stress_test.cc.

Variable Documentation

kNumAsyncReceiveThreads

const int kNumAsyncReceiveThreads = 50

Definition at line 48 of file thread_stress_test.cc.

kNumAsyncSendThreads

const int kNumAsyncSendThreads = 2

Definition at line 47 of file thread_stress_test.cc.

kNumAsyncServerThreads

const int kNumAsyncServerThreads = 50

Definition at line 49 of file thread_stress_test.cc.

kNumRpcs

const int kNumRpcs = 1000

Definition at line 50 of file thread_stress_test.cc.

kNumThreads

const int kNumThreads = 300

Definition at line 46 of file thread_stress_test.cc.