Classes
class	ResolverQueuedCallCanceller

Static Public Member Functions
static void	CheckResolution (void *arg, grpc_error_handle error)

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

static grpc_error_handle	Init (grpc_call_element elem, const grpc_call_element_args args)

static void	SetPollent (grpc_call_element elem, grpc_polling_entity pollent)

static void	StartTransportStreamOpBatch (grpc_call_element elem, grpc_transport_stream_op_batch batch)

Public Attributes
bool CheckResolutionLocked(grpc_call_element elem, grpc_error_handle error) ABSL_EXCLUSIVE_LOCKS_REQUIRED(&ClientChannel voi	AsyncResolutionDone )(grpc_call_element *elem, grpc_error_handle error)

Private Types
typedef bool(*	YieldCallCombinerPredicate) (const CallCombinerClosureList &closures)

Private Member Functions
	CallData (grpc_call_element *elem, const ClientChannel &chand, const grpc_call_element_args &args)

void	CreateDynamicCall (grpc_call_element *elem)

void	PendingBatchesAdd (grpc_call_element elem, grpc_transport_stream_op_batch batch)

void	PendingBatchesFail (grpc_call_element *elem, grpc_error_handle error, YieldCallCombinerPredicate yield_call_combiner_predicate)

void	PendingBatchesResume (grpc_call_element *elem)

	~CallData ()

Static Private Member Functions
static void	FailPendingBatchInCallCombiner (void *arg, grpc_error_handle error)

static size_t	GetBatchIndex (grpc_transport_stream_op_batch *batch)

static bool	NoYieldCallCombiner (const CallCombinerClosureList &)

static void	ResumePendingBatchInCallCombiner (void *arg, grpc_error_handle ignored)

static bool	YieldCallCombiner (const CallCombinerClosureList &)

static bool	YieldCallCombinerIfPendingBatchesFound (const CallCombinerClosureList &closures)

Private Attributes
Arena *	arena_

CallCombiner *	call_combiner_

grpc_call_context_element *	call_context_

gpr_cycle_counter	call_start_time_

grpc_error_handle	cancel_error_ = GRPC_ERROR_NONE

Timestamp	deadline_

grpc_deadline_state	deadline_state_

RefCountedPtr< DynamicFilters::Call >	dynamic_call_

RefCountedPtr< DynamicFilters >	dynamic_filters_

grpc_closure *	original_recv_trailing_metadata_ready_ = nullptr

grpc_call_stack *	owning_call_

grpc_slice	path_

grpc_transport_stream_op_batch *	pending_batches_ [MAX_PENDING_BATCHES] = {}

grpc_polling_entity *	pollent_ = nullptr

grpc_closure	recv_trailing_metadata_ready_

grpc_closure	resolution_done_closure_

