client_channel_stress_test.cc File Reference

#include <atomic>
#include <memory>
#include <mutex>
#include <random>
#include <sstream>
#include <string>
#include <thread>
#include "absl/memory/memory.h"
#include "absl/strings/str_cat.h"
#include <grpc/grpc.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.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/server.h>
#include <grpcpp/server_builder.h>
#include "src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb_balancer_addresses.h"
#include "src/core/ext/filters/client_channel/resolver/fake/fake_resolver.h"
#include "src/core/lib/address_utils/parse_address.h"
#include "src/core/lib/gprpp/ref_counted_ptr.h"
#include "src/core/lib/gprpp/thd.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/sockaddr.h"
#include "src/core/lib/resolver/server_address.h"
#include "src/core/lib/service_config/service_config_impl.h"
#include "src/proto/grpc/lb/v1/load_balancer.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 "test/cpp/end2end/test_service_impl.h"

Include dependency graph for client_channel_stress_test.cc:

Go to the source code of this file.

Namespaces
	grpc
	grpc::testing

Functions
int	main (int argc, char **argv)

Function Documentation

main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 346 of file client_channel_stress_test.cc.

Variable Documentation

all_backend_ports_

const std::vector<int> all_backend_ports_

private

Definition at line 134 of file client_channel_stress_test.cc.

backend_servers_

std::vector<ServerThread<BackendServiceImpl> > backend_servers_

private

Definition at line 335 of file client_channel_stress_test.cc.

backends_

std::vector<std::unique_ptr<BackendServiceImpl> > backends_

private

Definition at line 333 of file client_channel_stress_test.cc.

balancer_name

std::string balancer_name

Definition at line 220 of file client_channel_stress_test.cc.

balancer_servers_

std::vector<ServerThread<BalancerServiceImpl> > balancer_servers_

private

Definition at line 336 of file client_channel_stress_test.cc.

balancers_

std::vector<std::unique_ptr<BalancerServiceImpl> > balancers_

private

Definition at line 334 of file client_channel_stress_test.cc.

channel_

std::shared_ptr<Channel> channel_

private

Definition at line 330 of file client_channel_stress_test.cc.

client_threads_

std::vector<std::thread> client_threads_

private

Definition at line 339 of file client_channel_stress_test.cc.

port

int port

Definition at line 219 of file client_channel_stress_test.cc.

port_

int port_

Definition at line 211 of file client_channel_stress_test.cc.

response_generator_

grpc_core::RefCountedPtr<grpc_core::FakeResolverResponseGenerator> response_generator_

private

Definition at line 338 of file client_channel_stress_test.cc.

server_

std::unique_ptr<Server> server_

Definition at line 213 of file client_channel_stress_test.cc.

server_host_

const std::string server_host_ = "localhost"

private

Definition at line 329 of file client_channel_stress_test.cc.

service_

T* service_

Definition at line 214 of file client_channel_stress_test.cc.

shutdown_

std::atomic_bool shutdown_ {false}

private

Definition at line 133 of file client_channel_stress_test.cc.

stub_

std::unique_ptr<grpc::testing::EchoTestService::Stub> stub_

private

Definition at line 331 of file client_channel_stress_test.cc.

stub_mutex_

std::mutex stub_mutex_

private

Definition at line 332 of file client_channel_stress_test.cc.

thread_

std::unique_ptr<std::thread> thread_

Definition at line 215 of file client_channel_stress_test.cc.

type_

std::string type_

Definition at line 212 of file client_channel_stress_test.cc.