Searched refs:ChannelState (Results 1 – 10 of 10) sorted by relevance
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| D | Channel.cs | 117 public ChannelState State
137 …public async Task WaitForStateChangedAsync(ChannelState lastObservedState, DateTime? deadline = nu… in WaitForStateChangedAsync()
150 …public Task<bool> TryWaitForStateChangedAsync(ChannelState lastObservedState, DateTime? deadline =… in TryWaitForStateChangedAsync()
152 GrpcPreconditions.CheckArgument(lastObservedState != ChannelState.Shutdown, in TryWaitForStateChangedAsync()
213 while (currentState != ChannelState.Ready)
215 if (currentState == ChannelState.Shutdown)
306 private ChannelState GetConnectivityState(bool tryToConnect) in GetConnectivityState()
317 return ChannelState.Shutdown; in GetConnectivityState()
|
| D | ChannelState.cs | 27 public enum ChannelState enum
|
| /external/grpc-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()
|
| 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()
|
| /external/grpc-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 | 487 …public delegate ChannelState grpcsharp_channel_check_connectivity_state_delegate(ChannelSafeHandle… in grpcsharp_channel_check_connectivity_state_delegate()
488 …_channel_watch_connectivity_state_delegate(ChannelSafeHandle channel, ChannelState lastObservedSta… in grpcsharp_channel_watch_connectivity_state_delegate()
692 …public static extern ChannelState grpcsharp_channel_check_connectivity_state(ChannelSafeHandle cha… in grpcsharp_channel_check_connectivity_state()
695 …grpcsharp_channel_watch_connectivity_state(ChannelSafeHandle channel, ChannelState lastObservedSta… in grpcsharp_channel_watch_connectivity_state()
985 …public static extern ChannelState grpcsharp_channel_check_connectivity_state(ChannelSafeHandle cha… in grpcsharp_channel_check_connectivity_state()
988 …grpcsharp_channel_watch_connectivity_state(ChannelSafeHandle channel, ChannelState lastObservedSta… in grpcsharp_channel_watch_connectivity_state()
|
| /external/webrtc/webrtc/voice_engine/ |
| D | channel.h | 86 class ChannelState {
106 ChannelState() : lock_(CriticalSectionWrapper::CreateCriticalSection()) { in ChannelState() function
108 virtual ~ChannelState() {} in ~ChannelState()
502 ChannelState channel_state_;
|
| D | channel.cc | 554 ChannelState::State state = channel_state_.Get(); in GetAudioFrame()
|
| /external/grpc-grpc/templates/src/csharp/Grpc.Core/Internal/ |
| D | NativeMethods.Generated.cs.template | 55 …'ChannelState grpcsharp_channel_check_connectivity_state(ChannelSafeHandle channel, int tryToConne…
56 …'void grpcsharp_channel_watch_connectivity_state(ChannelSafeHandle channel, ChannelState lastObser…
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | end2end_test.cc | 1115 TEST_P(End2endTest, ChannelState) { in TEST_P() argument
|