#include "src/core/lib/security/transport/secure_endpoint.h"
#include <fcntl.h>
#include <sys/types.h>
#include <grpc/grpc.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include "src/core/lib/gpr/useful.h"
#include "src/core/lib/iomgr/endpoint_pair.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/slice/slice_internal.h"
#include "src/core/tsi/fake_transport_security.h"
#include "test/core/iomgr/endpoint_tests.h"
#include "test/core/util/test_config.h"

Include dependency graph for secure_endpoint_test.cc:

Classes
struct	intercept_endpoint

Macros
#define	TSI_FAKE_FRAME_HEADER_SIZE 4

Typedefs
typedef struct intercept_endpoint	intercept_endpoint

Functions
static void	clean_up (void)

static void	destroy_pollset (void *p, grpc_error_handle)

static void	inc_call_ctr (void *arg, grpc_error_handle)

int	main (int argc, char **argv)

static void	me_add_to_pollset (grpc_endpoint , grpc_pollset )

static void	me_add_to_pollset_set (grpc_endpoint , grpc_pollset_set )

static bool	me_can_track_err (grpc_endpoint *)

static void	me_delete_from_pollset_set (grpc_endpoint , grpc_pollset_set )

static void	me_destroy (grpc_endpoint *ep)

static int	me_get_fd (grpc_endpoint *)

static absl::string_view	me_get_local_address (grpc_endpoint *)

static absl::string_view	me_get_peer (grpc_endpoint *)

static void	me_read (grpc_endpoint ep, grpc_slice_buffer slices, grpc_closure *cb, bool urgent, int min_progress_size)

static void	me_shutdown (grpc_endpoint *ep, grpc_error_handle why)

static void	me_write (grpc_endpoint ep, grpc_slice_buffer slices, grpc_closure cb, void arg, int max_frame_size)

static grpc_endpoint_test_fixture	secure_endpoint_create_fixture_tcp_socketpair (size_t slice_size, grpc_slice *leftover_slices, size_t leftover_nslices, bool use_zero_copy_protector)

static grpc_endpoint_test_fixture	secure_endpoint_create_fixture_tcp_socketpair_leftover (size_t slice_size)

static grpc_endpoint_test_fixture	secure_endpoint_create_fixture_tcp_socketpair_leftover_zero_copy (size_t slice_size)

static grpc_endpoint_test_fixture	secure_endpoint_create_fixture_tcp_socketpair_noleftover (size_t slice_size)

static grpc_endpoint_test_fixture	secure_endpoint_create_fixture_tcp_socketpair_noleftover_zero_copy (size_t slice_size)

static void	test_leftover (grpc_endpoint_test_config config, size_t slice_size)

grpc_endpoint *	wrap_with_intercept_endpoint (grpc_endpoint *wrapped_ep)

Variables
static grpc_endpoint_test_config	configs []

static gpr_mu *	g_mu

static grpc_pollset *	g_pollset

static const grpc_endpoint_vtable	vtable

Macro Definition Documentation

◆ TSI_FAKE_FRAME_HEADER_SIZE

#define TSI_FAKE_FRAME_HEADER_SIZE 4

Definition at line 39 of file secure_endpoint_test.cc.

Typedef Documentation

◆ intercept_endpoint

typedef struct intercept_endpoint intercept_endpoint

Function Documentation

◆ clean_up()

static void clean_up ( void )

static

Definition at line 254 of file secure_endpoint_test.cc.

◆ destroy_pollset()

static void destroy_pollset	(	void *	p,
		grpc_error_handle
	)

static

Definition at line 306 of file secure_endpoint_test.cc.

◆ inc_call_ctr()

static void inc_call_ctr	(	void *	arg,
		grpc_error_handle
	)

static

Definition at line 269 of file secure_endpoint_test.cc.

◆ main()

int main	(	int	argc,
		char **	argv
	)

Definition at line 310 of file secure_endpoint_test.cc.

◆ me_add_to_pollset()

static void me_add_to_pollset	(	grpc_endpoint *	,
		grpc_pollset *
	)

static

Definition at line 72 of file secure_endpoint_test.cc.

◆ me_add_to_pollset_set()

static void me_add_to_pollset_set	(	grpc_endpoint *	,
		grpc_pollset_set *
	)

static

Definition at line 75 of file secure_endpoint_test.cc.

◆ me_can_track_err()

static bool me_can_track_err ( grpc_endpoint * )

static

Definition at line 103 of file secure_endpoint_test.cc.

◆ me_delete_from_pollset_set()

static void me_delete_from_pollset_set	(	grpc_endpoint *	,
		grpc_pollset_set *
	)

static

Definition at line 78 of file secure_endpoint_test.cc.

◆ me_destroy()

static void me_destroy ( grpc_endpoint * ep )

static

Definition at line 86 of file secure_endpoint_test.cc.

◆ me_get_fd()

static int me_get_fd ( grpc_endpoint * )

static

Definition at line 101 of file secure_endpoint_test.cc.

◆ me_get_local_address()

static absl::string_view me_get_local_address ( grpc_endpoint * )

static

Definition at line 97 of file secure_endpoint_test.cc.

◆ me_get_peer()

static absl::string_view me_get_peer ( grpc_endpoint * )

static

Definition at line 93 of file secure_endpoint_test.cc.

◆ me_read()

