Home
last modified time | relevance | path

Searched refs:ChannelState (Results 1 – 14 of 14) sorted by relevance

/third_party/grpc/src/core/ext/xds/
Dxds_client.cc86 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 …]
Dxds_client.h196 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/
Dxds_client.cc82 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 …]
Dxds_client.h159 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/
DChannel.cs115 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()
DChannelState.cs27 public enum ChannelState enum
/third_party/grpc/src/csharp/Grpc.Core.Tests/
DChannelTest.cs51 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()
DChannelConnectivityTest.cs66 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/
Dclient_idle_filter.cc110 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/
DChannelSafeHandle.cs62 public ChannelState CheckConnectivityState(bool tryToConnect) in CheckConnectivityState()
67 …public void WatchConnectivityState(ChannelState lastObservedState, Timespec deadline, CompletionQu… in WatchConnectivityState()
DNativeMethods.Generated.cs956 …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/
Dnative_methods.include54 …'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/
Dtest__xxsubinterpreters.py202 class ChannelState(namedtuple('ChannelState', 'pending closed')): class
1918 self._state = ChannelState()
2202 result = ChannelState(
/third_party/grpc/test/cpp/end2end/
Dend2end_test.cc1332 TEST_P(End2endTest, ChannelState) { in TEST_P() argument