filter_status_code.cc File Reference

#include <limits.h>
#include <stdbool.h>
#include <stdio.h>
#include <string.h>
#include <grpc/byte_buffer.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/time.h>
#include "src/core/lib/channel/channel_stack_builder.h"
#include "src/core/lib/config/core_configuration.h"
#include "src/core/lib/surface/call.h"
#include "src/core/lib/surface/channel_init.h"
#include "test/core/end2end/cq_verifier.h"
#include "test/core/end2end/end2end_tests.h"

Include dependency graph for filter_status_code.cc:

Go to the source code of this file.

Classes
struct	final_status_data

Typedefs
typedef struct final_status_data	final_status_data

Functions
static grpc_end2end_test_fixture	begin_test (grpc_end2end_test_config config, const char *test_name, grpc_channel_args *client_args, grpc_channel_args *server_args)
static void	client_destroy_call_elem (grpc_call_element *elem, const grpc_call_final_info *final_info, grpc_closure *)
static void	destroy_channel_elem (grpc_channel_element *)
static void	drain_cq (grpc_completion_queue *cq)
static void	end_test (grpc_end2end_test_fixture *f)
void	filter_status_code (grpc_end2end_test_config config)
void	filter_status_code_pre_init (void)
static gpr_timespec	five_seconds_from_now (void)
static grpc_error_handle	init_call_elem (grpc_call_element *elem, const grpc_call_element_args *args)
static grpc_error_handle	init_channel_elem (grpc_channel_element *, grpc_channel_element_args *)
static gpr_timespec	n_seconds_from_now (int n)
static void	server_destroy_call_elem (grpc_call_element *elem, const grpc_call_final_info *final_info, grpc_closure *)
static void	server_start_transport_stream_op_batch (grpc_call_element *elem, grpc_transport_stream_op_batch *op)
static void	shutdown_client (grpc_end2end_test_fixture *f)
static void	shutdown_server (grpc_end2end_test_fixture *f)
static void *	tag (intptr_t t)
static void	test_request (grpc_end2end_test_config config)

Variables
static grpc_call_stack *	g_client_call_stack
static gpr_cv	g_client_code_cv
static bool	g_client_code_recv
static grpc_status_code	g_client_status_code
static gpr_mu	g_mu
static grpc_call_stack *	g_server_call_stack
static gpr_cv	g_server_code_cv
static bool	g_server_code_recv
static grpc_status_code	g_server_status_code
static const grpc_channel_filter	test_client_filter
static const grpc_channel_filter	test_server_filter

Typedef Documentation

final_status_data

typedef struct final_status_data final_status_data

Function Documentation

begin_test()

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

static

Definition at line 56 of file filter_status_code.cc.

client_destroy_call_elem()

static void client_destroy_call_elem ( grpc_call_element *  elem, const grpc_call_final_info *  final_info, grpc_closure *    )

static

Definition at line 287 of file filter_status_code.cc.

destroy_channel_elem()

static void destroy_channel_elem ( grpc_channel_element *  )

static

Definition at line 322 of file filter_status_code.cc.

drain_cq()

static void drain_cq ( grpc_completion_queue *  cq )

static

Definition at line 76 of file filter_status_code.cc.

end_test()

static void end_test ( grpc_end2end_test_fixture *  f )

static

Definition at line 101 of file filter_status_code.cc.

filter_status_code()

void filter_status_code

(

grpc_end2end_test_config

config

)

Definition at line 358 of file filter_status_code.cc.

filter_status_code_pre_init()

void filter_status_code_pre_init

(

void

)

Definition at line 384 of file filter_status_code.cc.

five_seconds_from_now()

static gpr_timespec five_seconds_from_now ( void  )

static

Definition at line 72 of file filter_status_code.cc.

init_call_elem()

static grpc_error_handle init_call_elem ( grpc_call_element *  elem, const grpc_call_element_args *  args  )

static

Definition at line 280 of file filter_status_code.cc.

init_channel_elem()

static grpc_error_handle init_channel_elem ( grpc_channel_element *  , grpc_channel_element_args *    )

static

Definition at line 317 of file filter_status_code.cc.

n_seconds_from_now()

static gpr_timespec n_seconds_from_now ( int  n )

static

Definition at line 68 of file filter_status_code.cc.

server_destroy_call_elem()

static void server_destroy_call_elem ( grpc_call_element *  elem, const grpc_call_final_info *  final_info, grpc_closure *    )

static

Definition at line 302 of file filter_status_code.cc.

server_start_transport_stream_op_batch()

static void server_start_transport_stream_op_batch ( grpc_call_element *  elem, grpc_transport_stream_op_batch *  op  )

static

Definition at line 262 of file filter_status_code.cc.

shutdown_client()

static void shutdown_client ( grpc_end2end_test_fixture *  f )

static

Definition at line 95 of file filter_status_code.cc.

shutdown_server()

static void shutdown_server ( grpc_end2end_test_fixture *  f )

static

Definition at line 83 of file filter_status_code.cc.

tag()

static void* tag ( intptr_t  t )

static

Definition at line 54 of file filter_status_code.cc.

test_request()

static void test_request ( grpc_end2end_test_config  config )

static

Definition at line 111 of file filter_status_code.cc.

Variable Documentation

g_client_call_stack

grpc_call_stack* g_client_call_stack

static

Definition at line 45 of file filter_status_code.cc.

g_client_code_cv

gpr_cv g_client_code_cv

static

Definition at line 49 of file filter_status_code.cc.

g_client_code_recv

bool g_client_code_recv

static

Definition at line 47 of file filter_status_code.cc.

g_client_status_code

grpc_status_code g_client_status_code

static

Definition at line 51 of file filter_status_code.cc.

g_mu

gpr_mu g_mu

static

Definition at line 44 of file filter_status_code.cc.

g_server_call_stack

grpc_call_stack* g_server_call_stack

static

Definition at line 46 of file filter_status_code.cc.

g_server_code_cv

gpr_cv g_server_code_cv

static

Definition at line 50 of file filter_status_code.cc.

g_server_code_recv

bool g_server_code_recv

static

Definition at line 48 of file filter_status_code.cc.

g_server_status_code

grpc_status_code g_server_status_code

static

Definition at line 52 of file filter_status_code.cc.

test_client_filter

const grpc_channel_filter test_client_filter

static

Initial value:

= {
    grpc_call_next_op,
    nullptr,
    grpc_channel_next_op,
    sizeof(final_status_data),
    init_call_elem,
    grpc_call_stack_ignore_set_pollset_or_pollset_set,
    client_destroy_call_elem,
    0,
    init_channel_elem,
    grpc_channel_stack_no_post_init,
    destroy_channel_elem,
    grpc_channel_next_get_info,
    "client_filter_status_code"}

Definition at line 324 of file filter_status_code.cc.

test_server_filter

const grpc_channel_filter test_server_filter

static

Initial value:

= {
    server_start_transport_stream_op_batch,
    nullptr,
    grpc_channel_next_op,
    sizeof(final_status_data),
    init_call_elem,
    grpc_call_stack_ignore_set_pollset_or_pollset_set,
    server_destroy_call_elem,
    0,
    init_channel_elem,
    grpc_channel_stack_no_post_init,
    destroy_channel_elem,
    grpc_channel_next_get_info,
    "server_filter_status_code"}

Definition at line 339 of file filter_status_code.cc.