Public Member Functions | Private Member Functions | Static Private Member Functions | Private Attributes | List of all members
grpc_core::SubchannelStreamClient::CallState Class Reference
Inheritance diagram for grpc_core::SubchannelStreamClient::CallState:
Inheritance graph
[legend]

Public Member Functions

 CallState (RefCountedPtr< SubchannelStreamClient > client, grpc_pollset_set *interested_parties)
 
void Orphan () override
 
 ~CallState () override
 
- Public Member Functions inherited from grpc_core::Orphanable
Orphanable & operator= (const Orphanable &)=delete
 
 Orphanable (const Orphanable &)=delete
 

Private Member Functions

void CallEndedLocked (bool retry) ABSL_EXCLUSIVE_LOCKS_REQUIRED(&subchannel_stream_client_ -> mu_)
 
void Cancel ()
 
void RecvMessageReady ()
 
void StartBatch (grpc_transport_stream_op_batch *batch)
 

Static Private Member Functions

static void AfterCallStackDestruction (void *arg, grpc_error_handle error)
 
static void OnCancelComplete (void *arg, grpc_error_handle error)
 
static void OnComplete (void *arg, grpc_error_handle error)
 
static void RecvInitialMetadataReady (void *arg, grpc_error_handle error)
 
static void RecvMessageReady (void *arg, grpc_error_handle error)
 
static void RecvTrailingMetadataReady (void *arg, grpc_error_handle error)
 
static void StartBatchInCallCombiner (void *arg, grpc_error_handle error)
 
static void StartCancel (void *arg, grpc_error_handle error)
 

Private Attributes

grpc_closure after_call_stack_destruction_
 
ScopedArenaPtr arena_
 
grpc_transport_stream_op_batch batch_
 
SubchannelCall * call_
 
CallCombiner call_combiner_
 
std::atomic< bool > cancelled_ {false}
 
grpc_transport_stream_stats collect_stats_
 
grpc_call_context_element context_ [GRPC_CONTEXT_COUNT] = {}
 
grpc_closure on_complete_
 
grpc_transport_stream_op_batch_payload payload_
 
grpc_polling_entity pollent_
 
grpc_metadata_batch recv_initial_metadata_
 
grpc_closure recv_initial_metadata_ready_
 
absl::optional< SliceBuffer > recv_message_
 
grpc_transport_stream_op_batch recv_message_batch_
 
grpc_closure recv_message_ready_
 
grpc_metadata_batch recv_trailing_metadata_
 
grpc_transport_stream_op_batch recv_trailing_metadata_batch_
 
grpc_closure recv_trailing_metadata_ready_
 
std::atomic< bool > seen_response_ {false}
 
grpc_metadata_batch send_initial_metadata_
 
SliceBuffer send_message_
 
grpc_metadata_batch send_trailing_metadata_
 
RefCountedPtr< SubchannelStreamClient > subchannel_stream_client_
 

Additional Inherited Members

- Protected Member Functions inherited from grpc_core::Orphanable
 Orphanable ()
 
virtual ~Orphanable ()
 

Detailed Description

Definition at line 115 of file subchannel_stream_client.h.

Constructor & Destructor Documentation

◆ CallState()

grpc_core::SubchannelStreamClient::CallState::CallState ( RefCountedPtr< SubchannelStreamClient >  client,
grpc_pollset_set *  interested_parties 
)

Definition at line 166 of file subchannel_stream_client.cc.

◆ ~CallState()

grpc_core::SubchannelStreamClient::CallState::~CallState ( )
override

Definition at line 180 of file subchannel_stream_client.cc.

Member Function Documentation

◆ AfterCallStackDestruction()

void grpc_core::SubchannelStreamClient::CallState::AfterCallStackDestruction ( void *  arg,
grpc_error_handle  error 
)
staticprivate

Definition at line 314 of file subchannel_stream_client.cc.

◆ CallEndedLocked()

void grpc_core::SubchannelStreamClient::CallState::CallEndedLocked ( bool  retry) & -> mu_)
private

Definition at line 448 of file subchannel_stream_client.cc.

◆ Cancel()

void grpc_core::SubchannelStreamClient::CallState::Cancel ( ) &
private

Definition at line 337 of file subchannel_stream_client.cc.

◆ OnCancelComplete()

void grpc_core::SubchannelStreamClient::CallState::OnCancelComplete ( void *  arg,
grpc_error_handle  error 
)
staticprivate

Definition at line 320 of file subchannel_stream_client.cc.

◆ OnComplete()

void grpc_core::SubchannelStreamClient::CallState::OnComplete ( void *  arg,
grpc_error_handle  error 
)
staticprivate

Definition at line 350 of file subchannel_stream_client.cc.

◆ Orphan()

void grpc_core::SubchannelStreamClient::CallState::Orphan ( )
overridevirtual

Implements grpc_core::Orphanable.

Definition at line 198 of file subchannel_stream_client.cc.

◆ RecvInitialMetadataReady()

void grpc_core::SubchannelStreamClient::CallState::RecvInitialMetadataReady ( void *  arg,
grpc_error_handle  error 
)
staticprivate

Definition at line 359 of file subchannel_stream_client.cc.

◆ RecvMessageReady() [1/2]

void grpc_core::SubchannelStreamClient::CallState::RecvMessageReady ( )
private

Definition at line 367 of file subchannel_stream_client.cc.

◆ RecvMessageReady() [2/2]

void grpc_core::SubchannelStreamClient::CallState::RecvMessageReady ( void *  arg,
grpc_error_handle  error 
)
staticprivate

Definition at line 407 of file subchannel_stream_client.cc.

