Searched refs:ChannelState (Results 1 – 14 of 14) sorted by relevance
/third_party/grpc/src/core/ext/xds/ |
D | xds_client.cc | 86 class XdsClient::ChannelState::RetryableCall 89 explicit RetryableCall(RefCountedPtr<ChannelState> chand); 96 ChannelState* chand() const { return chand_.get(); } in chand() 110 RefCountedPtr<ChannelState> chand_; 122 class XdsClient::ChannelState::AdsCallState 132 ChannelState* chand() const { return parent_->chand(); } in chand() 305 class XdsClient::ChannelState::LrsCallState 317 ChannelState* chand() const { return parent_->chand(); } in chand() 405 class XdsClient::ChannelState::StateWatcher 408 explicit StateWatcher(RefCountedPtr<ChannelState> parent) in StateWatcher() [all …]
|
D | xds_client.h | 196 class ChannelState : public InternallyRefCounted<ChannelState> { 204 ChannelState(WeakRefCountedPtr<XdsClient> xds_client, 206 ~ChannelState() override; 305 OrphanablePtr<ChannelState> chand_;
|
/third_party/grpc/src/core/ext/filters/client_channel/xds/ |
D | xds_client.cc | 82 class XdsClient::ChannelState::RetryableCall 85 explicit RetryableCall(RefCountedPtr<ChannelState> chand); 92 ChannelState* chand() const { return chand_.get(); } in chand() 106 RefCountedPtr<ChannelState> chand_; 118 class XdsClient::ChannelState::AdsCallState 128 ChannelState* chand() const { return parent_->chand(); } in chand() 292 class XdsClient::ChannelState::LrsCallState 304 ChannelState* chand() const { return parent_->chand(); } in chand() 392 class XdsClient::ChannelState::StateWatcher 395 explicit StateWatcher(RefCountedPtr<ChannelState> parent) in StateWatcher() [all …]
|
D | xds_client.h | 159 class ChannelState : public InternallyRefCounted<ChannelState> { 167 ChannelState(RefCountedPtr<XdsClient> xds_client, grpc_channel* channel); 168 ~ChannelState(); 274 OrphanablePtr<ChannelState> chand_;
|
/third_party/grpc/src/csharp/Grpc.Core/ |
D | Channel.cs | 115 public ChannelState State 135 …public async Task WaitForStateChangedAsync(ChannelState lastObservedState, DateTime? deadline = nu… in WaitForStateChangedAsync() 148 …public Task<bool> TryWaitForStateChangedAsync(ChannelState lastObservedState, DateTime? deadline =… in TryWaitForStateChangedAsync() 150 GrpcPreconditions.CheckArgument(lastObservedState != ChannelState.Shutdown, in TryWaitForStateChangedAsync() 202 while (currentState != ChannelState.Ready) 204 if (currentState == ChannelState.Shutdown) 294 private ChannelState GetConnectivityState(bool tryToConnect) in GetConnectivityState() 305 return ChannelState.Shutdown; in GetConnectivityState()
|
D | ChannelState.cs | 27 public enum ChannelState enum
|
/third_party/grpc/src/csharp/Grpc.Core.Tests/ |
D | ChannelTest.cs | 51 Assert.AreEqual(ChannelState.Idle, channel.State); in State_IdleAfterCreation() 59 …eof(ArgumentException), async () => await channel.WaitForStateChangedAsync(ChannelState.Shutdown)); in WaitForStateChangedAsync_InvalidArgument() 94 Assert.AreEqual(ChannelState.Shutdown, channel.State); in StateIsShutdownAfterShutdown() 101 var stateChangedTask = channel.WaitForStateChangedAsync(ChannelState.Idle); in ShutdownFinishesWaitForStateChangedAsync() 112 …f(ObjectDisposedException), async () => await channel.WaitForStateChangedAsync(ChannelState.Idle)); in OperationsThrowAfterShutdown() 124 Assert.AreEqual(ChannelState.Shutdown, channel.State); in ChannelBaseShutdownAsyncInvokesShutdownAsync()
|
D | ChannelConnectivityTest.cs | 66 Assert.AreEqual(ChannelState.Ready, channel.State); in Channel_WaitForStateChangedAsync() 77 Assert.AreEqual(ChannelState.Ready, channel.State); in Channel_TryWaitForStateChangedAsync() 84 Assert.AreEqual(ChannelState.Ready, channel.State); in Channel_ConnectAsync() 87 Assert.AreEqual(ChannelState.Ready, channel.State); in Channel_ConnectAsync()
|
/third_party/grpc/src/core/ext/filters/client_idle/ |
D | client_idle_filter.cc | 110 enum ChannelState { enum 162 Atomic<ChannelState> state_{IDLE}; 209 ChannelState state = state_.Load(MemoryOrder::RELAXED); in IncreaseCallCount() 251 ChannelState state = state_.Load(MemoryOrder::RELAXED); in DecreaseCallCount() 315 ChannelState state = chand->state_.Load(MemoryOrder::RELAXED); in IdleTimerCallback()
|
/third_party/grpc/src/csharp/Grpc.Core/Internal/ |
D | ChannelSafeHandle.cs | 62 public ChannelState CheckConnectivityState(bool tryToConnect) in CheckConnectivityState() 67 …public void WatchConnectivityState(ChannelState lastObservedState, Timespec deadline, CompletionQu… in WatchConnectivityState()
|
D | NativeMethods.Generated.cs | 956 …public delegate ChannelState grpcsharp_channel_check_connectivity_state_delegate(ChannelSafeHandle… in grpcsharp_channel_check_connectivity_state_delegate() 957 …_channel_watch_connectivity_state_delegate(ChannelSafeHandle channel, ChannelState lastObservedSta… in grpcsharp_channel_watch_connectivity_state_delegate() 1172 …public static extern ChannelState grpcsharp_channel_check_connectivity_state(ChannelSafeHandle cha… in grpcsharp_channel_check_connectivity_state() 1175 …grpcsharp_channel_watch_connectivity_state(ChannelSafeHandle channel, ChannelState lastObservedSta… in grpcsharp_channel_watch_connectivity_state() 1492 …public static extern ChannelState grpcsharp_channel_check_connectivity_state(ChannelSafeHandle cha… in grpcsharp_channel_check_connectivity_state() 1495 …grpcsharp_channel_watch_connectivity_state(ChannelSafeHandle channel, ChannelState lastObservedSta… in grpcsharp_channel_watch_connectivity_state() 1812 …public static extern ChannelState grpcsharp_channel_check_connectivity_state(ChannelSafeHandle cha… in grpcsharp_channel_check_connectivity_state() 1815 …grpcsharp_channel_watch_connectivity_state(ChannelSafeHandle channel, ChannelState lastObservedSta… in grpcsharp_channel_watch_connectivity_state() 2132 …public static extern ChannelState grpcsharp_channel_check_connectivity_state(ChannelSafeHandle cha… in grpcsharp_channel_check_connectivity_state() 2135 …grpcsharp_channel_watch_connectivity_state(ChannelSafeHandle channel, ChannelState lastObservedSta… in grpcsharp_channel_watch_connectivity_state() [all …]
|
/third_party/grpc/templates/src/csharp/Grpc.Core/Internal/ |
D | native_methods.include | 54 …'ChannelState grpcsharp_channel_check_connectivity_state(ChannelSafeHandle channel, int tryToConne… 55 …'void grpcsharp_channel_watch_connectivity_state(ChannelSafeHandle channel, ChannelState lastObser…
|
/third_party/python/Lib/test/ |
D | test__xxsubinterpreters.py | 202 class ChannelState(namedtuple('ChannelState', 'pending closed')): class 1918 self._state = ChannelState() 2202 result = ChannelState(
|
/third_party/grpc/test/cpp/end2end/ |
D | end2end_test.cc | 1332 TEST_P(End2endTest, ChannelState) { in TEST_P() argument
|