transport.cc File Reference

#include <grpc/support/port_platform.h>
#include "src/core/lib/transport/transport.h"
#include <string.h>
#include <grpc/support/alloc.h>
#include <grpc/support/atm.h>
#include <grpc/support/log.h>
#include <grpc/support/sync.h>
#include "src/core/lib/gpr/alloc.h"
#include "src/core/lib/gprpp/memory.h"
#include "src/core/lib/iomgr/executor.h"
#include "src/core/lib/iomgr/iomgr.h"
#include "src/core/lib/slice/slice_internal.h"
#include "src/core/lib/slice/slice_string_helpers.h"
#include "src/core/lib/transport/transport_impl.h"

Data Structures
struct	made_transport_op
struct	made_transport_stream_op

Macros
#define	STREAM_REF_FROM_SLICE_REF(p)

Functions
void	grpc_stream_destroy (grpc_stream_refcount *refcount)
void	slice_stream_destroy (void *arg)
grpc_slice	grpc_slice_from_stream_owned_buffer (grpc_stream_refcount *refcount, void *buffer, size_t length)
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_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)
size_t	grpc_transport_stream_size (grpc_transport *transport)
void	grpc_transport_destroy (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_perform_stream_op (grpc_transport *transport, grpc_stream *stream, grpc_transport_stream_op_batch *op)
void	grpc_transport_perform_op (grpc_transport *transport, grpc_transport_op *op)
void	grpc_transport_set_pops (grpc_transport *transport, grpc_stream *stream, grpc_polling_entity *pollent)
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)
void	grpc_transport_stream_op_batch_finish_with_failure (grpc_transport_stream_op_batch *batch, grpc_error *error, grpc_core::CallCombiner *call_combiner)
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)

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

Macro Definition Documentation

STREAM_REF_FROM_SLICE_REF

#define STREAM_REF_FROM_SLICE_REF

(

p

)

Value:

  ((grpc_stream_refcount*)(((uint8_t*)p) - \
                           offsetof(grpc_stream_refcount, slice_refcount)))

Function Documentation

grpc_make_transport_op()

grpc_transport_op* grpc_make_transport_op

(

grpc_closure *

on_complete

)

grpc_make_transport_stream_op()

grpc_transport_stream_op_batch* grpc_make_transport_stream_op

(

grpc_closure *

on_complete

)

grpc_slice_from_stream_owned_buffer()

grpc_slice grpc_slice_from_stream_owned_buffer	(	grpc_stream_refcount *	refcount,
		void *	buffer,
		size_t	length
	)

grpc_stream_destroy()

void grpc_stream_destroy

(

grpc_stream_refcount *

refcount

)

grpc_stream_ref_init()

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

grpc_transport_destroy()

void grpc_transport_destroy

(

grpc_transport *

transport

)

grpc_transport_destroy_stream()

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

grpc_transport_get_endpoint()

grpc_endpoint* grpc_transport_get_endpoint

(

grpc_transport *

transport

)

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
	)

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
	)

grpc_transport_move_stats()

void grpc_transport_move_stats	(	grpc_transport_stream_stats *	from,
		grpc_transport_stream_stats *	to
	)

grpc_transport_perform_op()

void grpc_transport_perform_op	(	grpc_transport *	transport,
		grpc_transport_op *	op
	)

grpc_transport_perform_stream_op()

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

grpc_transport_set_pops()

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

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 *	error,
		grpc_core::CallCombiner *	call_combiner
	)

grpc_transport_stream_size()

size_t grpc_transport_stream_size

(

grpc_transport *

transport

)

slice_stream_destroy()

void slice_stream_destroy

(

void *

arg

)

Variable Documentation

grpc_trace_stream_refcount

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