passthru_endpoint.cc File Reference

#include "test/core/util/passthru_endpoint.h"
#include <inttypes.h>
#include <string.h>
#include <string>
#include "absl/strings/str_format.h"
#include <grpc/support/alloc.h>
#include <grpc/support/string_util.h>
#include "src/core/lib/gprpp/time.h"
#include "src/core/lib/iomgr/sockaddr.h"
#include "src/core/lib/iomgr/timer.h"
#include "src/core/lib/slice/slice_internal.h"

Include dependency graph for passthru_endpoint.cc:

Go to the source code of this file.

Classes
struct	grpc_passthru_endpoint_channel_effects
struct	half
struct	passthru_endpoint
struct	pending_op

Typedefs
typedef struct passthru_endpoint	passthru_endpoint

Functions
static void	do_next_sched_channel_action (void *arg, grpc_error_handle error)
static void	do_pending_read_op_locked (half *m, grpc_error_handle error)
static void	do_pending_write_op_locked (half *m, grpc_error_handle error)
void	flush_pending_ops_locked (half *m, grpc_error_handle error)
void	grpc_passthru_endpoint_create (grpc_endpoint **client, grpc_endpoint **server, grpc_passthru_endpoint_stats *stats, bool simulate_channel_actions)
void	grpc_passthru_endpoint_destroy (passthru_endpoint *p)
grpc_passthru_endpoint_stats *	grpc_passthru_endpoint_stats_create ()
void	grpc_passthru_endpoint_stats_destroy (grpc_passthru_endpoint_stats *stats)
void	grpc_slice_copy_split (grpc_slice src, uint64_t n, grpc_slice &split1, grpc_slice &split2)
static void	half_init (half *m, passthru_endpoint *parent, const char *half_name)
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 *ep)
static absl::string_view	me_get_peer (grpc_endpoint *ep)
static void	me_read (grpc_endpoint *ep, grpc_slice_buffer *slices, grpc_closure *cb, bool, int)
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 *, int)
static half *	other_half (half *h)
static void	sched_next_channel_action_locked (half *m)
static void	shutdown_locked (half *m, grpc_error_handle why)
void	start_scheduling_grpc_passthru_endpoint_channel_effects (grpc_endpoint *ep, const std::vector< grpc_passthru_endpoint_channel_action > &actions)

Variables
static const grpc_endpoint_vtable	vtable

Typedef Documentation

passthru_endpoint

typedef struct passthru_endpoint passthru_endpoint

Definition at line 36 of file passthru_endpoint.cc.

Function Documentation

do_next_sched_channel_action()

static void do_next_sched_channel_action ( void *  arg, grpc_error_handle  error  )

static

Definition at line 457 of file passthru_endpoint.cc.

do_pending_read_op_locked()

static void do_pending_read_op_locked ( half *  m, grpc_error_handle  error  )

static

Definition at line 77 of file passthru_endpoint.cc.

do_pending_write_op_locked()

static void do_pending_write_op_locked ( half *  m, grpc_error_handle  error  )

static

Definition at line 158 of file passthru_endpoint.cc.

flush_pending_ops_locked()

void flush_pending_ops_locked	(	half *	m,
		grpc_error_handle	error
	)

Definition at line 294 of file passthru_endpoint.cc.

grpc_passthru_endpoint_create()

void grpc_passthru_endpoint_create	(	grpc_endpoint **	client,
		grpc_endpoint **	server,
		grpc_passthru_endpoint_stats *	stats,
		bool	simulate_channel_actions
	)

Definition at line 413 of file passthru_endpoint.cc.

grpc_passthru_endpoint_destroy()

void grpc_passthru_endpoint_destroy

(

passthru_endpoint *

p

)

Definition at line 339 of file passthru_endpoint.cc.

grpc_passthru_endpoint_stats_create()

grpc_passthru_endpoint_stats* grpc_passthru_endpoint_stats_create

(

)

Definition at line 440 of file passthru_endpoint.cc.

grpc_passthru_endpoint_stats_destroy()

void grpc_passthru_endpoint_stats_destroy

(

grpc_passthru_endpoint_stats *

stats

)

Definition at line 449 of file passthru_endpoint.cc.

grpc_slice_copy_split()

void grpc_slice_copy_split	(	grpc_slice	src,
		uint64_t	n,
		grpc_slice &	split1,
		grpc_slice &	split2
	)

Definition at line 138 of file passthru_endpoint.cc.

half_init()

static void half_init ( half *  m, passthru_endpoint *  parent, const char *  half_name  )

static

Definition at line 397 of file passthru_endpoint.cc.

me_add_to_pollset()

static void me_add_to_pollset ( grpc_endpoint *  , grpc_pollset *    )

static

Definition at line 303 of file passthru_endpoint.cc.

me_add_to_pollset_set()

static void me_add_to_pollset_set ( grpc_endpoint *  , grpc_pollset_set *    )

static

Definition at line 306 of file passthru_endpoint.cc.

me_can_track_err()

static bool me_can_track_err ( grpc_endpoint *  )

static

Definition at line 381 of file passthru_endpoint.cc.

me_delete_from_pollset_set()

static void me_delete_from_pollset_set ( grpc_endpoint *  , grpc_pollset_set *    )

static

Definition at line 309 of file passthru_endpoint.cc.

me_destroy()

static void me_destroy ( grpc_endpoint *  ep )

static

Definition at line 350 of file passthru_endpoint.cc.

me_get_fd()

static int me_get_fd ( grpc_endpoint *  )

static

Definition at line 379 of file passthru_endpoint.cc.

me_get_local_address()

static absl::string_view me_get_local_address ( grpc_endpoint *  ep )

static

Definition at line 372 of file passthru_endpoint.cc.

me_get_peer()

static absl::string_view me_get_peer ( grpc_endpoint *  ep )

static

Definition at line 365 of file passthru_endpoint.cc.

me_read()

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

static

Definition at line 112 of file passthru_endpoint.cc.

me_shutdown()

static void me_shutdown ( grpc_endpoint *  ep, grpc_error_handle  why  )

static

Definition at line 331 of file passthru_endpoint.cc.

me_write()

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

static

Definition at line 261 of file passthru_endpoint.cc.

other_half()

static half* other_half ( half *  h )

static

Definition at line 153 of file passthru_endpoint.cc.

sched_next_channel_action_locked()

static void sched_next_channel_action_locked ( half *  m )

static

Definition at line 479 of file passthru_endpoint.cc.

shutdown_locked()

static void shutdown_locked ( half *  m, grpc_error_handle  why  )

static

Definition at line 312 of file passthru_endpoint.cc.

start_scheduling_grpc_passthru_endpoint_channel_effects()

void start_scheduling_grpc_passthru_endpoint_channel_effects	(	grpc_endpoint *	ep,
		const std::vector< grpc_passthru_endpoint_channel_action > &	actions
	)

Definition at line 495 of file passthru_endpoint.cc.

Variable Documentation

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 383 of file passthru_endpoint.cc.