◆ RecvTrailingMetadataReady()

void grpc_core::SubchannelStreamClient::CallState::RecvTrailingMetadataReady ( void *  arg,
grpc_error_handle  error 
)
staticprivate

Definition at line 414 of file subchannel_stream_client.cc.

◆ StartBatch()

void grpc_core::SubchannelStreamClient::CallState::StartBatch ( grpc_transport_stream_op_batch *  batch)
private

Definition at line 305 of file subchannel_stream_client.cc.

◆ StartBatchInCallCombiner()

void grpc_core::SubchannelStreamClient::CallState::StartBatchInCallCombiner ( void *  arg,
grpc_error_handle  error 
)
staticprivate

Definition at line 298 of file subchannel_stream_client.cc.

◆ StartCancel()

void grpc_core::SubchannelStreamClient::CallState::StartCancel ( void *  arg,
grpc_error_handle  error 
)
staticprivate

Definition at line 327 of file subchannel_stream_client.cc.

Member Data Documentation

◆ after_call_stack_destruction_

grpc_closure grpc_core::SubchannelStreamClient::CallState::after_call_stack_destruction_
private

Definition at line 192 of file subchannel_stream_client.h.

◆ arena_

ScopedArenaPtr grpc_core::SubchannelStreamClient::CallState::arena_
private

Definition at line 149 of file subchannel_stream_client.h.

◆ batch_

grpc_transport_stream_op_batch grpc_core::SubchannelStreamClient::CallState::batch_
private

Definition at line 159 of file subchannel_stream_client.h.

◆ call_

SubchannelCall* grpc_core::SubchannelStreamClient::CallState::call_
private

Definition at line 156 of file subchannel_stream_client.h.

◆ call_combiner_

CallCombiner grpc_core::SubchannelStreamClient::CallState::call_combiner_
private

Definition at line 150 of file subchannel_stream_client.h.

◆ cancelled_

std::atomic<bool> grpc_core::SubchannelStreamClient::CallState::cancelled_ {false}
private

Definition at line 184 of file subchannel_stream_client.h.

◆ collect_stats_

grpc_transport_stream_stats grpc_core::SubchannelStreamClient::CallState::collect_stats_
private

Definition at line 188 of file subchannel_stream_client.h.

◆ context_

grpc_call_context_element grpc_core::SubchannelStreamClient::CallState::context_[GRPC_CONTEXT_COUNT] = {}
private

Definition at line 151 of file subchannel_stream_client.h.

◆ on_complete_

grpc_closure grpc_core::SubchannelStreamClient::CallState::on_complete_
private

Definition at line 163 of file subchannel_stream_client.h.

◆ payload_

grpc_transport_stream_op_batch_payload grpc_core::SubchannelStreamClient::CallState::payload_
private

Definition at line 158 of file subchannel_stream_client.h.

◆ pollent_

grpc_polling_entity grpc_core::SubchannelStreamClient::CallState::pollent_
private

Definition at line 147 of file subchannel_stream_client.h.

◆ recv_initial_metadata_

grpc_metadata_batch grpc_core::SubchannelStreamClient::CallState::recv_initial_metadata_
private

Definition at line 175 of file subchannel_stream_client.h.

◆ recv_initial_metadata_ready_

grpc_closure grpc_core::SubchannelStreamClient::CallState::recv_initial_metadata_ready_
private

Definition at line 176 of file subchannel_stream_client.h.

◆ recv_message_

absl::optional<SliceBuffer> grpc_core::SubchannelStreamClient::CallState::recv_message_
private

Definition at line 179 of file subchannel_stream_client.h.

◆ recv_message_batch_

grpc_transport_stream_op_batch grpc_core::SubchannelStreamClient::CallState::recv_message_batch_
private

Definition at line 160 of file subchannel_stream_client.h.

◆ recv_message_ready_

grpc_closure grpc_core::SubchannelStreamClient::CallState::recv_message_ready_
private

Definition at line 180 of file subchannel_stream_client.h.

◆ recv_trailing_metadata_

grpc_metadata_batch grpc_core::SubchannelStreamClient::CallState::recv_trailing_metadata_
private

Definition at line 187 of file subchannel_stream_client.h.

◆ recv_trailing_metadata_batch_

grpc_transport_stream_op_batch grpc_core::SubchannelStreamClient::CallState::recv_trailing_metadata_batch_
private

Definition at line 161 of file subchannel_stream_client.h.

◆ recv_trailing_metadata_ready_

grpc_closure grpc_core::SubchannelStreamClient::CallState::recv_trailing_metadata_ready_
private

Definition at line 189 of file subchannel_stream_client.h.

◆ seen_response_

std::atomic<bool> grpc_core::SubchannelStreamClient::CallState::seen_response_ {false}
private

Definition at line 181 of file subchannel_stream_client.h.

◆ send_initial_metadata_

grpc_metadata_batch grpc_core::SubchannelStreamClient::CallState::send_initial_metadata_
private

Definition at line 166 of file subchannel_stream_client.h.

◆ send_message_

SliceBuffer grpc_core::SubchannelStreamClient::CallState::send_message_
private

Definition at line 169 of file subchannel_stream_client.h.

◆ send_trailing_metadata_

grpc_metadata_batch grpc_core::SubchannelStreamClient::CallState::send_trailing_metadata_
private

Definition at line 172 of file subchannel_stream_client.h.

◆ subchannel_stream_client_

RefCountedPtr<SubchannelStreamClient> grpc_core::SubchannelStreamClient::CallState::subchannel_stream_client_
private

Definition at line 146 of file subchannel_stream_client.h.

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

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