connected_channel.cc File Reference

#include <grpc/support/port_platform.h>
#include "src/core/lib/channel/connected_channel.h"
#include <grpc/impl/codegen/grpc_types.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/channel/channel_stack.h"
#include "src/core/lib/gpr/alloc.h"
#include "src/core/lib/iomgr/call_combiner.h"
#include "src/core/lib/iomgr/closure.h"
#include "src/core/lib/iomgr/error.h"
#include "src/core/lib/iomgr/polling_entity.h"
#include "src/core/lib/transport/transport.h"
#include "src/core/lib/transport/transport_fwd.h"

Include dependency graph for connected_channel.cc:

Go to the source code of this file.

Classes
struct	callback_state
struct	connected_channel_call_data
struct	connected_channel_channel_data

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

Typedefs
typedef struct connected_channel_call_data	call_data
typedef struct connected_channel_channel_data	channel_data

Functions
static void	connected_channel_destroy_call_elem (grpc_call_element *elem, const grpc_call_final_info *, grpc_closure *then_schedule_closure)
static void	connected_channel_destroy_channel_elem (grpc_channel_element *elem)
static void	connected_channel_get_channel_info (grpc_channel_element *, const grpc_channel_info *)
static grpc_error_handle	connected_channel_init_call_elem (grpc_call_element *elem, const grpc_call_element_args *args)
static grpc_error_handle	connected_channel_init_channel_elem (grpc_channel_element *elem, grpc_channel_element_args *args)
static void	connected_channel_start_transport_op (grpc_channel_element *elem, grpc_transport_op *op)
static void	connected_channel_start_transport_stream_op_batch (grpc_call_element *elem, grpc_transport_stream_op_batch *batch)
static callback_state *	get_state_for_batch (call_data *calld, grpc_transport_stream_op_batch *batch)
bool	grpc_add_connected_filter (grpc_core::ChannelStackBuilder *builder)
grpc_stream *	grpc_connected_channel_get_stream (grpc_call_element *elem)
static void	intercept_callback (call_data *calld, callback_state *state, bool free_when_done, const char *reason, grpc_closure **original_closure)
static void	run_cancel_in_call_combiner (void *arg, grpc_error_handle error)
static void	run_in_call_combiner (void *arg, grpc_error_handle error)
static void	set_pollset_or_pollset_set (grpc_call_element *elem, grpc_polling_entity *pollent)

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

Definition at line 98 of file connected_channel.cc.

MAX_BUFFER_LENGTH

#define MAX_BUFFER_LENGTH   8192

Definition at line 37 of file connected_channel.cc.

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

Definition at line 95 of file connected_channel.cc.

Typedef Documentation

call_data

typedef struct connected_channel_call_data call_data

channel_data

typedef struct connected_channel_channel_data channel_data

Function Documentation

connected_channel_destroy_call_elem()

static void connected_channel_destroy_call_elem ( grpc_call_element *  elem, const grpc_call_final_info *  , grpc_closure *  then_schedule_closure  )

static

Definition at line 173 of file connected_channel.cc.

connected_channel_destroy_channel_elem()

static void connected_channel_destroy_channel_elem ( grpc_channel_element *  elem )

static

Definition at line 194 of file connected_channel.cc.

connected_channel_get_channel_info()

static void connected_channel_get_channel_info ( grpc_channel_element *  , const grpc_channel_info *    )

static

Definition at line 202 of file connected_channel.cc.

connected_channel_init_call_elem()

static grpc_error_handle connected_channel_init_call_elem ( grpc_call_element *  elem, const grpc_call_element_args *  args  )

static

Definition at line 151 of file connected_channel.cc.

connected_channel_init_channel_elem()

static grpc_error_handle connected_channel_init_channel_elem ( grpc_channel_element *  elem, grpc_channel_element_args *  args  )

static

Definition at line 184 of file connected_channel.cc.

connected_channel_start_transport_op()

static void connected_channel_start_transport_op ( grpc_channel_element *  elem, grpc_transport_op *  op  )

static

Definition at line 144 of file connected_channel.cc.

connected_channel_start_transport_stream_op_batch()

static void connected_channel_start_transport_stream_op_batch ( grpc_call_element *  elem, grpc_transport_stream_op_batch *  batch  )

static

Definition at line 104 of file connected_channel.cc.

get_state_for_batch()

static callback_state* get_state_for_batch ( call_data *  calld, grpc_transport_stream_op_batch *  batch  )

static

Definition at line 81 of file connected_channel.cc.

grpc_add_connected_filter()

bool grpc_add_connected_filter

(

grpc_core::ChannelStackBuilder *

builder

)

Definition at line 231 of file connected_channel.cc.

grpc_connected_channel_get_stream()

grpc_stream* grpc_connected_channel_get_stream

(

grpc_call_element *

elem

)

Definition at line 238 of file connected_channel.cc.

intercept_callback()

static void intercept_callback ( call_data *  calld, callback_state *  state, bool  free_when_done, const char *  reason, grpc_closure **  original_closure  )

static

Definition at line 69 of file connected_channel.cc.

run_cancel_in_call_combiner()

static void run_cancel_in_call_combiner ( void *  arg, grpc_error_handle  error  )

static

Definition at line 64 of file connected_channel.cc.

run_in_call_combiner()

static void run_in_call_combiner ( void *  arg, grpc_error_handle  error  )

static

Definition at line 58 of file connected_channel.cc.

set_pollset_or_pollset_set()

static void set_pollset_or_pollset_set ( grpc_call_element *  elem, grpc_polling_entity *  pollent  )

static

Definition at line 164 of file connected_channel.cc.

Variable Documentation

grpc_connected_filter

const grpc_channel_filter grpc_connected_filter

Initial value:

= {
    connected_channel_start_transport_stream_op_batch,
    nullptr,
    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,
    [](grpc_channel_stack* channel_stack, grpc_channel_element* elem) {
      
      channel_stack->call_stack_size += grpc_transport_stream_size(
          static_cast<channel_data*>(elem->channel_data)->transport);
    },
    connected_channel_destroy_channel_elem,
    connected_channel_get_channel_info,
    "connected",
}

Definition at line 206 of file connected_channel.cc.