Static Private Attributes
void MaybeRemoveCallFromResolverQueuedCallsLocked(grpc_call_element elem) ABSL_EXCLUSIVE_LOCKS_REQUIRED(&ClientChannel void static MaybeAddCallToResolverQueuedCallsLocked(grpc_call_element elem) ABSL_EXCLUSIVE_LOCKS_REQUIRED(&ClientChannel voi	RecvTrailingMetadataReadyForConfigSelectorCommitCallback )(void *arg, grpc_error_handle error)

grpc_error_handle static ApplyServiceConfigToCallLocked(grpc_call_element elem, grpc_metadata_batch initial_metadata) ABSL_EXCLUSIVE_LOCKS_REQUIRED(&ClientChannel voi	ResolutionDone )(void *arg, grpc_error_handle error)

Detailed Description

Definition at line 110 of file client_channel.cc.

Member Typedef Documentation

◆ YieldCallCombinerPredicate

typedef bool(* grpc_core::ClientChannel::CallData::YieldCallCombinerPredicate) (const CallCombinerClosureList &closures)

private

Definition at line 149 of file client_channel.cc.

Constructor & Destructor Documentation

◆ CallData()

grpc_core::ClientChannel::CallData::CallData	(	grpc_call_element *	elem,
		const ClientChannel &	chand,
		const grpc_call_element_args &	args
	)

private

Definition at line 1879 of file client_channel.cc.

◆ ~CallData()

grpc_core::ClientChannel::CallData::~CallData ( )

private

Definition at line 1898 of file client_channel.cc.

Member Function Documentation

◆ CheckResolution()

void grpc_core::ClientChannel::CallData::CheckResolution	(	void *	arg,
		grpc_error_handle	error
	)

static

Definition at line 2340 of file client_channel.cc.

◆ CreateDynamicCall()

void grpc_core::ClientChannel::CallData::CreateDynamicCall ( grpc_call_element * elem )

private

Definition at line 2428 of file client_channel.cc.

◆ Destroy()

void grpc_core::ClientChannel::CallData::Destroy	(	grpc_call_element *	elem,
		const grpc_call_final_info *	final_info,
		grpc_closure *	then_schedule_closure
	)

static

Definition at line 1914 of file client_channel.cc.

◆ FailPendingBatchInCallCombiner()

void grpc_core::ClientChannel::CallData::FailPendingBatchInCallCombiner	(	void *	arg,
		grpc_error_handle	error
	)

staticprivate

Definition at line 2066 of file client_channel.cc.

◆ GetBatchIndex()

size_t grpc_core::ClientChannel::CallData::GetBatchIndex ( grpc_transport_stream_op_batch * batch )

staticprivate

Definition at line 2036 of file client_channel.cc.

◆ Init()

grpc_error_handle grpc_core::ClientChannel::CallData::Init	(	grpc_call_element *	elem,
		const grpc_call_element_args *	args
	)

static

Definition at line 1907 of file client_channel.cc.

◆ NoYieldCallCombiner()

static bool grpc_core::ClientChannel::CallData::NoYieldCallCombiner ( const CallCombinerClosureList & )

inlinestaticprivate

Definition at line 154 of file client_channel.cc.

◆ PendingBatchesAdd()

void grpc_core::ClientChannel::CallData::PendingBatchesAdd	(	grpc_call_element *	elem,
		grpc_transport_stream_op_batch *	batch
	)

private

Definition at line 2051 of file client_channel.cc.

◆ PendingBatchesFail()

void grpc_core::ClientChannel::CallData::PendingBatchesFail	(	grpc_call_element *	elem,
		grpc_error_handle	error,
		YieldCallCombinerPredicate	yield_call_combiner_predicate
	)

private

Definition at line 2077 of file client_channel.cc.

◆ PendingBatchesResume()

void grpc_core::ClientChannel::CallData::PendingBatchesResume ( grpc_call_element * elem )

private

Definition at line 2125 of file client_channel.cc.

◆ ResumePendingBatchInCallCombiner()

void grpc_core::ClientChannel::CallData::ResumePendingBatchInCallCombiner	(	void *	arg,
		grpc_error_handle	ignored
	)

staticprivate

Definition at line 2113 of file client_channel.cc.

◆ SetPollent()

void grpc_core::ClientChannel::CallData::SetPollent	(	grpc_call_element *	elem,
		grpc_polling_entity *	pollent
	)

static

Definition at line 2026 of file client_channel.cc.

◆ StartTransportStreamOpBatch()

void grpc_core::ClientChannel::CallData::StartTransportStreamOpBatch	(	grpc_call_element *	elem,
		grpc_transport_stream_op_batch *	batch
	)

static

Definition at line 1929 of file client_channel.cc.

◆ YieldCallCombiner()

static bool grpc_core::ClientChannel::CallData::YieldCallCombiner ( const CallCombinerClosureList & )

inlinestaticprivate

Definition at line 151 of file client_channel.cc.

◆ YieldCallCombinerIfPendingBatchesFound()

static bool grpc_core::ClientChannel::CallData::YieldCallCombinerIfPendingBatchesFound ( const CallCombinerClosureList & closures )

inlinestaticprivate

Definition at line 157 of file client_channel.cc.

Member Data Documentation

◆ arena_

Arena* grpc_core::ClientChannel::CallData::arena_

private

Definition at line 207 of file client_channel.cc.

◆ AsyncResolutionDone

void grpc_core::ClientChannel::CallData::AsyncResolutionDone

Definition at line 133 of file client_channel.cc.

◆ call_combiner_

CallCombiner* grpc_core::ClientChannel::CallData::call_combiner_

private

Definition at line 209 of file client_channel.cc.

◆ call_context_

grpc_call_context_element* grpc_core::ClientChannel::CallData::call_context_

private

Definition at line 210 of file client_channel.cc.

◆ call_start_time_

gpr_cycle_counter grpc_core::ClientChannel::CallData::call_start_time_

private

Definition at line 205 of file client_channel.cc.

◆ cancel_error_

grpc_error_handle grpc_core::ClientChannel::CallData::cancel_error_ = GRPC_ERROR_NONE

private

Definition at line 240 of file client_channel.cc.

◆ deadline_

Timestamp grpc_core::ClientChannel::CallData::deadline_

private

Definition at line 206 of file client_channel.cc.

◆ deadline_state_

grpc_deadline_state grpc_core::ClientChannel::CallData::deadline_state_

private

Definition at line 202 of file client_channel.cc.

◆ dynamic_call_

RefCountedPtr<DynamicFilters::Call> grpc_core::ClientChannel::CallData::dynamic_call_

private

Definition at line 230 of file client_channel.cc.

◆ dynamic_filters_

RefCountedPtr<DynamicFilters> grpc_core::ClientChannel::CallData::dynamic_filters_

private

Definition at line 229 of file client_channel.cc.

◆ original_recv_trailing_metadata_ready_

grpc_closure* grpc_core::ClientChannel::CallData::original_recv_trailing_metadata_ready_ = nullptr

private

Definition at line 226 of file client_channel.cc.

◆ owning_call_

grpc_call_stack* grpc_core::ClientChannel::CallData::owning_call_

private

Definition at line 208 of file client_channel.cc.

◆ path_

grpc_slice grpc_core::ClientChannel::CallData::path_

private

Definition at line 204 of file client_channel.cc.

◆ pending_batches_

grpc_transport_stream_op_batch* grpc_core::ClientChannel::CallData::pending_batches_[MAX_PENDING_BATCHES] = {}

private

Definition at line 237 of file client_channel.cc.

◆ pollent_

grpc_polling_entity* grpc_core::ClientChannel::CallData::pollent_ = nullptr

private

Definition at line 212 of file client_channel.cc.

◆ recv_trailing_metadata_ready_

grpc_closure grpc_core::ClientChannel::CallData::recv_trailing_metadata_ready_

private

Definition at line 227 of file client_channel.cc.

◆ RecvTrailingMetadataReadyForConfigSelectorCommitCallback

void grpc_core::ClientChannel::CallData::RecvTrailingMetadataReadyForConfigSelectorCommitCallback

staticprivate

Definition at line 191 of file client_channel.cc.

◆ resolution_done_closure_

grpc_closure grpc_core::ClientChannel::CallData::resolution_done_closure_

private

Definition at line 214 of file client_channel.cc.

◆ ResolutionDone

void grpc_core::ClientChannel::CallData::ResolutionDone

staticprivate

Definition at line 181 of file client_channel.cc.

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

client_channel.cc

Classes

Static Public Member Functions

Public Attributes

Private Types

Private Member Functions

Static Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Member Typedef Documentation

◆ YieldCallCombinerPredicate

Constructor & Destructor Documentation

◆ CallData()

◆ ~CallData()

Member Function Documentation

◆ CheckResolution()

◆ CreateDynamicCall()

◆ Destroy()

◆ FailPendingBatchInCallCombiner()

◆ GetBatchIndex()

◆ Init()

◆ NoYieldCallCombiner()

◆ PendingBatchesAdd()

◆ PendingBatchesFail()

◆ PendingBatchesResume()

◆ ResumePendingBatchInCallCombiner()

◆ SetPollent()

◆ StartTransportStreamOpBatch()

◆ YieldCallCombiner()

◆ YieldCallCombinerIfPendingBatchesFound()

Member Data Documentation

◆ arena_

◆ AsyncResolutionDone

◆ call_combiner_

◆ call_context_

◆ call_start_time_

◆ cancel_error_

◆ deadline_

◆ deadline_state_

◆ dynamic_call_

◆ dynamic_filters_

◆ original_recv_trailing_metadata_ready_

◆ owning_call_

◆ path_

◆ pending_batches_

◆ pollent_

◆ recv_trailing_metadata_ready_

◆ RecvTrailingMetadataReadyForConfigSelectorCommitCallback

◆ resolution_done_closure_

◆ ResolutionDone