#include <string.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/sync.h>
#include "src/core/ext/transport/inproc/inproc_transport.h"
#include "src/core/lib/surface/channel.h"
#include "src/core/lib/surface/completion_queue.h"
#include "src/core/lib/surface/server.h"
#include "test/core/end2end/end2end_tests.h"
#include "test/core/util/port.h"
#include "test/core/util/test_config.h"

Include dependency graph for inproc_callback_test.cc:

Classes
struct	inproc_fixture_data

Typedefs
typedef struct inproc_fixture_data	inproc_fixture_data

Functions
static grpc_end2end_test_fixture	begin_test (grpc_end2end_test_config config, const char test_name, const grpc_channel_args client_args, const grpc_channel_args *server_args)

static void	drain_cq (grpc_completion_queue *)

static void	end_test (grpc_end2end_test_fixture *f)

static void	expect_tag (intptr_t tag, bool ok)

static gpr_timespec	five_seconds_from_now ()

static grpc_end2end_test_fixture	inproc_create_fixture (const grpc_channel_args , const grpc_channel_args )

void	inproc_init_client (grpc_end2end_test_fixture f, const grpc_channel_args client_args)

void	inproc_init_server (grpc_end2end_test_fixture f, const grpc_channel_args server_args)

void	inproc_tear_down (grpc_end2end_test_fixture *f)

int	main (int argc, char **argv)

static gpr_timespec	n_seconds_from_now (int n)

static void	shutdown_client (grpc_end2end_test_fixture *f)

static void	shutdown_server (grpc_end2end_test_fixture *f)

static void	simple_request (grpc_end2end_test_config config)

static void	simple_request_body (grpc_end2end_test_config, grpc_end2end_test_fixture f)

static void	simple_request_pre_init ()

static grpc_completion_queue_functor *	tag (intptr_t t)

static void	test_invoke_10_simple_requests (grpc_end2end_test_config config)

static void	test_invoke_many_simple_requests (grpc_end2end_test_config config)

static void	test_invoke_simple_request (grpc_end2end_test_config config)

static void	verify_tags (gpr_timespec deadline)

Variables
static grpc_end2end_test_config	configs []

const size_t	kAvailableTags = 4

bool	tags [kAvailableTags]

static gpr_cv	tags_cv

bool	tags_expected [kAvailableTags]

static gpr_mu	tags_mu

bool	tags_needed [kAvailableTags]

bool	tags_valid [kAvailableTags]

Typedef Documentation

◆ inproc_fixture_data

typedef struct inproc_fixture_data inproc_fixture_data

Function Documentation

◆ begin_test()

static grpc_end2end_test_fixture begin_test	(	grpc_end2end_test_config	config,
		const char *	test_name,
		const grpc_channel_args *	client_args,
		const grpc_channel_args *	server_args
	)

static

Definition at line 244 of file inproc_callback_test.cc.

◆ drain_cq()

static void drain_cq ( grpc_completion_queue * )

static

Definition at line 262 of file inproc_callback_test.cc.

◆ end_test()

static void end_test ( grpc_end2end_test_fixture * f )

static

Definition at line 284 of file inproc_callback_test.cc.

◆ expect_tag()

static void expect_tag	(	intptr_t	tag,
		bool	ok
	)

static

Definition at line 122 of file inproc_callback_test.cc.

◆ five_seconds_from_now()

static gpr_timespec five_seconds_from_now ( )

static

Definition at line 260 of file inproc_callback_test.cc.

◆ inproc_create_fixture()

static grpc_end2end_test_fixture inproc_create_fixture	(	const grpc_channel_args *	,
		const grpc_channel_args *
	)

static

Definition at line 207 of file inproc_callback_test.cc.

◆ inproc_init_client()

void inproc_init_client	(	grpc_end2end_test_fixture *	f,
		const grpc_channel_args *	client_args
	)

Definition at line 223 of file inproc_callback_test.cc.

◆ inproc_init_server()

void inproc_init_server	(	grpc_end2end_test_fixture *	f,
		const grpc_channel_args *	server_args
	)

Definition at line 229 of file inproc_callback_test.cc.