static void me_read	(	grpc_endpoint *	ep,
		grpc_slice_buffer *	slices,
		grpc_closure *	cb,
		bool	urgent,
		int	min_progress_size
	)

static

Definition at line 47 of file secure_endpoint_test.cc.

◆ me_shutdown()

static void me_shutdown	(	grpc_endpoint *	ep,
		grpc_error_handle	why
	)

static

Definition at line 81 of file secure_endpoint_test.cc.

◆ me_write()

static void me_write	(	grpc_endpoint *	ep,
		grpc_slice_buffer *	slices,
		grpc_closure *	cb,
		void *	arg,
		int	max_frame_size
	)

static

Definition at line 53 of file secure_endpoint_test.cc.

◆ secure_endpoint_create_fixture_tcp_socketpair()

static grpc_endpoint_test_fixture secure_endpoint_create_fixture_tcp_socketpair	(	size_t	slice_size,
		grpc_slice *	leftover_slices,
		size_t	leftover_nslices,
		bool	use_zero_copy_protector
	)

static

Definition at line 126 of file secure_endpoint_test.cc.

◆ secure_endpoint_create_fixture_tcp_socketpair_leftover()

static grpc_endpoint_test_fixture secure_endpoint_create_fixture_tcp_socketpair_leftover ( size_t slice_size )

static

Definition at line 239 of file secure_endpoint_test.cc.

◆ secure_endpoint_create_fixture_tcp_socketpair_leftover_zero_copy()

static grpc_endpoint_test_fixture secure_endpoint_create_fixture_tcp_socketpair_leftover_zero_copy ( size_t slice_size )

static

Definition at line 247 of file secure_endpoint_test.cc.

◆ secure_endpoint_create_fixture_tcp_socketpair_noleftover()

static grpc_endpoint_test_fixture secure_endpoint_create_fixture_tcp_socketpair_noleftover ( size_t slice_size )

static

Definition at line 226 of file secure_endpoint_test.cc.

◆ secure_endpoint_create_fixture_tcp_socketpair_noleftover_zero_copy()

static grpc_endpoint_test_fixture secure_endpoint_create_fixture_tcp_socketpair_noleftover_zero_copy ( size_t slice_size )

static

Definition at line 232 of file secure_endpoint_test.cc.

◆ test_leftover()

static void test_leftover	(	grpc_endpoint_test_config	config,
		size_t	slice_size
	)

static

Definition at line 273 of file secure_endpoint_test.cc.

◆ wrap_with_intercept_endpoint()

grpc_endpoint* wrap_with_intercept_endpoint ( grpc_endpoint * wrapped_ep )

Definition at line 117 of file secure_endpoint_test.cc.

Variable Documentation

◆ configs

grpc_endpoint_test_config configs[]

static

Initial value:

= {
    {"secure_ep/tcp_socketpair",
     secure_endpoint_create_fixture_tcp_socketpair_noleftover, clean_up},
    {"secure_ep/tcp_socketpair_zero_copy",
     secure_endpoint_create_fixture_tcp_socketpair_noleftover_zero_copy,
     clean_up},
    {"secure_ep/tcp_socketpair_leftover",
     secure_endpoint_create_fixture_tcp_socketpair_leftover, clean_up},
    {"secure_ep/tcp_socketpair_leftover_zero_copy",
     secure_endpoint_create_fixture_tcp_socketpair_leftover_zero_copy,
     clean_up},
}

Definition at line 256 of file secure_endpoint_test.cc.

◆ g_mu

gpr_mu* g_mu

static

Definition at line 36 of file secure_endpoint_test.cc.

◆ g_pollset

grpc_pollset* g_pollset

static

Definition at line 37 of file secure_endpoint_test.cc.

◆ vtable

const grpc_endpoint_vtable vtable

static

Initial value:

= {me_read,
                                            me_write,
                                            me_add_to_pollset,
                                            me_add_to_pollset_set,
                                            me_delete_from_pollset_set,
                                            me_shutdown,
                                            me_destroy,
                                            me_get_peer,
                                            me_get_local_address,
                                            me_get_fd,
                                            me_can_track_err}

Definition at line 105 of file secure_endpoint_test.cc.

Classes

Macros

Typedefs

Functions

Variables

Macro Definition Documentation

◆ TSI_FAKE_FRAME_HEADER_SIZE

Typedef Documentation

◆ intercept_endpoint

Function Documentation

◆ clean_up()

◆ destroy_pollset()

◆ inc_call_ctr()

◆ main()

◆ me_add_to_pollset()

◆ me_add_to_pollset_set()

◆ me_can_track_err()

◆ me_delete_from_pollset_set()

◆ me_destroy()

◆ me_get_fd()

◆ me_get_local_address()

◆ me_get_peer()

◆ me_read()

◆ me_shutdown()

◆ me_write()

◆ secure_endpoint_create_fixture_tcp_socketpair()

◆ secure_endpoint_create_fixture_tcp_socketpair_leftover()

◆ secure_endpoint_create_fixture_tcp_socketpair_leftover_zero_copy()

◆ secure_endpoint_create_fixture_tcp_socketpair_noleftover()

◆ secure_endpoint_create_fixture_tcp_socketpair_noleftover_zero_copy()

◆ test_leftover()

◆ wrap_with_intercept_endpoint()

Variable Documentation

◆ configs

◆ g_mu

◆ g_pollset

◆ vtable