| /external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/ |
| D | xds_client.cc | 85 class XdsClient::ChannelState::RetryableCall
88 explicit RetryableCall(RefCountedPtr<ChannelState> chand);
95 ChannelState* chand() const { return chand_.get(); } in chand()
109 RefCountedPtr<ChannelState> chand_;
121 class XdsClient::ChannelState::AdsCallState
131 ChannelState* chand() const { return parent_->chand(); } in chand()
304 class XdsClient::ChannelState::LrsCallState
316 ChannelState* chand() const { return parent_->chand(); } in chand()
404 class XdsClient::ChannelState::StateWatcher
407 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_;
|
| /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/webrtc/modules/audio_processing/ns/ |
| D | noise_suppressor.h | 51 struct ChannelState { struct
52 ChannelState(const SuppressionParams& suppression_params, size_t num_bands);
74 std::vector<std::unique_ptr<ChannelState>> channels_; argument
|
| D | noise_suppressor.cc | 240 NoiseSuppressor::ChannelState::ChannelState( in ChannelState() function in webrtc::NoiseSuppressor::ChannelState
268 std::make_unique<ChannelState>(suppression_params_, num_bands_); in NoiseSuppressor()
326 std::unique_ptr<ChannelState>& ch_p = channels_[ch]; in Analyze()
|
| /external/rust/crates/grpcio-sys/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()
|
| /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/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/bin/ |
| D | run_channelz.py | 65 _ChannelState = grpc_channelz.ChannelState
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/rpc/ |
| D | grpc_channelz.py | 34 ChannelState = ChannelConnectivityState.State # pylint: disable=no-member variable
|
| /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/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/test_app/ |
| D | client_app.py | 39 _ChannelzChannelState = grpc_channelz.ChannelState
|
| /external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/ |
| D | xds_k8s_testcase.py | 46 _ChannelState = grpc_channelz.ChannelState
|
| /external/python/cpython3/Lib/test/ |
| D | test__xxsubinterpreters.py | 186 class ChannelState(namedtuple('ChannelState', 'pending closed')): class
1913 self._state = ChannelState()
2197 result = ChannelState(
|
| /external/ms-tpm-20-ref/Samples/Nucleo-TPM/L4A6RG/Drivers/STM32L4xx_HAL_Driver/Inc/ |
| D | stm32l4xx_hal_tim.h | 2023 void TIM_CCxChannelCmd(TIM_TypeDef* TIMx, uint32_t Channel, uint32_t ChannelState);
|
| /external/ms-tpm-20-ref/Samples/Nucleo-TPM/L476RG/Drivers/STM32L4xx_HAL_Driver/Inc/ |
| D | stm32l4xx_hal_tim.h | 2023 void TIM_CCxChannelCmd(TIM_TypeDef* TIMx, uint32_t Channel, uint32_t ChannelState);
|
| /external/ms-tpm-20-ref/Samples/Nucleo-TPM/L476RG/Drivers/STM32L4xx_HAL_Driver/Src/ |
| D | stm32l4xx_hal_tim.c | 5645 void TIM_CCxChannelCmd(TIM_TypeDef* TIMx, uint32_t Channel, uint32_t ChannelState) in TIM_CCxChannelCmd() argument
5659 TIMx->CCER |= (uint32_t)(ChannelState << Channel); in TIM_CCxChannelCmd()
|
| /external/ms-tpm-20-ref/Samples/Nucleo-TPM/L4A6RG/Drivers/STM32L4xx_HAL_Driver/Src/ |
| D | stm32l4xx_hal_tim.c | 5645 void TIM_CCxChannelCmd(TIM_TypeDef* TIMx, uint32_t Channel, uint32_t ChannelState) in TIM_CCxChannelCmd() argument
5659 TIMx->CCER |= (uint32_t)(ChannelState << Channel); in TIM_CCxChannelCmd()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | end2end_test.cc | 1115 TEST_P(End2endTest, ChannelState) { in TEST_P() argument
|