GRPC C++  1.39.1
Data Structures | Namespaces | Typedefs | Functions | Variables
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

class  grpc_core::TimerState
 
struct  start_timer_after_init_state
 
struct  base_call_data
 
struct  server_call_data
 

Namespaces

 grpc_core
 Round Robin Policy.
 

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

◆ 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,
sizeof(base_call_data),
deadline_init_call_elem,
deadline_destroy_call_elem,
0,
deadline_init_channel_elem,
deadline_destroy_channel_elem,
"deadline",
}
void grpc_channel_next_get_info(grpc_channel_element *elem, const grpc_channel_info *channel_info)
Definition: channel_stack.cc:243
void grpc_call_stack_ignore_set_pollset_or_pollset_set(grpc_call_element *, grpc_polling_entity *)
Definition: channel_stack.cc:218
void grpc_channel_next_op(grpc_channel_element *elem, grpc_transport_op *op)
Definition: channel_stack.cc:249
struct base_call_data base_call_data

◆ grpc_server_deadline_filter

const grpc_channel_filter grpc_server_deadline_filter
Initial value:
= {
deadline_server_start_transport_stream_op_batch,
deadline_init_call_elem,
deadline_destroy_call_elem,
0,
deadline_init_channel_elem,
deadline_destroy_channel_elem,
"deadline",
}
struct server_call_data server_call_data