transport.cc File Reference

#include <grpc/support/port_platform.h>
#include "src/core/lib/transport/transport.h"
#include <string.h>
#include <new>
#include "src/core/lib/gpr/alloc.h"
#include "src/core/lib/iomgr/exec_ctx.h"
#include "src/core/lib/iomgr/executor.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/transport/transport_impl.h"

Include dependency graph for transport.cc:

Go to the source code of this file.

Classes
struct	made_transport_op
struct	made_transport_stream_op

Functions
static void	destroy_made_transport_op (void *arg, grpc_error_handle error)
static void	destroy_made_transport_stream_op (void *arg, grpc_error_handle error)
grpc_transport_op *	grpc_make_transport_op (grpc_closure *on_complete)
grpc_transport_stream_op_batch *	grpc_make_transport_stream_op (grpc_closure *on_complete)
void	grpc_stream_destroy (grpc_stream_refcount *refcount)
void	grpc_stream_ref_init (grpc_stream_refcount *refcount, int, grpc_iomgr_cb_func cb, void *cb_arg, const char *object_type)
void	grpc_transport_destroy (grpc_transport *transport)
void	grpc_transport_destroy_stream (grpc_transport *transport, grpc_stream *stream, grpc_closure *then_schedule_closure)
grpc_endpoint *	grpc_transport_get_endpoint (grpc_transport *transport)
int	grpc_transport_init_stream (grpc_transport *transport, grpc_stream *stream, grpc_stream_refcount *refcount, const void *server_data, grpc_core::Arena *arena)
void	grpc_transport_move_one_way_stats (grpc_transport_one_way_stats *from, grpc_transport_one_way_stats *to)
void	grpc_transport_move_stats (grpc_transport_stream_stats *from, grpc_transport_stream_stats *to)
void	grpc_transport_perform_op (grpc_transport *transport, grpc_transport_op *op)
void	grpc_transport_perform_stream_op (grpc_transport *transport, grpc_stream *stream, grpc_transport_stream_op_batch *op)
void	grpc_transport_set_pops (grpc_transport *transport, grpc_stream *stream, grpc_polling_entity *pollent)
void	grpc_transport_stream_op_batch_finish_with_failure (grpc_transport_stream_op_batch *batch, grpc_error_handle error, grpc_core::CallCombiner *call_combiner)
void	grpc_transport_stream_op_batch_queue_finish_with_failure (grpc_transport_stream_op_batch *batch, grpc_error_handle error, grpc_core::CallCombinerClosureList *closures)
size_t	grpc_transport_stream_size (grpc_transport *transport)
static void	move64bits (uint64_t *from, uint64_t *to)
void	slice_stream_destroy (void *arg)

Variables
grpc_core::DebugOnlyTraceFlag	grpc_trace_stream_refcount (false, "stream_refcount")

Function Documentation

destroy_made_transport_op()

static void destroy_made_transport_op ( void *  arg, grpc_error_handle  error  )

static

Definition at line 198 of file transport.cc.

destroy_made_transport_stream_op()

static void destroy_made_transport_stream_op ( void *  arg, grpc_error_handle  error  )

static

Definition at line 220 of file transport.cc.

grpc_make_transport_op()

grpc_transport_op* grpc_make_transport_op

(

grpc_closure *

on_complete

)

Definition at line 205 of file transport.cc.

grpc_make_transport_stream_op()

grpc_transport_stream_op_batch* grpc_make_transport_stream_op

(

grpc_closure *

on_complete

)

Definition at line 230 of file transport.cc.

grpc_stream_destroy()

void grpc_stream_destroy

(

grpc_stream_refcount *

refcount

)

Definition at line 36 of file transport.cc.

grpc_stream_ref_init()

void grpc_stream_ref_init	(	grpc_stream_refcount *	refcount,
		int	,
		grpc_iomgr_cb_func	cb,
		void *	cb_arg,
		const char *	object_type
	)

Definition at line 59 of file transport.cc.

grpc_transport_destroy()

void grpc_transport_destroy

(

grpc_transport *

transport

)

Definition at line 96 of file transport.cc.

grpc_transport_destroy_stream()

void grpc_transport_destroy_stream	(	grpc_transport *	transport,
		grpc_stream *	stream,
		grpc_closure *	then_schedule_closure
	)

Definition at line 134 of file transport.cc.

grpc_transport_get_endpoint()

grpc_endpoint* grpc_transport_get_endpoint

(

grpc_transport *

transport

)

Definition at line 140 of file transport.cc.

grpc_transport_init_stream()

int grpc_transport_init_stream	(	grpc_transport *	transport,
		grpc_stream *	stream,
		grpc_stream_refcount *	refcount,
		const void *	server_data,
		grpc_core::Arena *	arena
	)

Definition at line 100 of file transport.cc.

grpc_transport_move_one_way_stats()

void grpc_transport_move_one_way_stats	(	grpc_transport_one_way_stats *	from,
		grpc_transport_one_way_stats *	to
	)

Definition at line 79 of file transport.cc.

grpc_transport_move_stats()

void grpc_transport_move_stats	(	grpc_transport_stream_stats *	from,
		grpc_transport_stream_stats *	to
	)

Definition at line 86 of file transport.cc.

grpc_transport_perform_op()

void grpc_transport_perform_op	(	grpc_transport *	transport,
		grpc_transport_op *	op
	)

Definition at line 114 of file transport.cc.

grpc_transport_perform_stream_op()

void grpc_transport_perform_stream_op	(	grpc_transport *	transport,
		grpc_stream *	stream,
		grpc_transport_stream_op_batch *	op
	)

Definition at line 108 of file transport.cc.

grpc_transport_set_pops()

void grpc_transport_set_pops	(	grpc_transport *	transport,
		grpc_stream *	stream,
		grpc_polling_entity *	pollent
	)

Definition at line 119 of file transport.cc.

grpc_transport_stream_op_batch_finish_with_failure()

void grpc_transport_stream_op_batch_finish_with_failure	(	grpc_transport_stream_op_batch *	batch,
		grpc_error_handle	error,
		grpc_core::CallCombiner *	call_combiner
	)

Definition at line 151 of file transport.cc.

grpc_transport_stream_op_batch_queue_finish_with_failure()

void grpc_transport_stream_op_batch_queue_finish_with_failure	(	grpc_transport_stream_op_batch *	batch,
		grpc_error_handle	error,
		grpc_core::CallCombinerClosureList *	closures
	)

Definition at line 161 of file transport.cc.

grpc_transport_stream_size()

size_t grpc_transport_stream_size

(

grpc_transport *

transport

)

Definition at line 92 of file transport.cc.

move64bits()

static void move64bits ( uint64_t *  from, uint64_t *  to  )

static

Definition at line 74 of file transport.cc.

slice_stream_destroy()

void slice_stream_destroy

(

void *

arg

)

Definition at line 54 of file transport.cc.

Variable Documentation

grpc_trace_stream_refcount

grpc_core::DebugOnlyTraceFlag grpc_trace_stream_refcount(false, "stream_refcount")