driver.cc File Reference

#include "test/cpp/qps/driver.h"
#include <cinttypes>
#include <deque>
#include <list>
#include <thread>
#include <unordered_map>
#include <vector>
#include "google/protobuf/timestamp.pb.h"
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/string_util.h>
#include <grpcpp/channel.h>
#include <grpcpp/client_context.h>
#include <grpcpp/create_channel.h>
#include "src/core/lib/gpr/env.h"
#include "src/core/lib/gprpp/host_port.h"
#include "src/core/lib/profiling/timers.h"
#include "src/proto/grpc/testing/worker_service.grpc.pb.h"
#include "test/core/util/port.h"
#include "test/core/util/test_config.h"
#include "test/cpp/qps/client.h"
#include "test/cpp/qps/histogram.h"
#include "test/cpp/qps/qps_worker.h"
#include "test/cpp/qps/stats.h"
#include "test/cpp/util/test_credentials_provider.h"

Include dependency graph for driver.cc:

Go to the source code of this file.

Classes
struct	grpc::testing::ClientData
struct	grpc::testing::ServerData

Namespaces
	grpc
	grpc::testing

Functions
static double	grpc::testing::CliPollCount (const ClientStats &s)
static int	grpc::testing::Cores (int n)
static void	grpc::testing::FinishClients (const std::vector< ClientData > &clients, const ClientArgs &client_mark)
static void	grpc::testing::FinishServers (const std::vector< ServerData > &servers, const ServerArgs &server_mark)
static std::string	grpc::testing::get_host (const std::string &worker)
static deque< string >	grpc::testing::get_workers (const string &env_name)
std::string	grpc::testing::GetCredType (const std::string &worker_addr, const std::map< std::string, std::string > &per_worker_credential_types, const std::string &credential_type)
static bool	grpc::testing::IsSuccess (const Status &s)
static void	grpc::testing::postprocess_scenario_result (ScenarioResult *result)
static void	grpc::testing::ReceiveFinalStatusFromClients (const std::vector< ClientData > &clients, Histogram &merged_latencies, std::unordered_map< int, int64_t > &merged_statuses, ScenarioResult &result)
static void	grpc::testing::ReceiveFinalStatusFromServer (const std::vector< ServerData > &servers, ScenarioResult &result)
bool	grpc::testing::RunQuit (const std::string &credential_type, const std::map< std::string, std::string > &per_worker_credential_types)
std::unique_ptr< ScenarioResult >	grpc::testing::RunScenario (const ClientConfig &initial_client_config, size_t num_clients, const ServerConfig &initial_server_config, size_t num_servers, int warmup_seconds, int benchmark_seconds, int spawn_local_worker_count, const std::string &qps_server_target_override, const std::string &credential_type, const std::map< std::string, std::string > &per_worker_credential_types, bool run_inproc, int32_t median_latency_collection_interval_millis)
static double	grpc::testing::ServerIdleCpuTime (const ServerStats &s)
static double	grpc::testing::ServerSystemTime (const ServerStats &s)
static double	grpc::testing::ServerTotalCpuTime (const ServerStats &s)
static double	grpc::testing::ServerUserTime (const ServerStats &s)
static double	grpc::testing::ServerWallTime (const ServerStats &s)
static void	grpc::testing::ShutdownClients (const std::vector< ClientData > &clients, ScenarioResult &result)
static void	grpc::testing::ShutdownServers (const std::vector< ServerData > &servers, ScenarioResult &result)
static double	grpc::testing::SvrPollCount (const ServerStats &s)
static double	grpc::testing::SystemTime (const ClientStats &s)
static double	grpc::testing::UserTime (const ClientStats &s)
static double	grpc::testing::WallTime (const ClientStats &s)

Variables
std::vector< grpc::testing::Server * > *	grpc::testing::g_inproc_servers = nullptr