grpc_core::SubchannelStreamClient Class Reference

#include <subchannel_stream_client.h>

Inheritance diagram for grpc_core::SubchannelStreamClient:

Classes
class	CallEventHandler
class	CallState

Public Member Functions
void	Orphan () override
	SubchannelStreamClient (RefCountedPtr< ConnectedSubchannel > connected_subchannel, grpc_pollset_set *interested_parties, std::unique_ptr< CallEventHandler > event_handler, const char *tracer)
	~SubchannelStreamClient () override
Public Member Functions inherited from grpc_core::InternallyRefCounted< SubchannelStreamClient >
	InternallyRefCounted (const InternallyRefCounted &)=delete
InternallyRefCounted &	operator= (const InternallyRefCounted &)=delete
Public Member Functions inherited from grpc_core::Orphanable
Orphanable &	operator= (const Orphanable &)=delete
	Orphanable (const Orphanable &)=delete

Private Member Functions
std::unique_ptr< CallEventHandler > event_handler_	ABSL_GUARDED_BY (mu_)
OrphanablePtr< CallState > call_state_	ABSL_GUARDED_BY (mu_)
BackOff retry_backoff_	ABSL_GUARDED_BY (mu_)
grpc_timer retry_timer_	ABSL_GUARDED_BY (mu_)
grpc_closure retry_timer_callback_	ABSL_GUARDED_BY (mu_)
bool retry_timer_callback_pending_	ABSL_GUARDED_BY (mu_)
void	StartCall ()
void	StartCallLocked () ABSL_EXCLUSIVE_LOCKS_REQUIRED(&mu_)
void	StartRetryTimerLocked () ABSL_EXCLUSIVE_LOCKS_REQUIRED(&mu_)

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

Private Attributes
MemoryAllocator	call_allocator_
RefCountedPtr< ConnectedSubchannel >	connected_subchannel_
grpc_pollset_set *	interested_parties_
Mutex	mu_
const char *	tracer_

Additional Inherited Members
Protected Member Functions inherited from grpc_core::InternallyRefCounted< SubchannelStreamClient >
	InternallyRefCounted (const char *trace=nullptr, intptr_t initial_refcount=1)
RefCountedPtr< SubchannelStreamClient >	Ref () GRPC_MUST_USE_RESULT
RefCountedPtr< SubchannelStreamClient >	Ref (const DebugLocation &location, const char *reason) GRPC_MUST_USE_RESULT
void	Unref ()
void	Unref (const DebugLocation &location, const char *reason)
	~InternallyRefCounted () override=default
Protected Member Functions inherited from grpc_core::Orphanable
	Orphanable ()
virtual	~Orphanable ()

Detailed Description

Definition at line 64 of file subchannel_stream_client.h.

Constructor & Destructor Documentation

SubchannelStreamClient()

grpc_core::SubchannelStreamClient::SubchannelStreamClient	(	RefCountedPtr< ConnectedSubchannel >	connected_subchannel,
		grpc_pollset_set *	interested_parties,
		std::unique_ptr< CallEventHandler >	event_handler,
		const char *	tracer
	)

Definition at line 50 of file subchannel_stream_client.cc.

~SubchannelStreamClient()

grpc_core::SubchannelStreamClient::~SubchannelStreamClient ( )

override

Definition at line 80 of file subchannel_stream_client.cc.

Member Function Documentation

ABSL_GUARDED_BY() [1/6]

std::unique_ptr<CallEventHandler> event_handler_ grpc_core::SubchannelStreamClient::ABSL_GUARDED_BY ( mu_  )

private

ABSL_GUARDED_BY() [2/6]

OrphanablePtr<CallState> call_state_ grpc_core::SubchannelStreamClient::ABSL_GUARDED_BY ( mu_  )

private

ABSL_GUARDED_BY() [3/6]

BackOff retry_backoff_ grpc_core::SubchannelStreamClient::ABSL_GUARDED_BY ( mu_  )

private

ABSL_GUARDED_BY() [4/6]

grpc_timer retry_timer_ grpc_core::SubchannelStreamClient::ABSL_GUARDED_BY ( mu_  )

private

ABSL_GUARDED_BY() [5/6]

grpc_closure retry_timer_callback_ grpc_core::SubchannelStreamClient::ABSL_GUARDED_BY ( mu_  )

private

ABSL_GUARDED_BY() [6/6]

bool retry_timer_callback_pending_ grpc_core::SubchannelStreamClient::ABSL_GUARDED_BY ( mu_  )

private

OnRetryTimer()

void grpc_core::SubchannelStreamClient::OnRetryTimer ( void *  arg, grpc_error_handle  error  )

staticprivate

Definition at line 144 of file subchannel_stream_client.cc.

Orphan()

void grpc_core::SubchannelStreamClient::Orphan ( )

overridevirtual

Implements grpc_core::Orphanable.

Definition at line 87 of file subchannel_stream_client.cc.

StartCall()

void grpc_core::SubchannelStreamClient::StartCall ( )

private

Definition at line 103 of file subchannel_stream_client.cc.

StartCallLocked()

void grpc_core::SubchannelStreamClient::StartCallLocked ( ) &

private

Definition at line 108 of file subchannel_stream_client.cc.

StartRetryTimerLocked()

void grpc_core::SubchannelStreamClient::StartRetryTimerLocked ( ) &

private

Definition at line 122 of file subchannel_stream_client.cc.

Member Data Documentation

call_allocator_

MemoryAllocator grpc_core::SubchannelStreamClient::call_allocator_

private

Definition at line 204 of file subchannel_stream_client.h.

connected_subchannel_

RefCountedPtr<ConnectedSubchannel> grpc_core::SubchannelStreamClient::connected_subchannel_

private

Definition at line 201 of file subchannel_stream_client.h.

interested_parties_

grpc_pollset_set* grpc_core::SubchannelStreamClient::interested_parties_

private

Definition at line 202 of file subchannel_stream_client.h.

mu_

Mutex grpc_core::SubchannelStreamClient::mu_

private

Definition at line 206 of file subchannel_stream_client.h.

tracer_

const char* grpc_core::SubchannelStreamClient::tracer_

private

Definition at line 203 of file subchannel_stream_client.h.

---

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

• subchannel_stream_client.h
• subchannel_stream_client.cc