GRPC C++  1.39.1
Data Structures | Public Member Functions | Static Public Member Functions
grpc_core::Subchannel Class Reference

#include <subchannel.h>

Data Structures

class  AsyncWatcherNotifierLocked
 
class  ConnectedSubchannelStateWatcher
 
class  ConnectivityStateWatcherInterface
 

Public Member Functions

 Subchannel (SubchannelKey key, OrphanablePtr< SubchannelConnector > connector, const grpc_channel_args *args)
 
 ~Subchannel () override
 
void ThrottleKeepaliveTime (int new_keepalive_time) ABSL_LOCKS_EXCLUDED(mu_)
 
const char * GetTargetAddress ()
 
const grpc_channel_argschannel_args () const
 
channelz::SubchannelNodechannelz_node ()
 
grpc_connectivity_state CheckConnectivityState (const absl::optional< std::string > &health_check_service_name, RefCountedPtr< ConnectedSubchannel > *connected_subchannel) ABSL_LOCKS_EXCLUDED(mu_)
 
void WatchConnectivityState (grpc_connectivity_state initial_state, const absl::optional< std::string > &health_check_service_name, RefCountedPtr< ConnectivityStateWatcherInterface > watcher) ABSL_LOCKS_EXCLUDED(mu_)
 
void CancelConnectivityStateWatch (const absl::optional< std::string > &health_check_service_name, ConnectivityStateWatcherInterface *watcher) ABSL_LOCKS_EXCLUDED(mu_)
 
void AttemptToConnect () ABSL_LOCKS_EXCLUDED(mu_)
 
void ResetBackoff () ABSL_LOCKS_EXCLUDED(mu_)
 
void Orphan () override ABSL_LOCKS_EXCLUDED(mu_)
 
- Public Member Functions inherited from grpc_core::DualRefCounted< Subchannel >
 ~DualRefCounted () override=default
 
RefCountedPtr< SubchannelRef () GRPC_MUST_USE_RESULT
 
RefCountedPtr< SubchannelRef (const DebugLocation &location, const char *reason) GRPC_MUST_USE_RESULT
 
void Unref ()
 
void Unref (const DebugLocation &location, const char *reason)
 
RefCountedPtr< SubchannelRefIfNonZero () GRPC_MUST_USE_RESULT
 
RefCountedPtr< SubchannelRefIfNonZero (const DebugLocation &location, const char *reason) GRPC_MUST_USE_RESULT
 
WeakRefCountedPtr< SubchannelWeakRef () GRPC_MUST_USE_RESULT
 
WeakRefCountedPtr< SubchannelWeakRef (const DebugLocation &location, const char *reason) GRPC_MUST_USE_RESULT
 
void WeakUnref ()
 
void WeakUnref (const DebugLocation &location, const char *reason)
 
 DualRefCounted (const DualRefCounted &)=delete
 
DualRefCountedoperator= (const DualRefCounted &)=delete
 
- Public Member Functions inherited from grpc_core::Orphanable
 Orphanable (const Orphanable &)=delete
 
Orphanableoperator= (const Orphanable &)=delete
 

Static Public Member Functions

static RefCountedPtr< SubchannelCreate (OrphanablePtr< SubchannelConnector > connector, const grpc_channel_args *args)
 
static grpc_arg CreateSubchannelAddressArg (const grpc_resolved_address *addr)
 
static const char * GetUriFromSubchannelAddressArg (const grpc_channel_args *args)
 
static void GetAddressFromSubchannelAddressArg (const grpc_channel_args *args, grpc_resolved_address *addr)
 

Additional Inherited Members

- Protected Member Functions inherited from grpc_core::DualRefCounted< Subchannel >
 DualRefCounted (const char *trace=nullptr, int32_t initial_refcount=1)
 
- Protected Member Functions inherited from grpc_core::Orphanable
 Orphanable ()
 
virtual ~Orphanable ()
 

Constructor & Destructor Documentation

◆ Subchannel()

grpc_core::Subchannel::Subchannel ( SubchannelKey  key,
OrphanablePtr< SubchannelConnector connector,
const grpc_channel_args args 
)

◆ ~Subchannel()

grpc_core::Subchannel::~Subchannel ( )
override

Member Function Documentation

◆ AttemptToConnect()

void grpc_core::Subchannel::AttemptToConnect ( )

◆ CancelConnectivityStateWatch()

void grpc_core::Subchannel::CancelConnectivityStateWatch ( const absl::optional< std::string > &  health_check_service_name,
ConnectivityStateWatcherInterface watcher 
)

◆ channel_args()

const grpc_channel_args* grpc_core::Subchannel::channel_args ( ) const
inline

◆ channelz_node()

channelz::SubchannelNode * grpc_core::Subchannel::channelz_node ( )

◆ CheckConnectivityState()

grpc_connectivity_state grpc_core::Subchannel::CheckConnectivityState ( const absl::optional< std::string > &  health_check_service_name,
RefCountedPtr< ConnectedSubchannel > *  connected_subchannel 
)

◆ Create()

RefCountedPtr< Subchannel > grpc_core::Subchannel::Create ( OrphanablePtr< SubchannelConnector connector,
const grpc_channel_args args 
)
static

◆ CreateSubchannelAddressArg()

grpc_arg grpc_core::Subchannel::CreateSubchannelAddressArg ( const grpc_resolved_address addr)
static

◆ GetAddressFromSubchannelAddressArg()

void grpc_core::Subchannel::GetAddressFromSubchannelAddressArg ( const grpc_channel_args args,
grpc_resolved_address addr 
)
static

◆ GetTargetAddress()

const char * grpc_core::Subchannel::GetTargetAddress ( )

◆ GetUriFromSubchannelAddressArg()

const char * grpc_core::Subchannel::GetUriFromSubchannelAddressArg ( const grpc_channel_args args)
static

◆ Orphan()

void grpc_core::Subchannel::Orphan ( )
overridevirtual

Implements grpc_core::Orphanable.

◆ ResetBackoff()

void grpc_core::Subchannel::ResetBackoff ( )

◆ ThrottleKeepaliveTime()

void grpc_core::Subchannel::ThrottleKeepaliveTime ( int  new_keepalive_time)

◆ WatchConnectivityState()

void grpc_core::Subchannel::WatchConnectivityState ( grpc_connectivity_state  initial_state,
const absl::optional< std::string > &  health_check_service_name,
RefCountedPtr< ConnectivityStateWatcherInterface watcher 
)

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