Searched refs:channel_state (Results 1 – 7 of 7) sorted by relevance
/external/libopus/silk/ |
D | dec_API.c | 40 silk_decoder_state channel_state[ DECODER_NUM_CHANNELS ]; member 68 silk_decoder_state *channel_state = ((silk_decoder *)decState)->channel_state; in silk_InitDecoder() local 71 ret = silk_init_decoder( &channel_state[ n ] ); in silk_InitDecoder() 101 silk_decoder_state *channel_state = psDec->channel_state; in silk_Decode() local 114 channel_state[ n ].nFramesDecoded = 0; /* Used to count frames in packet */ in silk_Decode() 120 ret += silk_init_decoder( &channel_state[ 1 ] ); in silk_Decode() 124 ( decControl->internalSampleRate == 1000*channel_state[ 0 ].fs_kHz ); in silk_Decode() 126 if( channel_state[ 0 ].nFramesDecoded == 0 ) { in silk_Decode() 131 channel_state[ n ].nFramesPerPacket = 1; in silk_Decode() 132 channel_state[ n ].nb_subfr = 2; in silk_Decode() [all …]
|
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
D | _channel_rpc.py | 98 def unary_unary(channel_state, method_descriptor): argument 99 rpc_state = channel_state.take_rpc_state(method_descriptor) 105 def unary_stream(channel_state, method_descriptor): argument 106 rpc_state = channel_state.take_rpc_state(method_descriptor) 112 def stream_unary(channel_state, method_descriptor): argument 113 rpc_state = channel_state.take_rpc_state(method_descriptor) 117 def stream_stream(channel_state, method_descriptor): argument 118 rpc_state = channel_state.take_rpc_state(method_descriptor)
|
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
D | channel.pyx.pxi | 102 _ChannelState channel_state, _CallState call_state, object operations, argument 106 with channel_state.condition: 111 channel_state.integrated_call_states[tag] = call_state 120 _ChannelState channel_state, _CallState call_state, object operations, argument 124 with channel_state.condition: 137 _ChannelState channel_state, _CallState call_state, grpc_status_code code, argument 140 with channel_state.condition: 148 _ChannelState channel_state, grpc_completion_queue *c_completion_queue, argument 151 with channel_state.condition: 153 channel_state.condition.notify_all() [all …]
|
/external/grpc-grpc/test/cpp/end2end/ |
D | client_lb_end2end_test.cc | 505 grpc_connectivity_state channel_state; in TEST_F() local 507 channel_state = channel->GetState(true /* try to connect */); in TEST_F() 508 } while (channel_state == GRPC_CHANNEL_READY); in TEST_F() 509 GPR_ASSERT(channel_state != GRPC_CHANNEL_READY); in TEST_F() 829 grpc_connectivity_state channel_state; in TEST_F() local 831 channel_state = channel->GetState(true /* try to connect */); in TEST_F() 832 } while (channel_state == GRPC_CHANNEL_READY); in TEST_F() 833 GPR_ASSERT(channel_state != GRPC_CHANNEL_READY); in TEST_F() 841 channel_state = channel->GetState(false /* try to connect */); in TEST_F() 842 GPR_ASSERT(channel_state == GRPC_CHANNEL_READY); in TEST_F()
|
/external/rust/crates/grpcio-sys/grpc/tools/run_tests/xds_k8s_test_driver/framework/test_app/ |
D | client_app.py | 153 channel_state: _ChannelzChannelState = channel.data.state.state 155 _ChannelzChannelState.Name(channel_state)) 156 if channel_state is state:
|
/external/libopus/doc/ |
D | opus_update.patch | 90 ret = silk_init_decoder( &channel_state[ n ] );
|
/external/webrtc/p2p/base/ |
D | p2p_transport_channel_unittest.cc | 3634 IceTransportState channel_state() { return channel_state_; } in channel_state() function in cricket::P2PTransportChannelPingTest 3937 EXPECT_EQ_WAIT(IceTransportState::STATE_FAILED, channel_state(), in TEST_P()
|