GRPC Core  9.0.0
Public Member Functions | Data Fields
grpc_call Struct Reference

Public Member Functions

 grpc_call (grpc_core::Arena *arena, const grpc_call_create_args &args)
 
 ~grpc_call ()
 

Data Fields

grpc_core::RefCount ext_ref
 
grpc_core::Arenaarena
 
grpc_core::CallCombiner call_combiner
 
grpc_completion_queuecq
 
grpc_polling_entity pollent
 
grpc_channelchannel
 
gpr_cycle_counter start_time = gpr_get_cycle_counter()
 
gpr_atm parent_call_atm = 0
 
child_callchild = nullptr
 
bool is_client
 
bool destroy_called = false
 has grpc_call_unref been called More...
 
bool cancellation_is_inherited = false
 flag indicating that cancellation is inherited More...
 
bool sent_initial_metadata = false
 which ops are in-flight More...
 
bool sending_message = false
 
bool sent_final_op = false
 
bool received_initial_metadata = false
 
bool receiving_message = false
 
bool requested_final_op = false
 
gpr_atm any_ops_sent_atm = 0
 
gpr_atm received_final_op_atm = 0
 
batch_controlactive_batches [6] = {}
 
grpc_transport_stream_op_batch_payload stream_op_payload
 
grpc_metadata_batch metadata_batch [2][2] = {}
 
grpc_metadata_arraybuffered_metadata [2] = {}
 
grpc_metadata compression_md
 
gpr_atm peer_string = 0
 
grpc_call_final_info final_info
 
grpc_message_compression_algorithm incoming_message_compression_algorithm
 
grpc_stream_compression_algorithm incoming_stream_compression_algorithm
 
uint32_t encodings_accepted_by_peer = 1 << GRPC_MESSAGE_COMPRESS_NONE
 
uint32_t stream_encodings_accepted_by_peer = 0
 
grpc_call_context_element context [GRPC_CONTEXT_COUNT] = {}
 
grpc_linked_mdelem send_extra_metadata [3]
 
int send_extra_metadata_count
 
grpc_millis send_deadline
 
grpc_core::ManualConstructor< grpc_core::SliceBufferByteStreamsending_stream
 
grpc_core::OrphanablePtr< grpc_core::ByteStreamreceiving_stream
 
grpc_byte_buffer ** receiving_buffer = nullptr
 
grpc_slice receiving_slice = grpc_empty_slice()
 
grpc_closure receiving_slice_ready
 
grpc_closure receiving_stream_ready
 
grpc_closure receiving_initial_metadata_ready
 
grpc_closure receiving_trailing_metadata_ready
 
uint32_t test_only_last_message_flags = 0
 
gpr_atm cancelled = 0
 
grpc_closure release_call
 
union {
   struct {
      grpc_status_code *   status
 
      grpc_slice *   status_details
 
      const char **   error_string
 
   }   client
 
   struct {
      int *   cancelled
 
