deadline_filter.cc File Reference

#include <grpc/support/port_platform.h>
#include "src/core/ext/filters/deadline/deadline_filter.h"
#include <stdbool.h>
#include <string.h>
#include <grpc/support/alloc.h>
#include <grpc/support/log.h>
#include <grpc/support/sync.h>
#include <grpc/support/time.h>
#include "src/core/lib/channel/channel_stack_builder.h"
#include "src/core/lib/gprpp/memory.h"
#include "src/core/lib/iomgr/timer.h"
#include "src/core/lib/slice/slice_internal.h"
#include "src/core/lib/surface/channel_init.h"

Data Structures
struct	start_timer_after_init_state
struct	base_call_data
struct	server_call_data

Typedefs
typedef struct base_call_data	base_call_data
typedef struct server_call_data	server_call_data

Functions
void	grpc_deadline_state_reset (grpc_call_element *elem, grpc_millis new_deadline)
void	grpc_deadline_state_client_start_transport_stream_op_batch (grpc_call_element *elem, grpc_transport_stream_op_batch *op)
bool	grpc_deadline_checking_enabled (const grpc_channel_args *channel_args)
void	grpc_deadline_filter_init (void)
void	grpc_deadline_filter_shutdown (void)

Variables
const grpc_channel_filter	grpc_client_deadline_filter
const grpc_channel_filter	grpc_server_deadline_filter

Typedef Documentation

base_call_data

typedef struct base_call_data base_call_data

server_call_data

typedef struct server_call_data server_call_data

Function Documentation

grpc_deadline_checking_enabled()

bool grpc_deadline_checking_enabled

(

const grpc_channel_args *

channel_args

)

grpc_deadline_filter_init()

void grpc_deadline_filter_init

(

void

)

grpc_deadline_filter_shutdown()

void grpc_deadline_filter_shutdown

(

void

)

grpc_deadline_state_client_start_transport_stream_op_batch()

void grpc_deadline_state_client_start_transport_stream_op_batch	(	grpc_call_element *	elem,
		grpc_transport_stream_op_batch *	op
	)

grpc_deadline_state_reset()

void grpc_deadline_state_reset	(	grpc_call_element *	elem,
		grpc_millis	new_deadline
	)

Variable Documentation

grpc_client_deadline_filter

const grpc_channel_filter grpc_client_deadline_filter

Initial value:

= {
    deadline_client_start_transport_stream_op_batch,
    grpc_channel_next_op,
    sizeof(base_call_data),
    deadline_init_call_elem,
    grpc_call_stack_ignore_set_pollset_or_pollset_set,
    deadline_destroy_call_elem,
    0,  
    deadline_init_channel_elem,
    deadline_destroy_channel_elem,
    grpc_channel_next_get_info,
    "deadline",
}

grpc_server_deadline_filter

const grpc_channel_filter grpc_server_deadline_filter

Initial value:

= {
    deadline_server_start_transport_stream_op_batch,
    grpc_channel_next_op,
    sizeof(server_call_data),
    deadline_init_call_elem,
    grpc_call_stack_ignore_set_pollset_or_pollset_set,
    deadline_destroy_call_elem,
    0,  
    deadline_init_channel_elem,
    deadline_destroy_channel_elem,
    grpc_channel_next_get_info,
    "deadline",
}