grpc: grpc_core::Server::CallData Class Reference

Public Types
enum	CallState { CallState::NOT_STARTED, CallState::PENDING, CallState::ACTIVATED, CallState::ZOMBIED }

Public Member Functions
	CallData (grpc_call_element *elem, const grpc_call_element_args &args, RefCountedPtr< Server > server)

void	FailCallCreation ()

void	KillZombie ()

bool	MaybeActivate ()

void	Publish (size_t cq_idx, RequestedCall *rc)

void	SetState (CallState state)

void	Start (grpc_call_element *elem)

	~CallData ()

Static Public Member Functions
static void	DestroyCallElement (grpc_call_element elem, const grpc_call_final_info , grpc_closure *)

static grpc_error_handle	InitCallElement (grpc_call_element elem, const grpc_call_element_args args)

static void	StartTransportStreamOpBatch (grpc_call_element elem, grpc_transport_stream_op_batch batch)

Private Member Functions
void	StartNewRpc (grpc_call_element *elem)

void	StartTransportStreamOpBatchImpl (grpc_call_element elem, grpc_transport_stream_op_batch batch)

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

static void	RecvInitialMetadataBatchComplete (void *arg, grpc_error_handle error)

static void	RecvInitialMetadataReady (void *arg, grpc_error_handle error)

static void	RecvTrailingMetadataReady (void *arg, grpc_error_handle error)

Private Attributes
grpc_call *	call_

CallCombiner *	call_combiner_

grpc_completion_queue *	cq_new_ = nullptr

Timestamp	deadline_ = Timestamp::InfFuture()

absl::optional< Slice >	host_

grpc_metadata_array	initial_metadata_

grpc_closure	kill_zombie_closure_

RequestMatcherInterface *	matcher_ = nullptr

grpc_closure *	original_recv_initial_metadata_ready_

grpc_closure *	original_recv_trailing_metadata_ready_

absl::optional< Slice >	path_

grpc_byte_buffer *	payload_ = nullptr

grpc_closure	publish_

grpc_metadata_batch *	recv_initial_metadata_ = nullptr

grpc_closure	recv_initial_metadata_batch_complete_

grpc_error_handle	recv_initial_metadata_error_ = GRPC_ERROR_NONE

uint32_t	recv_initial_metadata_flags_ = 0

grpc_closure	recv_initial_metadata_ready_

grpc_error_handle	recv_trailing_metadata_error_ = GRPC_ERROR_NONE

grpc_closure	recv_trailing_metadata_ready_

bool	seen_recv_trailing_metadata_ready_ = false

RefCountedPtr< Server >	server_

std::atomic< CallState >	state_ {CallState::NOT_STARTED}

Detailed Description

Definition at line 269 of file src/core/lib/surface/server.h.

Member Enumeration Documentation

◆ CallState

enum grpc_core::Server::CallData::CallState

strong

Enumerator
NOT_STARTED
PENDING
ACTIVATED
ZOMBIED

Definition at line 271 of file src/core/lib/surface/server.h.

Constructor & Destructor Documentation

◆ CallData()

grpc_core::Server::CallData::CallData	(	grpc_call_element *	elem,
		const grpc_call_element_args &	args,
		RefCountedPtr< Server >	server
	)

Definition at line 1181 of file src/core/lib/surface/server.cc.

◆ ~CallData()

grpc_core::Server::CallData::~CallData ( )

Definition at line 1193 of file src/core/lib/surface/server.cc.

Member Function Documentation

◆ DestroyCallElement()

void grpc_core::Server::CallData::DestroyCallElement	(	grpc_call_element *	elem,
		const grpc_call_final_info *	,
		grpc_closure *
	)

static

Definition at line 1437 of file src/core/lib/surface/server.cc.

◆ FailCallCreation()

void grpc_core::Server::CallData::FailCallCreation ( )

Definition at line 1211 of file src/core/lib/surface/server.cc.

◆ InitCallElement()

grpc_error_handle grpc_core::Server::CallData::InitCallElement	(	grpc_call_element *	elem,
		const grpc_call_element_args *	args
	)

static

Definition at line 1430 of file src/core/lib/surface/server.cc.

◆ KillZombie()

void grpc_core::Server::CallData::KillZombie ( )

Definition at line 1292 of file src/core/lib/surface/server.cc.

◆ MaybeActivate()

bool grpc_core::Server::CallData::MaybeActivate ( )

Definition at line 1204 of file src/core/lib/surface/server.cc.

◆ Publish()

void grpc_core::Server::CallData::Publish	(	size_t	cq_idx,
		RequestedCall *	rc
	)

Definition at line 1239 of file src/core/lib/surface/server.cc.

◆ PublishNewRpc()

void grpc_core::Server::CallData::PublishNewRpc	(	void *	arg,
		grpc_error_handle	error
	)

staticprivate

Definition at line 1270 of file src/core/lib/surface/server.cc.

◆ RecvInitialMetadataBatchComplete()

void grpc_core::Server::CallData::RecvInitialMetadataBatchComplete	(	void *	arg,
		grpc_error_handle	error
	)

staticprivate

Definition at line 1336 of file src/core/lib/surface/server.cc.

◆ RecvInitialMetadataReady()

void grpc_core::Server::CallData::RecvInitialMetadataReady	(	void *	arg,
		grpc_error_handle	error
	)

staticprivate

Definition at line 1371 of file src/core/lib/surface/server.cc.

◆ RecvTrailingMetadataReady()