      grpc_server *   server
 
   }   server
 
final_op
 
gpr_atm status_error = 0
 
gpr_atm recv_state = 0
 

Constructor & Destructor Documentation

◆ grpc_call()

grpc_call::grpc_call ( grpc_core::Arena arena,
const grpc_call_create_args args 
)
inline

◆ ~grpc_call()

grpc_call::~grpc_call ( )
inline

Field Documentation

◆ active_batches

batch_control* grpc_call::active_batches[6] = {}

◆ any_ops_sent_atm

gpr_atm grpc_call::any_ops_sent_atm = 0

◆ arena

grpc_core::Arena* grpc_call::arena

◆ buffered_metadata

grpc_metadata_array* grpc_call::buffered_metadata[2] = {}

◆ call_combiner

grpc_core::CallCombiner grpc_call::call_combiner

◆ cancellation_is_inherited

bool grpc_call::cancellation_is_inherited = false

flag indicating that cancellation is inherited

◆ cancelled [1/2]

gpr_atm grpc_call::cancelled = 0

◆ cancelled [2/2]

int* grpc_call::cancelled

◆ channel

grpc_channel* grpc_call::channel

◆ child

child_call* grpc_call::child = nullptr

◆ client

struct { ... } grpc_call::client

◆ compression_md

grpc_metadata grpc_call::compression_md

◆ context

◆ cq

grpc_completion_queue* grpc_call::cq

◆ destroy_called

bool grpc_call::destroy_called = false

has grpc_call_unref been called

◆ encodings_accepted_by_peer

uint32_t grpc_call::encodings_accepted_by_peer = 1 << GRPC_MESSAGE_COMPRESS_NONE

◆ error_string

const char** grpc_call::error_string

◆ ext_ref

grpc_core::RefCount grpc_call::ext_ref

◆ final_info

grpc_call_final_info grpc_call::final_info

◆ final_op

union { ... } grpc_call::final_op

◆ incoming_message_compression_algorithm

grpc_message_compression_algorithm grpc_call::incoming_message_compression_algorithm
Initial value:

◆ incoming_stream_compression_algorithm

grpc_stream_compression_algorithm grpc_call::incoming_stream_compression_algorithm
Initial value:

◆ is_client

bool grpc_call::is_client

◆ metadata_batch

grpc_metadata_batch grpc_call::metadata_batch[2][2] = {}

◆ parent_call_atm

gpr_atm grpc_call::parent_call_atm = 0

◆ peer_string

gpr_atm grpc_call::peer_string = 0

◆ pollent

grpc_polling_entity grpc_call::pollent

◆ received_final_op_atm

gpr_atm grpc_call::received_final_op_atm = 0

◆ received_initial_metadata

bool grpc_call::received_initial_metadata = false

◆ receiving_buffer

grpc_byte_buffer** grpc_call::receiving_buffer = nullptr

◆ receiving_initial_metadata_ready

grpc_closure grpc_call::receiving_initial_metadata_ready

◆ receiving_message

bool grpc_call::receiving_message = false

◆ receiving_slice

grpc_slice grpc_call::receiving_slice = grpc_empty_slice()

◆ receiving_slice_ready

grpc_closure grpc_call::receiving_slice_ready

◆ receiving_stream

grpc_core::OrphanablePtr<grpc_core::ByteStream> grpc_call::receiving_stream

◆ receiving_stream_ready

grpc_closure grpc_call::receiving_stream_ready

◆ receiving_trailing_metadata_ready

grpc_closure grpc_call::receiving_trailing_metadata_ready

◆ recv_state

gpr_atm grpc_call::recv_state = 0

◆ release_call

grpc_closure grpc_call::release_call

◆ requested_final_op

bool grpc_call::requested_final_op = false

◆ send_deadline

grpc_millis grpc_call::send_deadline

◆ send_extra_metadata

grpc_linked_mdelem grpc_call::send_extra_metadata[3]

◆ send_extra_metadata_count

int grpc_call::send_extra_metadata_count

◆ sending_message

bool grpc_call::sending_message = false

◆ sending_stream

◆ sent_final_op

bool grpc_call::sent_final_op = false

◆ sent_initial_metadata

bool grpc_call::sent_initial_metadata = false

which ops are in-flight

◆ server [1/2]

grpc_server* grpc_call::server

◆ server [2/2]

struct { ... } grpc_call::server

◆ start_time

gpr_cycle_counter grpc_call::start_time = gpr_get_cycle_counter()

◆ status

grpc_status_code* grpc_call::status

◆ status_details

grpc_slice* grpc_call::status_details

◆ status_error

gpr_atm grpc_call::status_error = 0

◆ stream_encodings_accepted_by_peer

uint32_t grpc_call::stream_encodings_accepted_by_peer = 0

◆ stream_op_payload

grpc_transport_stream_op_batch_payload grpc_call::stream_op_payload

◆ test_only_last_message_flags

uint32_t grpc_call::test_only_last_message_flags = 0

The documentation for this struct was generated from the following file: