GRPC Core  9.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)   ((grpc_stream*)((calld) + 1))
 
#define CALL_DATA_FROM_TRANSPORT_STREAM(transport_stream)   (((call_data*)(transport_stream)) - 1)
 

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)    (((call_data*)(transport_stream)) - 1)

◆ MAX_BUFFER_LENGTH

#define MAX_BUFFER_LENGTH   8192

◆ TRANSPORT_STREAM_FROM_CALL_DATA

#define TRANSPORT_STREAM_FROM_CALL_DATA (   calld)    ((grpc_stream*)((calld) + 1))

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
struct connected_channel_call_data call_data