void grpc_core::Server::CallData::RecvTrailingMetadataReady	(	void *	arg,
		grpc_error_handle	error
	)

staticprivate

Definition at line 1408 of file src/core/lib/surface/server.cc.

◆ SetState()

void grpc_core::Server::CallData::SetState ( CallState state )

Definition at line 1200 of file src/core/lib/surface/server.cc.

◆ Start()

void grpc_core::Server::CallData::Start ( grpc_call_element * elem )

Definition at line 1226 of file src/core/lib/surface/server.cc.

◆ StartNewRpc()

void grpc_core::Server::CallData::StartNewRpc ( grpc_call_element * elem )

private

Definition at line 1298 of file src/core/lib/surface/server.cc.

◆ StartTransportStreamOpBatch()

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

static

Definition at line 1444 of file src/core/lib/surface/server.cc.

◆ StartTransportStreamOpBatchImpl()

void grpc_core::Server::CallData::StartTransportStreamOpBatchImpl	(	grpc_call_element *	elem,
		grpc_transport_stream_op_batch *	batch
	)

private

Definition at line 1349 of file src/core/lib/surface/server.cc.

Member Data Documentation

◆ call_

grpc_call* grpc_core::Server::CallData::call_

private

Definition at line 324 of file src/core/lib/surface/server.h.

◆ call_combiner_

CallCombiner* grpc_core::Server::CallData::call_combiner_

private

Definition at line 356 of file src/core/lib/surface/server.h.

◆ cq_new_

grpc_completion_queue* grpc_core::Server::CallData::cq_new_ = nullptr

private

Definition at line 332 of file src/core/lib/surface/server.h.

◆ deadline_

Timestamp grpc_core::Server::CallData::deadline_ = Timestamp::InfFuture()

private

Definition at line 330 of file src/core/lib/surface/server.h.

◆ host_

absl::optional<Slice> grpc_core::Server::CallData::host_

private

Definition at line 329 of file src/core/lib/surface/server.h.

◆ initial_metadata_

grpc_metadata_array grpc_core::Server::CallData::initial_metadata_

private

Initial value:

=

grpc_metadata_array()

Definition at line 339 of file src/core/lib/surface/server.h.

◆ kill_zombie_closure_

grpc_closure grpc_core::Server::CallData::kill_zombie_closure_

private

Definition at line 337 of file src/core/lib/surface/server.h.

◆ matcher_

RequestMatcherInterface* grpc_core::Server::CallData::matcher_ = nullptr

private

Definition at line 334 of file src/core/lib/surface/server.h.

◆ original_recv_initial_metadata_ready_

grpc_closure* grpc_core::Server::CallData::original_recv_initial_metadata_ready_

private

Definition at line 346 of file src/core/lib/surface/server.h.

◆ original_recv_trailing_metadata_ready_

grpc_closure* grpc_core::Server::CallData::original_recv_trailing_metadata_ready_

private

Definition at line 351 of file src/core/lib/surface/server.h.

◆ path_

absl::optional<Slice> grpc_core::Server::CallData::path_

private

Definition at line 328 of file src/core/lib/surface/server.h.

◆ payload_

grpc_byte_buffer* grpc_core::Server::CallData::payload_ = nullptr

private

Definition at line 335 of file src/core/lib/surface/server.h.

◆ publish_

grpc_closure grpc_core::Server::CallData::publish_

private

Definition at line 354 of file src/core/lib/surface/server.h.

◆ recv_initial_metadata_

grpc_metadata_batch* grpc_core::Server::CallData::recv_initial_metadata_ = nullptr

private

Definition at line 343 of file src/core/lib/surface/server.h.

◆ recv_initial_metadata_batch_complete_

grpc_closure grpc_core::Server::CallData::recv_initial_metadata_batch_complete_

private

Definition at line 341 of file src/core/lib/surface/server.h.

◆ recv_initial_metadata_error_

grpc_error_handle grpc_core::Server::CallData::recv_initial_metadata_error_ = GRPC_ERROR_NONE

private

Definition at line 347 of file src/core/lib/surface/server.h.

◆ recv_initial_metadata_flags_

uint32_t grpc_core::Server::CallData::recv_initial_metadata_flags_ = 0

private

Definition at line 344 of file src/core/lib/surface/server.h.

◆ recv_initial_metadata_ready_

grpc_closure grpc_core::Server::CallData::recv_initial_metadata_ready_

private

Definition at line 345 of file src/core/lib/surface/server.h.

◆ recv_trailing_metadata_error_

grpc_error_handle grpc_core::Server::CallData::recv_trailing_metadata_error_ = GRPC_ERROR_NONE

private

Definition at line 352 of file src/core/lib/surface/server.h.

◆ recv_trailing_metadata_ready_

grpc_closure grpc_core::Server::CallData::recv_trailing_metadata_ready_

private

Definition at line 350 of file src/core/lib/surface/server.h.

◆ seen_recv_trailing_metadata_ready_

bool grpc_core::Server::CallData::seen_recv_trailing_metadata_ready_ = false

private

Definition at line 349 of file src/core/lib/surface/server.h.

◆ server_

RefCountedPtr<Server> grpc_core::Server::CallData::server_

private

Definition at line 322 of file src/core/lib/surface/server.h.

◆ state_

std::atomic<CallState> grpc_core::Server::CallData::state_ {CallState::NOT_STARTED}

private

Definition at line 326 of file src/core/lib/surface/server.h.

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

grpc_metadata_array

Definition: grpc_types.h:579

grpc
Author(s):
autogenerated on Fri May 16 2025 03:03:37