client_lb_end2end_test.cc File Reference

#include <algorithm>
#include <deque>
#include <memory>
#include <mutex>
#include <random>
#include <set>
#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 "absl/strings/str_join.h"
#include "absl/strings/string_view.h"
#include <grpc/grpc.h>
#include <grpc/support/alloc.h>
#include <grpc/support/atm.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/ext/call_metric_recorder.h>
#include <grpcpp/ext/orca_service.h>
#include <grpcpp/health_check_service_interface.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/global_subchannel_pool.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/address_utils/sockaddr_utils.h"
#include "src/core/lib/backoff/backoff.h"
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/gpr/env.h"
#include "src/core/lib/gprpp/debug_location.h"
#include "src/core/lib/gprpp/ref_counted_ptr.h"
#include "src/core/lib/gprpp/time.h"
#include "src/core/lib/iomgr/tcp_client.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.h"
#include "src/core/lib/service_config/service_config_impl.h"
#include "src/core/lib/surface/server.h"
#include "src/core/lib/transport/connectivity_state.h"
#include "src/cpp/client/secure_credentials.h"
#include "src/cpp/server/secure_server_credentials.h"
#include "src/proto/grpc/testing/echo.grpc.pb.h"
#include "src/proto/grpc/testing/xds/v3/orca_load_report.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/core/util/test_lb_policies.h"
#include "test/cpp/end2end/connection_delay_injector.h"
#include "test/cpp/end2end/test_service_impl.h"

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 2535 of file client_lb_end2end_test.cc.

Variable Documentation

addresses_seen_

std::vector<std::string> addresses_seen_

private

Definition at line 2397 of file client_lb_end2end_test.cc.

args_seen_list_

std::vector<grpc_core::PickArgsSeen> args_seen_list_

private

Definition at line 2057 of file client_lb_end2end_test.cc.

clients_

std::set<std::string> clients_

private

Definition at line 137 of file client_lb_end2end_test.cc.

clients_mu_

grpc::internal::Mutex clients_mu_

private

Definition at line 136 of file client_lb_end2end_test.cc.

cond_

grpc::internal::CondVar cond_

Definition at line 373 of file client_lb_end2end_test.cc.

creds_

std::shared_ptr<ChannelCredentials> creds_

protected

Definition at line 523 of file client_lb_end2end_test.cc.

current_test_instance_

OobBackendMetricTest* current_test_instance_

staticprivate

Definition at line 2055 of file client_lb_end2end_test.cc.

ipv6_only_

bool ipv6_only_ = false

private

Definition at line 217 of file client_lb_end2end_test.cc.

kAttributeKey

const char* kAttributeKey

staticprotected

Definition at line 2351 of file client_lb_end2end_test.cc.

last_status_

absl::Status last_status_

private

Definition at line 2164 of file client_lb_end2end_test.cc.

load_report_

absl::optional<xds::data::orca::v3::OrcaLoadReport> load_report_

private

Definition at line 139 of file client_lb_end2end_test.cc.

mu_

std::deque<BackendMetricReport> backend_metric_reports_ ABSL_GUARDED_BY& mu_

private

Definition at line 134 of file client_lb_end2end_test.cc.

orca_service_

experimental::OrcaService orca_service_

Definition at line 369 of file client_lb_end2end_test.cc.

port_

const int port_

Definition at line 366 of file client_lb_end2end_test.cc.

request_count_

int request_count_ = 0

private

Definition at line 135 of file client_lb_end2end_test.cc.

response_generator_

grpc_core::RefCountedPtr<grpc_core::FakeResolverResponseGenerator> response_generator_

private

Definition at line 219 of file client_lb_end2end_test.cc.

server_

std::unique_ptr<Server> server_

Definition at line 367 of file client_lb_end2end_test.cc.

server_host_

const std::string server_host_

protected

Definition at line 521 of file client_lb_end2end_test.cc.

servers_

std::vector<std::unique_ptr<ServerData> > servers_

protected

Definition at line 522 of file client_lb_end2end_test.cc.

service_

MyTestServiceImpl service_

Definition at line 368 of file client_lb_end2end_test.cc.

str_

std::string str_

private

Definition at line 2368 of file client_lb_end2end_test.cc.

thread_

std::unique_ptr<std::thread> thread_

Definition at line 370 of file client_lb_end2end_test.cc.

trailers_intercepted_

int trailers_intercepted_ = 0

private

Definition at line 2163 of file client_lb_end2end_test.cc.

trailing_metadata_

grpc_core::MetadataVector trailing_metadata_

private

Definition at line 2165 of file client_lb_end2end_test.cc.