◆ inproc_tear_down()

void inproc_tear_down ( grpc_end2end_test_fixture * f )

Definition at line 239 of file inproc_callback_test.cc.

◆ main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 489 of file inproc_callback_test.cc.

◆ n_seconds_from_now()

static gpr_timespec n_seconds_from_now ( int n )

static

Definition at line 256 of file inproc_callback_test.cc.

◆ shutdown_client()

static void shutdown_client ( grpc_end2end_test_fixture * f )

static

Definition at line 278 of file inproc_callback_test.cc.

◆ shutdown_server()

static void shutdown_server ( grpc_end2end_test_fixture * f )

static

Definition at line 269 of file inproc_callback_test.cc.

◆ simple_request()

static void simple_request ( grpc_end2end_test_config config )

static

Definition at line 468 of file inproc_callback_test.cc.

◆ simple_request_body()

static void simple_request_body	(	grpc_end2end_test_config	,
		grpc_end2end_test_fixture	f
	)

static

Definition at line 293 of file inproc_callback_test.cc.

◆ simple_request_pre_init()

static void simple_request_pre_init ( )

static

Definition at line 477 of file inproc_callback_test.cc.

◆ tag()

static grpc_completion_queue_functor* tag ( intptr_t t )

static

Definition at line 185 of file inproc_callback_test.cc.

◆ test_invoke_10_simple_requests()

static void test_invoke_10_simple_requests ( grpc_end2end_test_config config )

static

Definition at line 439 of file inproc_callback_test.cc.

◆ test_invoke_many_simple_requests()

static void test_invoke_many_simple_requests ( grpc_end2end_test_config config )

static

Definition at line 451 of file inproc_callback_test.cc.

◆ test_invoke_simple_request()

static void test_invoke_simple_request ( grpc_end2end_test_config config )

static

Definition at line 430 of file inproc_callback_test.cc.

◆ verify_tags()

static void verify_tags ( gpr_timespec deadline )

static

Definition at line 137 of file inproc_callback_test.cc.

Variable Documentation

◆ configs

grpc_end2end_test_config configs[]

static

Initial value:

= {
    {"inproc-callback", FEATURE_MASK_SUPPORTS_AUTHORITY_HEADER, nullptr,
     inproc_create_fixture, inproc_init_client, inproc_init_server,
     inproc_tear_down},
}

Definition at line 483 of file inproc_callback_test.cc.

◆ kAvailableTags

const size_t kAvailableTags = 4

Definition at line 113 of file inproc_callback_test.cc.

◆ tags

bool tags[kAvailableTags]

Definition at line 114 of file inproc_callback_test.cc.

◆ tags_cv

gpr_cv tags_cv

static

Definition at line 112 of file inproc_callback_test.cc.

◆ tags_expected

bool tags_expected[kAvailableTags]

Definition at line 116 of file inproc_callback_test.cc.

◆ tags_mu

gpr_mu tags_mu

static

Definition at line 111 of file inproc_callback_test.cc.

◆ tags_needed

bool tags_needed[kAvailableTags]

Definition at line 117 of file inproc_callback_test.cc.

◆ tags_valid

bool tags_valid[kAvailableTags]

Definition at line 115 of file inproc_callback_test.cc.

Classes

Typedefs

Functions

Variables

Typedef Documentation

◆ inproc_fixture_data

Function Documentation

◆ begin_test()

◆ drain_cq()

◆ end_test()

◆ expect_tag()

◆ five_seconds_from_now()

◆ inproc_create_fixture()

◆ inproc_init_client()

◆ inproc_init_server()

◆ inproc_tear_down()

◆ main()

◆ n_seconds_from_now()

◆ shutdown_client()

◆ shutdown_server()

◆ simple_request()

◆ simple_request_body()

◆ simple_request_pre_init()

◆ tag()

◆ test_invoke_10_simple_requests()

◆ test_invoke_many_simple_requests()

◆ test_invoke_simple_request()

◆ verify_tags()

Variable Documentation

◆ configs

◆ kAvailableTags

◆ tags

◆ tags_cv

◆ tags_expected

◆ tags_mu

◆ tags_needed

◆ tags_valid