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_stream *	grpc_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))))

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

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",
}