GRPC Core  18.0.0
Data Structures | Macros | Typedefs | Functions | Variables
connected_channel.cc File Reference
#include <grpc/support/port_platform.h>
#include "src/core/lib/channel/connected_channel.h"
#include <stdarg.h>
#include <stdio.h>
#include <string.h>
#include <grpc/byte_buffer.h>
#include <grpc/slice_buffer.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/transport/transport.h"

Data Structures

struct  connected_channel_channel_data
 
struct  callback_state
 
struct  connected_channel_call_data
 

Macros

#define MAX_BUFFER_LENGTH   8192
 
#define TRANSPORT_STREAM_FROM_CALL_DATA(calld)
 
#define CALL_DATA_FROM_TRANSPORT_STREAM(transport_stream)
 

Typedefs

typedef struct connected_channel_channel_data channel_data
 
typedef struct connected_channel_call_data call_data
 

Functions

bool grpc_add_connected_filter (grpc_channel_stack_builder *builder, void *arg_must_be_null)
 
grpc_streamgrpc_connected_channel_get_stream (grpc_call_element *elem)
 

Variables

const grpc_channel_filter grpc_connected_filter
 

Macro Definition Documentation

◆ CALL_DATA_FROM_TRANSPORT_STREAM

#define CALL_DATA_FROM_TRANSPORT_STREAM (   transport_stream)
Value:
((call_data*)(((char*)(transport_stream)) - \
GPR_ROUND_UP_TO_ALIGNMENT_SIZE(sizeof(call_data))))
struct connected_channel_call_data call_data

◆ MAX_BUFFER_LENGTH

#define MAX_BUFFER_LENGTH   8192

◆ TRANSPORT_STREAM_FROM_CALL_DATA

#define TRANSPORT_STREAM_FROM_CALL_DATA (   calld)
Value:
((grpc_stream*)(((char*)(calld)) + \
GPR_ROUND_UP_TO_ALIGNMENT_SIZE(sizeof(call_data))))
struct grpc_stream grpc_stream
Definition: transport.h:52

Typedef Documentation

◆ call_data

typedef struct connected_channel_call_data call_data

◆ channel_data

typedef struct connected_channel_channel_data channel_data

Function Documentation

◆ grpc_add_connected_filter()

bool grpc_add_connected_filter ( grpc_channel_stack_builder builder,
void *  arg_must_be_null 
)

◆ grpc_connected_channel_get_stream()

grpc_stream* grpc_connected_channel_get_stream ( grpc_call_element elem)

Variable Documentation

◆ grpc_connected_filter

const grpc_channel_filter grpc_connected_filter
Initial value:
= {
connected_channel_start_transport_stream_op_batch,
connected_channel_start_transport_op,
sizeof(call_data),
connected_channel_init_call_elem,
set_pollset_or_pollset_set,
connected_channel_destroy_call_elem,
sizeof(channel_data),
connected_channel_init_channel_elem,
connected_channel_destroy_channel_elem,
connected_channel_get_channel_info,
"connected",
}
struct connected_channel_channel_data channel_data