grpclb_end2end_test.cc File Reference

#include <deque>
#include <memory>
#include <mutex>
#include <set>
#include <sstream>
#include <string>
#include <thread>
#include <gmock/gmock.h>
#include <gtest/gtest.h>
#include "absl/memory/memory.h"
#include "absl/strings/str_cat.h"
#include "absl/strings/str_format.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/backup_poller.h"
#include "src/core/ext/filters/client_channel/lb_policy/grpclb/grpclb.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/gpr/env.h"
#include "src/core/lib/gprpp/ref_counted_ptr.h"
#include "src/core/lib/iomgr/sockaddr.h"
#include "src/core/lib/resolver/server_address.h"
#include "src/core/lib/security/credentials/fake/fake_credentials.h"
#include "src/core/lib/service_config/service_config_impl.h"
#include "src/cpp/client/secure_credentials.h"
#include "src/cpp/server/secure_server_credentials.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/resolve_localhost_ip46.h"
#include "test/core/util/test_config.h"
#include "test/cpp/end2end/counted_service.h"
#include "test/cpp/end2end/test_service_impl.h"
#include "test/cpp/util/test_config.h"

Include dependency graph for grpclb_end2end_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 2033 of file grpclb_end2end_test.cc.

Variable Documentation

backends_

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

protected

Definition at line 713 of file grpclb_end2end_test.cc.

balancer_name

std::string balancer_name

Definition at line 503 of file grpclb_end2end_test.cc.

balancers_

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

protected

Definition at line 714 of file grpclb_end2end_test.cc.

channel_

std::shared_ptr<Channel> channel_

protected

Definition at line 711 of file grpclb_end2end_test.cc.

client_load_reporting_interval_seconds_

const int client_load_reporting_interval_seconds_

private

Definition at line 333 of file grpclb_end2end_test.cc.

clients_mu_

std::set<std::string> clients_ ABSL_GUARDED_BY& clients_mu_

private

Definition at line 140 of file grpclb_end2end_test.cc.

drop_token_counts

std::map<std::string, size_t> drop_token_counts

Definition at line 161 of file grpclb_end2end_test.cc.

ipv6_only_

bool ipv6_only_ = false

protected

Definition at line 710 of file grpclb_end2end_test.cc.

kApplicationTargetName_

const std::string kApplicationTargetName_ = "application_target_name"

protected

Definition at line 718 of file grpclb_end2end_test.cc.

kRequestMessage_

const std::string kRequestMessage_ = "Live long and prosper."

protected

Definition at line 717 of file grpclb_end2end_test.cc.

load_report_cond_

grpc::internal::CondVar load_report_cond_

private

Definition at line 340 of file grpclb_end2end_test.cc.

mu_

grpc::internal::Mutex mu_

private

Definition at line 337 of file grpclb_end2end_test.cc.

num_backends_

const size_t num_backends_

protected

Definition at line 707 of file grpclb_end2end_test.cc.

num_balancers_

const size_t num_balancers_

protected

Definition at line 708 of file grpclb_end2end_test.cc.

num_calls_finished

size_t num_calls_finished = 0

Definition at line 158 of file grpclb_end2end_test.cc.

num_calls_finished_known_received

size_t num_calls_finished_known_received = 0

Definition at line 160 of file grpclb_end2end_test.cc.

num_calls_finished_with_client_failed_to_send

size_t num_calls_finished_with_client_failed_to_send = 0

Definition at line 159 of file grpclb_end2end_test.cc.

num_calls_started

size_t num_calls_started = 0

Definition at line 157 of file grpclb_end2end_test.cc.

port

int port

Definition at line 502 of file grpclb_end2end_test.cc.

port_

const int port_

Definition at line 698 of file grpclb_end2end_test.cc.

response_generator_

grpc_core::RefCountedPtr<grpc_core::FakeResolverResponseGenerator> response_generator_

protected

Definition at line 716 of file grpclb_end2end_test.cc.

responses_and_delays_

std::vector<ResponseDelayPair> responses_and_delays_

private

Definition at line 334 of file grpclb_end2end_test.cc.

running_

bool running_ = false

Definition at line 703 of file grpclb_end2end_test.cc.

server_

std::unique_ptr<Server> server_

Definition at line 701 of file grpclb_end2end_test.cc.

server_host_

const std::string server_host_

protected

Definition at line 706 of file grpclb_end2end_test.cc.

serverlist_cond_

grpc::internal::CondVar serverlist_cond_

private

Definition at line 338 of file grpclb_end2end_test.cc.

service_

T service_

Definition at line 700 of file grpclb_end2end_test.cc.

service_names_

std::vector<std::string> service_names_

private

Definition at line 335 of file grpclb_end2end_test.cc.

stub_

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

protected

Definition at line 712 of file grpclb_end2end_test.cc.

thread_

std::unique_ptr<std::thread> thread_

Definition at line 702 of file grpclb_end2end_test.cc.

type_

std::string type_

Definition at line 699 of file grpclb_end2end_test.cc.