GRPC C++  1.39.1
Data Structures | Macros | Functions | Variables
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_endpointgrpc_transport_get_endpoint (grpc_transport *transport)
 
void grpc_transport_stream_op_batch_finish_with_failure (grpc_transport_stream_op_batch *batch, grpc_error_handle error, grpc_core::CallCombiner *call_combiner)
 
grpc_transport_opgrpc_make_transport_op (grpc_closure *on_complete)
 
grpc_transport_stream_op_batchgrpc_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)))
Definition: transport.h:56

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_handle  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"   
)