#include <stdio.h>
#include <string.h>
#include <string>
#include "absl/strings/str_format.h"
#include <grpc/byte_buffer.h>
#include <grpc/byte_buffer_reader.h>
#include <grpc/compression.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/time.h>
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/surface/call.h"
#include "src/core/lib/surface/call_test_only.h"
#include "test/core/compression/args_utils.h"
#include "test/core/end2end/cq_verifier.h"
#include "test/core/end2end/end2end_tests.h"

Include dependency graph for compressed_payload.cc:

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, bool decompress_in_core)

void	compressed_payload (grpc_end2end_test_config config)

void	compressed_payload_pre_init (void)

static void	drain_cq (grpc_completion_queue *cq)

static void	end_test (grpc_end2end_test_fixture *f)

static gpr_timespec	five_seconds_from_now (void)

static gpr_timespec	n_seconds_from_now (int n)

static void	request_for_disabled_algorithm (grpc_end2end_test_config config, const char test_name, uint32_t send_flags_bitmask, grpc_compression_algorithm algorithm_to_disable, grpc_compression_algorithm requested_client_compression_algorithm, grpc_status_code expected_error, grpc_metadata client_metadata, bool decompress_in_core)

static void	request_with_payload_template (grpc_end2end_test_config config, const char test_name, uint32_t client_send_flags_bitmask, grpc_compression_algorithm default_client_channel_compression_algorithm, grpc_compression_algorithm default_server_channel_compression_algorithm, grpc_compression_algorithm expected_algorithm_from_client, grpc_compression_algorithm expected_algorithm_from_server, grpc_metadata client_init_metadata, bool set_server_level, grpc_compression_level server_compression_level, bool send_message_before_initial_metadata)

static void	request_with_payload_template_inner (grpc_end2end_test_config config, const char test_name, uint32_t client_send_flags_bitmask, grpc_compression_algorithm default_client_channel_compression_algorithm, grpc_compression_algorithm default_server_channel_compression_algorithm, grpc_compression_algorithm expected_algorithm_from_client, grpc_compression_algorithm expected_algorithm_from_server, grpc_metadata client_init_metadata, bool set_server_level, grpc_compression_level server_compression_level, bool send_message_before_initial_metadata, bool decompress_in_core)

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_invoke_request_with_compressed_payload (grpc_end2end_test_config config)

static void	test_invoke_request_with_compressed_payload_md_override (grpc_end2end_test_config config)

static void	test_invoke_request_with_disabled_algorithm (grpc_end2end_test_config config)

static void	test_invoke_request_with_exceptionally_uncompressed_payload (grpc_end2end_test_config config)

static void	test_invoke_request_with_send_message_before_initial_metadata (grpc_end2end_test_config config)

static void	test_invoke_request_with_server_level (grpc_end2end_test_config config)

static void	test_invoke_request_with_uncompressed_payload (grpc_end2end_test_config config)

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,
		bool	decompress_in_core
	)

static

Definition at line 42 of file compressed_payload.cc.

◆ compressed_payload()

void compressed_payload ( grpc_end2end_test_config config )

Definition at line 691 of file compressed_payload.cc.

◆ compressed_payload_pre_init()

void compressed_payload_pre_init ( void )

Definition at line 701 of file compressed_payload.cc.

◆ drain_cq()

static void drain_cq ( grpc_completion_queue * cq )

static

Definition at line 64 of file compressed_payload.cc.

◆ end_test()

static void end_test ( grpc_end2end_test_fixture * f )

static

Definition at line 89 of file compressed_payload.cc.

◆ five_seconds_from_now()

static gpr_timespec five_seconds_from_now ( void )

static

Definition at line 60 of file compressed_payload.cc.

◆ n_seconds_from_now()

static gpr_timespec n_seconds_from_now ( int n )

static

Definition at line 56 of file compressed_payload.cc.

◆ request_for_disabled_algorithm()

static void request_for_disabled_algorithm	(	grpc_end2end_test_config	config,
		const char *	test_name,
		uint32_t	send_flags_bitmask,
		grpc_compression_algorithm	algorithm_to_disable,
		grpc_compression_algorithm	requested_client_compression_algorithm,
		grpc_status_code	expected_error,
		grpc_metadata *	client_metadata,
		bool	decompress_in_core
	)

