client_callback_end2end_test.cc File Reference

#include <algorithm>
#include <condition_variable>
#include <functional>
#include <mutex>
#include <sstream>
#include <thread>
#include <gtest/gtest.h>
#include "absl/memory/memory.h"
#include <grpcpp/channel.h>
#include <grpcpp/client_context.h>
#include <grpcpp/create_channel.h>
#include <grpcpp/generic/generic_stub.h>
#include <grpcpp/impl/codegen/proto_utils.h>
#include <grpcpp/server.h>
#include <grpcpp/server_builder.h>
#include <grpcpp/server_context.h>
#include <grpcpp/support/client_callback.h>
#include "src/core/lib/gpr/env.h"
#include "src/core/lib/iomgr/iomgr.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/interceptors_util.h"
#include "test/cpp/end2end/test_service_impl.h"
#include "test/cpp/util/byte_buffer_proto_helper.h"
#include "test/cpp/util/string_ref_helper.h"
#include "test/cpp/util/test_credentials_provider.h"

Include dependency graph for client_callback_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 1570 of file client_callback_end2end_test.cc.

Variable Documentation

async_write_thread_

std::thread async_write_thread_

private

Definition at line 1217 of file client_callback_end2end_test.cc.

async_write_thread_cv_

std::condition_variable async_write_thread_cv_

private

Definition at line 1220 of file client_callback_end2end_test.cc.

async_write_thread_mu_

std::mutex async_write_thread_mu_

private

Definition at line 1219 of file client_callback_end2end_test.cc.

async_write_thread_start_

bool async_write_thread_start_ = false

private

Definition at line 1218 of file client_callback_end2end_test.cc.

callback_server

bool callback_server

Definition at line 66 of file client_callback_end2end_test.cc.

callback_service_

CallbackTestServiceImpl callback_service_

protected

Definition at line 341 of file client_callback_end2end_test.cc.

cancel

bool cancel {false}

Definition at line 634 of file client_callback_end2end_test.cc.

channel_

std::shared_ptr<Channel> channel_

protected

Definition at line 337 of file client_callback_end2end_test.cc.

client_cancel_

const ClientCancelInfo client_cancel_

private

Definition at line 731 of file client_callback_end2end_test.cc.

context_

ClientContext context_

private

Definition at line 726 of file client_callback_end2end_test.cc.

credentials_type

const std::string credentials_type

Definition at line 69 of file client_callback_end2end_test.cc.

cv_

std::condition_variable cv_

private

Definition at line 733 of file client_callback_end2end_test.cc.

desired_

std::string desired_

private

Definition at line 730 of file client_callback_end2end_test.cc.

done_

bool done_ = false

private

Definition at line 734 of file client_callback_end2end_test.cc.

generic_stub_

std::unique_ptr<grpc::GenericStub> generic_stub_

protected

Definition at line 339 of file client_callback_end2end_test.cc.

is_server_started_

bool is_server_started_ {false}

protected

Definition at line 335 of file client_callback_end2end_test.cc.

msgs_to_send_

const int msgs_to_send_

private

Definition at line 1212 of file client_callback_end2end_test.cc.

mu_

std::mutex mu_

private

Definition at line 732 of file client_callback_end2end_test.cc.

num_msgs_sent_

int num_msgs_sent_ {0}

private

Definition at line 728 of file client_callback_end2end_test.cc.

num_msgs_to_send_

const int num_msgs_to_send_

private

Definition at line 729 of file client_callback_end2end_test.cc.

ops_before_cancel

int ops_before_cancel

Definition at line 635 of file client_callback_end2end_test.cc.

picked_port_

int picked_port_ {0}

protected

Definition at line 336 of file client_callback_end2end_test.cc.

protocol

Protocol protocol

Definition at line 67 of file client_callback_end2end_test.cc.

reads_complete_

int reads_complete_ {0}

private

Definition at line 1011 of file client_callback_end2end_test.cc.

request_

EchoRequest request_

private

Definition at line 724 of file client_callback_end2end_test.cc.

response_

EchoResponse response_

private

Definition at line 725 of file client_callback_end2end_test.cc.

server_

std::unique_ptr<Server> server_

protected

Definition at line 342 of file client_callback_end2end_test.cc.

server_address_

std::ostringstream server_address_

protected

Definition at line 343 of file client_callback_end2end_test.cc.

server_try_cancel_

const ServerTryCancelRequestPhase server_try_cancel_

private

Definition at line 727 of file client_callback_end2end_test.cc.

service_

TestServiceImpl service_

protected

Definition at line 340 of file client_callback_end2end_test.cc.

stub_

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

protected

Definition at line 338 of file client_callback_end2end_test.cc.

use_interceptors

bool use_interceptors

Definition at line 68 of file client_callback_end2end_test.cc.

writes_complete_

int writes_complete_ {0}

private

Definition at line 1211 of file client_callback_end2end_test.cc.