static

Definition at line 98 of file compressed_payload.cc.

◆ request_with_payload_template()

static void request_with_payload_template	(	grpc_end2end_test_config	config,
		const char *	test_name,
		uint32_t	client_send_flags_bitmask,
		grpc_compression_algorithm	default_client_channel_compression_algorithm,
		grpc_compression_algorithm	default_server_channel_compression_algorithm,
		grpc_compression_algorithm	expected_algorithm_from_client,
		grpc_compression_algorithm	expected_algorithm_from_server,
		grpc_metadata *	client_init_metadata,
		bool	set_server_level,
		grpc_compression_level	server_compression_level,
		bool	send_message_before_initial_metadata
	)

static

Definition at line 569 of file compressed_payload.cc.

◆ request_with_payload_template_inner()

static void request_with_payload_template_inner	(	grpc_end2end_test_config	config,
		const char *	test_name,
		uint32_t	client_send_flags_bitmask,
		grpc_compression_algorithm	default_client_channel_compression_algorithm,
		grpc_compression_algorithm	default_server_channel_compression_algorithm,
		grpc_compression_algorithm	expected_algorithm_from_client,
		grpc_compression_algorithm	expected_algorithm_from_server,
		grpc_metadata *	client_init_metadata,
		bool	set_server_level,
		grpc_compression_level	server_compression_level,
		bool	send_message_before_initial_metadata,
		bool	decompress_in_core
	)

static

Definition at line 275 of file compressed_payload.cc.

◆ shutdown_client()

static void shutdown_client ( grpc_end2end_test_fixture * f )

static

Definition at line 83 of file compressed_payload.cc.

◆ shutdown_server()

static void shutdown_server ( grpc_end2end_test_fixture * f )

static

Definition at line 71 of file compressed_payload.cc.

◆ tag()

static void* tag ( intptr_t t )

static

Definition at line 40 of file compressed_payload.cc.

◆ test_invoke_request_with_compressed_payload()

static void test_invoke_request_with_compressed_payload ( grpc_end2end_test_config config )

static

Definition at line 613 of file compressed_payload.cc.

◆ test_invoke_request_with_compressed_payload_md_override()

static void test_invoke_request_with_compressed_payload_md_override ( grpc_end2end_test_config config )

static

Definition at line 639 of file compressed_payload.cc.

◆ test_invoke_request_with_disabled_algorithm()

static void test_invoke_request_with_disabled_algorithm ( grpc_end2end_test_config config )

static

Definition at line 679 of file compressed_payload.cc.

◆ test_invoke_request_with_exceptionally_uncompressed_payload()

static void test_invoke_request_with_exceptionally_uncompressed_payload ( grpc_end2end_test_config config )

static

Definition at line 595 of file compressed_payload.cc.

◆ test_invoke_request_with_send_message_before_initial_metadata()

static void test_invoke_request_with_send_message_before_initial_metadata ( grpc_end2end_test_config config )

static

Definition at line 622 of file compressed_payload.cc.

◆ test_invoke_request_with_server_level()

static void test_invoke_request_with_server_level ( grpc_end2end_test_config config )

static

Definition at line 631 of file compressed_payload.cc.

◆ test_invoke_request_with_uncompressed_payload()

static void test_invoke_request_with_uncompressed_payload ( grpc_end2end_test_config config )

static

Definition at line 604 of file compressed_payload.cc.

Functions

Function Documentation

◆ begin_test()

◆ compressed_payload()

◆ compressed_payload_pre_init()

◆ drain_cq()

◆ end_test()

◆ five_seconds_from_now()

◆ n_seconds_from_now()

◆ request_for_disabled_algorithm()

◆ request_with_payload_template()

◆ request_with_payload_template_inner()

◆ shutdown_client()

◆ shutdown_server()

◆ tag()

◆ test_invoke_request_with_compressed_payload()

◆ test_invoke_request_with_compressed_payload_md_override()

◆ test_invoke_request_with_disabled_algorithm()

◆ test_invoke_request_with_exceptionally_uncompressed_payload()

◆ test_invoke_request_with_send_message_before_initial_metadata()

◆ test_invoke_request_with_server_level()

◆ test_invoke_request_with_uncompressed_payload()